This is an automated email from the ASF dual-hosted git repository.
justinchen pushed a change to branch session-last-bug-13
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from be6d9337d67 fix
add e1095fd999b [To dev/1.3] Add result size limit and time slice control
for TransformOperator (#17402)
add b2a2462c9c4 [To dev/1.3] cpp session query timeout (#17403)
add 4b946d40ff3 [To dev/1.3] Remove OpenID authorizer and related
dependencies (#17406)
add 747811016a8 [To dev/1.3] Pipe: Fixed some potential OPC UA problems
(#17393) & Added IT for `` in opc (#17394)
add 6309e693871 [To dev/1.3] Pipe: Cleaned multiple potential problems in
pipe module (#17396) (#17417)
add 33fa6fa604e Subscription: Fixed multiple problems (#17418) (#17422)
add 03cc1bdfa35 Load: Fixed multiple bugs (#17413) (#17421)
add 28c4e020bc2 [To dev/1.3] Fix the deadlock at ConfigNode
PipeTaskCoordinatorLock (#17233) (#17424)
add 6dd58fd7f39 Merge branch 'dev/1.3' of https://github.com/apache/iotdb
into session-last-bug-13
No new revisions were added by this update.
Summary of changes:
.github/workflows/multi-language-client.yml | 6 +-
LICENSE-binary | 10 -
docker/src/main/Dockerfile-1c1d | 4 +-
.../it/env/cluster/node/AbstractNodeWrapper.java | 3 +-
.../iotdb/pipe/it/single/IoTDBPipeOPCUAIT.java | 40 ++--
.../client-cpp/src/main/IoTDBRpcDataSet.cpp | 1 +
.../client-cpp/src/main/SessionConnection.cpp | 2 +-
.../client-py/iotdb/utils/IoTDBRpcDataSet.py | 12 +-
.../client-py/tests/integration/test_todf.py | 2 +-
.../runtime/heartbeat/PipeHeartbeat.java | 2 +-
.../pipe/coordinator/task/PipeTaskCoordinator.java | 14 +-
.../coordinator/task/PipeTaskCoordinatorLock.java | 19 +-
.../pipe/source/IoTDBConfigRegionSource.java | 6 +-
.../subscription/SubscriptionCoordinator.java | 10 +-
.../iotdb/confignode/persistence/AuthorInfo.java | 10 +-
.../persistence/subscription/SubscriptionInfo.java | 51 ++--
iotdb-core/datanode/pom.xml | 25 --
.../db/pipe/agent/runtime/PipeAgentLauncher.java | 2 +-
.../db/pipe/agent/task/PipeDataNodeTaskAgent.java | 2 +-
.../agent/task/connection/PipeEventCollector.java | 2 +-
.../sink/PipeRealtimePriorityBlockingQueue.java | 11 +-
.../pipe/metric/overview/PipeResourceMetrics.java | 2 +-
.../receiver/PipeDataNodeReceiverMetrics.java | 4 +-
.../processor/aggregate/AggregateProcessor.java | 4 +-
.../resource/memory/PipeDynamicMemoryBlock.java | 4 +-
.../client/IoTDBDataNodeAsyncClientManager.java | 4 +-
.../batch/PipeTabletEventTsFileBatch.java | 9 +-
.../protocol/airgap/IoTDBDataRegionAirGapSink.java | 2 +-
.../protocol/opcua/server/OpcUaKeyStoreLoader.java | 14 +-
.../sink/protocol/opcua/server/OpcUaNameSpace.java | 7 +-
.../protocol/opcua/server/OpcUaServerBuilder.java | 1 +
.../websocket/WebSocketConnectorServer.java | 23 +-
.../PipeRealtimeDataRegionHybridSource.java | 34 +--
.../realtime/PipeRealtimeDataRegionLogSource.java | 42 +---
.../realtime/PipeRealtimeDataRegionSource.java | 35 +--
.../PipeRealtimeDataRegionTsFileSource.java | 18 +-
.../operator/process/TransformOperator.java | 18 +-
.../config/executor/ClusterConfigTaskExecutor.java | 2 +
.../plan/scheduler/load/LoadTsFileScheduler.java | 5 +-
.../db/storageengine/load/LoadTsFileManager.java | 4 +-
.../load/active/ActiveLoadPendingQueue.java | 4 +-
.../load/config/LoadTsFileConfigurator.java | 4 +-
.../load/memory/LoadTsFileMemoryManager.java | 1 -
.../load/metrics/LoadTsFileCostMetricsSet.java | 2 +-
.../agent/SubscriptionBrokerAgent.java | 2 +-
.../agent/SubscriptionConsumerAgent.java | 1 -
.../subscription/agent/SubscriptionTopicAgent.java | 21 +-
.../TsFileDeduplicationBlockingPendingQueue.java | 2 +-
.../db/auth/authorizer/OpenIdAuthorizerTest.java | 112 ---------
.../execution/operator/TransformOperatorTest.java | 135 +++++++++++
iotdb-core/node-commons/pom.xml | 16 --
.../conf/iotdb-system.properties.template | 5 -
.../commons/auth/authorizer/OpenIdAuthorizer.java | 266 ---------------------
.../apache/iotdb/commons/conf/CommonConfig.java | 11 -
.../iotdb/commons/conf/CommonDescriptor.java | 3 -
.../task/connection/BlockingPendingQueue.java | 21 +-
.../pipe/datastructure/pattern/PipePattern.java | 13 +-
.../pipe/sink/client/IoTDBSyncClientManager.java | 2 +-
.../meta/consumer/ConsumerGroupMeta.java | 9 +-
pom.xml | 39 +--
60 files changed, 350 insertions(+), 785 deletions(-)
delete mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/auth/authorizer/OpenIdAuthorizerTest.java
delete mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/auth/authorizer/OpenIdAuthorizer.java
