This is an automated email from the ASF dual-hosted git repository.
zhijiang pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 19bbd6d [FLINK-17945][python] Improve the error message when
instantiating non-existing Java class
add 9add433 [hotfix][checkpointing] Fix the formatting of
CheckpointBarrierUnaligner
add aa882c1 [FLINK-17994][checkpointing] Fix the race condition between
CheckpointBarrierUnaligner#processBarrier and #notifyBarrierReceived
No new revisions were added by this update.
Summary of changes:
.../runtime/io/CheckpointBarrierUnaligner.java | 99 ++++++++++----------
.../flink/streaming/runtime/tasks/StreamTask.java | 3 +-
.../runtime/io/CheckpointBarrierUnalignerTest.java | 100 ++++++++++++++++++++-
3 files changed, 149 insertions(+), 53 deletions(-)
