This is an automated email from the ASF dual-hosted git repository.
aloyszhang pushed a change to branch dev-offline-sync
in repository https://gitbox.apache.org/repos/asf/inlong.git
omit 9c714530a1 [INLONG-10561][Manager] Support configrations for bounded
source (#10571)
omit bf38d2a3aa [INLONG-10560][Sort] Support bounded pulsar source (#10569)
omit 2f67c3485b [INLONG-10566][Manager] fix auth failed and cronexpression
field type (#10567)
omit 8f75bf6708 [INLONG-10514][Manager] Support built-in schedule engine
trigger submitting of Flink batch job (#10515)
omit 8819bfc166 [INLONG-10459][Manager] Support schedule instance callback
to submit Flink batch job (#10510)
omit e3beb8c845 [INLONG-10360][Manager] Combine schedule state transition
with group operations (#10445)
omit 50b770583a [INLONG-10436][Manager] Move schedule configuration from
stream to group (#10437)
omit f5950f9232 [INLONG-10396][Manager] Support build-in schedule base on
quartz (#10412)
omit a915bb194f [INLONG-10395][Manager] Add interface for schedule client
and engine (#10397)
omit 43b29b4240 [INLONG-10247][Manager] Support schedule information
management for offline sync (#10254)
omit 5ed1c78184 [INLONG-9862][Manager] Support submit flink job for offline
sync (#9865)
omit b9f0c46d8b [INLONG-9822][Manager] Support flink job runtime execution
mode configuration (#9823)
omit 63499be245 [INLONG-9813][Manager] Support offline data sync management
(#9814)
omit cc77515131 [INLONG-9781][Manager] Add offline sync task type
definition (#9787)
add a6faf33d66 [INLONG-10501][Dashboard] Modify component type to be more
intuitive (#10503)
add f17cc77179 [INLONG-10506][Manager] When obtaining a template, return
information such as creator and modifier (#10507)
add e6ec72c684 [INLONG-10512][Manager] Support preview of data in kv data
type (#10513)
add d6be026cb9 [INLONG-8464][Sort] Add JDBC connector on Flink 1.15
(#10491)
add f7be768488 [INLONG-10516][Manager] Add flink 1.15 jdbc connectors to
manager image (#10517)
add db8944c5c3 [INLONG-10518][Sort] Add jdbc fileSet in
inlong-distribution sort-connectors-v1.15.xml (#10519)
add 147c49a689 [INLONG-10434][Manager] Allow creating cluster nodes
without setting port (#10435)
add 396ae72e0f [INLONG-10520][Manager] Fix the problem of protocol type
reported by dataproxy not correctly accepted (#10521)
add f1679e341e [INLONG-10522][SDK] SortSDK support assgin subscription
(#10523)
add 163fb5e8ab [INLONG-10500][Dashboard] Change the visible range to a
drop-down box (#10502)
add d4db882bc2 [INLONG-10524][Dashboard] Modify the time column (#10525)
add 31a6f8bcbc [INLONG-10535][Agent] Support minute level tasks (#10536)
add d5189626ab [INLONG-10531][SDK] Add InLong dataproxy python SDK based
on C++ SDK (#10538)
add ee5f93f4af [INLONG-10540][Sort] Sortstandalone unified configuration
metric reporter (#10541)
add ada439ce81 [INLONG-10358][Sort] Make pulsar source support report
audit information exactly once (#10511)
add 1dde4f7bcb [INLONG-10543][Manager] The delimiter and other
configurations in CLS and ES sink are obtained from the stream (#10545)
add 8724e9e198 [INLONG-10526][Sort] ClsSink support switch metadata
acquire mode (#10539)
add f45f26bbe2 [INLONG-10542][Agent] Remove the deleted watch directions
(#10544)
add 8de559e79a [INLONG-10547][Agent] Provide a clear prompt after the mq
type is incorrect (#10548)
add bda8f4c305 [INLONG-10532][SDK] Add dataproxy python SDK sample and the
corresponding document (#10546)
add 45870d22a6 [INLONG-10355][Sort] Make Iceberg source support report
audit information exactly once (#10551)
add d698b5cde6 [INLONG-10527][Sort] EsSink support switch metadata acquire
mode (#10552)
add b5eeffee2f [INLONG-10528][Sort] KafkaSink support switch metadata
acquire mode (#10553)
add 5b29cc0d57 [INLONG-10357][Sort] Make StarRocks sink support report
audit information exactly once (#10549)
add 8eec67bc72 [INLONG-10529][Sort] PulsarSink support switch metadata
acquire mode (#10554)
add 57985782d0 [INLONG-10317][Sort] Make Kafka source support report audit
information exactly once (#10550)
add 88595f8dbc [INLONG-10555][Sort] SortStandalone support report the
difference between two configuration (#10556)
add f112ec05cf [INLONG-10558][Manager] Support determining whether to
issue agent tasks based on the MD5 value (#10559)
add 1a01ea9dc5 [INLONG-10564][Agent] Request configuration with md5
included (#10565)
add 59b6c5fc52 [INLONG-10562][Manager] SortConfig supports set start and
stop consuming time (#10563)
add e0bbbb8510 [INLONG-10568][Sort] Change the starrocks connector UNKNOWN
datatype handle method (#10570)
add 2f1e6d0e36 [INLONG-10575][Sort] Make mysql source support report audit
information exactly once (#10576)
add 6d783daab4 [INLONG-9781][Manager] Add offline sync task type
definition (#9787)
add 62fe9cddd1 [INLONG-9813][Manager] Support offline data sync management
(#9814)
add eafee5f5a8 [INLONG-9822][Manager] Support flink job runtime execution
mode configuration (#9823)
add 1020de9647 [INLONG-9862][Manager] Support submit flink job for offline
sync (#9865)
add 966590f25a [INLONG-10247][Manager] Support schedule information
management for offline sync (#10254)
add b475ed8fda [INLONG-10395][Manager] Add interface for schedule client
and engine (#10397)
add 147298c265 [INLONG-10396][Manager] Support build-in schedule base on
quartz (#10412)
add 715c24cf7c [INLONG-10436][Manager] Move schedule configuration from
stream to group (#10437)
add 4cd124b3c9 [INLONG-10360][Manager] Combine schedule state transition
with group operations (#10445)
add 1c370548bc [INLONG-10459][Manager] Support schedule instance callback
to submit Flink batch job (#10510)
add 41b4403ff0 [INLONG-10514][Manager] Support built-in schedule engine
trigger submitting of Flink batch job (#10515)
add b9f1bcf72d [INLONG-10566][Manager] fix auth failed and cronexpression
field type (#10567)
add 1a69810d48 [INLONG-10560][Sort] Support bounded pulsar source (#10569)
add 6dcdaa3d13 [INLONG-10561][Manager] Support configrations for bounded
source (#10571)
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 (9c714530a1)
\
N -- N -- N refs/heads/dev-offline-sync (6dcdaa3d13)
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:
docker/docker-compose/docker-compose.yml | 2 +-
.../inlong/agent/constant/CycleUnitType.java | 5 +-
.../apache/inlong/agent/pojo/TaskProfileDto.java | 2 +-
.../apache/inlong/agent/utils/DateTransUtils.java | 37 +-
.../inlong/agent/installer/ManagerFetcher.java | 4 +-
.../agent/plugin/fetcher/ManagerFetcher.java | 45 +-
.../inlong/agent/plugin/task/file/FileScanner.java | 19 +-
.../inlong/agent/plugin/task/file/LogFileTask.java | 5 +-
.../inlong/agent/plugin/task/file/WatchEntity.java | 90 +---
.../agent/plugin/utils/file/FilePathUtil.java | 8 +-
.../agent/plugin/utils/file/NewDateUtils.java | 128 +----
.../inlong/agent/plugin/AgentBaseTestsHelper.java | 3 +-
.../inlong/agent/plugin/fetcher/TestManager.java | 60 +++
.../inlong/agent/plugin/task/TestLogFileTask.java | 101 ++--
.../inlong/agent/plugin/utils/TestUtils.java | 97 ++--
.../{20230928_1 => 202309281030_1}/test_1.txt | 0
.../{20230928_1 => 2023092810_1}/test_1.txt | 0
.../{20230928_1 => 202309301059_1}/test_1.txt | 0
.../20230928_1.txt => testScan/20241030/23/59.txt} | 0
.../inlong/common/heartbeat/HeartbeatMsg.java | 10 +
.../inlong/common/pojo/agent/AgentConfigInfo.java | 6 +-
.../common/pojo/agent/AgentConfigRequest.java | 3 +
.../InstallerCode.java => AgentResponseCode.java} | 14 +-
.../inlong/common/pojo/agent/TaskRequest.java | 2 +
.../inlong/common/pojo/agent/TaskResult.java | 2 +
.../common/pojo/agent/installer/ConfigResult.java | 4 +-
...ortClusterConfig.java => ClusterTagConfig.java} | 56 +--
.../apache/inlong/common/pojo/sort/SortConfig.java | 14 +-
.../sort/{SortTaskConfig.java => TaskConfig.java} | 51 +-
.../common/pojo/sort/dataflow/SourceConfig.java | 2 +
.../plugins/consumes/common/ConsumeDefaultInfo.ts | 15 -
.../plugins/groups/common/GroupDataTemplateInfo.ts | 35 +-
.../src/plugins/groups/common/GroupDefaultInfo.ts | 1 +
.../plugins/streams/common/StreamDefaultInfo.ts | 10 +-
.../src/plugins/sync/common/SyncDefaultInfo.ts | 3 +
inlong-dashboard/src/ui/locales/cn.json | 7 +-
inlong-dashboard/src/ui/locales/en.json | 7 +-
.../src/ui/pages/AgentModule/config.tsx | 17 +-
.../src/ui/pages/AgentPackage/config.tsx | 17 +-
.../src/ui/pages/ClusterTags/ClusterList.tsx | 13 +
inlong-dashboard/src/ui/pages/Clusters/index.tsx | 83 ++--
.../src/ui/pages/ConsumeDashboard/config.tsx | 23 +
.../src/ui/pages/ConsumeDashboard/index.tsx | 1 +
.../src/ui/pages/GroupDashboard/config.tsx | 25 +
.../src/ui/pages/GroupDataTemplate/CreateModal.tsx | 32 +-
.../src/ui/pages/GroupDataTemplate/index.tsx | 32 +-
inlong-dashboard/src/ui/pages/Nodes/index.tsx | 30 +-
.../src/ui/pages/SynchronizeDashboard/config.tsx | 26 +-
.../src/ui/pages/TenantManagement/config.tsx | 17 +-
.../src/ui/pages/UserManagement/config.tsx | 17 +-
.../src/main/assemblies/sort-connectors-v1.15.xml | 8 +
inlong-manager/manager-docker/Dockerfile | 1 +
inlong-manager/manager-docker/pom.xml | 7 +-
.../manager/pojo/cluster/ClusterNodeRequest.java | 1 -
.../BaseStreamSink.java} | 15 +-
.../manager/pojo/sink/ck/ClickHouseSinkDTO.java | 3 +-
.../inlong/manager/pojo/sink/cls/ClsSinkDTO.java | 3 +-
.../manager/pojo/sink/doris/DorisSinkDTO.java | 3 +-
.../manager/pojo/sink/es/ElasticsearchSinkDTO.java | 3 +-
.../pojo/sink/greenplum/GreenplumSinkDTO.java | 3 +-
.../manager/pojo/sink/hbase/HBaseSinkDTO.java | 3 +-
.../inlong/manager/pojo/sink/hdfs/HDFSSinkDTO.java | 3 +-
.../inlong/manager/pojo/sink/hive/HiveSinkDTO.java | 3 +-
.../inlong/manager/pojo/sink/hudi/HudiSinkDTO.java | 3 +-
.../manager/pojo/sink/iceberg/IcebergSinkDTO.java | 3 +-
.../manager/pojo/sink/kafka/KafkaSinkDTO.java | 3 +-
.../inlong/manager/pojo/sink/kudu/KuduSinkDTO.java | 3 +-
.../manager/pojo/sink/mysql/MySQLSinkDTO.java | 3 +-
.../manager/pojo/sink/oracle/OracleSinkDTO.java | 3 +-
.../pojo/sink/postgresql/PostgreSQLSinkDTO.java | 3 +-
.../manager/pojo/sink/pulsar/PulsarSinkDTO.java | 3 +-
.../manager/pojo/sink/redis/RedisSinkDTO.java | 3 +-
.../pojo/sink/sqlserver/SQLServerSinkDTO.java | 3 +-
.../pojo/sink/starrocks/StarRocksSinkDTO.java | 3 +-
.../tdsqlpostgresql/TDSQLPostgreSQLSinkDTO.java | 3 +-
.../manager/pojo/stream/BaseInlongStream.java | 2 +
.../manager/pojo/stream/InlongStreamExtParam.java | 6 +
.../inlong/manager/pojo/stream/TemplateInfo.java | 14 +
.../service/core/impl/AgentServiceImpl.java | 126 +++--
.../manager/service/core/impl/SortServiceImpl.java | 16 +-
.../service/datatype/KvDataTypeOperator.java | 100 ++++
.../service/heartbeat/HeartbeatManager.java | 21 +-
.../manager/service/sink/cls/ClsSinkOperator.java | 3 +
.../service/sink/es/ElasticsearchSinkOperator.java | 3 +
.../dataproxy-sdk-python/CMakeLists.txt | 33 +-
.../dataproxy-sdk-python/README.md | 117 +++++
.../dataproxy-sdk-python/build.sh | 73 +++
.../dataproxy-sdk-python/demo/config_example.json | 30 ++
.../dataproxy-sdk-python/demo/send_demo.py | 75 +++
.../dataproxy-sdk-python/inlong_dataproxy.cpp | 61 +++
.../inlong/sdk/sort/api/SortClientConfig.java | 16 +
.../apache/inlong/sdk/sort/entity/InLongTopic.java | 18 +
.../fetcher/kafka/KafkaMultiTopicsFetcher.java | 2 +-
.../fetcher/kafka/KafkaSingleTopicFetcher.java | 2 +-
.../fetcher/pulsar/PulsarMultiTopicsFetcher.java | 2 +-
.../fetcher/pulsar/PulsarSingleTopicFetcher.java | 2 +-
.../sort/fetcher/tube/TubeSingleTopicFetcher.java | 2 +-
.../org/apache/inlong/sdk/sort/util/TimeUtil.java | 41 +-
.../impl/pulsar/InLongPulsarFetcherImplTest.java | 1 +
.../config/holder/CommonPropertiesHolder.java | 13 +
.../config/holder/ManagerUrlHandler.java | 4 +
.../config/holder/v2/SortConfigHolder.java | 31 +-
.../config/holder/v2/SortConfigType.java | 12 +-
.../loader/CommonPropertiesManagerUrlLoader.java | 18 +
.../standalone/config/loader/ManagerUrlLoader.java | 2 +
.../loader/SortConfigQueryConsumeConfig.java | 18 +-
...der.java => ClassResourceSortConfigLoader.java} | 10 +-
...figLoader.java => ManagerSortConfigLoader.java} | 4 +-
.../sort/standalone/config/pojo/IdConfig.java | 20 +-
.../metrics/SortConfigMetricListener.java | 42 ++
.../metrics/SortConfigMetricReporter.java | 178 +++++++
.../standalone/utils/v2/FlumeConfigGenerator.java | 4 +-
.../sort/standalone/SortStandaloneApplication.java | 2 +
.../inlong/sort/standalone/sink/SinkContext.java | 116 +----
.../sort/standalone/sink/cls/ClsIdConfig.java | 11 +-
.../sort/standalone/sink/cls/ClsSinkContext.java | 63 ++-
.../standalone/sink/elasticsearch/EsIdConfig.java | 11 +-
.../sort/standalone/sink/elasticsearch/EsSink.java | 2 +-
.../sink/elasticsearch/EsSinkContext.java | 275 +++++++----
.../sink/kafka/KafkaFederationSinkContext.java | 68 ++-
.../sort/standalone/sink/kafka/KafkaIdConfig.java | 11 +-
.../sink/pulsar/PulsarFederationSinkContext.java | 62 ++-
.../standalone/sink/pulsar/PulsarIdConfig.java | 24 +-
.../sort/standalone/sink/v2/SinkContext.java | 165 -------
.../inlong/sort/standalone/v2/SortCluster.java | 6 +-
.../apache/inlong/sort/standalone/v2/SortTask.java | 4 +-
.../{SortClusterConfig.conf => SortConfig.conf} | 2 +-
.../src/test/java/common.properties | 2 +
.../{SortClusterConfig.conf => SortConfig.conf} | 2 +-
.../src/test/resources/common.properties | 3 +-
.../iceberg/source/reader/IcebergSourceReader.java | 9 +-
.../reader/InlongIcebergSourceReaderMetrics.java | 26 +-
.../sort-flink-v1.15/sort-connectors/jdbc/pom.xml | 108 +++++
.../clickhouse/ClickHouseRowConverter.java | 34 +-
.../sort/jdbc/dialect/JdbcDialectFactory.java | 51 ++
.../sort/jdbc/dialect/JdbcDialectLoader.java | 110 +++++
.../jdbc/dialect/clickhouse/ClickHouseDialect.java | 244 ++++++++++
.../clickhouse/ClickHouseDialectFactory.java | 30 +-
.../jdbc/internal/GenericJdbcSinkFunction.java | 82 ++++
.../sort/jdbc/internal/JdbcOutputFormat.java | 347 +++++++++++++
.../jdbc/internal/TableJdbcUpsertOutputFormat.java | 218 +++++++++
.../sort/jdbc/table/JdbcDynamicTableFactory.java | 317 ++++++++++++
.../sort/jdbc/table/JdbcDynamicTableSink.java | 147 ++++++
.../sort/jdbc/table/JdbcOutputFormatBuilder.java | 284 +++++++++++
.../org.apache.flink.table.factories.Factory | 0
...che.inlong.sort.jdbc.dialect.JdbcDialectFactory | 16 +
.../sort-flink-v1.15/sort-connectors/kafka/pom.xml | 1 +
.../inlong/sort/kafka/source/KafkaSource.java | 239 +++++++++
.../sort/kafka/source/KafkaSourceBuilder.java | 534 +++++++++++++++++++++
.../kafka/source/reader/KafkaSourceReader.java | 217 +++++++++
.../table/DynamicKafkaDeserializationSchema.java | 81 ++--
.../sort/kafka/table/KafkaDynamicSource.java | 11 +-
.../mysql/RowDataDebeziumDeserializeSchema.java | 35 +-
.../inlong/sort/mysql/source/MySqlSource.java | 5 +-
.../mysql/source/reader/MySqlSourceReader.java | 383 +++++++++++++++
.../sort-flink-v1.15/sort-connectors/pom.xml | 1 +
.../inlong/sort/pulsar/source/PulsarSource.java | 186 +++++++
.../sort/pulsar/source/PulsarSourceBuilder.java | 521 ++++++++++++++++++++
.../pulsar/source/PulsarSourceReaderFactory.java | 128 +++++
.../source/reader/PulsarOrderedSourceReader.java | 220 +++++++++
.../source/reader/PulsarSourceReaderBase.java | 87 ++++
.../source/reader/PulsarUnorderedSourceReader.java | 192 ++++++++
.../table/PulsarTableDeserializationSchema.java | 27 +-
.../sort/pulsar/table/PulsarTableSource.java | 3 +-
.../sink/table/StarRocksDynamicSinkFunctionV2.java | 49 +-
.../sink/table/StarRocksDynamicTableSink.java | 1 -
.../table/sink/table/StarRocksSinkOP.java | 36 +-
.../sink/table/StarRocksTableRowTransformer.java | 320 ++++++++++++
.../starrocks/table/sink/utils/SchemaUtils.java | 6 +-
licenses/inlong-sort-connectors/LICENSE | 35 +-
170 files changed, 7295 insertions(+), 1270 deletions(-)
create mode 100644
inlong-agent/agent-plugins/src/test/java/org/apache/inlong/agent/plugin/fetcher/TestManager.java
copy inlong-agent/agent-plugins/src/test/resources/testScan/{20230928_1 =>
202309281030_1}/test_1.txt (100%)
copy inlong-agent/agent-plugins/src/test/resources/testScan/{20230928_1 =>
2023092810_1}/test_1.txt (100%)
copy inlong-agent/agent-plugins/src/test/resources/testScan/{20230928_1 =>
202309301059_1}/test_1.txt (100%)
copy inlong-agent/agent-plugins/src/test/resources/{test/20230928_1.txt =>
testScan/20241030/23/59.txt} (100%)
rename
inlong-common/src/main/java/org/apache/inlong/common/pojo/agent/{installer/InstallerCode.java
=> AgentResponseCode.java} (78%)
rename
inlong-common/src/main/java/org/apache/inlong/common/pojo/sort/{SortClusterConfig.java
=> ClusterTagConfig.java} (73%)
rename
inlong-common/src/main/java/org/apache/inlong/common/pojo/sort/{SortTaskConfig.java
=> TaskConfig.java} (59%)
copy
inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/{stream/BaseInlongStream.java
=> sink/BaseStreamSink.java} (67%)
create mode 100644
inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/datatype/KvDataTypeOperator.java
copy
inlong-sort-standalone/sort-standalone-source/src/test/resources/common.properties
=> inlong-sdk/dataproxy-sdk-twins/dataproxy-sdk-python/CMakeLists.txt (53%)
create mode 100644
inlong-sdk/dataproxy-sdk-twins/dataproxy-sdk-python/README.md
create mode 100755 inlong-sdk/dataproxy-sdk-twins/dataproxy-sdk-python/build.sh
create mode 100644
inlong-sdk/dataproxy-sdk-twins/dataproxy-sdk-python/demo/config_example.json
create mode 100644
inlong-sdk/dataproxy-sdk-twins/dataproxy-sdk-python/demo/send_demo.py
create mode 100644
inlong-sdk/dataproxy-sdk-twins/dataproxy-sdk-python/inlong_dataproxy.cpp
copy
inlong-agent/agent-common/src/main/java/org/apache/inlong/agent/constant/CycleUnitType.java
=>
inlong-sort-standalone/sort-standalone-common/src/main/java/org/apache/inlong/sort/standalone/config/holder/v2/SortConfigType.java
(72%)
rename
inlong-sort-standalone/sort-standalone-common/src/main/java/org/apache/inlong/sort/standalone/config/loader/v2/{ClassResourceSortClusterConfigLoader.java
=> ClassResourceSortConfigLoader.java} (84%)
rename
inlong-sort-standalone/sort-standalone-common/src/main/java/org/apache/inlong/sort/standalone/config/loader/v2/{ManagerSortClusterConfigLoader.java
=> ManagerSortConfigLoader.java} (96%)
copy
inlong-common/src/main/java/org/apache/inlong/common/pojo/agent/AgentConfigRequest.java
=>
inlong-sort-standalone/sort-standalone-common/src/main/java/org/apache/inlong/sort/standalone/config/pojo/IdConfig.java
(81%)
create mode 100644
inlong-sort-standalone/sort-standalone-common/src/main/java/org/apache/inlong/sort/standalone/metrics/SortConfigMetricListener.java
create mode 100644
inlong-sort-standalone/sort-standalone-common/src/main/java/org/apache/inlong/sort/standalone/metrics/SortConfigMetricReporter.java
delete mode 100644
inlong-sort-standalone/sort-standalone-source/src/main/java/org/apache/inlong/sort/standalone/sink/v2/SinkContext.java
rename
inlong-sort-standalone/sort-standalone-source/src/test/java/{SortClusterConfig.conf
=> SortConfig.conf} (99%)
rename
inlong-sort-standalone/sort-standalone-source/src/test/resources/{SortClusterConfig.conf
=> SortConfig.conf} (99%)
create mode 100644
inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/jdbc/pom.xml
copy
inlong-common/src/main/java/org/apache/inlong/common/pojo/agent/AgentConfigInfo.java
=>
inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/jdbc/src/main/java/org/apache/inlong/sort/jdbc/converter/clickhouse/ClickHouseRowConverter.java
(58%)
create mode 100644
inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/jdbc/src/main/java/org/apache/inlong/sort/jdbc/dialect/JdbcDialectFactory.java
create mode 100644
inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/jdbc/src/main/java/org/apache/inlong/sort/jdbc/dialect/JdbcDialectLoader.java
create mode 100644
inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/jdbc/src/main/java/org/apache/inlong/sort/jdbc/dialect/clickhouse/ClickHouseDialect.java
copy
inlong-common/src/main/java/org/apache/inlong/common/pojo/agent/TaskResult.java
=>
inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/jdbc/src/main/java/org/apache/inlong/sort/jdbc/dialect/clickhouse/ClickHouseDialectFactory.java
(65%)
create mode 100644
inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/jdbc/src/main/java/org/apache/inlong/sort/jdbc/internal/GenericJdbcSinkFunction.java
create mode 100644
inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/jdbc/src/main/java/org/apache/inlong/sort/jdbc/internal/JdbcOutputFormat.java
create mode 100644
inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/jdbc/src/main/java/org/apache/inlong/sort/jdbc/internal/TableJdbcUpsertOutputFormat.java
create mode 100644
inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/jdbc/src/main/java/org/apache/inlong/sort/jdbc/table/JdbcDynamicTableFactory.java
create mode 100644
inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/jdbc/src/main/java/org/apache/inlong/sort/jdbc/table/JdbcDynamicTableSink.java
create mode 100644
inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/jdbc/src/main/java/org/apache/inlong/sort/jdbc/table/JdbcOutputFormatBuilder.java
copy inlong-sort/sort-flink/{sort-flink-v1.13 =>
sort-flink-v1.15}/sort-connectors/jdbc/src/main/resources/META-INF/services/org.apache.flink.table.factories.Factory
(100%)
create mode 100644
inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/jdbc/src/main/resources/META-INF/services/org.apache.inlong.sort.jdbc.dialect.JdbcDialectFactory
create mode 100644
inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/kafka/src/main/java/org/apache/inlong/sort/kafka/source/KafkaSource.java
create mode 100644
inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/kafka/src/main/java/org/apache/inlong/sort/kafka/source/KafkaSourceBuilder.java
create mode 100644
inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/kafka/src/main/java/org/apache/inlong/sort/kafka/source/reader/KafkaSourceReader.java
create mode 100644
inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/mysql-cdc/src/main/java/org/apache/inlong/sort/mysql/source/reader/MySqlSourceReader.java
create mode 100644
inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/pulsar/src/main/java/org/apache/inlong/sort/pulsar/source/PulsarSource.java
create mode 100644
inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/pulsar/src/main/java/org/apache/inlong/sort/pulsar/source/PulsarSourceBuilder.java
create mode 100644
inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/pulsar/src/main/java/org/apache/inlong/sort/pulsar/source/PulsarSourceReaderFactory.java
create mode 100644
inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/pulsar/src/main/java/org/apache/inlong/sort/pulsar/source/reader/PulsarOrderedSourceReader.java
create mode 100644
inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/pulsar/src/main/java/org/apache/inlong/sort/pulsar/source/reader/PulsarSourceReaderBase.java
create mode 100644
inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/pulsar/src/main/java/org/apache/inlong/sort/pulsar/source/reader/PulsarUnorderedSourceReader.java
copy
inlong-common/src/main/java/org/apache/inlong/common/pojo/agent/AgentConfigInfo.java
=>
inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/starrocks/src/main/java/org/apache/inlong/sort/starrocks/table/sink/table/StarRocksSinkOP.java
(55%)
create mode 100644
inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/starrocks/src/main/java/org/apache/inlong/sort/starrocks/table/sink/table/StarRocksTableRowTransformer.java
