This is an automated email from the ASF dual-hosted git repository.
thw pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from ec8ea8b [FLINK-13596][ml] Improve fallback conversion and test for
Table transformation.
add df5eb21 [FLINK-13027][fs-connector] SFS bulk-encoded writer supports
customized checkpoint policy
No new revisions were added by this update.
Summary of changes:
.../sink/filesystem/StreamingFileSink.java | 22 ++++++++++----
...ingPolicy.java => CheckpointRollingPolicy.java} | 34 ++++++++++------------
.../rollingpolicies/OnCheckpointRollingPolicy.java | 9 ++----
.../api/functions/sink/filesystem/TestUtils.java | 3 ++
4 files changed, 38 insertions(+), 30 deletions(-)
copy
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/filesystem/rollingpolicies/{OnCheckpointRollingPolicy.java
=> CheckpointRollingPolicy.java} (60%)
