This is an automated email from the ASF dual-hosted git repository.
jackietien pushed a change to branch object_type
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from cb9ea5056b6 Add VirtualFilePath and Path Generation
add 7800de6ad0d Correct the memroy calculation of BinaryColumnBuilder
add c5009f3ad61 Fix dead lock when take snapshot for Trigger and UDF
add 4cc6085e35c Pipe: Fix the error of Client object returning to object
pool after file transfer is completed (#15883)
add acaa72d703b Try delete sort tmp after driver is closed
add 57f22e770b1 [AINode] Fix the bug that the built-in model be deleted
(#15888)
add a10e2132d80 Fixed the NPE caused by view permission check
add 0a0ec3fb176 [AINode] Fix model management bugs (#15890)
add 966cfc73348 Change ErrorCode from 305 to 701 if there is no from clause
add 0fce0ccfdb0 Update tsfile version & add table view query it
add 309f205859d Update Release info after 2.0.4 released (#15898)
add 1ad56c78138 Pipe: Enabled waiting for pipes to finish & progress index
persist to config node in shutdown hook (#15896)
add 14b4382ff44 [AINode]Fix the parameter "predict_length" (#15900)
add 4be53debee7 Fix potential memory leak of Memory Pool
add 9042a0d2c43 Pipe: Reduced the progress index report interval & Added
some logs (#15905)
add e6bc39f4da5 Add more checkpoints in series scan
new 7d6fcfde35b resolve conflicts
The 1 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:
RELEASE_NOTES.md | 22 +++++
...reamIT.java => IoTDBConfigNodeSnapshot2IT.java} | 29 ++----
.../confignode/it/IoTDBConfigNodeSnapshotIT.java | 5 +-
.../db/it/IoTDBMultiTAGsWithAttributesTableIT.java | 8 +-
.../view/recent/IoTDBNullValueTableViewIT.java | 14 ++-
iotdb-core/ainode/ainode/core/config.py | 3 +-
iotdb-core/ainode/ainode/core/constant.py | 3 +
iotdb-core/ainode/ainode/core/exception.py | 5 +
iotdb-core/ainode/ainode/core/handler.py | 5 +-
.../ainode/core/manager/inference_manager.py | 8 +-
.../ainode/ainode/core/manager/model_manager.py | 9 +-
.../ainode/core/model/built_in_model_factory.py | 2 +-
.../ainode/ainode/core/model/model_storage.py | 103 +++++++++++++++------
.../core/model/sundial/ts_generation_mixin.py | 5 +
.../rpc/DataNodeAsyncRequestRPCHandler.java | 2 +-
.../handlers/rpc/PipeHeartbeatRPCHandler.java | 2 +-
.../iotdb/confignode/manager/ConfigManager.java | 18 ++++
.../apache/iotdb/confignode/manager/IManager.java | 3 +
.../iotdb/confignode/manager/ModelManager.java | 7 +-
.../pipe/agent/task/PipeConfigNodeTaskAgent.java | 22 ++---
.../runtime/heartbeat/PipeHeartbeatScheduler.java | 2 +-
.../iotdb/confignode/persistence/TriggerInfo.java | 3 -
.../iotdb/confignode/persistence/UDFInfo.java | 3 -
.../procedure/impl/model/DropModelProcedure.java | 57 ++++++------
.../thrift/ConfigNodeRPCServiceProcessor.java | 6 ++
.../db/pipe/agent/task/PipeDataNodeTaskAgent.java | 85 +++++++++++------
.../subtask/processor/PipeProcessorSubtask.java | 4 +-
.../async/IoTDBDataRegionAsyncConnector.java | 2 +-
.../event/common/heartbeat/PipeHeartbeatEvent.java | 6 +-
.../statement/PipeStatementInsertionEvent.java | 6 +-
.../tablet/PipeInsertNodeTabletInsertionEvent.java | 6 +-
.../common/tablet/PipeRawTabletInsertionEvent.java | 6 +-
.../common/tsfile/PipeTsFileInsertionEvent.java | 6 +-
.../dataregion/IoTDBDataRegionExtractor.java | 4 +-
.../PipeRealtimeDataRegionHybridExtractor.java | 5 +-
.../schemaregion/IoTDBSchemaRegionExtractor.java | 4 +-
.../iotdb/db/pipe/metric/PipeDataNodeMetrics.java | 6 +-
.../PipeDataNodeRemainingEventAndTimeOperator.java | 18 +++-
...ics.java => PipeDataNodeSinglePipeMetrics.java} | 15 ++-
.../iotdb/db/protocol/client/ConfigNodeClient.java | 8 ++
.../impl/DataNodeInternalRPCServiceImpl.java | 2 +-
.../execution/exchange/SharedTsBlockQueue.java | 2 +-
.../queryengine/execution/exchange/sink/ISink.java | 4 +-
.../execution/exchange/sink/LocalSinkChannel.java | 14 +--
.../execution/exchange/sink/ShuffleSinkHandle.java | 40 +++++---
.../execution/exchange/sink/SinkChannel.java | 10 +-
.../fragment/FragmentInstanceExecution.java | 44 +++++++--
.../AbstractSeriesAggregationScanOperator.java | 70 ++++++++++----
.../source/AbstractSeriesScanOperator.java | 46 ++++++---
.../execution/operator/source/SeriesScanUtil.java | 73 +++++++++++----
.../relational/AbstractAggTableScanOperator.java | 75 ++++++++++-----
.../AbstractDefaultAggTableScanOperator.java | 4 +-
.../relational/AbstractMergeSortJoinOperator.java | 14 +++
.../relational/AbstractTableScanOperator.java | 16 +++-
.../InformationSchemaContentSupplierFactory.java | 4 +-
.../relational/LastQueryAggTableScanOperator.java | 4 +-
.../execution/config/sys/pipe/ShowPipeTask.java | 4 +-
.../plan/relational/planner/QueryPlanner.java | 2 +-
.../metadata/view/CreateLogicalViewStatement.java | 13 ++-
.../iotdb/db/service/DataNodeShutdownHook.java | 36 ++++++-
.../utils/reader/SeriesDataBlockReader.java | 20 +++-
.../apache/iotdb/db/utils/ErrorHandlingUtils.java | 3 +-
.../iotdb/db/utils/sort/FileSpillerReader.java | 4 +-
.../queryengine/execution/exchange/StubSink.java | 6 +-
.../process/TableStreamSortOperatorTest.java | 11 +--
.../AlignedSeriesScanLimitOffsetPushDownTest.java | 97 +++++++++----------
.../AlignedSeriesScanPredicatePushDownTest.java | 47 +++++-----
...gleColumnSeriesScanLimitOffsetPushDownTest.java | 48 +++++-----
.../read/reader/series/SeriesReaderTestUtil.java | 17 ++++
.../series/SeriesScanLimitOffsetPushDownTest.java | 60 ++++++------
.../series/SeriesScanPredicatePushDownTest.java | 40 ++++----
.../iotdb/commons/client/ainode/AINodeClient.java | 5 +-
.../apache/iotdb/commons/conf/CommonConfig.java | 24 ++++-
.../commons/pipe/agent/task/PipeTaskAgent.java | 2 +-
.../iotdb/commons/pipe/config/PipeConfig.java | 7 +-
.../iotdb/commons/pipe/config/PipeDescriptor.java | 7 +-
.../commons/pipe/resource/log/PipeLogManager.java | 2 +-
.../commons/pipe/resource/log/PipeLogStatus.java | 4 +-
.../apache/iotdb/commons/utils/StatusUtils.java | 1 -
iotdb-doap.rdf | 8 ++
.../thrift-ainode/src/main/thrift/ainode.thrift | 6 +-
.../thrift-commons/src/main/thrift/common.thrift | 7 ++
.../src/main/thrift/confignode.thrift | 3 +
.../src/main/thrift/datanode.thrift | 9 +-
84 files changed, 952 insertions(+), 490 deletions(-)
copy
integration-test/src/test/java/org/apache/iotdb/confignode/it/{regionmigration/pass/commit/stream/IoTDBRegionMigrateNormalForIoTV2StreamIT.java
=> IoTDBConfigNodeSnapshot2IT.java} (63%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/metric/overview/{PipeDataNodeRemainingEventAndTimeMetrics.java
=> PipeDataNodeSinglePipeMetrics.java} (96%)
