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

Posted to commits@flink.apache.org by tw...@apache.org on 2022/01/11 10:19:53 UTC

[flink] branch master updated (23c477f -> 423b710)

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

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


    from 23c477f  [FLINK-25280][connector/kafka] Disable log deletion in KafkaTestEnvironmentImpl to prevent records from being deleted during test run
     add ca3a3cf  [FLINK-25390][table-common] Introduce forwardOptions for table and format factories
     add 423b710  [FLINK-25390][connector-kafka][json] Show usage of helper to forward and merge options

No new revisions were added by this update.

Summary of changes:
 .../connector/elasticsearch/table/TestContext.java |   1 +
 .../kafka/table/KafkaConnectorOptionsUtil.java     |   1 +
 .../kafka/table/KafkaDynamicTableFactory.java      |  20 ++-
 .../flink/formats/json/JsonFormatFactory.java      |  11 ++
 .../flink/formats/json/JsonFormatFactoryTest.java  | 137 ++++++++-------
 .../flink/table/catalog/ManagedTableListener.java  |   3 +-
 .../table/factories/DecodingFormatFactory.java     |   2 +-
 .../flink/table/factories/DynamicTableFactory.java |  67 +++++++-
 .../table/factories/EncodingFormatFactory.java     |   2 +-
 .../apache/flink/table/factories/FactoryUtil.java  | 189 +++++++++++++++++++--
 .../flink/table/factories/FormatFactory.java       |  52 ++++++
 .../flink/table/factories/FactoryUtilTest.java     | 165 ++++++++++++++++++
 .../table/factories/TestDynamicTableFactory.java   |   8 +
 .../flink/table/factories/TestFormatFactory.java   |   7 +
 .../flink/table/factories/utils/FactoryMocks.java  |   9 +
 15 files changed, 595 insertions(+), 79 deletions(-)
 create mode 100644 flink-table/flink-table-common/src/main/java/org/apache/flink/table/factories/FormatFactory.java