This is an automated email from the ASF dual-hosted git repository.
shuwenwei pushed a change to branch addMemoryControlForModEntriesInQuery
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 4e78d75799f fix reviewed issues
add 95fb59e6220 [AINode] Fix circular import bug (#16137)
add bebee2600a3 Fix vulnerability-check (#16140)
add edba62bd042 Update vulnerability-check.yml (#16142)
add b1dd87aa7f1 Support fill null value into tag and attribute and alias
array structure when create batch aligned and non-aligned timeseries. (#16139)
add 32910ff7b73 Load: Fix LoadPieceNode reading aligned Chunk causing OOM
(#16132)
add eaf075e166c Bump com.nimbusds:nimbus-jose-jwt from 9.37.3 to 9.37.4
(#15921)
add 5a9f6282afb Load: Reduce unnecessary MD5 calculations (#16141)
add 5c4c947eb64 Pipe: Removed the useless ser-de in receiver raw req &
Improved the handling logic for rowCount and null value bitmaps in
insertTabletNode (#16133)
add b206294d0c8 Increase availability when checking password & do not log
until close to expiration (#16146)
add b1deb6c7cf9 Pipe: Optimized the commit queue to avoid OOM problem
(#16145)
add dd3e8b2ea20 Fix nodeUrls shuffle error (#16147)
add d1fbaad95e3 Update jars in integration-tests (#16156)
add b4fdd40b33c Pipe: Changed the default periodical login behavior to
disabled
add fe3205cd32b fix FAST_LAST_QUERY metrics, using the same StatementType
add 89ff4636e3e fix FAST_LAST_QUERY metrics, set finish = true when use
cached
add e4a85cecd92 Pipe: Delete unnecessary metrics (#16165)
add 100cf590344 Add a switch to control if allow null value be included in
the "quantity total" metric statistic (#16057)
add 7001d5c56b3 Merge branch 'master' into
addMemoryControlForModEntriesInQuery
No new revisions were added by this update.
Summary of changes:
.github/workflows/vulnerability-check.yml | 4 +
.../iotdb/AlignedTimeseriesSessionExample.java | 123 +++++++++++++++
.../main/java/org/apache/iotdb/SessionExample.java | 103 ++++++++++++
.../src/test/resources/trigger-example.jar | Bin 9221 -> 9079 bytes
.../src/test/resources/udf-example.jar | Bin 10018 -> 8843 bytes
.../org/apache/iotdb/jdbc/IoTDBConnection.java | 20 ++-
.../java/org/apache/iotdb/session/Session.java | 50 +++++-
.../java/org/apache/iotdb/session/SessionTest.java | 12 ++
iotdb-core/ainode/ainode/core/constant.py | 2 +-
.../ainode/ainode/core/manager/model_manager.py | 3 +-
.../ainode/core/model/built_in_model_factory.py | 3 +-
iotdb-core/ainode/ainode/core/model/model_enums.py | 70 +++++++++
.../ainode/ainode/core/model/model_factory.py | 2 +-
iotdb-core/ainode/ainode/core/model/model_info.py | 59 +------
.../ainode/ainode/core/model/model_storage.py | 10 +-
iotdb-core/ainode/ainode/core/model/uri_utils.py | 3 +-
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 11 ++
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 13 ++
.../common/deletion/PipeDeleteDataNodeEvent.java | 5 +-
.../common/tablet/PipeRawTabletInsertionEvent.java | 11 +-
.../event/common/terminate/PipeTerminateEvent.java | 5 +-
.../common/tsfile/PipeTsFileInsertionEvent.java | 13 +-
.../overview/PipeDataNodeSinglePipeMetrics.java | 40 -----
.../statement/PipeConvertedInsertRowStatement.java | 2 +-
.../PipeConvertedInsertTabletStatement.java | 2 +-
.../request/PipeTransferTabletRawReq.java | 22 +--
.../request/PipeTransferTabletRawReqV2.java | 36 +----
.../protocol/rest/v2/impl/RestApiServiceImpl.java | 19 ++-
.../iotdb/db/protocol/session/SessionManager.java | 36 +++--
.../plan/node/load/LoadTsFilePieceNode.java | 42 ++++-
.../plan/planner/plan/node/write/InsertNode.java | 9 +-
.../planner/plan/node/write/InsertTabletNode.java | 32 ++--
.../plan/node/write/RelationalInsertRowNode.java | 6 +-
.../plan/node/write/RelationalInsertRowsNode.java | 6 +-
.../node/write/RelationalInsertTabletNode.java | 12 +-
.../plan/statement/crud/InsertBaseStatement.java | 22 +--
.../plan/statement/crud/InsertRowStatement.java | 6 +-
.../plan/statement/crud/InsertTabletStatement.java | 50 +++++-
.../iotdb/db/storageengine/StorageEngine.java | 3 +-
.../dataregion/memtable/AbstractMemTable.java | 56 ++++++-
.../db/storageengine/load/LoadTsFileManager.java | 6 +-
.../load/splitter/AlignedChunkData.java | 57 ++++---
.../splitter/BatchedAlignedValueChunkData.java | 24 +--
.../db/storageengine/load/splitter/ChunkData.java | 2 +-
.../broker/SubscriptionPrefetchingQueue.java | 12 +-
.../apache/iotdb/db/utils/DataNodeAuthUtils.java | 6 +-
.../conf/iotdb-system.properties.template | 5 +
.../apache/iotdb/commons/conf/CommonConfig.java | 11 +-
.../agent/task/progress/PipeEventCommitter.java | 70 +--------
.../task/progress/interval/PipeCommitInterval.java | 79 ++++++++++
.../task/progress/interval/PipeCommitQueue.java | 60 +++++++
.../pipe/datastructure/interval/Interval.java} | 27 ++--
.../datastructure/interval/IntervalManager.java | 74 +++++++++
.../iotdb/commons/pipe/event/EnrichedEvent.java | 40 ++---
.../org/apache/iotdb/commons/utils/FileUtils.java | 173 ++++++++++-----------
.../org/apache/iotdb/commons/utils/PathUtils.java | 3 +-
.../pipe/datastructure/PipeCommitQueueTest.java | 148 ++++++++++++++++++
pom.xml | 2 +-
58 files changed, 1211 insertions(+), 511 deletions(-)
create mode 100644 iotdb-core/ainode/ainode/core/model/model_enums.py
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/agent/task/progress/interval/PipeCommitInterval.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/agent/task/progress/interval/PipeCommitQueue.java
copy
iotdb-core/{datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/ast/ShowPipePlugins.java
=>
node-commons/src/main/java/org/apache/iotdb/commons/pipe/datastructure/interval/Interval.java}
(62%)
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/datastructure/interval/IntervalManager.java
create mode 100644
iotdb-core/node-commons/src/test/java/org/apache/iotdb/commons/pipe/datastructure/PipeCommitQueueTest.java
