This is an automated email from the ASF dual-hosted git repository.
jiangtian pushed a change to branch force_ci/support_schema_evolution
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from e46b91d193c spotss
add 78c1f492b60 Include the TSStatus code in Mqtt's error logs to
facilitate troubleshooting. (#17037)
add 31a07eaeb60 Pipe: Trimmed the unnecessary device getting for
historical tsFiles (#17036)
add 50c6183a8ac sesion cpp ssl (#16968)
add f74a7dcbcd3 Fix mods name of target files in settle compaction (#17043)
add d74fca109dc Repair the problem that accumulate index used
chunkMetadataList (#17040)
add a5f87298a55 [AINode] Fix the AINode cannot stop by script (#17045)
add ec9bd0d6da0 fix session cpp node-supplier (#17039)
add 2471938c505 Pipe: Fixed the semantic of reporting interval && Trimmed
the "toString" of InsertMultiTabletsStatement (#17044)
add dce185a745b Decouple mqtt from iotdb-server using ExternalService
framework (#17042)
add d8a0a5abda8 [AINode] Optimize model loading (#17046)
add 650cc085396 remove some useless code (#17047)
add 1befb1b4fe5 Pipe: disable multiple path and path exclusion (#17038)
add 8aef1952c31 Remove some method implementations related to the object
type (#17054)
add 56097ac5b2f Fix data export logic to avoid redundant high frequency
query (#17049)
add 36dadf5d965 Upper case data type from SQL statement, and add a
validation for non exist data type. (#17057)
add f4e8521f021 Fix the problem that "StateMachineProceduree not set next
state, but return HAS_MORE_STATE". (#17058)
add f198b8e4718 Change default dn rpc address (#17060)
add 6eeb91b7666 Fix the problem that fault a Exception named
"java.nio.BufferUnderflowException" when AlterTimeSeriesDataTypeProcedure
deserialize (#17062)
add 129c0d61c3f Pipe: Fixed the missing privilege check of aligned series
in tsFile scan parser & Fixed the missed parsing of insertNode privilege
(#17055)
add 5101489d412 Optimized the logger when table does not exist in DN
heartbeat && Pipe: Fixed the OPC UA Sink key getter logic and potentail NPE
when closing client && Load: Fixed the missing schema writing for "root" table
(#17063)
add 46a4ba26ed7 Fix cannot find Formatter when put mqtt-dependency-jar in
ext folder #17066
add f5470e848e1 [AINode] More accurate exceptions (#17061)
add f7589ab4d41 Fix memory init bug and ddl overflow bug (#17071)
add c39abcb8671 Integrate window function optimization rules into IoTDB
(#16953)
add b0495da2d6a fix last query bug #17073
add c52ae09c8a3 Merge branch 'master' into
force_ci/support_schema_evolution
No new revisions were added by this update.
Summary of changes:
.github/workflows/multi-language-client.yml | 13 +-
distribution/pom.xml | 8 +
distribution/src/assembly/all.xml | 4 +
distribution/src/assembly/datanode.xml | 6 +
...{common-files.xml => external-service-impl.xml} | 21 +-
example/client-cpp-example/src/CMakeLists.txt | 64 +-
example/mqtt-customize/pom.xml | 6 +-
.../server/CustomizedJsonPayloadFormatter.java | 6 +-
...Formatter => org.apache.iotdb.PayloadFormatter} | 0
external-service-impl/mqtt/pom.xml | 177 +
.../apache/iotdb}/mqtt/BrokerAuthenticator.java | 2 +-
.../apache/iotdb}/mqtt/JSONPayloadFormatter.java | 2 +-
.../apache/iotdb}/mqtt/LinePayloadFormatter.java | 2 +-
.../org/apache/iotdb}/mqtt/MPPPublishHandler.java | 9 +-
.../java/org/apache/iotdb/mqtt}/MQTTService.java | 28 +-
.../main/java/org/apache/iotdb}/mqtt/Message.java | 2 +-
.../apache/iotdb}/mqtt/PayloadFormatManager.java | 5 +-
.../org/apache/iotdb}/mqtt/PayloadFormatter.java | 2 +-
.../java/org/apache/iotdb}/mqtt/TableMessage.java | 2 +-
.../java/org/apache/iotdb}/mqtt/TreeMessage.java | 2 +-
.../org.apache.iotdb.mqtt.PayloadFormatter | 3 +-
.../iotdb}/mqtt/BrokerAuthenticatorTest.java | 18 +-
.../iotdb}/mqtt/JSONPayloadFormatterTest.java | 3 +-
.../iotdb}/mqtt/LinePayloadFormatterTest.java | 3 +-
.../iotdb}/mqtt/PayloadFormatManagerTest.java | 8 +-
{example/jdbc => external-service-impl}/pom.xml | 28 +-
integration-test/pom.xml | 12 +
integration-test/src/assembly/mpp-share.xml | 6 +
.../apache/iotdb/ainode/it/AINodeForecastIT.java | 21 +-
.../ainode/it/AINodeInstanceManagementIT.java | 8 +
.../db/it/last/IoTDBLastQueryLastCacheIT.java | 42 +
.../db/it/schema/IoTDBAlterTimeSeriesTypeIT.java | 16 +
.../auto/basic/IoTDBTreePatternFormatIT.java | 13 +
.../treemodel/manual/IoTDBPipeInclusionIT.java | 3 +
.../treemodel/manual/IoTDBPipePermissionIT.java | 14 +
.../iotdb/pipe/it/single/IoTDBPipeOPCUAIT.java | 8 +-
.../it/db/it/IoTDBWindowFunction3IT.java | 179 +
.../api/customizer/parameter/PipeParameters.java | 23 +-
.../customizer/parameter/PipeParametersTest.java | 6 +-
.../org/apache/iotdb/tool/data/ExportDataTree.java | 221 +-
iotdb-client/client-cpp/pom.xml | 34 +-
.../client-cpp/src/main/AbstractSessionBuilder.h | 39 +-
iotdb-client/client-cpp/src/main/CMakeLists.txt | 16 +-
iotdb-client/client-cpp/src/main/NodesSupplier.cpp | 73 +-
iotdb-client/client-cpp/src/main/NodesSupplier.h | 34 +-
iotdb-client/client-cpp/src/main/Session.cpp | 2 +-
iotdb-client/client-cpp/src/main/Session.h | 4 +
iotdb-client/client-cpp/src/main/SessionBuilder.h | 15 +
.../client-cpp/src/main/SessionConnection.cpp | 20 +-
.../client-cpp/src/main/SessionConnection.h | 5 +-
.../client-cpp/src/main/TableSessionBuilder.h | 15 +
.../client-cpp/src/main/ThriftConnection.cpp | 16 +-
.../client-cpp/src/main/ThriftConnection.h | 6 +-
iotdb-client/client-cpp/src/test/CMakeLists.txt | 42 +-
iotdb-client/client-cpp/src/test/catch2/catch.hpp | 17974 +++++++++++++++++++
iotdb-client/client-cpp/src/test/main.cpp | 15 +-
.../client-py/iotdb/tsfile/utils/tsblock_serde.py | 1 -
iotdb-core/ainode/iotdb/ainode/core/constant.py | 2 +
.../iotdb/ainode/core/inference/pool_controller.py | 11 +
.../iotdb/ainode/core/manager/inference_manager.py | 8 +-
iotdb-core/ainode/iotdb/ainode/core/rpc/handler.py | 10 +
iotdb-core/ainode/iotdb/ainode/core/rpc/service.py | 12 +-
.../pipe/agent/task/PipeConfigNodeSubtask.java | 27 +-
.../schema/AlterTimeSeriesDataTypeProcedure.java | 7 +-
...a => AlterTimeSeriesDataTypeProcedureTest.java} | 35 +-
iotdb-core/datanode/pom.xml | 12 -
.../org/apache/iotdb/db/auth/AuthorityChecker.java | 2 +
.../apache/iotdb/db/conf/DataNodeMemoryConfig.java | 17 +-
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 2 +-
.../dataregion/DataExecutionVisitor.java | 9 +-
...ception.java => AINodeConnectionException.java} | 14 +-
.../db/pipe/agent/task/PipeDataNodeTaskAgent.java | 6 +-
.../subtask/processor/PipeProcessorSubtask.java | 8 +-
.../agent/task/subtask/sink/PipeSinkSubtask.java | 40 +-
.../common/deletion/PipeDeleteDataNodeEvent.java | 1 +
.../tablet/PipeInsertNodeTabletInsertionEvent.java | 15 +-
.../scan/TsFileInsertionEventScanParser.java | 157 +-
.../protocol/thrift/IoTDBDataNodeReceiver.java | 2 +-
.../protocol/opcua/client/IoTDBOpcUaClient.java | 4 +-
.../sink/protocol/writeback/WriteBackSink.java | 2 +-
...istoricalDataRegionTsFileAndDeletionSource.java | 24 +-
.../impl/DataNodeInternalRPCServiceImpl.java | 8 -
.../queryengine/execution/QueryStateMachine.java | 2 +-
.../execution/executor/RegionReadExecutor.java | 4 +-
.../fragment/FragmentInstanceContext.java | 2 +-
.../execution/operator/GroupedTopNBuilder.java} | 14 +-
.../operator/GroupedTopNRowNumberAccumulator.java | 483 +
.../operator/GroupedTopNRowNumberBuilder.java | 182 +
.../queryengine/execution/operator/IdRegistry.java | 76 +
.../operator/RowIdComparisonStrategy.java} | 7 +-
.../execution/operator/RowIdHashStrategy.java} | 10 +-
.../operator/RowReference.java} | 37 +-
.../operator/RowReferenceTsBlockManager.java | 386 +
.../SimpleTsBlockWithPositionComparator.java | 52 +
.../operator/TsBlockWithPositionComparator.java} | 9 +-
.../{ProjectOperator.java => ValuesOperator.java} | 67 +-
.../operator/process/ai/InferenceOperator.java | 7 +-
.../operator/process/function/partition/Slice.java | 6 +-
.../operator/process/last/LastQueryOperator.java | 6 +-
.../operator/process/window/RowNumberOperator.java | 214 +
.../process/window/TopKRankingOperator.java | 278 +
.../relational/aggregation/RecordIterator.java | 6 +-
.../grouped/array/IntArrayFIFOQueue.java | 201 +
.../grouped/array/LongBigArrayFIFOQueue.java | 197 +
.../grouped/hash/NoChannelGroupByHash.java | 72 +
.../execution/schedule/AbstractDriverThread.java | 4 +-
.../execution/schedule/task/DriverTask.java | 12 +-
.../queryengine/plan/execution/QueryExecution.java | 2 +-
.../config/executor/ClusterConfigTaskExecutor.java | 31 +-
.../db/queryengine/plan/parser/ASTVisitor.java | 27 +-
.../plan/planner/TableOperatorGenerator.java | 129 +
.../plan/planner/plan/node/PlanGraphPrinter.java | 42 +
.../plan/planner/plan/node/PlanNodeType.java | 12 +
.../plan/planner/plan/node/PlanVisitor.java | 16 +
.../plan/node/write/RelationalInsertRowsNode.java | 43 -
.../node/write/RelationalInsertTabletNode.java | 51 -
.../function/tvf/ClassifyTableFunction.java | 10 +-
.../function/tvf/ForecastTableFunction.java | 10 +-
.../distribute/TableDistributedPlanGenerator.java | 70 +
.../iterative/rule/GatherAndMergeWindows.java | 333 +
.../iterative/rule/PushDownFilterIntoWindow.java | 166 +
.../iterative/rule/PushDownLimitIntoWindow.java | 100 +
...urceColumns.java => RemoveRedundantWindow.java} | 28 +-
.../iterative/rule/ReplaceWindowWithRowNumber.java | 72 +
.../relational/planner/iterative/rule/Util.java | 45 +-
.../plan/relational/planner/node/Patterns.java | 20 +-
.../relational/planner/node/RowNumberNode.java | 215 +
.../relational/planner/node/TopKRankingNode.java | 208 +
.../plan/relational/planner/node/ValuesNode.java | 236 +
.../plan/relational/planner/node/WindowNode.java | 4 +
.../optimizations/LogicalOptimizeFactory.java | 16 +-
.../planner/optimizations/SymbolMapper.java | 33 +-
.../optimizations/UnaliasSymbolReferences.java | 24 +
.../crud/InsertMultiTabletsStatement.java | 6 +-
.../db/queryengine/plan/udf/UDTFForecast.java | 8 +-
.../apache/iotdb/db/schemaengine/SchemaEngine.java | 12 +-
.../schemaregion/utils/ResourceByPathUtils.java | 54 +-
.../java/org/apache/iotdb/db/service/DataNode.java | 16 +-
.../externalservice/BuiltinExternalServices.java | 9 +-
.../ExternalServiceManagementService.java | 56 +-
.../db/storageengine/dataregion/DataRegion.java | 56 -
.../dataregion/modification/ModificationFile.java | 12 +-
.../db/storageengine/load/LoadTsFileManager.java | 6 +-
.../apache/iotdb/db/utils/ErrorHandlingUtils.java | 14 +-
.../org/apache/iotdb/db/utils/HeapTraversal.java | 64 +
.../org/apache/iotdb/db/utils/ObjectTypeUtils.java | 61 +-
....apache.iotdb.db.protocol.mqtt.PayloadFormatter | 21 -
.../pipe/event/PipeTsFileInsertionEventTest.java | 3 +
.../pipe/event/TsFileInsertionEventParserTest.java | 4 +-
.../db/pipe/pattern/TreePatternPruningTest.java | 2 +
.../db/pipe/source/IoTDBDataRegionSourceTest.java | 2 +
.../planner/WindowFunctionOptimizationTest.java | 300 +
.../planner/assertions/PlanMatchPattern.java | 38 +
...TopKMatcher.java => WindowFunctionMatcher.java} | 55 +-
.../settle/SettleCompactionTaskTest.java | 32 +
.../resources/conf/iotdb-system.properties | 2 +-
.../conf/iotdb-system.properties.template | 2 +-
.../iotdb/commons/auth/entity/TablePrivilege.java | 3 +
.../commons/exception/ObjectFileNotExist.java | 6 +-
.../exception/pipe/PipeNonReportException.java | 27 -
...imeSinkNonReportTimeConfigurableException.java} | 40 +-
...RuntimeSinkRetryTimesConfigurableException.java | 27 +-
.../task/subtask/PipeAbstractSinkSubtask.java | 52 +
.../pipe/config/constant/SystemConstant.java | 2 +-
.../datastructure/pattern/IoTDBTreePattern.java | 5 +
.../datastructure/pattern/PrefixTreePattern.java | 5 +
.../pipe/datastructure/pattern/TreePattern.java | 18 +
.../pattern/UnionIoTDBTreePattern.java | 5 +
.../datastructure/pattern/UnionTreePattern.java | 5 +
.../pattern/WithExclusionIoTDBTreePattern.java | 5 +
.../pattern/WithExclusionTreePattern.java | 5 +
.../iotdb/commons/pipe/event/EnrichedEvent.java | 5 +
.../pipe/receiver/PipeReceiverStatusHandler.java | 36 +-
.../apache/iotdb/commons/service/ServiceType.java | 1 -
.../commons/utils/ErrorHandlingCommonUtils.java} | 14 +-
.../src/main/thrift/datanode.thrift | 8 -
pom.xml | 1 +
177 files changed, 24008 insertions(+), 1116 deletions(-)
copy distribution/src/assembly/{common-files.xml => external-service-impl.xml}
(71%)
copy
example/mqtt-customize/src/main/resources/META-INF/services/{org.apache.iotdb.db.protocol.mqtt.PayloadFormatter
=> org.apache.iotdb.PayloadFormatter} (100%)
create mode 100644 external-service-impl/mqtt/pom.xml
rename {iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol =>
external-service-impl/mqtt/src/main/java/org/apache/iotdb}/mqtt/BrokerAuthenticator.java
(97%)
rename {iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol =>
external-service-impl/mqtt/src/main/java/org/apache/iotdb}/mqtt/JSONPayloadFormatter.java
(99%)
rename {iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol =>
external-service-impl/mqtt/src/main/java/org/apache/iotdb}/mqtt/LinePayloadFormatter.java
(99%)
rename {iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol =>
external-service-impl/mqtt/src/main/java/org/apache/iotdb}/mqtt/MPPPublishHandler.java
(98%)
rename {iotdb-core/datanode/src/main/java/org/apache/iotdb/db/service =>
external-service-impl/mqtt/src/main/java/org/apache/iotdb/mqtt}/MQTTService.java
(84%)
rename {iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol =>
external-service-impl/mqtt/src/main/java/org/apache/iotdb}/mqtt/Message.java
(96%)
rename {iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol =>
external-service-impl/mqtt/src/main/java/org/apache/iotdb}/mqtt/PayloadFormatManager.java
(96%)
rename {iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol =>
external-service-impl/mqtt/src/main/java/org/apache/iotdb}/mqtt/PayloadFormatter.java
(97%)
rename {iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol =>
external-service-impl/mqtt/src/main/java/org/apache/iotdb}/mqtt/TableMessage.java
(98%)
rename {iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol =>
external-service-impl/mqtt/src/main/java/org/apache/iotdb}/mqtt/TreeMessage.java
(97%)
rename
example/mqtt-customize/src/main/resources/META-INF/services/org.apache.iotdb.db.protocol.mqtt.PayloadFormatter
=>
external-service-impl/mqtt/src/main/resources/META-INF/services/org.apache.iotdb.mqtt.PayloadFormatter
(90%)
rename {iotdb-core/datanode/src/test/java/org/apache/iotdb/db/protocol =>
external-service-impl/mqtt/src/test/java/org/apache/iotdb}/mqtt/BrokerAuthenticatorTest.java
(77%)
rename {iotdb-core/datanode/src/test/java/org/apache/iotdb/db/protocol =>
external-service-impl/mqtt/src/test/java/org/apache/iotdb}/mqtt/JSONPayloadFormatterTest.java
(99%)
rename {iotdb-core/datanode/src/test/java/org/apache/iotdb/db/protocol =>
external-service-impl/mqtt/src/test/java/org/apache/iotdb}/mqtt/LinePayloadFormatterTest.java
(98%)
rename {iotdb-core/datanode/src/test/java/org/apache/iotdb/db/protocol =>
external-service-impl/mqtt/src/test/java/org/apache/iotdb}/mqtt/PayloadFormatManagerTest.java
(84%)
copy {example/jdbc => external-service-impl}/pom.xml (71%)
create mode 100644
integration-test/src/test/java/org/apache/iotdb/relational/it/db/it/IoTDBWindowFunction3IT.java
create mode 100644 iotdb-client/client-cpp/src/test/catch2/catch.hpp
copy
iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/procedure/impl/schema/{DeleteTimeSeriesProcedureTest.java
=> AlterTimeSeriesDataTypeProcedureTest.java} (61%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/exception/ainode/{ModelException.java
=> AINodeConnectionException.java} (69%)
copy
iotdb-core/{metrics/core/src/main/java/org/apache/iotdb/metrics/core/type/IoTDBRateMBean.java
=>
datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/GroupedTopNBuilder.java}
(74%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/GroupedTopNRowNumberAccumulator.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/GroupedTopNRowNumberBuilder.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/IdRegistry.java
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/{plan/analyze/cache/schema/dualkeycache/impl/DualKeyCachePolicy.java
=> execution/operator/RowIdComparisonStrategy.java} (84%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{exception/runtime/MemoryLeakException.java
=> queryengine/execution/operator/RowIdHashStrategy.java} (78%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/{plan/analyze/cache/schema/dualkeycache/IDualKeyCacheStats.java
=> execution/operator/RowReference.java} (50%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/RowReferenceTsBlockManager.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/SimpleTsBlockWithPositionComparator.java
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{exception/runtime/MemoryLeakException.java
=> queryengine/execution/operator/TsBlockWithPositionComparator.java} (76%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/process/{ProjectOperator.java
=> ValuesOperator.java} (60%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/process/window/RowNumberOperator.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/process/window/TopKRankingOperator.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/relational/aggregation/grouped/array/IntArrayFIFOQueue.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/relational/aggregation/grouped/array/LongBigArrayFIFOQueue.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/relational/aggregation/grouped/hash/NoChannelGroupByHash.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/planner/iterative/rule/GatherAndMergeWindows.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/planner/iterative/rule/PushDownFilterIntoWindow.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/planner/iterative/rule/PushDownLimitIntoWindow.java
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/planner/iterative/rule/{PruneOutputSourceColumns.java
=> RemoveRedundantWindow.java} (66%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/planner/iterative/rule/ReplaceWindowWithRowNumber.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/planner/node/RowNumberNode.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/planner/node/TopKRankingNode.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/planner/node/ValuesNode.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/utils/HeapTraversal.java
delete mode 100644
iotdb-core/datanode/src/main/resources/META-INF/services/org.apache.iotdb.db.protocol.mqtt.PayloadFormatter
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/relational/planner/WindowFunctionOptimizationTest.java
copy
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/relational/planner/assertions/{TopKMatcher.java
=> WindowFunctionMatcher.java} (59%)
delete mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/exception/pipe/PipeNonReportException.java
copy
iotdb-core/{datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/function/LongVariableConstraint.java
=>
node-commons/src/main/java/org/apache/iotdb/commons/exception/pipe/PipeRuntimeSinkNonReportTimeConfigurableException.java}
(54%)
copy
iotdb-core/{datanode/src/main/java/org/apache/iotdb/db/exception/runtime/MemoryLeakException.java
=>
node-commons/src/main/java/org/apache/iotdb/commons/utils/ErrorHandlingCommonUtils.java}
(74%)
