This is an automated email from the ASF dual-hosted git repository.
lzljs3620320 pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from de5e631 [hotfix][python] Shows only the slowest 20 tests
add 3f487c9 [FLINK-17590][fs-connector] Support bucket lifecycle listener
in streaming file sink buckets
No new revisions were added by this update.
Summary of changes:
.../api/functions/sink/filesystem/Bucket.java | 6 +-
.../sink/filesystem/BucketLifeCycleListener.java | 26 +++++---
.../api/functions/sink/filesystem/Buckets.java | 13 ++++
.../sink/filesystem/StreamingFileSink.java | 19 ++++++
.../sink/filesystem/BucketAssignerITCases.java | 1 +
.../api/functions/sink/filesystem/BucketsTest.java | 77 +++++++++++++++++++++-
.../sink/filesystem/RollingPolicyTest.java | 1 +
7 files changed, 130 insertions(+), 13 deletions(-)
copy
flink-runtime/src/main/java/org/apache/flink/runtime/state/OwnedTaskLocalStateStore.java
=>
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/filesystem/BucketLifeCycleListener.java
(59%)
