You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@inlong.apache.org by go...@apache.org on 2021/09/22 12:40:42 UTC
[incubator-inlong] branch master updated (feb89a3 -> 944b9b7)
This is an automated email from the ASF dual-hosted git repository.
gosonzhang pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-inlong.git.
from feb89a3 [INLONG-1569] The first_registered is not the same with its naming (#1577)
add 944b9b7 [INLONG-1579] fix the license header error (#1580)
No new revisions were added by this update.
Summary of changes:
inlong-dataproxy-sdk/pom.xml | 33 ++++++++++++----------
.../apache/inlong/dataproxy/ConfigConstants.java | 19 +++++++------
.../inlong/dataproxy/DefaultMessageSender.java | 19 +++++++------
.../org/apache/inlong/dataproxy/FileCallback.java | 19 +++++++------
.../org/apache/inlong/dataproxy/MessageSender.java | 19 +++++++------
.../inlong/dataproxy/MessageSenderFactory.java | 19 +++++++------
.../apache/inlong/dataproxy/ProxyClientConfig.java | 19 +++++++------
.../inlong/dataproxy/SendMessageCallback.java | 19 +++++++------
.../org/apache/inlong/dataproxy/SendResult.java | 19 +++++++------
.../inlong/dataproxy/codec/EncodeObject.java | 19 +++++++------
.../apache/inlong/dataproxy/codec/ErrorCode.java | 19 +++++++------
.../inlong/dataproxy/codec/ProtocolDecoder.java | 19 +++++++------
.../inlong/dataproxy/codec/ProtocolEncoder.java | 19 +++++++------
.../dataproxy/config/EncryptConfigEntry.java | 19 +++++++------
.../inlong/dataproxy/config/EncryptInfo.java | 19 +++++++------
.../apache/inlong/dataproxy/config/HostInfo.java | 19 +++++++------
.../inlong/dataproxy/config/ProxyConfigEntry.java | 19 +++++++------
.../dataproxy/config/ProxyConfigManager.java | 19 +++++++------
.../org/apache/inlong/dataproxy/demo/Event.java | 19 +++++++------
.../inlong/dataproxy/demo/MyFileCallBack.java | 19 +++++++------
.../inlong/dataproxy/demo/MyMessageCallBack.java | 19 +++++++------
.../inlong/dataproxy/demo/SendMsgThread.java | 19 +++++++------
.../inlong/dataproxy/http/InternalHttpSender.java | 19 +++++++------
.../inlong/dataproxy/metric/MessageRecord.java | 19 +++++++------
.../dataproxy/metric/MetricTimeNumSummary.java | 19 +++++++------
.../inlong/dataproxy/network/ClientHandler.java | 19 +++++++------
.../apache/inlong/dataproxy/network/ClientMgr.java | 19 +++++++------
.../dataproxy/network/ClientPipelineFactory.java | 19 +++++++------
.../inlong/dataproxy/network/HttpMessage.java | 19 +++++++------
.../inlong/dataproxy/network/HttpProxySender.java | 19 +++++++------
.../inlong/dataproxy/network/NettyClient.java | 19 +++++++------
.../dataproxy/network/ProxysdkException.java | 19 +++++++------
.../inlong/dataproxy/network/QueueObject.java | 19 +++++++------
.../apache/inlong/dataproxy/network/Sender.java | 19 +++++++------
.../inlong/dataproxy/network/SequentialID.java | 19 +++++++------
.../dataproxy/network/SyncMessageCallable.java | 19 +++++++------
.../inlong/dataproxy/network/TimeScanObject.java | 19 +++++++------
.../org/apache/inlong/dataproxy/network/Utils.java | 19 +++++++------
.../dataproxy/threads/IndexCollectThread.java | 19 +++++++------
.../dataproxy/threads/ManagerFetcherThread.java | 19 +++++++------
.../dataproxy/threads/MetricWorkerThread.java | 19 +++++++------
.../dataproxy/threads/TimeoutScanThread.java | 19 +++++++------
.../inlong/dataproxy/utils/ConcurrentHashSet.java | 19 +++++++------
.../apache/inlong/dataproxy/utils/EncryptUtil.java | 19 +++++++------
.../inlong/dataproxy/utils/MapBackedSet.java | 19 +++++++------
.../apache/inlong/dataproxy/utils/ProxyUtils.java | 19 +++++++------
.../dataproxy/utils/ServiceDiscoveryUtils.java | 19 +++++++------
.../java/org/apache/inlong/dataproxy/AppTest.java | 19 +++++++------
.../inlong/dataproxy/TestMetricWorkerThread.java | 19 +++++++------
inlong-dataproxy/dataproxy-dist/pom.xml | 32 +++++++++++----------
inlong-dataproxy/dataproxy-docker/pom.xml | 3 +-
inlong-dataproxy/dataproxy-source/pom.xml | 32 +++++++++++----------
inlong-dataproxy/pom.xml | 32 +++++++++++----------
inlong-distribution/distribution.xml | 4 +--
inlong-distribution/pom.xml | 30 ++++++++++----------
.../src/main/resources/generatorConfig.xml | 32 +++++++++++----------
.../mappers/AgentHeartBeatLogEntityMapper.xml | 32 +++++++++++----------
.../mappers/AgentSysConfigEntityMapper.xml | 32 +++++++++++----------
.../resources/mappers/BusinessEntityMapper.xml | 32 +++++++++++----------
.../resources/mappers/BusinessExtEntityMapper.xml | 32 +++++++++++----------
.../main/resources/mappers/ClusterInfoMapper.xml | 32 +++++++++++----------
.../mappers/CommonDbServerEntityMapper.xml | 32 +++++++++++----------
.../mappers/CommonFileServerEntityMapper.xml | 32 +++++++++++----------
.../resources/mappers/ConsumptionEntityMapper.xml | 32 +++++++++++----------
.../mappers/DataProxyClusterEntityMapper.xml | 32 +++++++++++----------
.../resources/mappers/DataSchemaEntityMapper.xml | 32 +++++++++++----------
.../mappers/DataSourceCmdConfigEntityMapper.xml | 32 +++++++++++----------
.../resources/mappers/DataStreamEntityMapper.xml | 32 +++++++++++----------
.../mappers/DataStreamExtEntityMapper.xml | 32 +++++++++++----------
.../mappers/DataStreamFieldEntityMapper.xml | 32 +++++++++++----------
.../src/main/resources/mappers/EventLogMapper.xml | 32 +++++++++++----------
.../resources/mappers/OperationLogEntityMapper.xml | 32 +++++++++++----------
.../mappers/ProcessInstanceEntityMapper.xml | 32 +++++++++++----------
.../main/resources/mappers/RoleEntityMapper.xml | 32 +++++++++++----------
.../mappers/SourceDbBasicEntityMapper.xml | 32 +++++++++++----------
.../mappers/SourceDbDetailEntityMapper.xml | 32 +++++++++++----------
.../mappers/SourceFileBasicEntityMapper.xml | 32 +++++++++++----------
.../mappers/SourceFileDetailEntityMapper.xml | 32 +++++++++++----------
.../resources/mappers/StorageExtEntityMapper.xml | 32 +++++++++++----------
.../resources/mappers/StorageHiveEntityMapper.xml | 32 +++++++++++----------
.../mappers/StorageHiveFieldEntityMapper.xml | 32 +++++++++++----------
.../main/resources/mappers/TaskDefEntityMapper.xml | 32 +++++++++++----------
.../main/resources/mappers/TaskEntityMapper.xml | 32 +++++++++++----------
.../resources/mappers/TaskFlowDefEntityMapper.xml | 32 +++++++++++----------
.../resources/mappers/TaskFlowEntityMapper.xml | 32 +++++++++++----------
.../resources/mappers/TaskInstanceEntityMapper.xml | 32 +++++++++++----------
.../main/resources/mappers/UserEntityMapper.xml | 32 +++++++++++----------
.../resources/mappers/UserRoleEntityMapper.xml | 32 +++++++++++----------
.../mappers/WorkflowApproverEntityMapper.xml | 32 +++++++++++----------
inlong-manager/manager-web/assembly.xml | 32 +++++++++++----------
inlong-manager/manager-web/bin/restart.sh | 31 ++++++++++----------
inlong-manager/manager-web/bin/shutdown.sh | 31 ++++++++++----------
inlong-manager/manager-web/bin/startup.sh | 31 ++++++++++----------
.../src/main/resources/logback-spring.xml | 32 +++++++++++----------
inlong-sort/pom.xml | 32 +++++++++++----------
inlong-sort/sort-api/pom.xml | 32 +++++++++++----------
inlong-sort/sort-common/pom.xml | 32 +++++++++++----------
inlong-sort/sort-core/pom.xml | 32 +++++++++++----------
.../hive/partition/JdbcHivePartitionTool.java | 27 ++++++++++--------
.../src/test/resources/log4j-test.properties | 30 +++++++++++---------
inlong-sort/sort-dist/pom.xml | 32 +++++++++++----------
inlong-sort/sort-formats/format-base/pom.xml | 33 ++++++++++++----------
inlong-sort/sort-formats/format-common/pom.xml | 33 ++++++++++++----------
inlong-sort/sort-formats/format-csv/pom.xml | 33 ++++++++++++----------
.../org.apache.flink.table.factories.TableFactory | 17 -----------
.../src/test/resources/log4j-test.properties | 30 +++++++++++---------
inlong-sort/sort-formats/format-kv/pom.xml | 33 ++++++++++++----------
.../org.apache.flink.table.factories.TableFactory | 17 -----------
.../src/test/resources/log4j-test.properties | 30 +++++++++++---------
inlong-sort/sort-formats/format-tdmsg-base/pom.xml | 33 ++++++++++++----------
inlong-sort/sort-formats/format-tdmsg-csv/pom.xml | 33 ++++++++++++----------
.../org.apache.flink.table.factories.TableFactory | 17 -----------
.../src/test/resources/log4j-test.properties | 30 +++++++++++---------
inlong-sort/sort-formats/pom.xml | 33 ++++++++++++----------
inlong-tubemq/bin/broker.cmd | 26 +++++++++--------
inlong-tubemq/bin/env.cmd | 26 +++++++++--------
inlong-tubemq/bin/master.cmd | 30 +++++++++++---------
.../tubemq/corebase/utils/KeyBuilderUtils.java | 5 ++--
.../tubemq-manager/bin/init-tube-cluster.sh | 10 +++----
inlong-tubemq/tubemq-manager/bin/start-manager.sh | 10 +++----
inlong-tubemq/tubemq-manager/bin/stop-manager.sh | 11 ++++----
inlong-tubemq/tubemq-manager/conf/logback.xml | 4 +--
inlong-tubemq/tubemq-manager/pom.xml | 5 ++--
.../tubemq-manager/src/main/assembly/assembly.xml | 5 ++--
.../src/main/resources/application.properties | 30 +++++++++++---------
.../tubemq-server/src/saveServerVersion.cmd | 30 +++++++++++---------
126 files changed, 1620 insertions(+), 1484 deletions(-)