This is an automated email from the ASF dual-hosted git repository.
jackietien pushed a change to branch tsbs/iot
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 4ec3f2f9276 remove useless print
add feb61e8d83a Pipe: Fix InsertRowsNode is not supported in batch mode
(#12517)
add 6d445f92a1e Pipe: Degraded the lock in PipeEventCollector to avoid
waitForTsFileClose() blocking pipe drop (#12518)
add c893101de1b Pipe: cache leader support batch mode (#12486)
add 741a218fb75 fix filter push down is not valid in template align by
device situation
add c12c84101c8 Fixed invalid links in En version & CH version for README
(#12512)
add 98d185d5694 fixed default parameters, output ulimit as empty, remove
excess logs from the bat script (#12522)
add 3e57c3fc78c Adjust the hard connection error log information to debug
level (#12523)
add f16df817848 Add new optimization rule: remove `Project` under
`RawDataAggregation`
new 6767474f619 Merge remote-tracking branch 'origin/master' into tsbs/iot
add 2cb13ed1613 Pipe: timely restart pipes according to the deletion of
original TsFiles (#12406)
add 48d87bc4fd8 Pipe: Fixed the bug that events that do not trigger
collection in processorSubtask may not be reported & the pipes that extract
deletion in dataRegion extractor may be auto-restarted (#12497)
add d506eb78cb4 Load: Update TsFile Resource when
enable_auto_create_schema and verify schema are FALSE in Analysis Stage (#12525)
add 8f23949384d Change TsFile version
new e36b4d3303b Merge remote-tracking branch 'origin/master' into tsbs/iot
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:
README.md | 2 +-
README_ZH.md | 4 +-
.../org/apache/iotdb/tool/IoTDBDataBackTool.java | 2 +-
.../db/pipe/agent/task/PipeDataNodeTaskAgent.java | 57 +++-
.../client/IoTDBDataNodeAsyncClientManager.java | 10 +-
.../IoTDBDataNodeCacheLeaderClientManager.java | 2 +-
.../client/IoTDBDataNodeSyncClientManager.java | 9 +
...oTDBThriftAsyncPipeTransferBatchReqBuilder.java | 36 ---
...IoTDBThriftSyncPipeTransferBatchReqBuilder.java | 29 --
...ferBatchReqBuilder.java => PipeEventBatch.java} | 61 ++--
.../builder/PipeTransferBatchReqBuilder.java | 219 +++++---------
.../request/PipeTransferTabletBatchReq.java | 23 +-
.../request/PipeTransferTabletBinaryReq.java | 57 ++--
.../request/PipeTransferTabletInsertNodeReq.java | 13 +-
.../async/IoTDBDataRegionAsyncConnector.java | 49 +--
.../PipeTransferTabletBatchEventHandler.java | 19 +-
.../thrift/sync/IoTDBDataRegionSyncConnector.java | 40 ++-
.../db/pipe/connector/util/LeaderCacheUtils.java | 69 +++++
.../common/tsfile/PipeTsFileInsertionEvent.java | 4 +-
.../dataregion/IoTDBDataRegionExtractor.java | 6 +
.../iotdb/db/pipe/metric/PipeProcessorMetrics.java | 24 +-
.../protocol/thrift/IoTDBDataNodeReceiver.java | 51 +++-
.../pipe/resource/tsfile/PipeTsFileResource.java | 33 ++-
.../resource/tsfile/PipeTsFileResourceManager.java | 35 ++-
.../pipe/task/connection/PipeEventCollector.java | 21 +-
.../subtask/processor/PipeProcessorSubtask.java | 20 +-
.../plan/analyze/LoadTsfileAnalyzer.java | 39 +--
.../plan/optimization/AggregationPushDown.java | 18 +-
.../plan/planner/TemplatedLogicalPlanBuilder.java | 5 +-
.../source/AlignedSeriesAggregationScanNode.java | 6 +-
.../crud/InsertMultiTabletsStatement.java | 8 +
.../db/storageengine/dataregion/DataRegion.java | 2 +-
.../resource/PipeTsFileResourceManagerTest.java | 16 +-
.../plan/optimization/AggregationPushDownTest.java | 69 +++++
.../plan/optimization/TestPlanBuilder.java | 20 ++
.../distribution/AggregationAlignByDeviceTest.java | 44 ---
.../planner/distribution/AlignedByDeviceTest.java | 328 ++-------------------
.../src/assembly/resources/sbin/health_check.bat | 2 -
.../src/assembly/resources/sbin/health_check.sh | 1 +
.../apache/iotdb/commons/conf/CommonConfig.java | 11 +
.../iotdb/commons/conf/CommonDescriptor.java | 5 +
.../iotdb/commons/pipe/config/PipeConfig.java | 7 +
pom.xml | 2 +-
43 files changed, 707 insertions(+), 771 deletions(-)
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/payload/evolvable/builder/IoTDBThriftAsyncPipeTransferBatchReqBuilder.java
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/payload/evolvable/builder/IoTDBThriftSyncPipeTransferBatchReqBuilder.java
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/payload/evolvable/builder/{PipeTransferBatchReqBuilder.java
=> PipeEventBatch.java} (76%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/util/LeaderCacheUtils.java
