This is an automated email from the ASF dual-hosted git repository.
jark pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 3fa10a1 [hotfix] Fix PerJobMiniClusterFactory does not properly
calculate numSlotsPerTaskManager.
add 3f6080f [FLINK-16581][table-planner-blink] Support state ttl for
Mini-Batch deduplication using StateTtlConfig
No new revisions were added by this update.
Summary of changes:
.../physical/stream/StreamExecDeduplicate.scala | 13 +++----
.../DeduplicateKeepFirstRowFunction.java | 26 ++++++--------
.../DeduplicateKeepLastRowFunction.java | 26 ++++++--------
.../MiniBatchDeduplicateKeepFirstRowFunction.java | 13 +++++--
.../MiniBatchDeduplicateKeepLastRowFunction.java | 12 +++++--
.../join/stream/AbstractStreamingJoinOperator.java | 2 --
.../join/stream/StreamingJoinOperator.java | 12 +++----
.../join/stream/StreamingSemiAntiJoinOperator.java | 6 ++--
.../join/stream/state/JoinRecordStateViews.java | 26 ++++----------
.../stream/state/OuterJoinRecordStateViews.java | 13 ++++---
...orySegmentPool.java => StateTtlConfigUtil.java} | 42 ++++++++++------------
.../deduplicate/DeduplicateFunctionTestBase.java | 2 --
.../DeduplicateKeepFirstRowFunctionTest.java | 27 ++++++++++++--
.../DeduplicateKeepLastRowFunctionTest.java | 30 +++++++++++++++-
...niBatchDeduplicateKeepFirstRowFunctionTest.java | 29 ++++++++++++++-
...iniBatchDeduplicateKeepLastRowFunctionTest.java | 35 +++++++++++++++---
16 files changed, 198 insertions(+), 116 deletions(-)
copy
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/util/{MemorySegmentPool.java
=> StateTtlConfigUtil.java} (54%)
