This is an automated email from the ASF dual-hosted git repository.
tanxinyu pushed a change to branch wal_compression
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from aa3e38f310b try bug
add 1020258bdf8 PipeConsensus: fix concurrent problems regarding to
initiate receiver and progressIndex & optimize receiver logs & fix npe (#12790)
add 0afc1bea507 Pipe: Fix remaining time metrics is not dropped after
dropPipe(pipeName) & alter pipe does not take effect in non-data regions
(#12795)
add 86aa71177f1 Pipe: Added collect invocation count in the caculation of
data region extractor events for data node remaining time (#12799)
add 7f34bc03129 Specify error msg when DriverTask is aborted by
MemoryNotEnoughException
add 5c23a355579 Add flush cause metric (#12803)
add ada45de7d37 use template file start 1c1d (#12808)
add 3fa0320d81d Pipe/PipeConsensus: support progressIndex for
InsertRowsNode (#12806)
add 7106bca5020 Modify ttl (#12811)
add 7b73b26400a Merge remote-tracking branch 'origin/master' into
wal_compression
No new revisions were added by this update.
Summary of changes:
.../org/apache/iotdb/db/qp/sql/IoTDBSqlParser.g4 | 2 +-
.../iotdb/confignode/conf/ConfigNodeConfig.java | 12 --
.../confignode/conf/ConfigNodeDescriptor.java | 2 +-
.../impl/pipe/task/AlterPipeProcedureV2.java | 44 +++--
iotdb-core/datanode/pom.xml | 4 +-
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 3 +
.../db/pipe/agent/task/PipeDataNodeTaskAgent.java | 4 +-
.../pipeconsensus/PipeConsensusAsyncConnector.java | 12 +-
.../consensus/ProgressIndexDataNodeManager.java | 20 ++-
.../PipeDataNodeRemainingEventAndTimeMetrics.java | 13 ++
.../PipeDataNodeRemainingEventAndTimeOperator.java | 29 +++-
.../pipeconsensus/PipeConsensusReceiver.java | 71 ++++----
.../pipeconsensus/PipeConsensusReceiverAgent.java | 53 ++++--
.../pipe/task/connection/PipeEventCollector.java | 4 +
.../subtask/processor/PipeProcessorSubtask.java | 4 +
.../common/header/ColumnHeaderConstant.java | 1 -
.../execution/schedule/AbstractDriverThread.java | 12 +-
.../schedule/DriverTaskAbortedException.java | 3 +
.../planner/plan/node/write/InsertRowsNode.java | 11 ++
.../iotdb/db/service/metrics/WritingMetrics.java | 186 ++++++++++++++-------
.../iotdb/db/storageengine/StorageEngine.java | 6 -
.../db/storageengine/dataregion/DataRegion.java | 20 ++-
.../dataregion/memtable/TsFileProcessor.java | 3 +-
.../read/reader/common/PriorityMergeReader.java | 3 +
.../storageengine/dataregion/wal/node/WALNode.java | 2 +-
.../iotdb/metrics/core/type/IoTDBCounter.java | 4 +-
.../conf/iotdb-system.properties.template | 32 ++--
.../consensus/index/impl/RecoverProgressIndex.java | 5 +-
.../iotdb/commons/service/metric/enums/Metric.java | 7 +-
29 files changed, 380 insertions(+), 192 deletions(-)
