This is an automated email from the ASF dual-hosted git repository.
jiangtian pushed a change to branch strong_password
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from fc38b6b09d1 remove config entrance
add 7d5b7c50809 [AINode] Enhance the robustness of AINode (#15695)
add 4e2fb589a24 add debug entry (#15694)
add cb91cbf4bc8 [AINode] Update python dependencies (#15712)
add c6d5e29b327 more accurate mermory size (#15713)
add 24209d50ace IoTV2: Remove events that do not retry in leader's
transfer buffer & fix concurrency bug of retryQueue & fix retry interval &
refine log (#15684)
add 3e6aaa3a4cc fix cpp client processing null value (#15700)
add e315e44bf94 User password encryption upgraded from MD5 to SHA256.
(#15680)
add 6cee5f4fbee Fix arrary index out-of-bounds in agg query with align by
device when cross region
add 921d9e24804 Subscription IT: intro retry rule for flaky tests (#15698)
add be0b921ea88 Pipe: Add retry for tablet batch req to avoid
retransmission when memory is insufficient (#15715)
add 99ada4fbe40 Load: Convert to tablets when node is read-only (#15693)
add 18b10bc2d3b Pipe: Fix the inconsistency between schema and values
columns in the process of building tsfile (#15625)
add c5b8d9c8c25 use environment variable and PBKDF to generate main
encrypt key (#15711)
add 855ea12c523 Put last query IT only in 1c1d
add 83ebf5b1a9c Support order by time for Agg align by device query with
cross region data
add b3d0ad72e31 Skip update-cache logic when loading TsFile in
IoTV2Consensus (#15729)
add 369971c8164 fix datanode check (#15730)
add 9d474682cf5 Enhance "remove region" sql to handle the case of DataNode
not exist (#15728)
add 346ee720e7a [remove datanode] Fix ArrayIndexOutOfBoundsException in
computeInitialDbLoad (#15718)
add a2432d2fc2f Fixed the bug that the characters surrounded by "" cannot
be parsed in tree view path
add 7b5a2b39416 Using join to query views of non-aligned series may throw
NullPointerException
add 882c4b7898c Fixed the bug that the old view's cache is not cleared
when altering its name
add 232e0c9054f Fix timeout didn't pass to client bug
add 726d0935320 Subscription: fix drop subscription from session under
table model (#15725)
add cc3c442a1e2 Return empty result set for non aligned series when no
filed columns can be obtained from view
add b34e05e5da4 fix exception msg in RPR
add 58927a19d3a Fixed the potential failure for table view query with
pattern beyond databases
add 9b9212d40a9 Merge branch 'master' into strong_password
No new revisions were added by this update.
Summary of changes:
.../org/apache/iotdb/ainode/it/AINodeBasicIT.java | 8 +-
.../it/query/recent/IoTDBTableAggregationIT.java | 171 +++++++++++++++------
.../query/view/recent/IoTDBTableViewQueryIT.java | 5 +
.../relational/it/schema/IoTDBDatabaseIT.java | 4 +-
.../iotdb/relational/it/schema/IoTDBTableIT.java | 72 +++++----
.../org/apache/iotdb/subscription/it/Retry.java | 10 +-
.../apache/iotdb/subscription/it/RetryRule.java | 69 +++++++++
...oTDBSnapshotTSPatternDatasetPushConsumerIT.java | 8 +
...IoTDBSnapshotTSPatternTsfilePushConsumerIT.java | 8 +
.../multi/IoTDBOneConsumerMultiTopicsTsfileIT.java | 7 +
iotdb-client/client-cpp/src/main/Common.h | 15 +-
.../client-cpp/src/main/IoTDBRpcDataSet.cpp | 68 ++++----
iotdb-client/client-cpp/src/main/IoTDBRpcDataSet.h | 42 ++---
iotdb-client/client-cpp/src/main/NodesSupplier.cpp | 16 +-
.../client-cpp/src/main/SessionDataSet.cpp | 78 +++++++---
iotdb-client/client-cpp/src/main/SessionDataSet.h | 32 ++--
iotdb-client/client-cpp/src/test/cpp/sessionIT.cpp | 66 ++++----
.../src/test/cpp/sessionRelationalIT.cpp | 81 ++++++++--
iotdb-core/ainode/ainode/core/constant.py | 4 +-
iotdb-core/ainode/ainode/core/handler.py | 4 +
iotdb-core/ainode/ainode/core/ingress/dataset.py | 32 +---
iotdb-core/ainode/ainode/core/ingress/iotdb.py | 84 +++++++---
iotdb-core/ainode/poetry.lock | 138 +++++++++++------
iotdb-core/ainode/pyproject.toml | 3 +-
.../iotdb/confignode/manager/ConfigManager.java | 26 +++-
.../iotdb/confignode/manager/ProcedureManager.java | 44 ++++--
.../region/GreedyCopySetRegionGroupAllocator.java | 8 +-
.../subscription/SubscriptionCoordinator.java | 3 +-
.../partition/DatabasePartitionTable.java | 10 +-
.../persistence/partition/PartitionInfo.java | 2 +-
.../persistence/partition/RegionGroup.java | 6 +-
.../impl/node/RemoveDataNodesProcedure.java | 5 +-
.../procedure/impl/schema/SchemaUtils.java | 20 ++-
.../table/AbstractAlterOrDropTableProcedure.java | 23 ++-
.../impl/schema/table/CreateTableProcedure.java | 8 +-
.../impl/schema/table/RenameTableProcedure.java | 6 +-
.../GreedyCopySetRemoveNodeReplicaSelectTest.java | 11 +-
.../consensus/iot/IoTConsensusServerImpl.java | 7 +-
.../iotdb/consensus/iot/logdispatcher/Batch.java | 17 +-
.../consensus/iot/logdispatcher/LogDispatcher.java | 9 +-
.../consensus/iot/logdispatcher/SyncStatus.java | 6 +-
.../iotdb/db/auth/ClusterAuthorityFetcher.java | 5 +
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 3 -
.../org/apache/iotdb/db/conf/IoTDBStartCheck.java | 29 ++--
.../pipeconsensus/PipeConsensusAsyncConnector.java | 28 ++--
.../handler/PipeConsensusDeleteEventHandler.java | 4 +-
.../PipeConsensusTabletInsertionEventHandler.java | 5 +-
.../PipeConsensusTsFileInsertionEventHandler.java | 10 +-
.../util/builder/PipeTableModelTsFileBuilder.java | 1 +
.../builder/PipeTableModelTsFileBuilderV2.java | 53 ++++---
.../util/builder/PipeTreeModelTsFileBuilder.java | 1 +
.../util/builder/PipeTreeModelTsFileBuilderV2.java | 42 +++--
.../event/realtime/PipeRealtimeEventFactory.java | 6 +-
...oricalDataRegionTsFileAndDeletionExtractor.java | 2 +-
.../pipeconsensus/PipeConsensusReceiver.java | 12 +-
.../protocol/thrift/IoTDBDataNodeReceiver.java | 63 +++++---
.../impl/DataNodeInternalRPCServiceImpl.java | 10 +-
.../exchange/source/LocalSourceHandle.java | 13 +-
.../fragment/FragmentInstanceManager.java | 8 +-
.../rowpattern/expression/ArithmeticOperator.java | 7 +-
.../rowpattern/expression/ComparisonOperator.java | 8 +-
.../process/rowpattern/expression/Computation.java | 9 +-
.../rowpattern/expression/LogicalOperator.java | 4 +-
.../expression/PatternExpressionComputation.java | 3 +-
.../schema/source/TableDeviceQuerySource.java | 9 +-
.../schema/dualkeycache/impl/DualKeyCacheImpl.java | 1 +
.../plan/analyze/load/LoadTsFileAnalyzer.java | 9 +-
.../execution/config/TableConfigTaskVisitor.java | 4 +-
.../config/metadata/ai/CreateTrainingTask.java | 6 -
.../metadata/relational/ShowCreateViewTask.java | 9 +-
.../plan/planner/OperatorTreeGenerator.java | 4 +-
.../plan/planner/TableOperatorGenerator.java | 28 +++-
.../plan/planner/distribution/SourceRewriter.java | 70 ++++++++-
.../planner/plan/node/process/AggregationNode.java | 3 +-
.../plan/node/process/RawDataAggregationNode.java | 3 +-
.../source/AlignedSeriesAggregationScanNode.java | 15 +-
.../node/source/SeriesAggregationScanNode.java | 15 +-
.../relational/analyzer/ExpressionAnalyzer.java | 19 ++-
.../relational/planner/TableLogicalPlanner.java | 5 +
.../optimizations/PushPredicateIntoTableScan.java | 3 +-
.../planner/rowpattern/IrRowPattern.java | 40 ++---
.../plan/relational/sql/parser/AstBuilder.java | 7 +-
.../plan/scheduler/load/LoadTsFileScheduler.java | 27 +---
.../db/schemaengine/table/DataNodeTableCache.java | 42 ++++-
.../iotdb/db/schemaengine/table/ITableCache.java | 10 +-
.../db/storageengine/dataregion/DataRegion.java | 3 +-
.../dataregion/utils/TsFileResourceUtils.java | 5 +-
.../file/AbstractTsFileRecoverPerformer.java | 2 +-
.../SchemaRegionSimpleRecoverTest.java | 4 +-
...nAlignedTreeDeviceViewScanOperatorTreeTest.java | 4 +-
.../distribution/AggregationAlignByDeviceTest.java | 57 +++++++
.../analyzer/RowPatternRecognitionTest.java | 32 ++++
.../plan/relational/analyzer/TreeViewTest.java | 4 +-
.../fetcher/cache/TableDeviceSchemaCacheTest.java | 12 +-
.../security/encrypt/MessageDigestEncryptTest.java | 12 +-
.../storageengine/dataregion/DataRegionTest.java | 4 +-
.../TableModelCompactionWithTTLTest.java | 4 +-
.../file/UnsealedTsFileRecoverPerformerTest.java | 4 +-
.../commons/auth/authorizer/BasicAuthorizer.java | 42 +++--
.../iotdb/commons/client/ainode/AINodeClient.java | 4 +-
.../iotdb/commons/client/ainode/AINodeInfo.java | 29 ----
.../apache/iotdb/commons/conf/CommonConfig.java | 12 --
.../commons/exception/QueryTimeoutException.java | 4 +
.../org/apache/iotdb/commons/path/PartialPath.java | 12 ++
.../iotdb/commons/pipe/event/EnrichedEvent.java | 4 +-
.../security/encrypt/AsymmetricEncrypt.java | 23 ++-
.../security/encrypt/MessageDigestEncrypt.java | 10 +-
.../org/apache/iotdb/commons/utils/AuthUtils.java | 22 ++-
.../src/main/thrift/confignode.thrift | 1 -
.../src/main/thrift/iotconsensus.thrift | 1 +
.../src/main/thrift/datanode.thrift | 1 +
pom.xml | 2 +-
112 files changed, 1501 insertions(+), 704 deletions(-)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/schemaengine/schemaregion/SchemaRegion.java
=> integration-test/src/test/java/org/apache/iotdb/subscription/it/Retry.java
(77%)
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/RetryRule.java
delete mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/client/ainode/AINodeInfo.java
