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

Posted to commits@flink.apache.org by ja...@apache.org on 2020/11/19 03:47:15 UTC

[flink] branch master updated (cd833c2 -> b4d885d)

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

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


    from cd833c2  [FLINK-20062][hive] ContinuousHiveSplitEnumerator should be lock-free
     add b4d885d  [FLINK-20187][table-common] Fix factory discovering is failed when source and sink factories are not implemented in one class

No new revisions were added by this update.

Summary of changes:
 .../apache/flink/table/factories/FactoryUtil.java  | 55 +++++++++++++---------
 .../flink/table/factories/FactoryUtilTest.java     | 25 +++++++++-
 ...ctory.java => TestDynamicTableSinkFactory.java} | 18 ++++---
 ...ory.java => TestDynamicTableSourceFactory.java} | 18 ++++---
 .../org.apache.flink.table.factories.Factory       |  2 +
 5 files changed, 80 insertions(+), 38 deletions(-)
 copy flink-table/flink-table-common/src/test/java/org/apache/flink/table/factories/{TestDynamicTableSinkOnlyFactory.java => TestDynamicTableSinkFactory.java} (70%)
 copy flink-table/flink-table-common/src/test/java/org/apache/flink/table/factories/{TestDynamicTableSourceOnlyFactory.java => TestDynamicTableSourceFactory.java} (70%)