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
discard 0ce3d755da [INLONG-9822][Manager] Support flink job runtime execution
mode configuration (#9823)
omit d5af6a94e2 [INLONG-9813][Manager] Support offline data sync management
(#9814)
omit 9e96c4e37b [INLONG-9781][Manager] Add offline sync task type
definition (#9787)
add 293ab1ab3e [INLONG-9766][Audit] Support user-defined SocketAddress
loader getting AuditProxy (#9767)
add 55f639537d [INLONG-9784][Audit] Optimize sending memory management
when the audit-proxy config is null (#9786)
add 7c4adbf564 [INLONG-9773][Manager] SortSDK configuration support
acquire tenant from InlongGroup (#9776)
add 03933e4072 [INLONG-9783][Sort] Add compatibility processing of tid to
streamId changes in the message deserialization base class (#9785)
add 29574c04cf [INLONG-9774][Sort] Support rowdata way of sort InLong
message tlog-kv format (#9780)
add 2f0bab5e8d [INLONG-9735][Manager] Bump the Spring version 5.3.27 to
5.3.32 (#9790)
add 45e7afc108 [INLONG-9788][Sort] Supports data parse that contains
delimiters in kv and csv data format (#9789)
add 44f2b04677 [INLONG-9793][Manager] Fix the problem of Manager client
workflowApi.listprocess failed to pass parameters correctly (#9794)
add 5a58040909 [INLONG-9791][Sort] Return null instead of throwing an
exception when deserialization by type fails (#9792)
add 829a09bb9f [INLONG-9795][Sort] Optimize the definition of enumeration
variables and remove the semicolon (#9764)
add 0585278b81 [INLONG-9797][Audit] Audit-SDK reporting supports version
number dimension (#9800)
add 70e36029ea [INLONG-9807][Audit] Add debug log for audit-proxy (#9809)
add 039e681f11 [INLONG-9008][Manager] Set the ignoreParseError field to
null (#9810)
add 3ae27abb3f [INLONG-9802][Agent] Add an agent installer module for
agent installation (#9803)
add 2ea39a2765 [INLONG-9809][Audit] SDK supports both singleton and
non-singleton usage (#9812)
add 5bd1010743 [INLONG-9804][Agent] Add Pulsar source for Agent (#9805)
add b6e1064dcf [INLONG-9816][Agent] Add config class for installer (#9817)
add b08d1612b0 [INLONG-9806][Agent] Add installer configuration file
(#9815)
add 58b2fc963c [INLONG-9818][Manager] Decode Msg based on the manager's
configuration (#9819)
add f84ad372a4 [INLONG-8676][Manager] Elasticsearch - Modify the calling
method from SDK to HTTP (#9057)
add 7189f34d0b [INLONG-9755][Sort] NPE exception when using default
configuration to start inlong-sort-standalone (#9824)
add 4649b8e546 [INLONG-9825][Manager] Reduce the creation of
RestClusterClient (#9826)
add 43bcb9d859 [INLONG-9827][Manager] Fix the problem of failed to check
if the consumption group exists (#9828)
add fd95e72ba5 [INLONG-9833][Agent] Add module state to distinguish
whether the module has been downloaded or installed (#9834)
add 23bbce2de1 [INLONG-9831][Agent] Increase configuration acquisition
capability (#9832)
add 8e5dd5003e [INLONG-9829][Agent] Add guardian scripts (#9830)
new 875e07cd74 [INLONG-9781][Manager] Add offline sync task type
definition (#9787)
new 5cdd94d4c9 [INLONG-9813][Manager] Support offline data sync management
(#9814)
new 1323736a0b [INLONG-9822][Manager] Support flink job runtime execution
mode configuration (#9823)
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 (0ce3d755da)
\
N -- N -- N refs/heads/dev-offline-sync (1323736a0b)
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.
The 3 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../inlong/agent/conf/AbstractConfiguration.java | 2 +-
.../inlong/agent/constant/FetcherConstants.java | 21 +-
.../inlong/agent/constant/TaskConstants.java | 10 +
.../org/apache/inlong/agent/pojo/PulsarTask.java | 36 ++-
.../apache/inlong/agent/pojo/TaskProfileDto.java | 29 +++
.../org/apache/inlong/agent/utils/HttpManager.java | 26 +-
.../apache/inlong/agent/core/HeartbeatManager.java | 4 +-
inlong-agent/agent-installer/assembly.xml | 60 +++++
inlong-agent/agent-installer/bin/installer-env.sh | 60 +++++
inlong-agent/agent-installer/bin/installer.sh | 125 +++++++++
.../agent-installer/conf/installer.properties | 43 +++
inlong-agent/{ => agent-installer}/conf/log4j2.xml | 0
inlong-agent/agent-installer/pom.xml | 88 +++++++
.../org/apache/inlong/agent/installer/Main.java | 127 +++++++++
.../org/apache/inlong/agent/installer/Manager.java | 96 +++++++
.../inlong/agent/installer/ManagerFetcher.java | 223 ++++++++++++++++
.../agent/installer/ManagerResultFormatter.java | 49 ++++
.../inlong/agent/installer/ModuleManager.java | 129 +++++++++
.../installer/conf/InstallerConfiguration.java | 67 +++++
.../agent/plugin/fetcher/ManagerFetcher.java | 24 +-
.../agent/plugin/instance/PulsarInstance.java | 183 +++++++++++++
.../inlong/agent/plugin/sources/KafkaSource.java | 1 -
.../{KafkaSource.java => PulsarSource.java} | 180 ++++++-------
.../inlong/agent/plugin/task/PulsarTask.java | 177 +++++++++++++
inlong-agent/pom.xml | 1 +
.../apache/inlong/audit/protocol/AuditData.java | 9 +
.../audit-common/src/main/proto/AuditApi.proto | 1 +
.../inlong/audit/source/ServerMessageHandler.java | 10 +
.../org/apache/inlong/audit/AuditOperator.java | 244 +----------------
.../{AuditOperator.java => AuditReporterImpl.java} | 145 +++++++----
.../loader/DefaultISocketAddressListLoader.java | 63 +++++
.../audit/loader/DnsSocketAddressListLoader.java | 77 ++++++
.../audit/loader/SocketAddressListLoader.java | 21 +-
.../apache/inlong/audit/send/SenderChannel.java | 76 ++++--
.../org/apache/inlong/audit/send/SenderGroup.java | 144 ++++++----
.../apache/inlong/audit/send/SenderHandler.java | 26 ++
.../apache/inlong/audit/send/SenderManager.java | 91 +++++--
.../org/apache/inlong/audit/util/AuditData.java | 51 +++-
.../java/org/apache/inlong/audit/util/IpPort.java | 148 -----------
.../org/apache/inlong/audit/util/SenderResult.java | 12 +-
.../apache/inlong/audit/util/AuditDataTest.java | 4 +-
.../org/apache/inlong/audit/util/IpPortTest.java | 55 ----
.../common/pojo/agent/installer/ConfigResult.java | 51 ++--
.../common/pojo/agent/installer/ModuleConfig.java | 72 +++++
.../pojo/agent/installer/ModuleStateEnum.java | 35 ++-
.../common/pojo/agent/installer/PackageConfig.java | 34 +--
.../api/inner/client/WorkflowApproverClient.java | 2 +
.../client/api/inner/client/WorkflowClient.java | 3 +
.../api/inner/client/WorkflowEventClient.java | 3 +-
.../manager/client/api/service/WorkflowApi.java | 5 +-
.../client/api/service/WorkflowApproverApi.java | 4 +-
.../client/api/service/WorkflowEventApi.java | 3 +-
.../inlong/manager/common/util/HttpUtils.java | 18 ++
.../manager/plugin/flink/FlinkClientService.java | 16 +-
.../manager/plugin/flink/FlinkClientService.java | 16 +-
.../es/ElasticsearchAggregationsTermsInfo.java | 71 +++++
.../pojo/node/es/ElasticsearchQueryInfo.java | 91 +++++++
.../pojo/node/es/ElasticsearchQuerySortInfo.java | 47 ++--
.../manager/pojo/node/es/ElasticsearchRequest.java | 57 ++++
.../sink/es/ElasticsearchCreateIndexResponse.java | 26 +-
.../sink/es/ElasticsearchIndexMappingInfo.java | 84 ++++++
.../pojo/sort/node/base/ExtractNodeProvider.java | 2 +-
.../pojo/sort/node/provider/KafkaProvider.java | 2 +-
.../pojo/sort/node/provider/PulsarProvider.java | 2 +-
.../pojo/sort/node/provider/RedisProvider.java | 2 +-
.../pojo/sort/node/provider/TubeMqProvider.java | 2 +-
.../inlong/manager/pojo/source/StreamSource.java | 3 +-
.../pojo/source/iceberg/IcebergSourceDTO.java | 5 +
.../manager/pojo/source/kafka/KafkaSource.java | 2 +-
.../manager/pojo/source/kafka/KafkaSourceDTO.java | 2 +-
.../pojo/source/kafka/KafkaSourceRequest.java | 2 +-
.../manager/pojo/stream/InlongStreamExtParam.java | 2 +-
.../manager/pojo/stream/InlongStreamInfo.java | 2 +-
.../manager/pojo/stream/InlongStreamRequest.java | 2 +-
inlong-manager/manager-service/pom.xml | 40 +--
.../service/core/impl/AgentServiceImpl.java | 2 +-
.../service/core/impl/AuditServiceImpl.java | 140 +++++++---
.../service/core/impl/SortSourceServiceImpl.java | 12 +-
.../service/group/AbstractGroupOperator.java | 2 +-
.../node/es/ElasticsearchDataNodeOperator.java | 3 +-
.../resource/queue/pulsar/PulsarOperator.java | 10 +-
.../resource/queue/tubemq/TubeMQOperator.java | 55 ++--
.../service/resource/sink/es/ElasticsearchApi.java | 289 ++++++++++++---------
.../resource/sink/es/ElasticsearchConfig.java | 106 +++++---
.../manager/service/sink/ElasticsearchApiTest.java | 248 ++++++++++++++++++
.../loader/ClassResourceQueryConsumeConfig.java | 1 +
.../InLongMsgCsv2DeserializationInfo.java | 7 +-
.../InLongMsgCsvDeserializationInfo.java | 9 +-
.../InLongMsgDeserializationInfo.java | 10 +-
.../InLongMsgKvDeserializationInfo.java | 7 +-
.../InLongMsgTlogCsvDeserializationInfo.java | 7 +-
.../InLongMsgTlogKvDeserializationInfo.java | 7 +-
.../deserialization/JsonDeserializationInfo.java | 3 +
.../deserialization/KvDeserializationInfo.java | 5 +-
.../sort/redis/common/config/RedisDataType.java | 3 +-
.../inlong/sort/formats/base/TableFormatUtils.java | 9 +-
.../sort/formats/inlongmsg/FailureHandler.java | 20 ++
.../formats/inlongmsg/IgnoreFailureHandler.java | 10 +
.../sort/formats/inlongmsg/NoOpFailureHandler.java | 11 +
.../inlong/sort/formats/util/StringUtils.java | 74 +++++-
.../sort/formats/common/StringUtilsTest.java | 115 ++++++++
.../sort/formats/base/TableFormatUtilsTest.java | 10 +-
.../formats/csv/CsvDeserializationSchemaTest.java | 11 +-
.../inlong/sort/formats/csv/CsvUtilsTest.java | 10 +-
.../InLongMsgCsvFormatDeserializerTest.java | 20 +-
.../InLongMsgKvFormatDeserializerTest.java | 2 +-
.../InLongMsgTlogCsvFormatDeserializerTest.java | 2 +-
.../InLongMsgTlogKvFormatDeserializerTest.java | 2 +-
.../formats/kv/KvDeserializationSchemaTest.java | 2 +-
.../apache/inlong/sort/formats/kv/KvUtilsTest.java | 36 ++-
.../sort/formats/inlongmsg/InLongMsgUtils.java | 35 ++-
.../InLongMsgCsvFormatDeserializerTest.java | 35 ++-
.../InLongMsgKvFormatDeserializerTest.java | 2 +-
.../InLongMsgTlogCsvFormatDeserializer.java | 13 +-
.../inlongmsgtlogcsv/InLongMsgTlogCsvUtils.java | 26 +-
.../InLongMsgTlogCsvFormatDeserializerTest.java | 25 +-
.../format-inlongmsg-rowdata-tlogkv/pom.xml | 136 ++++++++++
.../formats/inlongmsgtlogkv/InLongMsgTlogKv.java | 96 +++++++
.../InLongMsgTlogKvFormatDeserializer.java} | 144 ++++++----
.../inlongmsgtlogkv/InLongMsgTlogKvUtils.java} | 98 +++----
.../inlongmsgtlogkv/InLongMsgTlogKvValidator.java | 0
.../org.apache.flink.table.factories.TableFactory | 0
.../InLongMsgTlogKvFormatDeserializerTest.java | 104 ++++----
.../inlongmsgtlogkv/InLongMsgTlogKvTest.java | 110 ++++++++
.../src/test/resources/log4j-test.properties | 0
.../formats/base/DefaultDeserializationSchema.java | 37 ++-
.../sort/formats/base/TableFormatUtilsTest.java | 10 +-
.../csv/CsvRowDataDeserializationSchema.java | 8 +-
.../csv/CsvRowDataDeserializationSchemaTest.java | 9 +-
.../json/JsonRowDataDeserializationSchema.java | 12 +-
.../formats/json/FieldToRowDataConvertersTest.java | 2 +
.../json/JsonRowDataDeserializationSchemaTest.java | 4 -
.../formats/json/JsonRowDataSerDeTestBase.java | 2 +
.../formats/json/RowDataToFieldConvertersTest.java | 6 +-
.../formats/kv/KvRowDataDeserializationSchema.java | 10 +-
.../kv/KvRowDataDeserializationSchemaTest.java | 2 +-
.../apache/inlong/sort/formats/kv/KvUtilsTest.java | 30 ++-
inlong-sort/sort-formats/format-rowdata/pom.xml | 1 +
inlong-sort/sort-formats/pom.xml | 1 +
licenses/inlong-audit/LICENSE | 16 +-
licenses/inlong-audit/NOTICE | 2 +-
.../inlong-audit/licenses/LICENSE-spring-aop.txt | 4 +-
.../inlong-audit/licenses/LICENSE-spring-beans.txt | 4 +-
.../licenses/LICENSE-spring-context.txt | 4 +-
.../inlong-audit/licenses/LICENSE-spring-core.txt | 4 +-
.../licenses/LICENSE-spring-expression.txt | 4 +-
.../inlong-audit/licenses/LICENSE-spring-jcl.txt | 4 +-
.../inlong-audit/licenses/LICENSE-spring-jdbc.txt | 4 +-
.../inlong-audit/licenses/LICENSE-spring-tx.txt | 4 +-
licenses/inlong-manager/LICENSE | 22 +-
licenses/inlong-manager/NOTICE | 4 +-
.../inlong-manager/licenses/LICENSE-spring-aop.txt | 4 +-
.../licenses/LICENSE-spring-beans.txt | 4 +-
.../licenses/LICENSE-spring-context-support.txt | 4 +-
.../licenses/LICENSE-spring-context.txt | 4 +-
.../licenses/LICENSE-spring-core.txt | 4 +-
.../licenses/LICENSE-spring-expression.txt | 4 +-
.../inlong-manager/licenses/LICENSE-spring-jcl.txt | 4 +-
.../licenses/LICENSE-spring-jdbc.txt | 4 +-
.../inlong-manager/licenses/LICENSE-spring-tx.txt | 4 +-
.../inlong-manager/licenses/LICENSE-spring-web.txt | 4 +-
.../licenses/LICENSE-spring-webmvc.txt | 4 +-
licenses/inlong-tubemq-manager/LICENSE | 24 +-
licenses/inlong-tubemq-manager/NOTICE | 6 +-
.../licenses/LICENSE-spring-aop.txt | 4 +-
.../licenses/LICENSE-spring-aspects.txt | 4 +-
.../licenses/LICENSE-spring-beans.txt | 4 +-
.../licenses/LICENSE-spring-context.txt | 4 +-
.../licenses/LICENSE-spring-core.txt | 4 +-
.../licenses/LICENSE-spring-expression.txt | 4 +-
.../licenses/LICENSE-spring-jcl.txt | 4 +-
.../licenses/LICENSE-spring-jdbc.txt | 4 +-
.../licenses/LICENSE-spring-orm.txt | 4 +-
.../licenses/LICENSE-spring-tx.txt | 4 +-
.../licenses/LICENSE-spring-web.txt | 4 +-
.../licenses/LICENSE-spring-webmvc.txt | 4 +-
licenses/inlong-tubemq-server/LICENSE | 18 +-
licenses/inlong-tubemq-server/NOTICE | 2 +-
.../licenses/LICENSE-spring-aop.txt | 4 +-
.../licenses/LICENSE-spring-beans.txt | 4 +-
.../licenses/LICENSE-spring-context.txt | 4 +-
.../licenses/LICENSE-spring-core.txt | 4 +-
.../licenses/LICENSE-spring-expression.txt | 4 +-
.../licenses/LICENSE-spring-jcl.txt | 4 +-
.../licenses/LICENSE-spring-jdbc.txt | 4 +-
.../licenses/LICENSE-spring-orm.txt | 4 +-
.../licenses/LICENSE-spring-tx.txt | 4 +-
pom.xml | 2 +-
188 files changed, 4520 insertions(+), 1600 deletions(-)
copy
inlong-sort/sort-common/src/main/java/org/apache/inlong/sort/protocol/deserialization/JsonDeserializationInfo.java
=>
inlong-agent/agent-common/src/main/java/org/apache/inlong/agent/pojo/PulsarTask.java
(53%)
create mode 100644 inlong-agent/agent-installer/assembly.xml
create mode 100755 inlong-agent/agent-installer/bin/installer-env.sh
create mode 100755 inlong-agent/agent-installer/bin/installer.sh
create mode 100755 inlong-agent/agent-installer/conf/installer.properties
copy inlong-agent/{ => agent-installer}/conf/log4j2.xml (100%)
create mode 100644 inlong-agent/agent-installer/pom.xml
create mode 100644
inlong-agent/agent-installer/src/main/java/org/apache/inlong/agent/installer/Main.java
create mode 100755
inlong-agent/agent-installer/src/main/java/org/apache/inlong/agent/installer/Manager.java
create mode 100644
inlong-agent/agent-installer/src/main/java/org/apache/inlong/agent/installer/ManagerFetcher.java
create mode 100755
inlong-agent/agent-installer/src/main/java/org/apache/inlong/agent/installer/ManagerResultFormatter.java
create mode 100755
inlong-agent/agent-installer/src/main/java/org/apache/inlong/agent/installer/ModuleManager.java
create mode 100644
inlong-agent/agent-installer/src/main/java/org/apache/inlong/agent/installer/conf/InstallerConfiguration.java
create mode 100644
inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/instance/PulsarInstance.java
copy
inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/sources/{KafkaSource.java
=> PulsarSource.java} (64%)
create mode 100644
inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/task/PulsarTask.java
copy
inlong-audit/audit-sdk/src/main/java/org/apache/inlong/audit/{AuditOperator.java
=> AuditReporterImpl.java} (66%)
create mode 100644
inlong-audit/audit-sdk/src/main/java/org/apache/inlong/audit/loader/DefaultISocketAddressListLoader.java
create mode 100644
inlong-audit/audit-sdk/src/main/java/org/apache/inlong/audit/loader/DnsSocketAddressListLoader.java
copy
inlong-sort/sort-common/src/main/java/org/apache/inlong/sort/protocol/deserialization/JsonDeserializationInfo.java
=>
inlong-audit/audit-sdk/src/main/java/org/apache/inlong/audit/loader/SocketAddressListLoader.java
(66%)
delete mode 100644
inlong-audit/audit-sdk/src/main/java/org/apache/inlong/audit/util/IpPort.java
delete mode 100644
inlong-audit/audit-sdk/src/test/java/org/apache/inlong/audit/util/IpPortTest.java
copy
inlong-audit/audit-sdk/src/main/java/org/apache/inlong/audit/util/SenderResult.java
=>
inlong-common/src/main/java/org/apache/inlong/common/pojo/agent/installer/ConfigResult.java
(56%)
create mode 100644
inlong-common/src/main/java/org/apache/inlong/common/pojo/agent/installer/ModuleConfig.java
copy
inlong-sort/sort-common/src/main/java/org/apache/inlong/sort/protocol/deserialization/JsonDeserializationInfo.java
=>
inlong-common/src/main/java/org/apache/inlong/common/pojo/agent/installer/ModuleStateEnum.java
(55%)
copy
inlong-sort/sort-common/src/main/java/org/apache/inlong/sort/protocol/deserialization/JsonDeserializationInfo.java
=>
inlong-common/src/main/java/org/apache/inlong/common/pojo/agent/installer/PackageConfig.java
(64%)
create mode 100644
inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/node/es/ElasticsearchAggregationsTermsInfo.java
create mode 100644
inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/node/es/ElasticsearchQueryInfo.java
copy
inlong-audit/audit-sdk/src/main/java/org/apache/inlong/audit/util/SenderResult.java
=>
inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/node/es/ElasticsearchQuerySortInfo.java
(58%)
create mode 100644
inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/node/es/ElasticsearchRequest.java
copy
inlong-sort/sort-common/src/main/java/org/apache/inlong/sort/protocol/deserialization/JsonDeserializationInfo.java
=>
inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/sink/es/ElasticsearchCreateIndexResponse.java
(66%)
create mode 100644
inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/sink/es/ElasticsearchIndexMappingInfo.java
create mode 100644
inlong-manager/manager-service/src/test/java/org/apache/inlong/manager/service/sink/ElasticsearchApiTest.java
create mode 100644
inlong-sort/sort-formats/format-common/src/test/java/org/apache/inlong/sort/formats/common/StringUtilsTest.java
create mode 100644
inlong-sort/sort-formats/format-rowdata/format-inlongmsg-rowdata-tlogkv/pom.xml
create mode 100644
inlong-sort/sort-formats/format-rowdata/format-inlongmsg-rowdata-tlogkv/src/main/java/org/apache/inlong/sort/formats/inlongmsgtlogkv/InLongMsgTlogKv.java
copy
inlong-sort/sort-formats/format-rowdata/{format-inlongmsg-rowdata-tlogcsv/src/main/java/org/apache/inlong/sort/formats/inlongmsgtlogcsv/InLongMsgTlogCsvFormatDeserializer.java
=>
format-inlongmsg-rowdata-tlogkv/src/main/java/org/apache/inlong/sort/formats/inlongmsgtlogkv/InLongMsgTlogKvFormatDeserializer.java}
(59%)
copy
inlong-sort/sort-formats/format-rowdata/{format-inlongmsg-rowdata-tlogcsv/src/main/java/org/apache/inlong/sort/formats/inlongmsgtlogcsv/InLongMsgTlogCsvUtils.java
=>
format-inlongmsg-rowdata-tlogkv/src/main/java/org/apache/inlong/sort/formats/inlongmsgtlogkv/InLongMsgTlogKvUtils.java}
(66%)
copy inlong-sort/sort-formats/{format-row/format-inlongmsg-tlogkv =>
format-rowdata/format-inlongmsg-rowdata-tlogkv}/src/main/java/org/apache/inlong/sort/formats/inlongmsgtlogkv/InLongMsgTlogKvValidator.java
(100%)
copy inlong-sort/sort-formats/{format-row/format-inlongmsg-tlogkv =>
format-rowdata/format-inlongmsg-rowdata-tlogkv}/src/main/resources/META-INF/services/org.apache.flink.table.factories.TableFactory
(100%)
copy inlong-sort/sort-formats/{format-row/format-inlongmsg-tlogkv =>
format-rowdata/format-inlongmsg-rowdata-tlogkv}/src/test/java/org/apache/inlong/sort/formats/inlongmsgtlogkv/InLongMsgTlogKvFormatDeserializerTest.java
(67%)
create mode 100644
inlong-sort/sort-formats/format-rowdata/format-inlongmsg-rowdata-tlogkv/src/test/java/org/apache/inlong/sort/formats/inlongmsgtlogkv/InLongMsgTlogKvTest.java
copy inlong-sort/sort-formats/{format-row/format-inlongmsg-tlogcsv =>
format-rowdata/format-inlongmsg-rowdata-tlogkv}/src/test/resources/log4j-test.properties
(100%)
