This is an automated email from the ASF dual-hosted git repository.
haonan pushed a change to branch ssl_between_nodes
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from e9e8a9a2f14 add log
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 8fb982d9e6e Fix some daily UT/ITs (#16172)
add a0f31fe1634 Fix ref count of IoTConsensus request not decreased in
allocation failure (#16169)
add c030c64036e Add logs for migration related daily IT (#16175)
add a18c7805052 Fix the status code of fetching schema when memory is not
enough
add 47fb1925fcc Add memory control for mod entries in query
add 014755275ec Pipe: Changed back the default value of tsFile batch to
16M (#16174)
add cf6746dc195 Use oracle jdk in 1c3dIT (#16181)
add 02959ffc541 Change all query example into iterator style
add 5302d356650 Fix daily IT jdk download (#16188)
add 821b647ef15 [AINode] Update test env and dependency version (#16189)
add a835194b466 Fix query leak during login & fix inconsistent expiration
hints & skipped expiration check when password history is missing (#16166)
add db461ca0a39 [AINode] Revert transformers version (#16191)
add ec47d0ae494 [AINode] Enable CI related to Timer (#16192)
add df898aeb7c0 Merge branch 'master' of github.com:apache/iotdb into
ssl_between_nodes
add 3199dbd3bc0 fix IT on jdk8
No new revisions were added by this update.
Summary of changes:
.github/workflows/cluster-it-1c1d1a.yml | 6 +-
.github/workflows/cluster-it-1c3d.yml | 2 +-
.github/workflows/daily-it.yml | 6 +-
.github/workflows/table-cluster-it-1c3d.yml | 2 +-
.github/workflows/vulnerability-check.yml | 4 +
.../iotdb/AlignedTimeseriesSessionExample.java | 123 +++++++
.../main/java/org/apache/iotdb/SessionExample.java | 219 +++++++-----
.../java/org/apache/iotdb/SessionPoolExample.java | 23 --
.../org/apache/iotdb/TableModelSessionExample.java | 23 +-
.../apache/iotdb/TableModelSessionPoolExample.java | 38 +--
.../org/apache/iotdb/it/env/cluster/env/AIEnv.java | 2 +-
.../iotdb/it/env/cluster/node/AINodeWrapper.java | 42 +++
.../iotdb/ainode/it/AINodeModelManageIT.java | 37 +-
...IoTDBRegionOperationReliabilityITFramework.java | 3 +
.../IoTDBRegionGroupExpandAndShrinkForIoTV1IT.java | 14 +-
...IoTDBExampleIT.java => IoTDBLoginAndOutIT.java} | 52 ++-
.../relational/it/db/it/IoTDBInternalSSLIT.java | 12 +-
.../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/poetry.lock | 377 +++++++++------------
iotdb-core/ainode/pyproject.toml | 6 +-
.../logdispatcher/IoTConsensusMemoryManager.java | 100 +++++-
.../consensus/iot/logdispatcher/LogDispatcher.java | 22 +-
.../consensus/iot/logdispatcher/SyncStatus.java | 20 +-
.../IoTConsensusMemoryManagerTest.java | 103 ++++++
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 22 ++
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 53 +--
.../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 | 55 ++-
.../execution/MemoryEstimationHelper.java | 16 +
.../fragment/FragmentInstanceContext.java | 66 ++++
.../execution/fragment/QueryContext.java | 98 ++++--
.../operator/schema/SchemaFetchScanOperator.java | 10 +-
.../db/queryengine/plan/analyze/Analyzer.java | 7 +-
.../analyze/schema/ClusterSchemaFetchExecutor.java | 3 +
.../plan/planner/TableOperatorGenerator.java | 2 +
.../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 +-
.../sql/ast/RelationalAuthorStatement.java | 9 +-
.../plan/statement/crud/InsertBaseStatement.java | 22 +-
.../plan/statement/crud/InsertRowStatement.java | 6 +-
.../plan/statement/crud/InsertTabletStatement.java | 50 ++-
.../plan/statement/sys/AuthorStatement.java | 9 +-
.../iotdb/db/storageengine/StorageEngine.java | 3 +-
.../dataregion/memtable/AbstractMemTable.java | 56 ++-
.../dataregion/modification/DeletionPredicate.java | 14 +-
.../dataregion/modification/IDPredicate.java | 30 +-
.../dataregion/modification/ModEntry.java | 12 +-
.../dataregion/modification/ModificationFile.java | 4 -
.../modification/TableDeletionEntry.java | 11 +
.../dataregion/modification/TreeDeletionEntry.java | 28 +-
.../filescan/impl/ClosedFileScanHandleImpl.java | 16 +-
.../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 | 23 +-
.../apache/iotdb/db/utils/ErrorHandlingUtils.java | 4 +-
.../org/apache/iotdb/db/conf/PropertiesTest.java | 37 +-
.../org/apache/iotdb/db/utils/AnnotationTest.java | 53 +--
.../conf/iotdb-system.properties.template | 12 +
.../apache/iotdb/commons/conf/CommonConfig.java | 11 +-
.../apache/iotdb/commons/path/PathPatternNode.java | 18 +-
.../apache/iotdb/commons/path/PatternTreeMap.java | 15 +-
.../agent/task/progress/PipeEventCommitter.java | 70 +---
.../task/progress/interval/PipeCommitInterval.java | 79 +++++
.../task/progress/interval/PipeCommitQueue.java | 60 ++++
.../pipe/config/constant/PipeSinkConstant.java | 2 +-
.../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 | 4 +-
92 files changed, 2108 insertions(+), 1028 deletions(-)
copy
integration-test/src/test/java/org/apache/iotdb/db/it/{IoTDBExampleIT.java =>
IoTDBLoginAndOutIT.java} (53%)
create mode 100644
iotdb-core/consensus/src/test/java/org/apache/iotdb/consensus/iot/logdispatcher/IoTConsensusMemoryManagerTest.java
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
