This is an automated email from the ASF dual-hosted git repository.
xingtanzjr pushed a change to branch fast_performer_force_decoding
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 40fbe5aa12d Fast performer force decoding (#10705)
add 996efd86ed9 Update Jenkinsfile and ignore sonar check in Jenkins
(#10693)
add d4c643c3778 [IOTDB-6043] Pipe: a framework to support wal hardlink
mode (#10440)
add f687dcb7f76 Fix potential memory leak in MemoryPool
add c0c4ad29b3a [RatisConsensus] Support linearizable read when leader
switches (#10699)
add 3a1a26a397e add build info in show cluster (#10595)
add 3c6ab756d56 add time partition in compaction comparator (#10662)
add e903f6e576b Fix python IT by adding the check of cluster status
(#10698)
add b43dc9d0f58 fix windows cpp IT (#10704)
add 011c1ec7fce Merge branch 'master' into fast_performer_force_decoding
No new revisions were added by this update.
Summary of changes:
.github/workflows/client-cpp.yml | 13 +-
.github/workflows/client-python.yml | 3 -
Jenkinsfile | 32 ++--
iotdb-client/client-py/iotdb/IoTDBContainer.py | 7 +
.../consensus/request/ConfigPhysicalPlan.java | 4 +
.../consensus/request/ConfigPhysicalPlanType.java | 1 +
.../write/confignode/ApplyConfigNodePlan.java | 1 -
...onfigNodePlan.java => UpdateBuildInfoPlan.java} | 42 +++---
.../iotdb/confignode/manager/ConfigManager.java | 16 +-
.../iotdb/confignode/manager/ProcedureManager.java | 2 +-
.../iotdb/confignode/manager/node/NodeManager.java | 55 +++++--
.../persistence/executor/ConfigPlanExecutor.java | 3 +
.../confignode/persistence/node/NodeInfo.java | 93 +++++++++++-
.../procedure/env/ConfigNodeProcedureEnv.java | 11 +-
.../impl/node/AddConfigNodeProcedure.java | 19 ++-
.../iotdb/confignode/service/ConfigNode.java | 80 +++++-----
.../impl/node/AddConfigNodeProcedureTest.java | 4 +-
.../ratis/ApplicationStateMachineProxy.java | 24 ++-
.../iotdb/consensus/ratis/RatisConsensus.java | 3 +-
.../db/pipe/agent/runtime/PipeRuntimeAgent.java | 2 +-
.../tablet/PipeInsertNodeTabletInsertionEvent.java | 4 +-
.../common/tsfile/PipeTsFileInsertionEvent.java | 4 +-
.../PipeHardlinkFileDirStartupCleaner.java | 10 +-
.../db/pipe/resource/PipeResourceManager.java | 31 +++-
.../PipeTsFileResourceManager.java} | 25 +--
.../db/pipe/resource/wal/PipeWALResource.java | 26 ++--
.../pipe/resource/wal/PipeWALResourceManager.java | 46 ++++--
.../wal/hardlink/PipeWALHardlinkResource.java} | 31 ++--
.../hardlink/PipeWALHardlinkResourceManager.java | 167 +++++++++++++++++++++
.../wal/selfhost/PipeWALSelfHostResource.java} | 25 +--
.../selfhost/PipeWALSelfHostResourceManager.java} | 22 +--
.../common/header/ColumnHeaderConstant.java | 3 +-
.../execution/exchange/MPPDataExchangeManager.java | 2 +-
.../execution/exchange/sink/SinkChannel.java | 2 +-
.../queryengine/execution/memory/MemoryPool.java | 91 +++--------
.../execution/config/metadata/ShowClusterTask.java | 10 +-
.../java/org/apache/iotdb/db/service/DataNode.java | 2 +
.../DefaultCompactionTaskComparatorImpl.java | 14 ++
.../dataregion/wal/checkpoint/MemTableInfo.java | 4 +
.../storageengine/dataregion/wal/node/WALNode.java | 5 +-
.../dataregion/wal/utils/WALEntryHandler.java | 37 ++++-
...est.java => PipeTsFileResourceManagerTest.java} | 61 ++++----
.../PipeWALHardlinkResourceManagerTest.java | 114 ++++++++++++++
.../compaction/CompactionTaskComparatorTest.java | 58 +++++++
.../resources/conf/iotdb-common.properties | 16 +-
.../apache/iotdb/commons/conf/CommonConfig.java | 36 ++++-
.../iotdb/commons/conf/CommonDescriptor.java | 10 ++
.../iotdb/commons/pipe/config/PipeConfig.java | 22 +++
.../src/main/thrift/confignode.thrift | 4 +
49 files changed, 971 insertions(+), 326 deletions(-)
copy
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/confignode/{ApplyConfigNodePlan.java
=> UpdateBuildInfoPlan.java} (63%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/resource/{file =>
}/PipeHardlinkFileDirStartupCleaner.java (87%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/resource/{file/PipeFileResourceManager.java
=> tsfile/PipeTsFileResourceManager.java} (90%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{storageengine/dataregion/wal/utils/listener/WALFlushListener.java
=> pipe/resource/wal/hardlink/PipeWALHardlinkResource.java} (53%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/resource/wal/hardlink/PipeWALHardlinkResourceManager.java
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{storageengine/dataregion/wal/utils/listener/WALFlushListener.java
=> pipe/resource/wal/selfhost/PipeWALSelfHostResource.java} (59%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{storageengine/dataregion/wal/utils/listener/WALFlushListener.java
=> pipe/resource/wal/selfhost/PipeWALSelfHostResourceManager.java} (59%)
rename
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/resource/{PipeFileResourceManagerTest.java
=> PipeTsFileResourceManagerTest.java} (74%)
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/resource/PipeWALHardlinkResourceManagerTest.java
