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 89b77f74325 fix test
add 3021737d9b7 Avoid NPE in dealWithException of QueryExecution
add 9bb8e9b58d2 [AINode] Update AINode docker file and pytorch dependency
(#15979)
add a804650a7fe Bump version to 2.0.6-SNAPSHOT
add 5bb17061bb5 [AINode] Bump version to 2.0.6.dev (#15988)
add 2288d7af396 [AINode] AINode docker compose file (#15987)
add f076824eb05 Pipe: Fixed some errors in cherry-picking (#15984)
add d34054dec5e Pipe: Fix the problem that a cluster crash in the
multi-cluster receiving end causes all synchronization to be suspended (#15962)
add 75d7f27fbdf Pipe: Reduce IoTDBAirGapConnector Handshake times (#15990)
add b9e7bd3aece Load: Fixed the issue that the loading table model file
failed under Tree Dialect Cli (#15942)
add 0340423366a Pipe: Update the log of the heartbeat process reported by
DN to CN (#15983)
add fbc28c6e27a Fixed issues in the rest service module: BLOB, DATE, table
model parameters, and added statistical delay monitoring items to
FastLastQuery. (#15917)
add 1d2f36ec00c Fix that stopping ratis may get stuck due to closed
FlushManager (#15992)
add de05c67c519 Pipe: Handle existing hardlink in createHardLink method
(#15998)
add 7214e1f3677 Pipe: Report progress index for filter-outed insertion
events in realtime extractors (#15975)
add 37ce6d17ddb Pipe: Do not transfer historical tsFiles when restarts in
realtime-only mode (#15996)
add 4f9e75f944f Pipe: Fixed the renaming view's concurrency problem
add 9fb66af4084 Avoid potential deadlock in TableFunctionLeafOperator
add 2c6e00f1f1e Support extract value filter push down
add a9f1a9b19c6 Merge branch 'master' into strong_password
add d8359ffca82 fix tests
No new revisions were added by this update.
Summary of changes:
code-coverage/pom.xml | 2 +-
distribution/pom.xml | 12 +-
.../main/DockerCompose/docker-compose-ainode.yml | 30 ++-
.../docker-compose-cluster-1c1d1a.yml | 4 +-
docker/src/main/Dockerfile-1.0.0-ainode | 5 +-
example/client-cpp-example/pom.xml | 2 +-
example/jdbc/pom.xml | 2 +-
example/mqtt-customize/pom.xml | 2 +-
example/mqtt/pom.xml | 2 +-
example/pipe-count-point-processor/pom.xml | 2 +-
example/pipe-opc-ua-sink/pom.xml | 2 +-
example/pom.xml | 2 +-
example/rest-java-example/pom.xml | 2 +-
.../java/org/apache/iotdb/TableHttpExample.java | 2 +-
.../java/org/apache/iotdb/TableHttpsExample.java | 2 +-
example/schema/pom.xml | 2 +-
example/session/pom.xml | 2 +-
example/trigger/pom.xml | 2 +-
example/udf/pom.xml | 2 +-
integration-test/pom.xml | 32 +--
.../iotdb/it/env/cluster/node/AINodeWrapper.java | 2 +-
.../org/apache/iotdb/db/it/IoTDBRestServiceIT.java | 145 +++++++++++-
...oTDBRestartIT.java => IoTDBRestartRatisIT.java} | 12 +-
.../manual/basic/IoTDBPipeDataSinkIT.java | 14 +-
.../manual/basic/IoTDBPipeExtractorIT.java | 2 +
.../query/recent/extract/IoTDBExtractTableIT.java | 107 ++++++++-
.../relational/it/rest/it/IoTDBRestServiceIT.java | 32 ++-
iotdb-api/external-api/pom.xml | 2 +-
iotdb-api/pipe-api/pom.xml | 2 +-
iotdb-api/pom.xml | 2 +-
iotdb-api/trigger-api/pom.xml | 2 +-
iotdb-api/udf-api/pom.xml | 2 +-
iotdb-client/cli/pom.xml | 22 +-
iotdb-client/client-cpp/pom.xml | 4 +-
iotdb-client/client-py/pom.xml | 8 +-
iotdb-client/isession/pom.xml | 8 +-
iotdb-client/jdbc/pom.xml | 8 +-
iotdb-client/pom.xml | 2 +-
iotdb-client/service-rpc/pom.xml | 6 +-
iotdb-client/session/pom.xml | 10 +-
iotdb-core/ainode/ainode/core/ainode.py | 10 +-
iotdb-core/ainode/ainode/core/config.py | 68 +++---
iotdb-core/ainode/ainode/core/constant.py | 52 ++---
iotdb-core/ainode/ainode/core/rpc/service.py | 4 +-
iotdb-core/ainode/ainode/core/script.py | 6 +-
iotdb-core/ainode/poetry.lock | 259 ++++++++++++---------
iotdb-core/ainode/pom.xml | 10 +-
iotdb-core/ainode/pyproject.toml | 5 +-
.../ainode/resources/conf/iotdb-ainode.properties | 20 +-
iotdb-core/antlr/pom.xml | 2 +-
iotdb-core/confignode/pom.xml | 26 +--
.../iotdb/confignode/manager/ConfigManager.java | 2 +-
.../iotdb/confignode/manager/ProcedureManager.java | 60 +++--
.../runtime/heartbeat/PipeHeartbeatParser.java | 5 +-
.../receiver/protocol/IoTDBConfigNodeReceiver.java | 1 +
.../impl/schema/table/RenameTableProcedure.java | 4 +
iotdb-core/consensus/pom.xml | 14 +-
iotdb-core/datanode/pom.xml | 40 ++--
.../client/IoTDBDataNodeAsyncClientManager.java | 49 +++-
.../thrift/sync/IoTDBDataRegionSyncConnector.java | 5 +
.../tablet/PipeInsertNodeTabletInsertionEvent.java | 6 -
.../dataregion/IoTDBDataRegionExtractor.java | 46 +---
...oricalDataRegionTsFileAndDeletionExtractor.java | 84 +------
.../realtime/assigner/PipeDataRegionAssigner.java | 53 ++++-
.../matcher/CachedSchemaPatternMatcher.java | 27 ++-
.../realtime/matcher/PipeDataRegionMatcher.java | 9 +-
.../resource/tsfile/PipeTsFileResourceManager.java | 60 ++---
.../rest/table/v1/handler/QueryDataSetHandler.java | 36 ++-
.../table/v1/handler/RequestValidationHandler.java | 12 +-
.../v1/handler/StatementConstructionHandler.java | 4 +-
.../rest/v1/handler/QueryDataSetHandler.java | 54 ++++-
.../rest/v2/handler/QueryDataSetHandler.java | 37 ++-
.../protocol/rest/v2/impl/RestApiServiceImpl.java | 13 +-
.../db/queryengine/common/MPPQueryContext.java | 4 +
.../function/TableFunctionLeafOperator.java | 12 +-
.../plan/analyze/load/LoadTsFileAnalyzer.java | 22 ++
.../queryengine/plan/execution/QueryExecution.java | 32 +--
.../predicate/ConvertPredicateToFilterVisitor.java | 108 ++++++++-
.../PredicateCombineIntoTableScanChecker.java | 50 ++--
.../optimizations/PushPredicateIntoTableScan.java | 21 +-
.../queryengine/plan/statement/StatementType.java | 4 +-
.../iotdb/db/service/DataNodeShutdownHook.java | 2 +-
.../dataregion/memtable/TsFileProcessor.java | 7 -
.../rescon/memory/AbstractPoolManager.java | 16 +-
.../pattern/CachedSchemaPatternMatcherTest.java | 4 +-
.../relational/analyzer/ExtractExpressionTest.java | 10 +
.../plan/relational/analyzer/TestMetadata.java | 57 +++--
iotdb-core/metrics/core/pom.xml | 4 +-
iotdb-core/metrics/interface/pom.xml | 8 +-
iotdb-core/metrics/pom.xml | 2 +-
iotdb-core/node-commons/pom.xml | 24 +-
.../apache/iotdb/commons/conf/CommonConfig.java | 16 ++
.../iotdb/commons/pipe/config/PipeConfig.java | 7 +
.../iotdb/commons/pipe/config/PipeDescriptor.java | 5 +
.../connector/client/IoTDBSyncClientManager.java | 14 ++
.../connector/protocol/IoTDBAirGapConnector.java | 11 +
.../org/apache/iotdb/commons/utils/FileUtils.java | 30 ++-
iotdb-core/pom.xml | 2 +-
iotdb-core/relational-grammar/pom.xml | 2 +-
iotdb-protocol/openapi/pom.xml | 2 +-
.../src/main/openapi3/iotdb_rest_table_v1.yaml | 2 +-
iotdb-protocol/pom.xml | 2 +-
iotdb-protocol/thrift-ainode/pom.xml | 4 +-
iotdb-protocol/thrift-commons/pom.xml | 2 +-
iotdb-protocol/thrift-confignode/pom.xml | 4 +-
iotdb-protocol/thrift-consensus/pom.xml | 4 +-
iotdb-protocol/thrift-datanode/pom.xml | 4 +-
library-udf/pom.xml | 4 +-
pom.xml | 4 +-
scripts/sbin/stop-ainode.sh | 22 +-
scripts/sbin/windows/stop-ainode.bat | 18 +-
111 files changed, 1412 insertions(+), 722 deletions(-)
copy
integration-test/src/test/java/org/apache/iotdb/db/it/{IoTDBRestartIT.java =>
IoTDBRestartRatisIT.java} (98%)
