This is an automated email from the ASF dual-hosted git repository.
vernedeng pushed a change to branch branch-2.1
in repository https://gitbox.apache.org/repos/asf/inlong.git
omit 94d12f1485 [INLONG-11663][SDK] Increase the conn pool size for Golang
SDK (#11677)
omit 583e658b20 [INLONG-11675][SDK] Optimize IpUtils class related
implementation (#11676)
omit 4d45c7b258 [INLONG-11672][SDK] Remove the implementation of
org.apache.inlong.sdk.dataproxy.pb.* (#11673)
omit 305f359636 [INLONG-11660][SDK] Close exist conns if initConns() failed
in Golang SDK (#11664)
omit 004c2be5e4 [INLONG-11670][SDK] Rename the ProxysdkException class name
to ProxySdkException (#11671)
omit 9995c22774 [INLONG-11668][SDK] Add max life time support for the
connections in conn pool of Golang SDK (#11669)
omit a110f9f8ae [INLONG-11662][SDK] Enable TCP keep alive for Golang SDK
(#11666)
omit 9247e428b4 [INLONG-11661][SDK] Do not mark endpoint unavailable when
it is the only one in Golang SDK (#11665)
omit 9030cf30c0 [INLONG-11658][Sort] Fix the NPE of the Kafka sink error
log for some exceptions without metadata information (#11659)
omit 3442ece4f4 [INLONG-11656][SDK] DataProxy Java SDK lacks a common-lang
dependency (#11657)
omit e2a26968c8 [INLONG-11349][Sort] Integrate opentelemetry for
sort-connectors-v1.15 (#11351)
omit db5619d5b3 [INLONG-11621][Sort] Support auth key encryption when use
inlong sdk dirty sink (#11653)
omit 91d0b03666 [INLONG-11645][Release] Bumped master branch version to
2.2.0-SNAPSHOT (#11651)
add d21b6a03df [INLONG-11646][Release] Bumped version of branch-2.1.0 to
2.1.0 (#11652)
add 0b1d207f3d [INLONG-11647][Release] Change the tag of Docker images to
2.1.0 (#11654)
add 433f531853 [INLONG-11656][SDK] DataProxy Java SDK lacks a common-lang
dependency (#11657)
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 (94d12f1485)
\
N -- N -- N refs/heads/branch-2.1 (433f531853)
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:
conf/inlong.conf | 2 +-
docker/docker-compose/.env | 2 +-
docker/kubernetes/README.md | 2 +-
docker/kubernetes/values.yaml | 14 +-
inlong-agent/agent-common/pom.xml | 2 +-
inlong-agent/agent-core/pom.xml | 2 +-
inlong-agent/agent-docker/README.md | 2 +-
inlong-agent/agent-docker/pom.xml | 2 +-
inlong-agent/agent-installer/pom.xml | 2 +-
inlong-agent/agent-plugins/pom.xml | 2 +-
.../plugin/sinks/filecollect/SenderManager.java | 4 +-
inlong-agent/agent-release/pom.xml | 2 +-
inlong-agent/pom.xml | 2 +-
inlong-audit/audit-common/pom.xml | 2 +-
inlong-audit/audit-docker/README.md | 2 +-
inlong-audit/audit-docker/pom.xml | 2 +-
inlong-audit/audit-proxy/pom.xml | 2 +-
inlong-audit/audit-release/pom.xml | 2 +-
inlong-audit/audit-sdk/pom.xml | 2 +-
inlong-audit/audit-service/pom.xml | 2 +-
inlong-audit/audit-store/pom.xml | 2 +-
inlong-audit/pom.xml | 2 +-
inlong-common/pom.xml | 2 +-
.../inlong/common/msg/AttributeConstants.java | 10 +-
inlong-dashboard/pom.xml | 2 +-
inlong-dataproxy/dataproxy-dist/pom.xml | 2 +-
inlong-dataproxy/dataproxy-docker/README.md | 2 +-
inlong-dataproxy/dataproxy-docker/pom.xml | 2 +-
inlong-dataproxy/dataproxy-source/pom.xml | 2 +-
inlong-dataproxy/pom.xml | 2 +-
inlong-distribution/pom.xml | 2 +-
inlong-manager/manager-client-examples/pom.xml | 2 +-
inlong-manager/manager-client-tools/pom.xml | 2 +-
inlong-manager/manager-client/pom.xml | 2 +-
inlong-manager/manager-common/pom.xml | 2 +-
inlong-manager/manager-dao/pom.xml | 2 +-
inlong-manager/manager-docker/README.md | 2 +-
inlong-manager/manager-docker/pom.xml | 2 +-
inlong-manager/manager-plugins/base/pom.xml | 2 +-
.../manager-plugins-flink-v1.13/pom.xml | 2 +-
.../manager-plugins-flink-v1.15/pom.xml | 2 +-
.../manager-plugins-flink-v1.18/pom.xml | 2 +-
inlong-manager/manager-plugins/pom.xml | 2 +-
inlong-manager/manager-pojo/pom.xml | 2 +-
inlong-manager/manager-schedule/pom.xml | 2 +-
inlong-manager/manager-service/pom.xml | 2 +-
inlong-manager/manager-test/pom.xml | 2 +-
inlong-manager/manager-web/pom.xml | 2 +-
inlong-manager/manager-workflow/pom.xml | 2 +-
inlong-manager/pom.xml | 2 +-
.../dataproxy-sdk-golang/README.md | 2 -
.../dataproxy-sdk-golang/connpool/connpool.go | 211 ++--------
.../dataproxy-sdk-golang/dataproxy/client.go | 14 +-
.../dataproxy-sdk-golang/dataproxy/options.go | 4 +-
.../dataproxy/options_basic.go | 7 -
inlong-sdk/dataproxy-sdk/pom.xml | 24 +-
.../inlong/sdk/dataproxy/DefaultMessageSender.java | 58 +--
.../apache/inlong/sdk/dataproxy/MessageSender.java | 18 +-
.../inlong/sdk/dataproxy/ProxyClientConfig.java | 37 +-
.../sdk/dataproxy/codec/ProtocolEncoder.java | 7 +-
.../sdk/dataproxy/config/ProxyConfigManager.java | 4 +-
.../sdk/dataproxy/example/HttpClientExample.java | 11 +-
.../sdk/dataproxy/example/TcpClientExample.java | 8 +-
.../sdk/dataproxy/exception/ProxySdkException.java | 48 ---
.../inlong/sdk/dataproxy/network/ClientMgr.java | 3 +-
.../inlong/sdk/dataproxy/network/IpUtils.java | 137 +++++++
.../sdk/dataproxy/network/ProxysdkException.java | 22 +-
.../inlong/sdk/dataproxy/network/Sender.java | 22 +-
.../inlong/sdk/dataproxy/network/SequentialID.java | 4 +-
.../inlong/sdk/dataproxy/pb/ISenderBuilder.java | 67 +++
.../sdk/dataproxy/pb/MessageSenderBuilder.java | 448 ++++++++++++++++++++
.../sdk/dataproxy/pb/PbProtocolMessageSender.java | 456 +++++++++++++++++++++
.../inlong/sdk/dataproxy/pb/ProxySdkSink.java | 275 +++++++++++++
.../inlong/sdk/dataproxy/pb/SdkChannelWorker.java | 200 +++++++++
.../sdk/dataproxy/pb/SdkProxyChannelManager.java | 405 ++++++++++++++++++
.../sdk/dataproxy/pb/SdkSenderClientHandler.java | 166 ++++++++
.../sdk/dataproxy/pb/channel/BufferQueue.java | 167 ++++++++
.../dataproxy/pb/channel/BufferQueueChannel.java | 189 +++++++++
.../dataproxy/pb/channel/ProfileTransaction.java | 126 ++++++
.../sdk/dataproxy/pb/channel/SizeSemaphore.java | 126 ++++++
.../pb/config/ContextProxyClusterConfigLoader.java | 95 +++++
.../pb/config/FileProxyClusterConfigLoader.java | 119 ++++++
.../sdk/dataproxy/pb/config/LoaderType.java} | 32 +-
.../pb/config/ManagerProxyClusterConfigLoader.java | 174 ++++++++
.../pb/config/ProxyClusterConfigHolder.java | 264 ++++++++++++
.../pb/config/ProxyClusterConfigLoader.java | 49 +++
.../sdk/dataproxy/pb/config/pojo/ErrorCode.java} | 31 +-
.../config/pojo/GetProxyConfigByAgentResponse.java | 123 ++++++
.../pb/config/pojo/GetProxyConfigBySdkRequest.java | 65 +++
.../config/pojo/GetProxyConfigBySdkResponse.java | 101 +++++
.../pojo/GetProxyConfigByStreamResponse.java | 118 ++++++
.../pb/config/pojo/InlongStreamConfig.java | 108 +++++
.../pb/config/pojo/ProxyClusterConfig.java | 176 ++++++++
.../pb/config/pojo/ProxyClusterResult.java | 118 ++++++
.../config/pojo/ProxyInfo.java} | 52 ++-
.../config/pojo/ProxyNodeInfo.java} | 52 ++-
.../sdk/dataproxy/pb/context/CallbackProfile.java | 116 ++++++
.../sdk/dataproxy/pb/context/Constants.java} | 27 +-
.../inlong/sdk/dataproxy/pb/context/InlongId.java} | 39 +-
.../sdk/dataproxy/pb/context/ProfileEvent.java | 102 +++++
.../sdk/dataproxy/pb/context/SdkProfile.java | 92 +++++
.../sdk/dataproxy/pb/context/SdkSinkContext.java | 271 ++++++++++++
.../sdk/dataproxy/pb/context/SinkContext.java | 216 ++++++++++
.../sdk/dataproxy/pb/dispatch/DispatchManager.java | 163 ++++++++
.../sdk/dataproxy/pb/dispatch/DispatchProfile.java | 193 +++++++++
.../sdk/dataproxy/pb/metrics/SdkMetricItem.java | 212 ++++++++++
.../sdk/dataproxy/pb/metrics/SdkMetricItemSet.java | 76 ++++
.../pb/network/ByteArrayToBinaryEncoder.java} | 36 +-
.../inlong/sdk/dataproxy/pb/network/IpPort.java | 146 +++++++
.../inlong/sdk/dataproxy/pb/network/IpUtils.java | 205 +++++++++
.../sdk/dataproxy/pb/network/TcpChannel.java | 181 ++++++++
.../sdk/dataproxy/pb/network/TcpChannelGroup.java | 348 ++++++++++++++++
.../inlong/sdk/dataproxy/pb/network/TcpResult.java | 102 +++++
.../sdk/dataproxy/threads/MetricWorkerThread.java | 4 +-
.../inlong/sdk/dataproxy/utils/AuthzUtils.java | 51 ---
.../inlong/sdk/dataproxy/utils/ProxyUtils.java | 24 --
.../{ProxyUtilsTest.java => UtilsTest.java} | 6 +-
inlong-sdk/dirty-data-sdk/pom.xml | 2 +-
.../inlong/sdk/dirtydata/InlongSdkDirtySender.java | 3 +-
inlong-sdk/pom.xml | 2 +-
inlong-sdk/sdk-common/pom.xml | 2 +-
inlong-sdk/sort-sdk/pom.xml | 4 +-
inlong-sdk/transform-sdk/pom.xml | 4 +-
inlong-sort-standalone/pom.xml | 2 +-
.../sort-standalone-common/pom.xml | 2 +-
.../sort-standalone-dist/pom.xml | 2 +-
.../sort-standalone-source/pom.xml | 2 +-
.../sink/kafka/KafkaProducerCluster.java | 21 +-
inlong-sort/pom.xml | 2 +-
inlong-sort/sort-api/pom.xml | 2 +-
inlong-sort/sort-common/pom.xml | 2 +-
.../inlong/sort/configuration/Constants.java | 3 -
inlong-sort/sort-core/pom.xml | 2 +-
.../main/java/org/apache/inlong/sort/Entrance.java | 2 -
inlong-sort/sort-dist/pom.xml | 2 +-
inlong-sort/sort-end-to-end-tests/pom.xml | 2 +-
.../sort-end-to-end-tests-v1.13/pom.xml | 2 +-
.../sort-end-to-end-tests-v1.15/pom.xml | 2 +-
.../inlong/sort/tests/Kafka2StarRocksTest.java | 20 -
.../inlong/sort/tests/Mysql2StarRocksTest.java | 21 +-
.../inlong/sort/tests/Pulsar2StarRocksTest.java | 19 -
.../sort/tests/utils/FlinkContainerTestEnv.java | 1 -
.../tests/utils/FlinkContainerTestEnvJRE8.java | 1 -
.../src/test/resources/env/otel-config.yaml | 35 --
.../src/test/resources/flinkSql/mysql_test.sql | 2 +-
.../sort-end-to-end-tests-v1.18/pom.xml | 2 +-
inlong-sort/sort-flink/base/pom.xml | 2 +-
.../org/apache/inlong/sort/base/Constants.java | 6 -
.../base/dirty/sink/sdk/InlongSdkDirtySink.java | 1 +
.../dirty/sink/sdk/InlongSdkDirtySinkFactory.java | 37 +-
.../inlong/sort/base/dirty/utils/AESUtils.java | 99 -----
inlong-sort/sort-flink/cdc-base/pom.xml | 2 +-
inlong-sort/sort-flink/pom.xml | 2 +-
inlong-sort/sort-flink/sort-flink-v1.13/pom.xml | 2 +-
.../sort-flink-v1.13/sort-connectors/doris/pom.xml | 2 +-
.../sort-connectors/elasticsearch-6/pom.xml | 2 +-
.../sort-connectors/elasticsearch-7/pom.xml | 2 +-
.../sort-connectors/elasticsearch-base/pom.xml | 2 +-
.../sort-connectors/filesystem/pom.xml | 2 +-
.../sort-flink-v1.13/sort-connectors/hbase/pom.xml | 2 +-
.../sort-flink-v1.13/sort-connectors/hive/pom.xml | 2 +-
.../sort-flink-v1.13/sort-connectors/hudi/pom.xml | 2 +-
.../sort-connectors/iceberg/pom.xml | 2 +-
.../sort-flink-v1.13/sort-connectors/jdbc/pom.xml | 2 +-
.../sort-flink-v1.13/sort-connectors/kafka/pom.xml | 2 +-
.../sort-flink-v1.13/sort-connectors/kudu/pom.xml | 2 +-
.../sort-connectors/mongodb-cdc/pom.xml | 2 +-
.../sort-connectors/mysql-cdc/pom.xml | 2 +-
.../sort-connectors/oracle-cdc/pom.xml | 2 +-
.../sort-flink-v1.13/sort-connectors/pom.xml | 2 +-
.../sort-connectors/postgres-cdc/pom.xml | 2 +-
.../sort-connectors/pulsar/pom.xml | 2 +-
.../sort-flink-v1.13/sort-connectors/redis/pom.xml | 2 +-
.../sort-connectors/sqlserver-cdc/pom.xml | 2 +-
.../sort-connectors/starrocks/pom.xml | 2 +-
.../sort-connectors/tubemq/pom.xml | 2 +-
.../sort-flink-dependencies/pom.xml | 2 +-
inlong-sort/sort-flink/sort-flink-v1.15/pom.xml | 2 +-
.../sort-connectors/elasticsearch-base/pom.xml | 2 +-
.../sort-flink-v1.15/sort-connectors/hbase/pom.xml | 2 +-
.../sort-flink-v1.15/sort-connectors/hudi/pom.xml | 2 +-
.../sort-connectors/iceberg/pom.xml | 4 +-
.../inlong/sort/iceberg/source/IcebergSource.java | 11 +-
.../sort/iceberg/source/IcebergTableSource.java | 4 -
.../iceberg/source/reader/IcebergSourceReader.java | 27 +-
.../sort-flink-v1.15/sort-connectors/jdbc/pom.xml | 2 +-
.../sort-flink-v1.15/sort-connectors/kafka/pom.xml | 4 +-
.../inlong/sort/kafka/source/KafkaSource.java | 8 +-
.../sort/kafka/source/KafkaSourceBuilder.java | 9 +-
.../kafka/source/reader/KafkaSourceReader.java | 30 +-
.../sort/kafka/table/KafkaDynamicSource.java | 18 +-
.../sort/kafka/table/KafkaDynamicTableFactory.java | 10 +-
.../table/UpsertKafkaDynamicTableFactory.java | 5 +-
.../sort-connectors/mongodb-cdc/pom.xml | 2 +-
.../sort-connectors/mysql-cdc/pom.xml | 4 +-
.../apache/inlong/sort/mysql/MySqlTableSource.java | 7 -
.../inlong/sort/mysql/MysqlTableFactory.java | 4 +-
.../inlong/sort/mysql/source/MySqlSource.java | 8 +-
.../sort/mysql/source/MySqlSourceBuilder.java | 8 +-
.../mysql/source/reader/MySqlSourceReader.java | 25 +-
.../sort-flink-v1.15/sort-connectors/pom.xml | 2 +-
.../sort-connectors/postgres-cdc/pom.xml | 2 +-
.../sort-connectors/pulsar/pom.xml | 4 +-
.../inlong/sort/pulsar/PulsarTableFactory.java | 10 +-
.../inlong/sort/pulsar/source/PulsarSource.java | 8 +-
.../sort/pulsar/source/PulsarSourceBuilder.java | 9 +-
.../pulsar/source/PulsarSourceReaderFactory.java | 9 +-
.../source/reader/PulsarOrderedSourceReader.java | 6 +-
.../source/reader/PulsarSourceReaderBase.java | 25 +-
.../source/reader/PulsarUnorderedSourceReader.java | 6 +-
.../sort/pulsar/table/PulsarTableSource.java | 16 +-
.../sort-flink-v1.15/sort-connectors/redis/pom.xml | 2 +-
.../sort-connectors/sqlserver-cdc/pom.xml | 2 +-
.../sort-connectors/starrocks/pom.xml | 2 +-
.../sort-connectors/tubemq/pom.xml | 2 +-
.../sort-flink-dependencies/pom.xml | 2 +-
inlong-sort/sort-flink/sort-flink-v1.18/pom.xml | 2 +-
.../sort-connectors/elasticsearch-base/pom.xml | 2 +-
.../sort-connectors/elasticsearch6/pom.xml | 2 +-
.../sort-connectors/elasticsearch7/pom.xml | 2 +-
.../sort-flink-v1.18/sort-connectors/jdbc/pom.xml | 2 +-
.../sort-flink-v1.18/sort-connectors/kafka/pom.xml | 2 +-
.../sort-flink-v1.18/sort-connectors/pom.xml | 2 +-
.../sort-connectors/pulsar/pom.xml | 2 +-
.../sort-flink-dependencies/pom.xml | 2 +-
inlong-sort/sort-formats/format-common/pom.xml | 2 +-
.../sort-formats/format-row/format-base/pom.xml | 2 +-
.../sort-formats/format-row/format-csv/pom.xml | 2 +-
.../format-row/format-inlongmsg-base/pom.xml | 2 +-
.../format-row/format-inlongmsg-binlog/pom.xml | 2 +-
.../format-row/format-inlongmsg-csv/pom.xml | 2 +-
.../format-row/format-inlongmsg-kv/pom.xml | 2 +-
.../format-row/format-inlongmsg-pb/pom.xml | 2 +-
.../format-row/format-inlongmsg-tlogcsv/pom.xml | 2 +-
.../format-row/format-inlongmsg-tlogkv/pom.xml | 2 +-
.../format-row/format-json-v1.13/pom.xml | 2 +-
.../format-row/format-json-v1.15/pom.xml | 2 +-
.../format-row/format-json-v1.18/pom.xml | 2 +-
.../sort-formats/format-row/format-kv/pom.xml | 2 +-
inlong-sort/sort-formats/format-row/pom.xml | 2 +-
.../format-inlongmsg-rowdata-base/pom.xml | 2 +-
.../format-inlongmsg-rowdata-binlog/pom.xml | 2 +-
.../format-inlongmsg-rowdata-csv/pom.xml | 2 +-
.../format-inlongmsg-rowdata-kv/pom.xml | 2 +-
.../format-inlongmsg-rowdata-pb/pom.xml | 2 +-
.../format-inlongmsg-rowdata-tlogcsv/pom.xml | 2 +-
.../format-inlongmsg-rowdata-tlogkv/pom.xml | 2 +-
.../format-rowdata/format-rowdata-base/pom.xml | 2 +-
.../format-rowdata/format-rowdata-csv/pom.xml | 2 +-
.../format-rowdata/format-rowdata-json/pom.xml | 2 +-
.../format-rowdata/format-rowdata-kv/pom.xml | 2 +-
inlong-sort/sort-formats/format-rowdata/pom.xml | 2 +-
inlong-sort/sort-formats/pom.xml | 2 +-
inlong-tubemq/pom.xml | 2 +-
inlong-tubemq/tubemq-client/pom.xml | 2 +-
inlong-tubemq/tubemq-connectors/pom.xml | 2 +-
.../tubemq-connector-flume/pom.xml | 2 +-
.../tubemq-connector-spark/pom.xml | 2 +-
inlong-tubemq/tubemq-core/pom.xml | 2 +-
inlong-tubemq/tubemq-docker/pom.xml | 2 +-
inlong-tubemq/tubemq-docker/tubemq-all/README.md | 2 +-
inlong-tubemq/tubemq-docker/tubemq-all/pom.xml | 2 +-
inlong-tubemq/tubemq-docker/tubemq-build/pom.xml | 2 +-
inlong-tubemq/tubemq-docker/tubemq-cpp/pom.xml | 2 +-
.../tubemq-docker/tubemq-manager/README.md | 2 +-
inlong-tubemq/tubemq-docker/tubemq-manager/pom.xml | 2 +-
inlong-tubemq/tubemq-example/pom.xml | 2 +-
inlong-tubemq/tubemq-manager/pom.xml | 2 +-
inlong-tubemq/tubemq-server/pom.xml | 2 +-
pom.xml | 2 +-
270 files changed, 7259 insertions(+), 1194 deletions(-)
delete mode 100644
inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk/dataproxy/exception/ProxySdkException.java
create mode 100644
inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk/dataproxy/network/IpUtils.java
rename
inlong-sort/sort-end-to-end-tests/sort-end-to-end-tests-v1.15/src/test/java/org/apache/inlong/sort/tests/utils/OpenTelemetryContainer.java
=>
inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk/dataproxy/network/ProxysdkException.java
(67%)
create mode 100644
inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk/dataproxy/pb/ISenderBuilder.java
create mode 100644
inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk/dataproxy/pb/MessageSenderBuilder.java
create mode 100644
inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk/dataproxy/pb/PbProtocolMessageSender.java
create mode 100644
inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk/dataproxy/pb/ProxySdkSink.java
create mode 100644
inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk/dataproxy/pb/SdkChannelWorker.java
create mode 100644
inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk/dataproxy/pb/SdkProxyChannelManager.java
create mode 100644
inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk/dataproxy/pb/SdkSenderClientHandler.java
create mode 100644
inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk/dataproxy/pb/channel/BufferQueue.java
create mode 100644
inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk/dataproxy/pb/channel/BufferQueueChannel.java
create mode 100644
inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk/dataproxy/pb/channel/ProfileTransaction.java
create mode 100644
inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk/dataproxy/pb/channel/SizeSemaphore.java
create mode 100644
inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk/dataproxy/pb/config/ContextProxyClusterConfigLoader.java
create mode 100644
inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk/dataproxy/pb/config/FileProxyClusterConfigLoader.java
copy
inlong-sdk/dataproxy-sdk/src/{test/java/org/apache/inlong/sdk/dataproxy/ProxyUtilsTest.java
=> main/java/org/apache/inlong/sdk/dataproxy/pb/config/LoaderType.java} (64%)
create mode 100644
inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk/dataproxy/pb/config/ManagerProxyClusterConfigLoader.java
create mode 100644
inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk/dataproxy/pb/config/ProxyClusterConfigHolder.java
create mode 100644
inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk/dataproxy/pb/config/ProxyClusterConfigLoader.java
copy
inlong-sdk/dataproxy-sdk/src/{test/java/org/apache/inlong/sdk/dataproxy/ProxyUtilsTest.java
=> main/java/org/apache/inlong/sdk/dataproxy/pb/config/pojo/ErrorCode.java}
(65%)
create mode 100644
inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk/dataproxy/pb/config/pojo/GetProxyConfigByAgentResponse.java
create mode 100644
inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk/dataproxy/pb/config/pojo/GetProxyConfigBySdkRequest.java
create mode 100644
inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk/dataproxy/pb/config/pojo/GetProxyConfigBySdkResponse.java
create mode 100644
inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk/dataproxy/pb/config/pojo/GetProxyConfigByStreamResponse.java
create mode 100644
inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk/dataproxy/pb/config/pojo/InlongStreamConfig.java
create mode 100644
inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk/dataproxy/pb/config/pojo/ProxyClusterConfig.java
create mode 100644
inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk/dataproxy/pb/config/pojo/ProxyClusterResult.java
copy
inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk/dataproxy/{network/SequentialID.java
=> pb/config/pojo/ProxyInfo.java} (53%)
copy
inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk/dataproxy/{network/SequentialID.java
=> pb/config/pojo/ProxyNodeInfo.java} (52%)
create mode 100644
inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk/dataproxy/pb/context/CallbackProfile.java
copy
inlong-sdk/dataproxy-sdk/src/{test/java/org/apache/inlong/sdk/dataproxy/ProxyUtilsTest.java
=> main/java/org/apache/inlong/sdk/dataproxy/pb/context/Constants.java} (60%)
copy
inlong-sdk/dataproxy-sdk/src/{test/java/org/apache/inlong/sdk/dataproxy/ProxyUtilsTest.java
=> main/java/org/apache/inlong/sdk/dataproxy/pb/context/InlongId.java} (51%)
create mode 100644
inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk/dataproxy/pb/context/ProfileEvent.java
create mode 100644
inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk/dataproxy/pb/context/SdkProfile.java
create mode 100644
inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk/dataproxy/pb/context/SdkSinkContext.java
create mode 100644
inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk/dataproxy/pb/context/SinkContext.java
create mode 100644
inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk/dataproxy/pb/dispatch/DispatchManager.java
create mode 100644
inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk/dataproxy/pb/dispatch/DispatchProfile.java
create mode 100644
inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk/dataproxy/pb/metrics/SdkMetricItem.java
create mode 100644
inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk/dataproxy/pb/metrics/SdkMetricItemSet.java
copy
inlong-sdk/dataproxy-sdk/src/{test/java/org/apache/inlong/sdk/dataproxy/ProxyUtilsTest.java
=>
main/java/org/apache/inlong/sdk/dataproxy/pb/network/ByteArrayToBinaryEncoder.java}
(52%)
create mode 100644
inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk/dataproxy/pb/network/IpPort.java
create mode 100644
inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk/dataproxy/pb/network/IpUtils.java
create mode 100644
inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk/dataproxy/pb/network/TcpChannel.java
create mode 100644
inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk/dataproxy/pb/network/TcpChannelGroup.java
create mode 100644
inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk/dataproxy/pb/network/TcpResult.java
delete mode 100644
inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk/dataproxy/utils/AuthzUtils.java
rename
inlong-sdk/dataproxy-sdk/src/test/java/org/apache/inlong/sdk/dataproxy/{ProxyUtilsTest.java
=> UtilsTest.java} (88%)
delete mode 100644
inlong-sort/sort-end-to-end-tests/sort-end-to-end-tests-v1.15/src/test/resources/env/otel-config.yaml
delete mode 100644
inlong-sort/sort-flink/base/src/main/java/org/apache/inlong/sort/base/dirty/utils/AESUtils.java
