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