Commits

Commits on Aug 10, 2020

[FLINK-18688][table-planner-blink] Fix binary row writing with incorrect order in ProjectionCodeGenerator by removing for loop optimization
tsreaper
committedAug 10, 2020

Commits on Jul 29, 2020

[FLINK-18668][table-runtime-blink] BytesHashMap#growAndRehash should release newly allocated segments before throwing the exception
tsreaper
committedJul 29, 2020

Commits on Jul 23, 2020

[FLINK-18558][streaming] Introduce collect iterator with at least once semantics and exactly once semantics without fault tolerance
tsreaper
committedJul 23, 2020

Commits on Jun 3, 2020

[FLINK-17774][streaming] Serialize results in CollectSinkFunction to deal with object reuse

tsreaper
authored and
wuchong
committedJun 3, 2020

Commits on May 21, 2020

[FLINK-17817][streaming] Fix type serializer duplication in CollectSinkFunction
tsreaper
committedMay 21, 2020

Commits on May 18, 2020

[FLINK-17791][table][streaming] Support collecting query results under all execution and network environments
tsreaper
committedMay 18, 2020

Commits on May 17, 2020

[FLINK-17735][streaming] Add an iterator to collect sink results through coordination rest api
tsreaper
committedMay 17, 2020

Commits on May 16, 2020

[FLINK-17734][streaming] Add an operator coordinator and sink function to collect sink data.

tsreaper
authored and
KurtYoung
committedMay 16, 2020

Commits on May 14, 2020

[FLINK-14807][rest] Introduce REST API for communication between clients and operator coordinators
tsreaper
committedMay 14, 2020
[FLINK-17680][docs] Support @ExcludeFromDocumentation when generating REST API documentations

tsreaper
authored and
tillrohrmann
committedMay 14, 2020

Commits on Apr 17, 2020

[FLINK-17023][scripts] Improve handling of unexpected input
tsreaper
committedApr 17, 2020

Commits on Apr 15, 2020

Commits on Apr 10, 2020

[FLINK-17081][table-planner-blink] Extend batch integration tests with TestLogger
tsreaper
committedApr 10, 2020

Commits on Mar 16, 2020

[FLINK-16541][doc] Fix document of table.exec.shuffle-mode
tsreaper
committedMar 16, 2020

Commits on Dec 6, 2019

[FLINK-13943][table-planner-blink] Provide utility method to convert table to Java List

tsreaper
authored and
KurtYoung
committedDec 6, 2019

Commits on Aug 13, 2019

[FLINK-13490][jdbc] Fix return null in JDBCUtils::getFieldFromResultSet

tsreaper
authored and
wuchong
committedAug 13, 2019

Commits on Aug 7, 2019

[FLINK-13521][sql-client] Allow setting configurations in SQL CLI

tsreaper
authored and
twalthr
committedAug 7, 2019

Commits on Aug 2, 2019

[FLINK-13546][travis] Add TPC-H E2E test in travis cron job

tsreaper
authored and
wuchong
committedAug 2, 2019
[FLINK-13436][e2e] Add TPC-H queries as E2E tests

tsreaper
authored and
wuchong
committedAug 2, 2019
[table-api-java] Change the default value of table.exec.sort.default-limit to -1

tsreaper
authored and
wuchong
committedAug 2, 2019

Commits on Jul 23, 2019

[FLINK-13075][table-planner-blink] Project pushdown rule shouldn't require the TableSource return a modified schema in blink planner

tsreaper
authored and
wuchong
committedJul 23, 2019

Commits on Jul 22, 2019

[FLINK-13323][table-runtime-blink] Add tests for complex data formats

tsreaper
authored and
wuchong
committedJul 22, 2019
[FLINK-13322][table-runtime-blink] Fix serializer snapshot recovery in BaseArray and BaseMap serializers

tsreaper
authored and
wuchong
committedJul 22, 2019
[FLINK-13304][table-runtime-blink] Fix implementation of getString and getBinary method in NestedRow

tsreaper
authored and
wuchong
committedJul 22, 2019

Commits on Jul 15, 2019

[FLINK-13236][table-runtime-blink] Fix bug and improve performance in TopNBuffer (apache#9098 )

tsreaper
authored and
wuchong
committedJul 15, 2019

Commits on Jul 11, 2019

[FLINK-13118][jdbc] Introduce JDBC table factory and bridge JDBC table source with streaming table source (apache#9029 )

tsreaper
authored and
wuchong
committedJul 11, 2019
[FLINK-13198][table-api] Add a utility to validate and parse duration in DescriptorProperties

tsreaper
authored and
wuchong
committedJul 11, 2019
[FLINK-13198][core] Add a utility to parse String to Duration

tsreaper
authored and
wuchong
committedJul 11, 2019