This is an automated email from the ASF dual-hosted git repository.
caogaofei pushed a change to branch full_outer_join
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from c04c6ed3725 fix serialize of CoalesceExpression
add 5de8dc7a4db IoTConsensusV2: Introduce IoTConsensusV2 and corresponding
mode option (#13440)
add acda1a0f092 Make log dispatcher stop in parallel #13588
add cb4befcbd45 fix bug (#13590)
add 24d1191a8e7 Fix potential NPE when write FileTimeIndexCache (#13583)
add 197965e9ae9 Skip the file timestamp check of tsfiles generated by
repair task (#13581)
add 737c4ccea98 Fix print error log when dir is not exist (#13591)
add 5b22e7b010b Handle commit failure of table procedures
add ed85c44817b add coalesce
add ada53c66f9d fix serialize of CoalesceExpression
add 6c78ead76d6 fix
new ec592af3d29 Merge branch 'add_coalesce' into full_outer_join
new b7def7aab58 fix it
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/it/env/cluster/ClusterConstant.java | 4 +-
.../org/apache/iotdb/it/env/cluster/EnvUtils.java | 18 +-
.../org/apache/iotdb/db/it/utils/TestUtils.java | 4 +-
.../db/it/IoTDBMultiIDsWithAttributesTableIT.java | 92 +++++----
.../confignode/conf/ConfigNodeStartupCheck.java | 5 +-
.../consensus/request/ConfigPhysicalPlanType.java | 1 +
.../{ShowTablePlan.java => FetchTablePlan.java} | 17 +-
.../{ShowTableResp.java => FetchTableResp.java} | 21 +-
.../iotdb/confignode/manager/ConfigManager.java | 23 +++
.../apache/iotdb/confignode/manager/IManager.java | 4 +
.../iotdb/confignode/manager/ProcedureManager.java | 16 +-
.../manager/load/balancer/RouteBalancer.java | 3 -
.../manager/schema/ClusterSchemaManager.java | 16 ++
.../persistence/executor/ConfigPlanExecutor.java | 3 +
.../persistence/schema/ClusterSchemaInfo.java | 23 +++
.../confignode/persistence/schema/ConfigMTree.java | 17 ++
.../impl/schema/table/AddTableColumnProcedure.java | 1 -
.../impl/schema/table/CreateTableProcedure.java | 1 -
.../schema/table/SetTablePropertiesProcedure.java | 1 -
.../thrift/ConfigNodeRPCServiceProcessor.java | 7 +
.../apache/iotdb/consensus/ConsensusFactory.java | 23 +--
.../consensus/config/PipeConsensusConfig.java | 26 ++-
.../apache/iotdb/consensus/iot/IoTConsensus.java | 4 +
.../consensus/iot/logdispatcher/LogDispatcher.java | 11 +-
.../iotdb/consensus/ratis/RatisConsensus.java | 3 +
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 50 +++--
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 32 +--
.../db/consensus/DataRegionConsensusImpl.java | 4 +-
.../agent/receiver/PipeDataNodeReceiverAgent.java | 2 +-
.../pipeconsensus/PipeConsensusAsyncConnector.java | 4 +-
.../pipeconsensus/PipeConsensusReceiver.java | 13 +-
.../iotdb/db/protocol/client/ConfigNodeClient.java | 9 +
.../relational/TableFullOuterJoinOperator.java | 4 +-
.../config/executor/ClusterConfigTaskExecutor.java | 22 ++-
.../config/executor/IConfigTaskExecutor.java | 4 +
.../plan/planner/plan/node/write/InsertNode.java | 1 -
.../fetcher/TableHeaderSchemaValidator.java | 60 ++++--
.../plan/relational/sql/ast/Expression.java | 3 +
.../db/schemaengine/table/DataNodeTableCache.java | 217 ++++++++++++++++-----
.../java/org/apache/iotdb/db/service/DataNode.java | 3 +-
.../iotdb/db/storageengine/StorageEngine.java | 3 -
.../db/storageengine/dataregion/DataRegion.java | 10 +-
.../execute/task/AbstractCompactionTask.java | 2 +-
.../task/InsertionCrossSpaceCompactionTask.java | 2 +
.../task/RepairUnsortedFileCompactionTask.java | 4 +
.../compaction/repair/RepairDataFileScanUtil.java | 10 +-
.../repair/RepairTimePartitionScanTask.java | 2 +-
.../dataregion/tsfile/TsFileResource.java | 2 +-
.../FileTimeIndexCacheWriter.java | 8 +-
.../storageengine/dataregion/wal/WALManager.java | 18 +-
.../dataregion/wal/recover/WALNodeRecoverTask.java | 7 +-
.../conf/iotdb-system.properties.template | 25 ++-
.../assembly/resources/sbin/destroy-datanode.bat | 12 +-
.../assembly/resources/sbin/destroy-datanode.sh | 4 +-
.../apache/iotdb/commons/schema/table/TsTable.java | 4 +-
.../schema/table/TsTableInternalRPCUtil.java | 94 ++++++---
.../org/apache/iotdb/commons/utils/PathUtils.java | 7 +
.../src/main/thrift/confignode.thrift | 7 +
58 files changed, 691 insertions(+), 302 deletions(-)
copy
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/table/{ShowTablePlan.java
=> FetchTablePlan.java} (72%)
copy
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/table/{ShowTableResp.java
=> FetchTableResp.java} (61%)
