This is an automated email from the ASF dual-hosted git repository.
rong pushed a change to branch fix-pipe-ref-count-leak
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 2a2d3f6e2b4 Update EnrichedEvent.java
add c8f4fda4363 fix
add 029f1e9e7df Revert "Update EnrichedEvent.java"
add 45d18ec0ba9 fix
add 7c808c5cbac Refactor/ai node build update (#13302)
add edc3e8b8099 Fix query stuck while DN restarting & keep quite while
cleaning sort tmp file
add e0c695aa2ad Subscription: always return negative TabletsPayload resp
for tablets streaming transmission (#13339)
add a3c5df8779b Add clusterId check when restarting nodes (#13315)
add 566106b0053 Merge branch 'master' of https://github.com/apache/iotdb
into fix-pipe-ref-count-leak
No new revisions were added by this update.
Summary of changes:
iotdb-core/ainode/iotdb/ainode/script.py | 52 +-
iotdb-core/ainode/poetry.lock | 1442 ++++++++++++++++++++
iotdb-core/ainode/pom.xml | 357 ++---
iotdb-core/ainode/pyproject.toml | 2 +-
.../ainode/resources/pom.properties | 8 +-
iotdb-core/ainode/resources/sbin/remove-ainode.bat | 4 +-
iotdb-core/ainode/resources/sbin/remove-ainode.sh | 4 +-
.../ainode/resources/syncPythonVersion.groovy | 192 +++
.../iotdb/confignode/conf/ConfigNodeConfig.java | 2 +-
.../iotdb/confignode/manager/ConfigManager.java | 2 +
.../manager/node/ClusterNodeStartUtils.java | 19 +
.../iotdb/confignode/manager/node/NodeManager.java | 11 +-
.../iotdb/confignode/service/ConfigNode.java | 2 +-
.../org/apache/iotdb/db/conf/IoTDBStartCheck.java | 8 +
.../pipe/task/connection/PipeEventCollector.java | 9 +-
.../subtask/connector/PipeConnectorSubtask.java | 21 +-
.../PipeRealtimePriorityBlockingQueue.java | 1 +
.../subtask/processor/PipeProcessorSubtask.java | 5 +-
.../db/queryengine/execution/driver/Driver.java | 2 +-
.../fragment/FragmentInstanceExecution.java | 2 +-
.../execution/fragment/FragmentInstanceState.java | 2 +-
.../scheduler/FixedRateFragInsStateTracker.java | 60 +-
.../java/org/apache/iotdb/db/service/DataNode.java | 20 +-
.../batch/SubscriptionPipeTabletEventBatch.java | 12 +-
.../iotdb/commons/pipe/event/EnrichedEvent.java | 6 +-
.../pipe/task/connection/BlockingPendingQueue.java | 1 +
.../commons/pipe/task/subtask/PipeSubtask.java | 2 +
.../org/apache/iotdb/commons/utils/FileUtils.java | 10 +-
.../src/main/thrift/confignode.thrift | 2 +
pom.xml | 14 +-
30 files changed, 2007 insertions(+), 267 deletions(-)
create mode 100644 iotdb-core/ainode/poetry.lock
copy iotdb-client/session/src/test/resources/iotdb-datanode.properties =>
iotdb-core/ainode/resources/pom.properties (91%)
create mode 100644 iotdb-core/ainode/resources/syncPythonVersion.groovy
