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

Posted to commits@seatunnel.apache.org by ga...@apache.org on 2023/01/03 02:15:50 UTC

[incubator-seatunnel] branch dev updated (ef1b8b1bb -> c20cad5b3)

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

gaojun2048 pushed a change to branch dev
in repository https://gitbox.apache.org/repos/asf/incubator-seatunnel.git


    from ef1b8b1bb [Improve] [Connector-V2] Change Connector Custom Config Prefix To Map (#3719)
     add c20cad5b3 [Feature][starter][flink] Support transform-v2 for flink  (#3396)

No new revisions were added by this update.

Summary of changes:
 .../flink/execution/TransformExecuteProcessor.java | 53 +++++++++++++++++-----
 .../resources/assertion/fakesource_to_assert.conf  |  9 ++--
 .../test/resources/iotdb/iotdb_source_to_sink.conf | 10 +++-
 .../apache/seatunnel/e2e/common/TestSuiteBase.java |  2 +-
 .../resources/datahub/fakesource_to_datahub.conf   |  4 --
 .../test/resources/jdbc/fakesource_to_jdbc.conf    |  3 --
 .../jdbc/jdbc_mysql_source_and_sink_parallel.conf  |  9 ++--
 ...mysql_source_and_sink_parallel_upper_lower.conf |  8 ++--
 .../jdbc_postgres_source_and_sink_parallel.conf    |  8 ++--
 ...tgres_source_and_sink_parallel_upper_lower.conf |  7 ++-
 .../seatunnel/e2e/transform/TestSuiteBase.java     |  2 +-
 .../seatunnel-flink-connector-v2-example/pom.xml   |  1 -
 .../main/resources/examples/fake_to_console.conf   |  3 --
 .../flink/FlinkTransformPluginDiscovery.java       | 42 -----------------
 .../SeaTunnelFlinkTransformPluginDiscovery.java    | 12 ++---
 .../translation/serialization/RowConverter.java    |  3 +-
 16 files changed, 84 insertions(+), 92 deletions(-)
 delete mode 100644 seatunnel-plugin-discovery/src/main/java/org/apache/seatunnel/plugin/discovery/flink/FlinkTransformPluginDiscovery.java