You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@flink.apache.org by xu...@apache.org on 2025/06/24 12:26:47 UTC

(flink) branch master updated (df5bdc6b31f -> 15c48d3b446)

This is an automated email from the ASF dual-hosted git repository.

xuyangzhong pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git


    from df5bdc6b31f [FLINK-37703][hadoop] Splitting the non-local write unit test to seperated class to fix the unstable tests
     add 15c48d3b446 [FLINK-37976][table-runtime] Fix the inconsistency between the number handled by the table async execution controller and the number in the epoch (#26708)

No new revisions were added by this update.

Summary of changes:
 .../runtime/stream/sql/DeltaJoinITCase.scala       |  3 +-
 .../operators/join/lookup/keyordered/Epoch.java    |  8 +++
 .../join/lookup/keyordered/EpochManager.java       |  5 ++
 .../keyordered/TableAsyncExecutionController.java  |  6 +++
 .../lookup/TableKeyedAsyncWaitOperatorTest.java    | 58 ++++++++++++++++++----
 5 files changed, 68 insertions(+), 12 deletions(-)