This is an automated email from the ASF dual-hosted git repository.
jackietien pushed a change to branch ty/removeTsFileModule
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 0bfa806f62f tmp
add 0fa3eb6395c Pipe: Fixed the bug that empty tsfile may not be marked
when already closed & Improved exception.conflict.resolve-strategy parsing &
Improved config/schema region snapshot listenning logger & Refactor (#12265)
add 804ee600cd4 Pipe: Improved handling logic for transferred statements &
Allow root.__system.** schemas to reach the receiver side (#12276)
add fd48ef68254 Pipe: support different load balance strategies for data
sync (#12281)
new 70908c750d4 Merge remote-tracking branch 'origin/master' into
ty/removeTsFileModule
new 87bba5bd4de Fix compile error
The 2 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:
.../iotdb/hadoop/tsfile/TSMRWriteExample.java | 4 +-
integration-test/import-control.xml | 2 +-
.../src/test/resources/logback-test.xml | 2 +-
.../parameter/PipeParameterValidator.java | 22 +--
.../java/org/apache/iotdb/tool/ImportData.java | 12 +-
iotdb-client/cli/src/test/resources/logback.xml | 2 +-
.../apache/iotdb/spark/tsfile/DefaultSource.scala | 4 +-
.../iotdb/spark/tsfile/NarrowConverter.scala | 3 +-
.../apache/iotdb/spark/tsfile/WideConverter.scala | 9 +-
.../statemachine/ConfigRegionStateMachine.java | 18 ++-
.../client/IoTDBConfigNodeSyncClientManager.java | 8 +-
.../protocol/IoTDBConfigRegionConnector.java | 6 +-
.../extractor/ConfigRegionListeningFilter.java | 11 --
.../receiver/protocol/IoTDBConfigNodeReceiver.java | 8 -
.../PipeConfigPhysicalPlanTSStatusVisitor.java | 3 +
.../schemaregion/SchemaRegionStateMachine.java | 8 +-
.../client/IoTDBDataNodeAsyncClientManager.java | 86 +++++++++--
.../client/IoTDBDataNodeSyncClientManager.java | 5 +-
.../async/IoTDBDataRegionAsyncConnector.java | 4 +-
.../thrift/sync/IoTDBDataNodeSyncConnector.java | 5 +-
.../common/tsfile/PipeTsFileInsertionEvent.java | 42 ++++--
.../realtime/PipeRealtimeDataRegionExtractor.java | 2 +-
.../visitor/PipeStatementExceptionVisitor.java | 27 +++-
.../visitor/PipeStatementTSStatusVisitor.java | 23 +--
.../dataregion/compaction/settle/SettleTask.java | 2 +-
.../dataregion/memtable/TsFileProcessor.java | 163 ++++++++++-----------
.../compaction/cross/MergeUpgradeTest.java | 3 +-
.../config/constant/PipeConnectorConstant.java | 18 +++
.../pipe/connector/PipeReceiverStatusHandler.java | 10 +-
.../pipe/connector/client/IoTDBSyncClient.java | 4 +-
.../connector/client/IoTDBSyncClientManager.java | 107 ++++++++++++--
.../connector/protocol/IoTDBAirGapConnector.java | 98 +++++++++++--
.../pipe/connector/protocol/IoTDBConnector.java | 57 +++++--
.../connector/protocol/IoTDBSslSyncConnector.java | 6 +-
pom.xml | 2 +-
35 files changed, 547 insertions(+), 239 deletions(-)
