You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@seatunnel.apache.org by ke...@apache.org on 2023/04/17 03:18:41 UTC
[incubator-seatunnel] branch docker/engine updated (27d04d939 -> bb9adbbbe)
This is an automated email from the ASF dual-hosted git repository.
kezhenxu94 pushed a change to branch docker/engine
in repository https://gitbox.apache.org/repos/asf/incubator-seatunnel.git
discard 27d04d939 Add Docker image for engine
add fbb8270b2 [Improve][Translation][Flink] Optimize code structure & remove redundant code (#4527)
add ce800d542 [Feature][E2E][Spark] Enable spark e2e test cases (#4534)
add 06fa850da [Jdbc][Chore] improve the exception message when primary key not found in row (#4474)
add a97f33797 [Improve][Connector-V2][Jdbc] Jdbc source supports factory SPI (#4264)
add 74d4d2485 [Hotfix][Connector-V2][Jdbc] Simple sql has the highest priority (#4548)
add 3579e6de6 [DOC][FQA.md] Correct `transform sql` config (#4495)
add e2c107323 [Improve] [Connector-V2] Throw StarRocks Serialize Error To Client (#4484)
add 8f6822ea2 [Hotfix][Zeta] Fix the bug of parsing multi sinks (#4554)
add 884f733c3 [Improve][connector][kafka] Set default value for partition option (#4524)
add fcde8ee9c [Improve][Zeta] Fallback when the CatalogTables is empty (#4551)
add 5e5859546 [Hotfix][Catalog] Filter out unavailable constrain keys (#4557)
add c350c984f [Hotfix][Zeta] Fix savepoint test case error (#4561)
add e33389755 [Feature][Connector-V2] Add rocketmq source and sink (#4007)
add 5c4f17df2 [Fix][Connector-V2] Fix file-oss config check bug and amend file-oss-jindo factoryIdentifier (#4581)
add bc4c767d5 [Chore][CI/CD] Delete docker.yml and fix wrong cron syntax (#4522)
add e6b4f9872 [Feature][Connector][Jdbc] Add vertica connector. (#4303)
add bb9adbbbe Add Docker image for engine
This update added new revisions after undoing existing revisions.
That is to say, some revisions that were in the old version of the
branch are not in the new version. This situation occurs
when a user --force pushes a change and generates a repository
containing something like this:
* -- * -- B -- O -- O -- O (27d04d939)
\
N -- N -- N refs/heads/docker/engine (bb9adbbbe)
You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
No new revisions were added by this update.
Summary of changes:
.github/workflows/backend.yml | 4 +-
.github/workflows/docker.yml | 48 ---
.../connector-v2/Error-Quick-Reference-Manual.md | 16 +
docs/en/connector-v2/sink/Jdbc.md | 4 +-
docs/en/connector-v2/sink/RocketMQ.md | 82 +++++
docs/en/connector-v2/source/Jdbc.md | 2 +
docs/en/connector-v2/source/RocketMQ.md | 142 ++++++++
docs/en/faq.md | 9 +-
plugin-mapping.properties | 3 +-
release-note.md | 3 +
.../apache/seatunnel/api/table/type/MapType.java | 6 +-
.../seatunnel/api/table/type/SeaTunnelRowType.java | 2 +-
seatunnel-common/pom.xml | 9 +-
.../seatunnel/file/oss/sink/OssFileSink.java | 2 +-
.../file/oss/sink/OssFileSinkFactory.java | 2 +-
.../seatunnel/file/oss/source/OssFileSource.java | 2 +-
.../file/oss/source/OssFileSourceFactory.java | 2 +-
.../seatunnel/file/oss/sink/OssFileSink.java | 2 +-
.../seatunnel/file/oss/source/OssFileSource.java | 2 +-
seatunnel-connectors-v2/connector-jdbc/pom.xml | 12 +
.../catalog/mysql/MysqlCreateTableSqlBuilder.java | 4 +
.../jdbc/internal/JdbcOutputFormatBuilder.java | 16 +-
.../VerticaDialect.java} | 36 +-
.../VerticaDialectFactory.java} | 9 +-
.../VerticaJdbcRowConverter.java} | 6 +-
.../dialect/vertica/VerticaTypeMapper.java | 177 ++++++++++
.../seatunnel/jdbc/source/JdbcSource.java | 120 +++----
.../seatunnel/jdbc/source/JdbcSourceFactory.java | 160 +++++++++
.../seatunnel/kafka/sink/KafkaSinkFactory.java | 5 +-
.../seatunnel/kafka/sink/KafkaSinkWriter.java | 18 +-
.../pom.xml | 25 +-
.../rocketmq/common/RocketMqAdminUtil.java | 319 ++++++++++++++++++
.../rocketmq/common/RocketMqBaseConfiguration.java | 255 ++++++++++++++
.../seatunnel/rocketmq/common/SchemaFormat.java} | 37 +-
.../seatunnel/rocketmq/common/StartMode.java | 14 +-
.../seatunnel/rocketmq/config/Config.java | 68 ++++
.../seatunnel/rocketmq/config/ConsumerConfig.java | 89 +++++
.../seatunnel/rocketmq/config/ProducerConfig.java | 71 ++++
.../exception/RocketMqConnectorErrorCode.java | 71 ++++
.../exception/RocketMqConnectorException.java} | 10 +-
.../serialize/DefaultSeaTunnelRowSerializer.java | 127 +++++++
.../serialize/SeaTunnelRowSerializer.java | 10 +-
.../seatunnel/rocketmq/sink/ProducerMetadata.java} | 32 +-
.../rocketmq/sink/RocketMqNoTransactionSender.java | 102 ++++++
.../rocketmq/sink/RocketMqProducerSender.java | 11 +-
.../seatunnel/rocketmq/sink/RocketMqSink.java | 170 ++++++++++
.../rocketmq/sink/RocketMqSinkFactory.java} | 24 +-
.../rocketmq/sink/RocketMqSinkWriter.java | 102 ++++++
.../rocketmq/sink/RocketMqTransactionSender.java | 80 +++++
.../rocketmq}/source/ConsumerMetadata.java | 25 +-
.../rocketmq/source/RocketMqConsumerThread.java | 69 ++++
.../seatunnel/rocketmq/source/RocketMqSource.java | 288 ++++++++++++++++
.../rocketmq/source/RocketMqSourceFactory.java} | 38 ++-
.../rocketmq/source/RocketMqSourceReader.java} | 217 ++++++------
.../rocketmq/source/RocketMqSourceSplit.java} | 67 ++--
.../source/RocketMqSourceSplitEnumerator.java | 352 +++++++++++++++++++
.../rocketmq/source/RocketMqSourceState.java | 28 +-
.../starrocks/sink/StarRocksSinkWriter.java | 6 +-
seatunnel-connectors-v2/pom.xml | 1 +
seatunnel-dist/pom.xml | 7 +
.../clickhouse/ClickhouseSinkCDCChangelogIT.java | 6 +
.../e2e/connector/file/local/LocalFileIT.java | 7 +
.../connector-jdbc-e2e-part-3/pom.xml | 5 +
.../seatunnel/jdbc/JdbcSinkCDCChangelogIT.java | 6 +
.../connectors/seatunnel/jdbc/JdbcVerticaIT.java | 138 ++++++++
.../resources/jdbc_vertica_source_and_sink.conf} | 39 +--
.../seatunnel/e2e/connector/kafka/KafkaIT.java | 36 ++
....conf => kafka_default_sink_fake_to_kafka.conf} | 3 +-
.../pom.xml | 38 ++-
.../e2e/connector/rocketmq/RocketMqContainer.java | 102 ++++++
.../e2e/connector/rocketmq/RocketMqIT.java | 372 +++++++++++++++++++++
.../src/test/resources/log4j2-test.properties | 7 +
.../resources/rocketmq-sink_fake_to_rocketmq.conf} | 8 +-
.../rocketmq-source_json_to_console.conf} | 48 ++-
.../rocketmq-source_text_to_console.conf} | 27 +-
.../rocketmq-text-sink_fake_to_rocketmq.conf} | 8 +-
.../rocketmq_source_earliest_to_console.conf} | 41 +--
.../rocketmq_source_group_offset_to_console.conf} | 32 +-
.../rocketmq_source_latest_to_console.conf} | 45 ++-
...cketmq_source_specific_offsets_to_console.conf} | 34 +-
.../rocketmq_source_timestamp_to_console.conf} | 32 +-
seatunnel-e2e/seatunnel-connector-v2-e2e/pom.xml | 1 +
.../apache/seatunnel/e2e/common/TestSuiteBase.java | 2 +-
.../common/container/spark/Spark2Container.java | 2 +-
.../common/container/spark/Spark3Container.java | 2 +-
.../engine/client/SeaTunnelClientTest.java | 24 +-
.../src/test/resources/log4j2-test.properties | 4 +
.../core/parse/MultipleTableJobConfigParser.java | 18 +-
.../server/checkpoint/CheckpointCloseReason.java | 3 +-
.../server/checkpoint/CheckpointCoordinator.java | 15 +-
.../CheckpointBarrierTriggerOperation.java | 2 +-
.../server/dag/physical/PhysicalPlanGenerator.java | 1 +
.../seatunnel/engine/server/master/JobMaster.java | 5 +
.../seatunnel-translation-flink/pom.xml | 1 +
.../seatunnel-translation-flink-13/pom.xml | 14 +-
.../translation/flink/sink/FlinkSink.java | 101 ------
.../translation/flink/sink/FlinkSinkWriter.java | 95 ------
.../flink/utils/TypeConverterUtils.java | 205 ------------
.../seatunnel-translation-flink-15/pom.xml | 8 +-
.../serialization/CommitWrapperSerializer.java | 74 ----
.../flink/serialization/FlinkRowConverter.java | 129 -------
.../FlinkSimpleVersionedSerializer.java | 56 ----
.../serialization/FlinkWriterStateSerializer.java | 77 -----
.../flink/serialization/KryoTypeInfo.java | 41 ---
.../flink/serialization/WrappedRow.java | 54 ---
.../translation/flink/sink/CommitWrapper.java | 36 --
.../translation/flink/sink/FlinkCommitter.java | 64 ----
.../flink/sink/FlinkGlobalCommitter.java | 80 -----
.../translation/flink/sink/FlinkWriterState.java | 54 ---
.../flink/source/BaseSeaTunnelSourceFunction.java | 180 ----------
.../translation/flink/source/RowCollector.java | 58 ----
.../flink/source/SeaTunnelCoordinatedSource.java | 45 ---
.../flink/source/SeaTunnelParallelSource.java | 52 ---
.../pom.xml | 5 +-
.../serialization/CommitWrapperSerializer.java | 0
.../flink/serialization/FlinkRowConverter.java | 0
.../FlinkSimpleVersionedSerializer.java | 0
.../serialization/FlinkWriterStateSerializer.java | 0
.../flink/serialization/KryoTypeInfo.java | 0
.../flink/serialization/WrappedRow.java | 0
.../translation/flink/sink/CommitWrapper.java | 0
.../translation/flink/sink/FlinkCommitter.java | 0
.../flink/sink/FlinkGlobalCommitter.java | 0
.../translation/flink/sink/FlinkSink.java | 0
.../translation/flink/sink/FlinkSinkWriter.java | 0
.../translation/flink/sink/FlinkWriterState.java | 0
.../flink/source/BaseSeaTunnelSourceFunction.java | 0
.../translation/flink/source/RowCollector.java | 0
.../flink/source/SeaTunnelCoordinatedSource.java | 0
.../flink/source/SeaTunnelParallelSource.java | 0
.../flink/utils/TypeConverterUtils.java | 0
tools/dependencies/known-dependencies.txt | 1 +
132 files changed, 4065 insertions(+), 2098 deletions(-)
delete mode 100644 .github/workflows/docker.yml
create mode 100644 docs/en/connector-v2/sink/RocketMQ.md
create mode 100644 docs/en/connector-v2/source/RocketMQ.md
copy seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/dialect/{oracle/OracleDialect.java => vertica/VerticaDialect.java} (83%)
copy seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/dialect/{gbase8a/Gbase8aDialectFactory.java => vertica/VerticaDialectFactory.java} (85%)
copy seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/dialect/{phoenix/PhoenixJdbcRowConverter.java => vertica/VerticaJdbcRowConverter.java} (90%)
create mode 100644 seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/dialect/vertica/VerticaTypeMapper.java
copy seatunnel-connectors-v2/{connector-kafka => connector-rocketmq}/pom.xml (78%)
create mode 100644 seatunnel-connectors-v2/connector-rocketmq/src/main/java/org/apache/seatunnel/connectors/seatunnel/rocketmq/common/RocketMqAdminUtil.java
create mode 100644 seatunnel-connectors-v2/connector-rocketmq/src/main/java/org/apache/seatunnel/connectors/seatunnel/rocketmq/common/RocketMqBaseConfiguration.java
copy seatunnel-connectors-v2/{connector-clickhouse/src/main/java/org/apache/seatunnel/connectors/seatunnel/clickhouse/config/ClickhouseFileCopyMethod.java => connector-rocketmq/src/main/java/org/apache/seatunnel/connectors/seatunnel/rocketmq/common/SchemaFormat.java} (57%)
copy seatunnel-api/src/main/java/org/apache/seatunnel/api/table/connector/SerializationFormat.java => seatunnel-connectors-v2/connector-rocketmq/src/main/java/org/apache/seatunnel/connectors/seatunnel/rocketmq/common/StartMode.java (74%)
create mode 100644 seatunnel-connectors-v2/connector-rocketmq/src/main/java/org/apache/seatunnel/connectors/seatunnel/rocketmq/config/Config.java
create mode 100644 seatunnel-connectors-v2/connector-rocketmq/src/main/java/org/apache/seatunnel/connectors/seatunnel/rocketmq/config/ConsumerConfig.java
create mode 100644 seatunnel-connectors-v2/connector-rocketmq/src/main/java/org/apache/seatunnel/connectors/seatunnel/rocketmq/config/ProducerConfig.java
create mode 100644 seatunnel-connectors-v2/connector-rocketmq/src/main/java/org/apache/seatunnel/connectors/seatunnel/rocketmq/exception/RocketMqConnectorErrorCode.java
copy seatunnel-connectors-v2/{connector-file/connector-file-oss-jindo/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/oss/exception/OssJindoConnectorException.java => connector-rocketmq/src/main/java/org/apache/seatunnel/connectors/seatunnel/rocketmq/exception/RocketMqConnectorException.java} (81%)
create mode 100644 seatunnel-connectors-v2/connector-rocketmq/src/main/java/org/apache/seatunnel/connectors/seatunnel/rocketmq/serialize/DefaultSeaTunnelRowSerializer.java
copy seatunnel-connectors-v2/{connector-kafka/src/main/java/org/apache/seatunnel/connectors/seatunnel/kafka => connector-rocketmq/src/main/java/org/apache/seatunnel/connectors/seatunnel/rocketmq}/serialize/SeaTunnelRowSerializer.java (77%)
copy seatunnel-connectors-v2/{connector-iotdb/src/main/java/org/apache/seatunnel/connectors/seatunnel/iotdb/state/IoTDBSourceState.java => connector-rocketmq/src/main/java/org/apache/seatunnel/connectors/seatunnel/rocketmq/sink/ProducerMetadata.java} (56%)
create mode 100644 seatunnel-connectors-v2/connector-rocketmq/src/main/java/org/apache/seatunnel/connectors/seatunnel/rocketmq/sink/RocketMqNoTransactionSender.java
copy seatunnel-api/src/main/java/org/apache/seatunnel/api/transform/PartitionSeaTunnelTransform.java => seatunnel-connectors-v2/connector-rocketmq/src/main/java/org/apache/seatunnel/connectors/seatunnel/rocketmq/sink/RocketMqProducerSender.java (76%)
create mode 100644 seatunnel-connectors-v2/connector-rocketmq/src/main/java/org/apache/seatunnel/connectors/seatunnel/rocketmq/sink/RocketMqSink.java
copy seatunnel-connectors-v2/{connector-redis/src/main/java/org/apache/seatunnel/connectors/seatunnel/redis/sink/RedisSinkFactory.java => connector-rocketmq/src/main/java/org/apache/seatunnel/connectors/seatunnel/rocketmq/sink/RocketMqSinkFactory.java} (63%)
create mode 100644 seatunnel-connectors-v2/connector-rocketmq/src/main/java/org/apache/seatunnel/connectors/seatunnel/rocketmq/sink/RocketMqSinkWriter.java
create mode 100644 seatunnel-connectors-v2/connector-rocketmq/src/main/java/org/apache/seatunnel/connectors/seatunnel/rocketmq/sink/RocketMqTransactionSender.java
copy seatunnel-connectors-v2/{connector-kafka/src/main/java/org/apache/seatunnel/connectors/seatunnel/kafka => connector-rocketmq/src/main/java/org/apache/seatunnel/connectors/seatunnel/rocketmq}/source/ConsumerMetadata.java (61%)
create mode 100644 seatunnel-connectors-v2/connector-rocketmq/src/main/java/org/apache/seatunnel/connectors/seatunnel/rocketmq/source/RocketMqConsumerThread.java
create mode 100644 seatunnel-connectors-v2/connector-rocketmq/src/main/java/org/apache/seatunnel/connectors/seatunnel/rocketmq/source/RocketMqSource.java
copy seatunnel-connectors-v2/{connector-kafka/src/main/java/org/apache/seatunnel/connectors/seatunnel/kafka/source/KafkaSourceFactory.java => connector-rocketmq/src/main/java/org/apache/seatunnel/connectors/seatunnel/rocketmq/source/RocketMqSourceFactory.java} (53%)
copy seatunnel-connectors-v2/{connector-kafka/src/main/java/org/apache/seatunnel/connectors/seatunnel/kafka/source/KafkaSourceReader.java => connector-rocketmq/src/main/java/org/apache/seatunnel/connectors/seatunnel/rocketmq/source/RocketMqSourceReader.java} (53%)
copy seatunnel-connectors-v2/{connector-kafka/src/main/java/org/apache/seatunnel/connectors/seatunnel/kafka/source/KafkaSourceSplit.java => connector-rocketmq/src/main/java/org/apache/seatunnel/connectors/seatunnel/rocketmq/source/RocketMqSourceSplit.java} (51%)
create mode 100644 seatunnel-connectors-v2/connector-rocketmq/src/main/java/org/apache/seatunnel/connectors/seatunnel/rocketmq/source/RocketMqSourceSplitEnumerator.java
copy seatunnel-engine/seatunnel-engine-core/src/main/java/org/apache/seatunnel/engine/core/job/VertexInfo.java => seatunnel-connectors-v2/connector-rocketmq/src/main/java/org/apache/seatunnel/connectors/seatunnel/rocketmq/source/RocketMqSourceState.java (65%)
create mode 100644 seatunnel-e2e/seatunnel-connector-v2-e2e/connector-jdbc-e2e/connector-jdbc-e2e-part-3/src/test/java/org/apache/seatunnel/connectors/seatunnel/jdbc/JdbcVerticaIT.java
copy seatunnel-e2e/seatunnel-connector-v2-e2e/{connector-datahub-e2e/src/test/resources/fakesource_to_datahub.conf => connector-jdbc-e2e/connector-jdbc-e2e-part-3/src/test/resources/jdbc_vertica_source_and_sink.conf} (60%)
copy seatunnel-e2e/seatunnel-connector-v2-e2e/connector-kafka-e2e/src/test/resources/{kafkaTextsink_fake_to_kafka.conf => kafka_default_sink_fake_to_kafka.conf} (95%)
copy seatunnel-e2e/seatunnel-connector-v2-e2e/{connector-iceberg-hadoop3-e2e => connector-rocketmq-e2e}/pom.xml (76%)
create mode 100644 seatunnel-e2e/seatunnel-connector-v2-e2e/connector-rocketmq-e2e/src/test/java/org/apache/seatunnel/e2e/connector/rocketmq/RocketMqContainer.java
create mode 100644 seatunnel-e2e/seatunnel-connector-v2-e2e/connector-rocketmq-e2e/src/test/java/org/apache/seatunnel/e2e/connector/rocketmq/RocketMqIT.java
copy seatunnel-e2e/seatunnel-connector-v2-e2e/{connector-cdc-mysql-e2e => connector-rocketmq-e2e}/src/test/resources/log4j2-test.properties (88%)
copy seatunnel-e2e/seatunnel-connector-v2-e2e/{connector-kafka-e2e/src/test/resources/kafkasink_fake_to_kafka.conf => connector-rocketmq-e2e/src/test/resources/rocketmq-sink_fake_to_rocketmq.conf} (92%)
copy seatunnel-e2e/seatunnel-connector-v2-e2e/{connector-kafka-e2e/src/test/resources/kafkasource_json_to_console.conf => connector-rocketmq-e2e/src/test/resources/rocketmq-source_json_to_console.conf} (67%)
copy seatunnel-e2e/seatunnel-connector-v2-e2e/{connector-kafka-e2e/src/test/resources/kafkasource_text_to_console.conf => connector-rocketmq-e2e/src/test/resources/rocketmq-source_text_to_console.conf} (82%)
copy seatunnel-e2e/seatunnel-connector-v2-e2e/{connector-kafka-e2e/src/test/resources/kafkaTextsink_fake_to_kafka.conf => connector-rocketmq-e2e/src/test/resources/rocketmq-text-sink_fake_to_rocketmq.conf} (92%)
copy seatunnel-e2e/seatunnel-connector-v2-e2e/{connector-kafka-e2e/src/test/resources/kafka/kafkasource_earliest_to_console.conf => connector-rocketmq-e2e/src/test/resources/rocketmq/rocketmq_source_earliest_to_console.conf} (67%)
copy seatunnel-e2e/seatunnel-connector-v2-e2e/{connector-kafka-e2e/src/test/resources/kafka/kafkasource_group_offset_to_console.conf => connector-rocketmq-e2e/src/test/resources/rocketmq/rocketmq_source_group_offset_to_console.conf} (74%)
copy seatunnel-e2e/seatunnel-connector-v2-e2e/{connector-kafka-e2e/src/test/resources/kafka/kafkasource_latest_to_console.conf => connector-rocketmq-e2e/src/test/resources/rocketmq/rocketmq_source_latest_to_console.conf} (66%)
copy seatunnel-e2e/seatunnel-connector-v2-e2e/{connector-kafka-e2e/src/test/resources/kafka/kafkasource_specific_offsets_to_console.conf => connector-rocketmq-e2e/src/test/resources/rocketmq/rocketmq_source_specific_offsets_to_console.conf} (76%)
copy seatunnel-e2e/seatunnel-connector-v2-e2e/{connector-kafka-e2e/src/test/resources/kafka/kafkasource_earliest_to_console.conf => connector-rocketmq-e2e/src/test/resources/rocketmq/rocketmq_source_timestamp_to_console.conf} (76%)
delete mode 100644 seatunnel-translation/seatunnel-translation-flink/seatunnel-translation-flink-13/src/main/java/org/apache/seatunnel/translation/flink/sink/FlinkSink.java
delete mode 100644 seatunnel-translation/seatunnel-translation-flink/seatunnel-translation-flink-13/src/main/java/org/apache/seatunnel/translation/flink/sink/FlinkSinkWriter.java
delete mode 100644 seatunnel-translation/seatunnel-translation-flink/seatunnel-translation-flink-13/src/main/java/org/apache/seatunnel/translation/flink/utils/TypeConverterUtils.java
delete mode 100644 seatunnel-translation/seatunnel-translation-flink/seatunnel-translation-flink-15/src/main/java/org/apache/seatunnel/translation/flink/serialization/CommitWrapperSerializer.java
delete mode 100644 seatunnel-translation/seatunnel-translation-flink/seatunnel-translation-flink-15/src/main/java/org/apache/seatunnel/translation/flink/serialization/FlinkRowConverter.java
delete mode 100644 seatunnel-translation/seatunnel-translation-flink/seatunnel-translation-flink-15/src/main/java/org/apache/seatunnel/translation/flink/serialization/FlinkSimpleVersionedSerializer.java
delete mode 100644 seatunnel-translation/seatunnel-translation-flink/seatunnel-translation-flink-15/src/main/java/org/apache/seatunnel/translation/flink/serialization/FlinkWriterStateSerializer.java
delete mode 100644 seatunnel-translation/seatunnel-translation-flink/seatunnel-translation-flink-15/src/main/java/org/apache/seatunnel/translation/flink/serialization/KryoTypeInfo.java
delete mode 100644 seatunnel-translation/seatunnel-translation-flink/seatunnel-translation-flink-15/src/main/java/org/apache/seatunnel/translation/flink/serialization/WrappedRow.java
delete mode 100644 seatunnel-translation/seatunnel-translation-flink/seatunnel-translation-flink-15/src/main/java/org/apache/seatunnel/translation/flink/sink/CommitWrapper.java
delete mode 100644 seatunnel-translation/seatunnel-translation-flink/seatunnel-translation-flink-15/src/main/java/org/apache/seatunnel/translation/flink/sink/FlinkCommitter.java
delete mode 100644 seatunnel-translation/seatunnel-translation-flink/seatunnel-translation-flink-15/src/main/java/org/apache/seatunnel/translation/flink/sink/FlinkGlobalCommitter.java
delete mode 100644 seatunnel-translation/seatunnel-translation-flink/seatunnel-translation-flink-15/src/main/java/org/apache/seatunnel/translation/flink/sink/FlinkWriterState.java
delete mode 100644 seatunnel-translation/seatunnel-translation-flink/seatunnel-translation-flink-15/src/main/java/org/apache/seatunnel/translation/flink/source/BaseSeaTunnelSourceFunction.java
delete mode 100644 seatunnel-translation/seatunnel-translation-flink/seatunnel-translation-flink-15/src/main/java/org/apache/seatunnel/translation/flink/source/RowCollector.java
delete mode 100644 seatunnel-translation/seatunnel-translation-flink/seatunnel-translation-flink-15/src/main/java/org/apache/seatunnel/translation/flink/source/SeaTunnelCoordinatedSource.java
delete mode 100644 seatunnel-translation/seatunnel-translation-flink/seatunnel-translation-flink-15/src/main/java/org/apache/seatunnel/translation/flink/source/SeaTunnelParallelSource.java
copy seatunnel-translation/seatunnel-translation-flink/{seatunnel-translation-flink-15 => seatunnel-translation-flink-common}/pom.xml (93%)
rename seatunnel-translation/seatunnel-translation-flink/{seatunnel-translation-flink-13 => seatunnel-translation-flink-common}/src/main/java/org/apache/seatunnel/translation/flink/serialization/CommitWrapperSerializer.java (100%)
rename seatunnel-translation/seatunnel-translation-flink/{seatunnel-translation-flink-13 => seatunnel-translation-flink-common}/src/main/java/org/apache/seatunnel/translation/flink/serialization/FlinkRowConverter.java (100%)
rename seatunnel-translation/seatunnel-translation-flink/{seatunnel-translation-flink-13 => seatunnel-translation-flink-common}/src/main/java/org/apache/seatunnel/translation/flink/serialization/FlinkSimpleVersionedSerializer.java (100%)
rename seatunnel-translation/seatunnel-translation-flink/{seatunnel-translation-flink-13 => seatunnel-translation-flink-common}/src/main/java/org/apache/seatunnel/translation/flink/serialization/FlinkWriterStateSerializer.java (100%)
rename seatunnel-translation/seatunnel-translation-flink/{seatunnel-translation-flink-13 => seatunnel-translation-flink-common}/src/main/java/org/apache/seatunnel/translation/flink/serialization/KryoTypeInfo.java (100%)
rename seatunnel-translation/seatunnel-translation-flink/{seatunnel-translation-flink-13 => seatunnel-translation-flink-common}/src/main/java/org/apache/seatunnel/translation/flink/serialization/WrappedRow.java (100%)
rename seatunnel-translation/seatunnel-translation-flink/{seatunnel-translation-flink-13 => seatunnel-translation-flink-common}/src/main/java/org/apache/seatunnel/translation/flink/sink/CommitWrapper.java (100%)
rename seatunnel-translation/seatunnel-translation-flink/{seatunnel-translation-flink-13 => seatunnel-translation-flink-common}/src/main/java/org/apache/seatunnel/translation/flink/sink/FlinkCommitter.java (100%)
rename seatunnel-translation/seatunnel-translation-flink/{seatunnel-translation-flink-13 => seatunnel-translation-flink-common}/src/main/java/org/apache/seatunnel/translation/flink/sink/FlinkGlobalCommitter.java (100%)
rename seatunnel-translation/seatunnel-translation-flink/{seatunnel-translation-flink-15 => seatunnel-translation-flink-common}/src/main/java/org/apache/seatunnel/translation/flink/sink/FlinkSink.java (100%)
rename seatunnel-translation/seatunnel-translation-flink/{seatunnel-translation-flink-15 => seatunnel-translation-flink-common}/src/main/java/org/apache/seatunnel/translation/flink/sink/FlinkSinkWriter.java (100%)
rename seatunnel-translation/seatunnel-translation-flink/{seatunnel-translation-flink-13 => seatunnel-translation-flink-common}/src/main/java/org/apache/seatunnel/translation/flink/sink/FlinkWriterState.java (100%)
rename seatunnel-translation/seatunnel-translation-flink/{seatunnel-translation-flink-13 => seatunnel-translation-flink-common}/src/main/java/org/apache/seatunnel/translation/flink/source/BaseSeaTunnelSourceFunction.java (100%)
rename seatunnel-translation/seatunnel-translation-flink/{seatunnel-translation-flink-13 => seatunnel-translation-flink-common}/src/main/java/org/apache/seatunnel/translation/flink/source/RowCollector.java (100%)
rename seatunnel-translation/seatunnel-translation-flink/{seatunnel-translation-flink-13 => seatunnel-translation-flink-common}/src/main/java/org/apache/seatunnel/translation/flink/source/SeaTunnelCoordinatedSource.java (100%)
rename seatunnel-translation/seatunnel-translation-flink/{seatunnel-translation-flink-13 => seatunnel-translation-flink-common}/src/main/java/org/apache/seatunnel/translation/flink/source/SeaTunnelParallelSource.java (100%)
rename seatunnel-translation/seatunnel-translation-flink/{seatunnel-translation-flink-15 => seatunnel-translation-flink-common}/src/main/java/org/apache/seatunnel/translation/flink/utils/TypeConverterUtils.java (100%)