This is an automated email from the ASF dual-hosted git repository.
haonan pushed a change to branch TableSession
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from a9394379003 Revert "remove sqlDialect and database in tree model
session builder"
add 1b33c55153a Change LogicalOptimizer and DistributionOptimizer
singleton (#14158)
add 3cb544e39b2 Pipe: Reduce the memory usage & Enable insertNode memory
control for stream mode degrade and stuck restart (#14102)
add adcedc0bc57 [remove datanode] Refuse to remove when there are any
other unknown or readonly DataNodes in the consensus group (#14145)
add ec5d2ca1603 LOGGER.error(e.getMessage()) IS REALLY A BAD IDEA (#14137)
add 4edc42b97f8 Pipe: Fix the problem that the Aligned information of the
Tablet generated by TsFileInsertionEventScanParser is incorrect (#14136)
add 01a46eeab7e Bump tsfile version to 1.2.0-dd29bcc-SNAPSHOT #14163
add e66f3a8a727 Fixed bug where Ratis could not write large requests and
could not be configured (#14160)
add d7c3f12289d Merge branch 'master' of github.com:apache/iotdb into
TableSession
No new revisions were added by this update.
Summary of changes:
.../pipe/runtime/PipeHandleMetaChangePlan.java | 8 +-
.../response/pipe/task/PipeTableResp.java | 5 +-
.../statemachine/ConfigRegionStateMachine.java | 6 +-
.../iotdb/confignode/manager/ProcedureManager.java | 24 +++++
.../manager/partition/PartitionManager.java | 4 +-
.../pipe/agent/task/PipeConfigNodeTaskAgent.java | 4 +-
.../runtime/heartbeat/PipeHeartbeat.java | 3 +-
.../runtime/heartbeat/PipeHeartbeatParser.java | 5 +-
.../manager/pipe/metric/PipeConfigNodeMetrics.java | 4 +-
... => PipeTemporaryMetaInCoordinatorMetrics.java} | 29 +++---
.../persistence/executor/ConfigPlanExecutor.java | 4 +-
.../confignode/persistence/pipe/PipeInfo.java | 16 +--
.../confignode/persistence/pipe/PipeTaskInfo.java | 4 +-
.../procedure/env/RemoveDataNodeHandler.java | 20 +++-
.../confignode/manager/ProcedureManagerTest.java | 24 +++++
.../apache/iotdb/consensus/config/RatisConfig.java | 28 ------
.../apache/iotdb/consensus/ratis/utils/Utils.java | 23 +++--
.../dataregion/DataRegionStateMachine.java | 2 +-
.../db/pipe/agent/runtime/PipeAgentLauncher.java | 2 +-
.../db/pipe/agent/task/PipeDataNodeTaskAgent.java | 30 ++++--
.../evolvable/batch/PipeTabletEventPlainBatch.java | 10 +-
.../async/IoTDBDataRegionAsyncConnector.java | 2 +-
.../tablet/PipeInsertNodeTabletInsertionEvent.java | 30 +++++-
.../common/tablet/PipeRawTabletInsertionEvent.java | 6 +-
.../scan/TsFileInsertionEventScanParser.java | 14 ++-
.../PipeRealtimeDataRegionHybridExtractor.java | 12 ++-
.../impl/DataNodeInternalRPCServiceImpl.java | 7 +-
.../iotdb/db/queryengine/plan/Coordinator.java | 35 ++++++-
.../config/executor/ClusterConfigTaskExecutor.java | 6 +-
.../TableModelStatementMemorySourceVisitor.java | 7 +-
.../plan/planner/TableOperatorGenerator.java | 3 +-
.../relational/planner/TableLogicalPlanner.java | 16 +--
.../plan/relational/planner/TableModelPlanner.java | 19 +++-
.../distribute/TableDistributedPlanner.java | 21 +++-
.../dataregion/wal/utils/WALEntryHandler.java | 12 +--
.../TsFileResourceProgressIndexTest.java | 5 +
.../commons/consensus/index/ProgressIndex.java | 12 ++-
.../consensus/index/impl/HybridProgressIndex.java | 36 ++++---
.../consensus/index/impl/IoTProgressIndex.java | 12 +++
.../consensus/index/impl/MetaProgressIndex.java | 9 +-
.../consensus/index/impl/MinimumProgressIndex.java | 5 +
.../consensus/index/impl/RecoverProgressIndex.java | 13 +++
.../consensus/index/impl/SimpleProgressIndex.java | 9 +-
.../consensus/index/impl/StateProgressIndex.java | 17 +++-
.../index/impl/TimeWindowStateProgressIndex.java | 24 +++++
.../commons/pipe/agent/task/PipeTaskAgent.java | 49 ++++++++++
.../commons/pipe/agent/task/meta/PipeMeta.java | 17 +++-
.../pipe/agent/task/meta/PipeTemporaryMeta.java | 73 +-------------
.../agent/task/meta/PipeTemporaryMetaInAgent.java | 107 +++++++++++++++++++++
...ta.java => PipeTemporaryMetaInCoordinator.java} | 5 +-
.../pipe/agent/task/progress/CommitterKey.java | 2 +-
.../task/progress/PipeEventCommitManager.java | 12 ++-
.../iotdb/commons/pipe/event/EnrichedEvent.java | 6 --
.../iotdb/commons/pipe/task/PipeMetaDeSerTest.java | 19 ++--
pom.xml | 2 +-
55 files changed, 627 insertions(+), 252 deletions(-)
rename
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/metric/{PipeTemporaryMetaMetrics.java
=> PipeTemporaryMetaInCoordinatorMetrics.java} (82%)
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/agent/task/meta/PipeTemporaryMetaInAgent.java
copy
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/agent/task/meta/{PipeTemporaryMeta.java
=> PipeTemporaryMetaInCoordinator.java} (94%)
