This is an automated email from the ASF dual-hosted git repository.
haonan pushed a change to branch rc/1.2.2
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 779faef77c2 Pipe: fix file handle leak when processing with
extractor.pattern (#11209) (#11213)
new 12dff2e2669 Revert "[To rel/1.2][IOTDB-6149] Fix incorrect output of
UDF with multiple inputs"
new d33b33c97eb Revert "Pipe: push down the construction of history events
to save memory when large amount of pipes are running (#11067) (#11135)"
new 69e22d0d1c3 Revert "[IOTDB-6137] Improved error messages for
expressions as constants in GROUP BY"
new 658a6170d75 Revert "Pipe: Improve performance for 10000+ pipes
(#11021) (#11051)"
new 8bc636ac0fc Revert "[IOTDB-6134] Fill statement content in show
queries for inner schema fetch"
new 1007e5496a3 Revert "Fix possible NPE while executing show cluster or
show cluster details"
new 913b25d5689 Revert "[IOTDB-6130] Delete data by specific pattern
didn't work"
new d4b3c914a67 Revert "[To rel/1.2] Fix mods file contains writable view"
new 5d4c2e57e53 Revert "[To rel/1.2] add hot load compaction configs
(#10759)"
new 0893e51a318 Revert "[To rel/1.2][IOTDB-6162] Enhanced accuracy in
deleting data (#11202)"
new a46189e9b23 Revert "[To rel/1.2][IOTDB-6138] Fix the support of
negative timestamp (#11071)"
new b0e0a1d4d3a Revert "Pipe: fix file handle leak when processing with
extractor.pattern (#11209) (#11213)"
new 4d7274e9dd3 Revert "[To rel/1.2] Pipe: fix NPE in
PipeEnrichedInsertBaseStatement#isQuery when analyzing statement in metadata
mismatch scenarios (#11203) (#11206)"
new 34ab26e6c95 Revert "[To rel/1.2][ISSUE-11199] Pipe: fix NPE when
casting from null values in InsertRowNode deserialization (#11200) (#11205)"
new 19d056f9593 Revert "[To rel/1.2][IOTDB-6143] Pipe: Support
PipeConnector subtasks with the same parameters concurrently scheduling
(#11185)"
The 15 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:
.../apache/iotdb/db/it/IoTDBInsertWithQueryIT.java | 23 +---
.../iotdb/db/it/udf/IoTDBUDFWindowQueryIT.java | 17 ++-
.../iotdb/session/it/IoTDBSessionSimpleIT.java | 45 -------
.../org/apache/iotdb/pipe/api/PipeConnector.java | 10 +-
.../org/apache/iotdb/pipe/api/PipeProcessor.java | 10 +-
.../event/dml/insertion/TsFileInsertionEvent.java | 2 +-
.../main/java/org/apache/iotdb/rpc/RpcUtils.java | 29 +----
.../java/org/apache/iotdb/rpc/RpcUtilsTest.java | 67 -----------
.../manager/partition/PartitionManager.java | 5 +-
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 92 --------------
.../dataregion/DataExecutionVisitor.java | 2 +-
.../iotdb/db/pipe/agent/task/PipeTaskAgent.java | 9 +-
.../config/constant/PipeConnectorConstant.java | 6 -
.../protocol/airgap/IoTDBAirGapConnector.java | 8 +-
.../connector/protocol/opcua/OpcUaConnector.java | 72 +++--------
.../thrift/async/IoTDBThriftAsyncConnector.java | 8 +-
.../protocol/websocket/WebSocketConnector.java | 66 +++--------
.../common/tsfile/PipeTsFileInsertionEvent.java | 15 +--
.../tsfile/TsFileInsertionDataContainer.java | 1 -
.../PipeHistoricalDataRegionTsFileExtractor.java | 114 ++++++------------
.../resource/tsfile/PipeTsFileResourceManager.java | 16 +--
.../connector/PipeConnectorSubtaskManager.java | 132 +++++++--------------
.../protocol/thrift/impl/ClientRPCServiceImpl.java | 10 +-
.../impl/DataNodeInternalRPCServiceImpl.java | 4 +-
.../execution/load/AlignedChunkData.java | 4 +-
.../execution/load/NonAlignedChunkData.java | 4 +-
.../queryengine/execution/load/TsFileSplitter.java | 20 ++--
.../db/queryengine/plan/analyze/Analysis.java | 6 +-
.../queryengine/plan/analyze/AnalyzeVisitor.java | 31 +++--
.../analyze/schema/ClusterSchemaFetchExecutor.java | 14 +--
.../config/metadata/ShowClusterDetailsTask.java | 54 ++-------
.../execution/config/metadata/ShowClusterTask.java | 30 +----
.../db/queryengine/plan/parser/ASTVisitor.java | 42 +++----
.../plan/node/load/LoadSingleTsFileNode.java | 6 +-
.../planner/plan/node/write/DeleteDataNode.java | 24 ++--
.../planner/plan/node/write/InsertRowNode.java | 6 +-
.../planner/plan/node/write/InsertRowsNode.java | 4 +-
.../plan/node/write/InsertRowsOfOneDeviceNode.java | 4 +-
.../planner/plan/node/write/InsertTabletNode.java | 33 ++++--
.../plan/statement/crud/InsertRowStatement.java | 4 +-
.../crud/InsertRowsOfOneDeviceStatement.java | 5 +-
.../plan/statement/crud/InsertTabletStatement.java | 17 ++-
.../crud/PipeEnrichedInsertBaseStatement.java | 3 +-
.../MultiInputColumnIntermediateLayer.java | 10 +-
.../iotdb/db/storageengine/StorageEngine.java | 21 +++-
.../db/storageengine/dataregion/DataRegion.java | 72 ++++++++---
.../compaction/schedule/CompactionTaskManager.java | 1 +
.../dataregion/tsfile/TsFileManager.java | 19 ---
.../tsfile/timeindex/DeviceTimeIndex.java | 9 +-
.../dataregion/tsfile/timeindex/FileTimeIndex.java | 6 +-
.../iotdb/db/tools/TsFileSplitByPartitionTool.java | 10 +-
.../org/apache/iotdb/db/utils/CommonUtils.java | 7 --
.../apache/iotdb/db/utils/TimePartitionUtils.java} | 30 ++---
.../plan/node/write/WritePlanNodeSplitTest.java | 30 +++--
.../iotdb/db/storageengine/StorageEngineTest.java | 14 ---
.../storageengine/dataregion/DataRegionTest.java | 56 ++++-----
...eCrossSpaceCompactionWithFastPerformerTest.java | 15 ++-
...sSpaceCompactionWithReadPointPerformerTest.java | 15 ++-
.../InnerSeqCompactionWithFastPerformerTest.java | 6 +-
...nerSeqCompactionWithReadChunkPerformerTest.java | 6 +-
.../settle/SettleRequestHandlerTest.java | 2 +-
.../iotdb/commons/partition/DataPartition.java | 17 +--
.../apache/iotdb/commons/path/PathPatternTree.java | 10 ++
.../iotdb/commons/utils/TimePartitionUtils.java | 79 ------------
.../iotdb/commons/path/PathPatternTreeTest.java | 2 +-
65 files changed, 490 insertions(+), 1021 deletions(-)
delete mode 100644
iotdb-client/service-rpc/src/test/java/org/apache/iotdb/rpc/RpcUtilsTest.java
copy
iotdb-core/{node-commons/src/main/java/org/apache/iotdb/commons/auth/authorizer/LocalFileAuthorizer.java
=> datanode/src/main/java/org/apache/iotdb/db/utils/TimePartitionUtils.java}
(52%)
delete mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/utils/TimePartitionUtils.java
