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

Posted to commits@flink.apache.org by ch...@apache.org on 2019/11/15 13:44:43 UTC

[flink] branch master updated (22b2a88 -> fdc2555)

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

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


    from 22b2a88  [FLINK-13850] refactor part file configurations into a single method
     add fdc2555  Revert "[FLINK-13850] refactor part file configurations into a single method"

No new revisions were added by this update.

Summary of changes:
 docs/dev/connectors/streamfile_sink.md             | 14 ----
 .../api/functions/sink/filesystem/Bucket.java      | 24 +++---
 .../functions/sink/filesystem/BucketFactory.java   |  4 +-
 .../api/functions/sink/filesystem/Buckets.java     | 10 +--
 .../sink/filesystem/DefaultBucketFactoryImpl.java  |  8 +-
 .../sink/filesystem/OutputFileConfig.java          | 98 ----------------------
 .../functions/sink/filesystem/PartFileConfig.java} | 42 +++++-----
 .../sink/filesystem/StreamingFileSink.java         | 58 ++++++++-----
 .../sink/filesystem/BucketAssignerITCases.java     |  2 +-
 .../api/functions/sink/filesystem/BucketTest.java  | 32 ++-----
 .../api/functions/sink/filesystem/BucketsTest.java |  6 +-
 .../functions/sink/filesystem/BulkWriterTest.java  |  3 +-
 .../sink/filesystem/RollingPolicyTest.java         |  2 +-
 .../api/functions/sink/filesystem/TestUtils.java   |  9 +-
 14 files changed, 101 insertions(+), 211 deletions(-)
 delete mode 100644 flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/filesystem/OutputFileConfig.java
 copy flink-streaming-java/src/{test/java/org/apache/flink/streaming/api/functions/sink/filesystem/utils/NoOpCommitter.java => main/java/org/apache/flink/streaming/api/functions/sink/filesystem/PartFileConfig.java} (52%)