You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ja...@apache.org on 2022/07/14 04:22:59 UTC
[iotdb] branch QueryException updated (8322e9e83d -> 384910aefe)
This is an automated email from the ASF dual-hosted git repository.
jackietien pushed a change to branch QueryException
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 8322e9e83d Fix compiler error
add d1f2ce3792 [CLIENT-PY]Optimize the performance of filling null values (#6555)
add a7be051e5f fix (#6630)
add d3ce150b52 Fix typo in user guide (#6619)
add d1dd425fcd [IOTDB-3718] Unify retry logic of SyncClientPool in ConfigNode (#6613)
add 86efede983 [IOTDB-3736] Remove DELETED status for TsFileResource (#6618)
add 7ecb0fff4f Refine Analyzer and LogicalPlanner (#6633)
add 0bc4e3dbb1 [IOTDB-3792] Show region tool support query condition of storage group (#6631)
add 5bdede4229 [IOTDB-3795] Remove setting read-only when handling compaction exception
add 16607fa29a Fix InnerSpaceCompactionExceptionTest (#6639)
add a944f97b0c [IOTDB-3788] insertRecord support insert Binary as TEXT DataType (#6634)
add 0eeabbca62 [IOTDB-3520] Support executeBatchStatement for MPP framework (#6628)
add 1b81a2b41e [IOTDB-3728] Greedy Region Allocator (#6611)
add 203b15bae6 [IOTDB-3352][IOTDB-3782] Fix the cache problem in PartitionCache and Optimize. (#6624)
add 6dc4757d2c [IOTDB-3457] start new feature: data node shrink (#6236)
add 4c99996e9d Add back the logic of blocking insert before holding writelock (#6649)
add 1824a86575 [Session] print ip and port for connection failure (#6650)
add aaeda83e9a [IOTDB-3805] Document and example of TEXT session interface (#6645)
add 7d0f517de5 Add more log to the cancellation operation of FragmentInstanceStateTracker (#6647)
add e4823ec57a [IOTDB-3756]Support mount template and query mount info (#6652)
add d56baad266 [IOTDB-3799] Create read_consistency_level parameter (#6638)
add 035779b7b8 [IOTDB-3811] Add registeredConfigNode into NodeInfo's snapshot #6659
add 6e193e8f56 Change 0.12.6 website download link (#6667)
add b6d6d7200a Merge remote-tracking branch 'origin/master' into QueryException
add 384910aefe Fix some CI
No new revisions were added by this update.
Summary of changes:
.../org/apache/iotdb/db/qp/sql/IoTDBSqlParser.g4 | 2 +-
client-py/iotdb/utils/IoTDBRpcDataSet.py | 36 +-
.../resources/conf/iotdb-confignode.properties | 22 +-
.../confignode/client/AsyncDataNodeClientPool.java | 1 -
.../ConfigNodeRequestType.java} | 13 +-
.../DataNodeRequestType.java} | 14 +-
.../client/SyncConfigNodeClientPool.java | 142 +-
.../confignode/client/SyncDataNodeClientPool.java | 153 +-
.../iotdb/confignode/conf/ConfigNodeConfig.java | 26 +-
.../confignode/conf/ConfigNodeDescriptor.java | 34 +-
.../confignode/conf/ConfigNodeRemoveCheck.java | 17 +-
.../consensus/request/ConfigPhysicalPlan.java | 12 +
.../consensus/request/ConfigPhysicalPlanType.java | 6 +-
.../GetPathsSetTemplatePlan.java} | 26 +-
.../request/read/GetRegionInfoListPlan.java | 40 +-
.../request/write/RemoveDataNodePlan.java | 219 +++
...unctionPlan.java => SetSchemaTemplatePlan.java} | 32 +-
.../request/write/UpdateRegionLocationPlan.java | 86 ++
...upSchemaResp.java => DataNodeToStatusResp.java} | 40 +-
.../{TemplateInfoResp.java => PathInfoResp.java} | 15 +-
.../statemachine/PartitionRegionStateMachine.java | 2 +
.../confignode/manager/ClusterSchemaManager.java | 36 +
.../iotdb/confignode/manager/ConfigManager.java | 52 +
.../confignode/manager/DataNodeRemoveManager.java | 805 +++++++++++
.../apache/iotdb/confignode/manager/IManager.java | 34 +
.../iotdb/confignode/manager/NodeManager.java | 74 +-
.../iotdb/confignode/manager/PartitionManager.java | 21 +
.../confignode/manager/PermissionManager.java | 6 +-
.../manager/load/balancer/RegionBalancer.java | 25 +-
.../balancer/region/CopySetRegionAllocator.java | 2 +-
.../balancer/region/GreedyRegionAllocator.java | 68 +
.../confignode/persistence/ClusterSchemaInfo.java | 46 +-
.../iotdb/confignode/persistence/NodeInfo.java | 209 +++
.../persistence/executor/ConfigPlanExecutor.java | 32 +-
.../persistence/partition/PartitionInfo.java | 43 +
.../partition/StorageGroupPartitionTable.java | 65 +-
.../persistence/schema/TemplateTable.java | 31 +-
.../procedure/env/ConfigNodeProcedureEnv.java | 24 +-
.../iotdb/confignode/service/ConfigNode.java | 10 +-
.../thrift/ConfigNodeRPCServiceProcessor.java | 48 +-
.../request/ConfigPhysicalPlanSerDeTest.java | 37 +-
.../request/write/RemoveDataNodePlanTest.java | 151 ++
.../balancer/region/GreedyRegionAllocatorTest.java | 88 ++
.../persistence/ClusterSchemaInfoTest.java | 49 +
.../confignode/persistence/PartitionInfoTest.java | 79 +-
.../multileader/client/DispatchLogHandler.java | 2 +
.../multileader/logdispatcher/IndexController.java | 11 -
.../multileader/logdispatcher/LogDispatcher.java | 11 +-
docs/Download/README.md | 34 +-
docs/UserGuide/API/Programming-Java-Native-API.md | 13 +-
.../Maintenance-Tools/Maintenance-Command.md | 56 +
.../Reference/ConfigNode-Config-Manual.md | 10 +
docs/zh/Download/README.md | 34 +-
.../UserGuide/API/Programming-Java-Native-API.md | 11 +
.../Maintenance-Tools/Maintenance-Command.md | 58 +
docs/zh/UserGuide/QuickStart/QuickStart.md | 4 +-
.../Reference/ConfigNode-Config-Manual.md | 9 +
.../main/java/org/apache/iotdb/SessionExample.java | 44 +-
.../apache/iotdb/session/IoTDBSessionSimpleIT.java | 57 +
.../iotdb/commons/enums/DataNodeRemoveState.java | 39 +-
.../iotdb/commons/enums/RegionMigrateState.java | 37 +-
.../service/AbstractThriftServiceThread.java | 4 +
.../apache/iotdb/commons/service/ServiceType.java | 1 +
.../schemaregion/rocksdb/mnode/RMNode.java | 10 +
.../resources/conf/iotdb-datanode.properties | 2 +-
.../apache/iotdb/db/client/ConfigNodeClient.java | 69 +
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 12 +-
.../org/apache/iotdb/db/conf/IoTDBStopCheck.java | 76 +
.../compaction/CompactionExceptionHandler.java | 5 -
.../db/engine/compaction/CompactionUtils.java | 4 +-
.../compaction/cross/CrossSpaceCompactionTask.java | 1 -
.../iotdb/db/engine/storagegroup/DataRegion.java | 13 +-
.../db/engine/storagegroup/TsFileResource.java | 15 +-
.../engine/storagegroup/TsFileResourceStatus.java | 3 +-
.../apache/iotdb/db/metadata/MetadataConstant.java | 3 +
.../idtable/entry/InsertMeasurementMNode.java | 10 +
.../org/apache/iotdb/db/metadata/mnode/IMNode.java | 4 +
.../iotdb/db/metadata/mnode/InternalMNode.java | 14 +
.../iotdb/db/metadata/mnode/MeasurementMNode.java | 15 +-
.../mtree/{MTreeAboveSG.java => ConfigMTree.java} | 160 ++-
.../db/metadata/schemaregion/SchemaEngine.java | 6 +-
.../storagegroup/StorageGroupSchemaManager.java | 6 +-
.../metadata/template/ClusterTemplateManager.java | 51 +
.../db/metadata/template/ITemplateManager.java | 17 +
.../iotdb/db/metadata/template/Template.java | 14 +-
.../iotdb/db/mpp/common/header/HeaderConstant.java | 6 +
.../iotdb/db/mpp/plan/analyze/AnalyzeVisitor.java | 1484 ++++++++++++++++++++
.../apache/iotdb/db/mpp/plan/analyze/Analyzer.java | 1450 +------------------
.../mpp/plan/analyze/ClusterPartitionFetcher.java | 610 ++------
.../db/mpp/plan/analyze/cache/PartitionCache.java | 786 +++++++++++
.../analyze/cache/StorageGroupCacheResult.java | 68 +
.../iotdb/db/mpp/plan/constant/StatementType.java | 2 +
.../plan/execution/config/ConfigTaskVisitor.java | 14 +
...emplateTask.java => SetSchemaTemplateTask.java} | 12 +-
...plateTask.java => ShowPathSetTemplateTask.java} | 42 +-
.../config/executor/ClusterConfigTaskExecutor.java | 48 +
.../config/executor/IConfigTaskExecutor.java | 8 +
.../executor/StandaloneConfigTaskExecutor.java | 26 +
.../iotdb/db/mpp/plan/parser/ASTVisitor.java | 36 +
.../db/mpp/plan/planner/LogicalPlanVisitor.java | 679 +++++++++
.../iotdb/db/mpp/plan/planner/LogicalPlanner.java | 655 ---------
.../scheduler/FixedRateFragInsStateTracker.java | 29 +-
.../scheduler/FragmentInstanceDispatcherImpl.java | 10 +-
.../db/mpp/plan/statement/StatementVisitor.java | 12 +
.../statement/metadata/ShowRegionStatement.java | 19 +-
...tement.java => SetSchemaTemplateStatement.java} | 33 +-
...ment.java => ShowPathSetTemplateStatement.java} | 16 +-
.../java/org/apache/iotdb/db/service/DataNode.java | 122 +-
.../iotdb/db/service/RegionMigrateService.java | 471 +++++++
.../service/thrift/impl/ClientRPCServiceImpl.java | 54 +-
.../impl/DataNodeInternalRPCServiceImpl.java | 217 ++-
.../db/tools/settle/TsFileAndModSettleTool.java | 3 -
.../apache/iotdb/db/conf/IoTDBStopCheckTest.java | 110 ++
.../inner/InnerSpaceCompactionExceptionTest.java | 3 -
...{MTreeAboveSGTest.java => ConfigMTreeTest.java} | 46 +-
.../iotdb/db/metadata/mtree/MTreeBelowSGTest.java | 4 +-
.../datanode1conf/iotdb-datanode.properties | 2 +-
.../datanode2conf/iotdb-datanode.properties | 2 +-
.../datanode3conf/iotdb-datanode.properties | 2 +-
.../java/org/apache/iotdb/rpc/TSStatusCode.java | 10 +-
.../apache/iotdb/session/SessionConnection.java | 84 +-
.../apache/iotdb/session/util/SessionUtils.java | 13 +-
thrift-commons/src/main/thrift/common.thrift | 8 +
.../src/main/thrift/confignode.thrift | 34 +
thrift/src/main/thrift/datanode.thrift | 57 +-
.../iotdb/tsfile/utils/ReadWriteIOUtils.java | 13 +
.../apache/iotdb/tsfile/write/record/Tablet.java | 8 +-
127 files changed, 8014 insertions(+), 3212 deletions(-)
copy confignode/src/main/java/org/apache/iotdb/confignode/{procedure/state/DeleteStorageGroupState.java => client/ConfigNodeRequestType.java} (81%)
copy confignode/src/main/java/org/apache/iotdb/confignode/{exception/NotEnoughDataNodeException.java => client/DataNodeRequestType.java} (78%)
copy confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/{write/DropFunctionPlan.java => read/GetPathsSetTemplatePlan.java} (69%)
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/RemoveDataNodePlan.java
copy confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/{DropFunctionPlan.java => SetSchemaTemplatePlan.java} (65%)
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/UpdateRegionLocationPlan.java
copy confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/{StorageGroupSchemaResp.java => DataNodeToStatusResp.java} (62%)
copy confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/{TemplateInfoResp.java => PathInfoResp.java} (77%)
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/manager/DataNodeRemoveManager.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/manager/load/balancer/region/GreedyRegionAllocator.java
create mode 100644 confignode/src/test/java/org/apache/iotdb/confignode/consensus/request/write/RemoveDataNodePlanTest.java
create mode 100644 confignode/src/test/java/org/apache/iotdb/confignode/manager/load/balancer/region/GreedyRegionAllocatorTest.java
copy server/src/main/java/org/apache/iotdb/db/wal/utils/WALFileStatus.java => node-commons/src/main/java/org/apache/iotdb/commons/enums/DataNodeRemoveState.java (60%)
copy server/src/main/java/org/apache/iotdb/db/wal/utils/WALFileStatus.java => node-commons/src/main/java/org/apache/iotdb/commons/enums/RegionMigrateState.java (60%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/conf/IoTDBStopCheck.java
rename server/src/main/java/org/apache/iotdb/db/metadata/mtree/{MTreeAboveSG.java => ConfigMTree.java} (82%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/plan/analyze/AnalyzeVisitor.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/plan/analyze/cache/PartitionCache.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/plan/analyze/cache/StorageGroupCacheResult.java
copy server/src/main/java/org/apache/iotdb/db/mpp/plan/execution/config/{CreateSchemaTemplateTask.java => SetSchemaTemplateTask.java} (74%)
copy server/src/main/java/org/apache/iotdb/db/mpp/plan/execution/config/{ShowSchemaTemplateTask.java => ShowPathSetTemplateTask.java} (61%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/LogicalPlanVisitor.java
copy server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/metadata/template/{ShowNodesInSchemaTemplateStatement.java => SetSchemaTemplateStatement.java} (65%)
copy server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/metadata/template/{ShowNodesInSchemaTemplateStatement.java => ShowPathSetTemplateStatement.java} (84%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/service/RegionMigrateService.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/conf/IoTDBStopCheckTest.java
rename server/src/test/java/org/apache/iotdb/db/metadata/mtree/{MTreeAboveSGTest.java => ConfigMTreeTest.java} (92%)