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

Posted to commits@flink.apache.org by ga...@apache.org on 2022/11/20 10:01:50 UTC

[flink] branch master updated (d745f5b3f7a -> a56af3b5702)

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

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


    from d745f5b3f7a [FLINK-29234] JobMasterServiceLeadershipRunner#closeAsync has a lock with an excessive range
     add a56af3b5702 [FLINK-29557] Fix the SinkOperator with OutputFormatFunction is not recognized as InputFormatOperator

No new revisions were added by this update.

Summary of changes:
 .../api/operators/AbstractUdfStreamOperator.java   |  3 +-
 .../api/operators/OutputFormatOperatorFactory.java |  2 +-
 .../api/operators/SimpleOperatorFactory.java       | 12 +++--
 .../SimpleOutputFormatOperatorFactory.java         | 20 +++-----
 .../api/operators/UserFunctionProvider.java        | 28 ++++++++++
 .../runtime/operators/sink/SinkOperatorTest.java   | 59 ++++++++++++++++++++++
 6 files changed, 107 insertions(+), 17 deletions(-)
 create mode 100644 flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/UserFunctionProvider.java
 create mode 100644 flink-table/flink-table-runtime/src/test/java/org/apache/flink/table/runtime/operators/sink/SinkOperatorTest.java