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

Posted to commits@flink.apache.org by kk...@apache.org on 2020/11/07 12:29:32 UTC

[flink] branch master updated (f850f55 -> 0ccea43)

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

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


    from f850f55  [FLINK-19823][table][fs-connector] Filesystem connector supports de/serialization schema
     add 0ccea43  [FLINK-19963] Allow SinkWriter use processing timer service.

No new revisions were added by this update.

Summary of changes:
 .../org/apache/flink/api/connector/sink/Sink.java  | 39 ++++++++++
 .../operators/sink/AbstractSinkWriterOperator.java | 75 +++++++++++++++----
 .../sink/AbstractSinkWriterOperatorFactory.java    |  5 +-
 .../operators/sink/StatefulSinkWriterOperator.java |  3 +
 .../sink/StatefulSinkWriterOperatorFactory.java    |  5 +-
 .../sink/StatelessSinkWriterOperator.java          |  4 +-
 .../sink/StatelessSinkWriterOperatorFactory.java   |  5 +-
 .../operators/sink/SinkWriterOperatorTestBase.java | 83 ++++++++++++++++++----
 .../streaming/runtime/operators/sink/TestSink.java | 11 ++-
 9 files changed, 196 insertions(+), 34 deletions(-)