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 88871b2 [FLINK-18029][kafka] Add more ITCases for Kafka with new
formats (avro, csv, json)
add 0a1b0c6 [FLINK-18110][fs-connector] StreamingFileSink notifies for
buckets detected to be inactive on restoring
No new revisions were added by this update.
Summary of changes:
.../api/functions/sink/filesystem/Buckets.java | 23 +++++++----
.../api/functions/sink/filesystem/BucketsTest.java | 48 +++++++++++++++++++++-
2 files changed, 62 insertions(+), 9 deletions(-)
