This is an automated email from the ASF dual-hosted git repository.
godfrey pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 767dd71 [hotfix][rest][tests] Clarify instructions for generating API
snapshot
add ea83307 [FLINK-21697][table-planner-blink] Support
StreamExecMiniBatchAssigner json serialization/deserialization
No new revisions were added by this update.
Summary of changes:
.../nodes/exec/SingleTransformationTranslator.java | 4 +-
.../exec/stream/StreamExecMiniBatchAssigner.java | 35 +++++++--
.../planner/plan/trait/MiniBatchInterval.java | 90 ++++++++++++++++++++++
.../trait/{UpdateKind.java => MiniBatchMode.java} | 22 +++---
.../stream/StreamPhysicalMiniBatchAssigner.scala | 4 +-
.../StreamCommonSubGraphBasedOptimizer.scala | 2 +-
.../stream/MiniBatchIntervalInferRule.scala | 5 +-
.../plan/trait/MiniBatchIntervalTrait.scala | 45 +----------
.../table/planner/plan/utils/FlinkRelOptUtil.scala | 18 ++---
.../exec/stream/GroupAggregateJsonPlanTest.java | 13 ++++
.../nodes/exec/stream/JsonSerdeCoverageTest.java | 1 -
...DistinctAggCalls[isMiniBatchEnabled=false].out} | 2 +-
...tDistinctAggCalls[isMiniBatchEnabled=true].out} | 32 ++++----
...CallsWithGroupBy[isMiniBatchEnabled=false].out} | 0
...gCallsWithGroupBy[isMiniBatchEnabled=true].out} | 0
...ggWithoutGroupBy[isMiniBatchEnabled=false].out} | 0
...AggWithoutGroupBy[isMiniBatchEnabled=true].out} | 0
...rDefinedAggCalls[isMiniBatchEnabled=false].out} | 0
...erDefinedAggCalls[isMiniBatchEnabled=true].out} | 32 ++++----
.../planner/plan/utils/FlinkRelOptUtilTest.scala | 24 +++---
.../flink/table/planner/utils/TableTestBase.scala | 11 ++-
21 files changed, 215 insertions(+), 125 deletions(-)
create mode 100644
flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/trait/MiniBatchInterval.java
copy
flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/trait/{UpdateKind.java
=> MiniBatchMode.java} (63%)
copy
flink-table/flink-table-planner-blink/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/GroupAggregateJsonPlanTest_jsonplan/{testDistinctAggCalls.out
=> testDistinctAggCalls[isMiniBatchEnabled=false].out} (99%)
rename
flink-table/flink-table-planner-blink/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/GroupAggregateJsonPlanTest_jsonplan/{testDistinctAggCalls.out
=> testDistinctAggCalls[isMiniBatchEnabled=true].out} (97%)
copy
flink-table/flink-table-planner-blink/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/GroupAggregateJsonPlanTest_jsonplan/{testSimpleAggCallsWithGroupBy.out
=> testSimpleAggCallsWithGroupBy[isMiniBatchEnabled=false].out} (100%)
rename
flink-table/flink-table-planner-blink/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/GroupAggregateJsonPlanTest_jsonplan/{testSimpleAggCallsWithGroupBy.out
=> testSimpleAggCallsWithGroupBy[isMiniBatchEnabled=true].out} (100%)
copy
flink-table/flink-table-planner-blink/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/GroupAggregateJsonPlanTest_jsonplan/{testSimpleAggWithoutGroupBy.out
=> testSimpleAggWithoutGroupBy[isMiniBatchEnabled=false].out} (100%)
rename
flink-table/flink-table-planner-blink/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/GroupAggregateJsonPlanTest_jsonplan/{testSimpleAggWithoutGroupBy.out
=> testSimpleAggWithoutGroupBy[isMiniBatchEnabled=true].out} (100%)
copy
flink-table/flink-table-planner-blink/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/GroupAggregateJsonPlanTest_jsonplan/{testUserDefinedAggCalls.out
=> testUserDefinedAggCalls[isMiniBatchEnabled=false].out} (100%)
rename
flink-table/flink-table-planner-blink/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/GroupAggregateJsonPlanTest_jsonplan/{testUserDefinedAggCalls.out
=> testUserDefinedAggCalls[isMiniBatchEnabled=true].out} (97%)
