You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by hu...@apache.org on 2022/10/26 02:13:48 UTC
[iotdb] branch lmh/intoOperator updated (943d67c915 -> 2dc4440864)
This is an automated email from the ASF dual-hosted git repository.
hui pushed a change to branch lmh/intoOperator
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 943d67c915 Merge remote-tracking branch 'origin/master' into lmh/intoOperator
add 6d4173ebb6 [IOTDB-4720] Refactor UDFExecutableManager for new UDF management
add fcfe89a51b [RatisConsensus] fix conf name
add cbc622573f [IOTDB-4664] add updatePeer interface in IConsensus (#7634)
add c416f43d6c Add MLogLoad-Tool document to website config (#7715)
add b0263f0c57 Update IoTDB nifi process doc (#7637)
add 2bcb19da0c [IOTDB-4678] Sync DataNode start-up process (#7691)
add fb6568790b [IOTDB-4692] SchemaFile adaptation for cluster metadata validation (#7658)
add eb051006ba Lowering Partition related logs' level (#7714)
add 6f27466c9a Use 1c1d docker to run go client IT (#7718)
add 82253fa242 [IOTDB-4734] Modify create function grammar and process (#7719)
add 8c2b803ce4 Rerun a new query execution thread while previous one is interrupted (#7722)
add 8a68f3a8ce [IOTDB-4751] Fix GROUP BY TAGS being without any error message (#7720)
add 1dc78a0c0e Merge remote-tracking branch 'origin/master' into lmh/intoOperator
add 2dc4440864 fix review
No new revisions were added by this update.
Summary of changes:
.github/workflows/client-go.yml | 2 +-
.../org/apache/iotdb/db/qp/sql/IoTDBSqlParser.g4 | 4 +-
client-go | 2 +-
.../client/async/AsyncDataNodeClientPool.java | 8 +-
.../confignode/conf/ConfigNodeDescriptor.java | 2 +-
.../iotdb/confignode/manager/ConfigManager.java | 24 ++-
.../apache/iotdb/confignode/manager/IManager.java | 8 +
.../iotdb/confignode/manager/SyncManager.java | 30 ++-
.../iotdb/confignode/manager/UDFManager.java | 16 +-
.../iotdb/confignode/persistence/UDFInfo.java | 7 +-
.../persistence/sync/ClusterSyncInfo.java | 25 +++
.../impl/sync/AbstractOperatePipeProcedure.java | 3 +
.../procedure/impl/sync/CreatePipeProcedure.java | 1 +
.../procedure/impl/sync/DropPipeProcedure.java | 5 +-
.../procedure/impl/sync/StartPipeProcedure.java | 4 +-
.../procedure/impl/sync/StopPipeProcedure.java | 4 +-
.../iotdb/confignode/service/ConfigNode.java | 3 -
.../thrift/ConfigNodeRPCServiceProcessor.java | 10 +-
.../org/apache/iotdb/consensus/IConsensus.java | 10 +
.../multileader/MultiLeaderConsensus.java | 5 +
.../iotdb/consensus/ratis/RatisConsensus.java | 5 +
.../consensus/standalone/StandAloneConsensus.java | 5 +
docs/UserGuide/Ecosystem-Integration/NiFi-IoTDB.md | 56 +++--
.../UserGuide/Ecosystem-Integration/NiFi-IoTDB.md | 53 +++--
.../java/org/apache/iotdb/it/env/MppConfig.java | 6 +
.../org/apache/iotdb/itbase/env/BaseConfig.java | 8 +
.../org/apache/iotdb/db/it/IoTDBNestedQueryIT.java | 8 +-
.../db/it/IoTDBSyntaxConventionIdentifierIT.java | 3 +
.../it/IoTDBSyntaxConventionStringLiteralIT.java | 5 +
.../db/it/aggregation/IoTDBTagAggregationIT.java | 16 ++
.../iotdb/db/it/env/StandaloneEnvConfig.java | 11 +
.../it/schema/IoTDBMetadataFetchSchemaFileIT.java | 25 ++-
.../iotdb/db/it/udf/IoTDBUDFManagementIT.java | 3 +
.../db/it/udf/IoTDBUDFOtherWindowQueryIT.java | 3 +
.../iotdb/db/it/udf/IoTDBUDFWindowQueryIT.java | 2 +
.../db/it/udf/IoTDBUDTFAlignByTimeQueryIT.java | 3 +
.../db/it/udf/IoTDBUDTFBuiltinFunctionIT.java | 3 +
.../iotdb/db/it/udf/IoTDBUDTFHybridQueryIT.java | 2 +
.../iotdb/db/it/udf/IoTDBUDTFNonAlignQueryIT.java | 2 +
node-commons/pom.xml | 5 +
.../apache/iotdb/commons/service/ServiceType.java | 1 -
.../apache/iotdb/commons/udf/UDFInformation.java | 83 ++++++--
.../org/apache/iotdb/commons/udf/UDFTable.java | 20 ++
.../iotdb/commons/udf/service/SnapshotUtils.java | 96 ---------
.../commons/udf/service/UDFExecutableManager.java | 85 +++-----
.../iotdb/commons/udf/service/UDFLogWriter.java | 83 --------
.../commons/udf/service/UDFManagementService.java | 146 ++++++++-----
.../apache/iotdb/db/client/ConfigNodeClient.java | 17 ++
.../iotdb/db/client/DataNodeInternalClient.java | 4 +-
.../iotdb/db/metadata/mtree/IMTreeBelowSG.java | 36 ++++
.../db/metadata/mtree/MTreeBelowSGCachedImpl.java | 100 +++++++++
.../db/metadata/mtree/MTreeBelowSGMemoryImpl.java | 3 +
.../iotdb/db/metadata/mtree/store/IMTreeStore.java | 14 ++
.../schemaregion/SchemaRegionSchemaFileImpl.java | 6 +-
.../operator/process/DeviceViewIntoOperator.java | 2 +-
.../execution/operator/process/IntoOperator.java | 2 +-
.../execution/schedule/AbstractDriverThread.java | 60 ++++--
.../db/mpp/execution/schedule/DriverScheduler.java | 38 +++-
.../mpp/execution/schedule/DriverTaskThread.java | 5 +-
.../schedule/DriverTaskTimeoutSentinelThread.java | 5 +-
.../db/mpp/execution/schedule/ThreadProducer.java | 14 +-
.../iotdb/db/mpp/plan/analyze/AnalyzeVisitor.java | 8 +-
.../config/executor/ClusterConfigTaskExecutor.java | 88 +++++++-
.../config/executor/IConfigTaskExecutor.java | 6 +-
.../executor/StandaloneConfigTaskExecutor.java | 9 +-
.../config/metadata/CreateFunctionTask.java | 15 +-
.../config/metadata/ShowFunctionsTask.java | 8 +-
.../iotdb/db/mpp/plan/parser/ASTVisitor.java | 59 +++---
.../db/mpp/plan/statement/crud/QueryStatement.java | 19 +-
.../metadata/CreateFunctionStatement.java | 21 +-
.../apache/iotdb/db/qp/executor/PlanExecutor.java | 16 +-
.../java/org/apache/iotdb/db/service/DataNode.java | 18 +-
.../impl/DataNodeInternalRPCServiceImpl.java | 24 +--
.../java/org/apache/iotdb/db/sync/SyncService.java | 45 +++-
.../db/sync/common/ClusterSyncInfoFetcher.java | 14 +-
.../trigger/service/TriggerManagementService.java | 18 +-
.../schemaRegion/SchemaRegionBasicTest.java | 231 +++++++++++++++++++++
...gionTest.java => SchemaRegionSnapshotTest.java} | 2 +-
.../multimode/SchemaRegionFullMemoryTest.java} | 17 +-
.../multimode/SchemaRegionMemoryTest.java} | 20 +-
.../multimode/SchemaRegionNonMemoryTest.java} | 17 +-
.../multimode/SchemaRegionPartialMemoryTest.java} | 17 +-
.../multimode/SchemaRegionSchemaFileTest.java} | 20 +-
.../DriverTaskTimeoutSentinelThreadTest.java | 23 +-
.../iotdb/db/mpp/plan/plan/LogicalPlannerTest.java | 40 ++++
.../iotdb/db/qp/physical/PhysicalPlanTest.java | 2 +
.../query/dataset/UDTFAlignByTimeDataSetTest.java | 2 +
.../java/org/apache/iotdb/rpc/TSStatusCode.java | 5 +
site/src/main/.vuepress/config.js | 4 +-
.../src/main/thrift/confignode.thrift | 12 +-
thrift/src/main/thrift/datanode.thrift | 13 +-
91 files changed, 1433 insertions(+), 577 deletions(-)
copy server/src/test/java/org/apache/iotdb/db/wal/buffer/WALBufferTest.java => integration-test/src/test/java/org/apache/iotdb/db/it/schema/IoTDBMetadataFetchSchemaFileIT.java (52%)
delete mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/udf/service/SnapshotUtils.java
delete mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/udf/service/UDFLogWriter.java
copy node-commons/src/main/java/org/apache/iotdb/commons/service/StartupCheck.java => server/src/main/java/org/apache/iotdb/db/mpp/execution/schedule/ThreadProducer.java (68%)
create mode 100644 server/src/test/java/org/apache/iotdb/db/metadata/schemaRegion/SchemaRegionBasicTest.java
rename server/src/test/java/org/apache/iotdb/db/metadata/schemaRegion/{SchemaRegionTest.java => SchemaRegionSnapshotTest.java} (99%)
copy server/src/test/java/org/apache/iotdb/db/{wal/buffer/WALBufferTest.java => metadata/schemaRegion/multimode/SchemaRegionFullMemoryTest.java} (62%)
copy server/src/test/java/org/apache/iotdb/db/{wal/buffer/WALBufferTest.java => metadata/schemaRegion/multimode/SchemaRegionMemoryTest.java} (60%)
copy server/src/test/java/org/apache/iotdb/db/{wal/buffer/WALBufferTest.java => metadata/schemaRegion/multimode/SchemaRegionNonMemoryTest.java} (62%)
copy server/src/test/java/org/apache/iotdb/db/{wal/buffer/WALBufferTest.java => metadata/schemaRegion/multimode/SchemaRegionPartialMemoryTest.java} (62%)
copy server/src/test/java/org/apache/iotdb/db/{wal/buffer/WALBufferTest.java => metadata/schemaRegion/multimode/SchemaRegionSchemaFileTest.java} (59%)