This is an automated email from the ASF dual-hosted git repository.
jackietien pushed a change to branch ExtractBug
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from a08b5d8eec4 Fix DateTimeUtils init order bug
add 7af9122872f Fix CI
add 935b9a8f00e Pipe: Fixed the config meta transfer problem (#16280)
add 8e9c43479c8 Pipe: Modify epoch status metric changes (#16272)
add b1ab9b3eb97 encrypt key generate and destroy (#16176)
add c8d7072a4ef Merge remote-tracking branch 'origin/master' into
ExtractBug
No new revisions were added by this update.
Summary of changes:
.../it/env/cluster/config/MppCommonConfig.java | 6 --
.../env/cluster/config/MppSharedCommonConfig.java | 7 ---
.../it/env/remote/config/RemoteCommonConfig.java | 5 --
.../org/apache/iotdb/itbase/env/CommonConfig.java | 2 -
.../scalar/IoTDBFormatFunctionTableIT.java | 1 +
.../response/pipe/task/PipeTableResp.java | 11 ++--
.../agent/runtime/PipeConfigNodeRuntimeAgent.java | 11 +---
.../pipe/agent/task/PipeConfigNodeSubtask.java | 51 ++++++++---------
.../pipe/agent/task/PipeConfigNodeTaskAgent.java | 11 +---
.../pipe/agent/task/PipeConfigNodeTaskBuilder.java | 6 +-
.../PipeConfigPhysicalPlanTSStatusVisitor.java | 1 +
.../pipe/source/IoTDBConfigRegionSource.java | 2 +-
.../confignode/persistence/pipe/PipeInfo.java | 10 ++--
.../confignode/persistence/pipe/PipeTaskInfo.java | 16 +++---
.../impl/pipe/AbstractOperatePipeProcedureV2.java | 4 +-
.../impl/pipe/runtime/PipeMetaSyncProcedure.java | 4 +-
.../impl/pipe/task/CreatePipeProcedureV2.java | 4 +-
.../pipe/util/PipeExternalSourceLoadBalancer.java | 2 +-
.../org/apache/iotdb/db/conf/IoTDBStartCheck.java | 61 ++++++++++++++++++--
.../db/pipe/agent/task/PipeDataNodeTaskAgent.java | 19 +++----
.../agent/task/builder/PipeDataNodeBuilder.java | 2 +-
.../task/builder/PipeDataNodeTaskBuilder.java | 6 +-
.../pipe/agent/task/stage/PipeTaskSourceStage.java | 9 ++-
.../agent/task/subtask/sink/PipeSinkSubtask.java | 66 +++++++++++-----------
.../task/subtask/sink/PipeSinkSubtaskManager.java | 6 +-
...istoricalDataRegionTsFileAndDeletionSource.java | 6 +-
.../PipeRealtimeDataRegionHybridSource.java | 1 +
.../realtime/PipeRealtimeDataRegionLogSource.java | 1 +
.../realtime/PipeRealtimeDataRegionSource.java | 21 ++++++-
.../PipeRealtimeDataRegionTsFileSource.java | 2 +
.../dataregion/realtime/epoch/TsFileEpoch.java | 28 ++++++++-
.../realtime/epoch/TsFileEpochManager.java | 3 -
.../db/pipe/source/mqtt/MQTTPublishHandler.java | 4 +-
.../iotdb/db/pipe/source/mqtt/MQTTSource.java | 6 +-
.../config/executor/ClusterConfigTaskExecutor.java | 14 ++---
.../iotdb/db/service/DataNodeShutdownHook.java | 4 ++
.../subtask/SubscriptionSinkSubtaskManager.java | 2 +-
.../agent/plugin/PipeDataNodePluginAgentTest.java | 4 +-
.../db/pipe/consensus/DeletionResourceTest.java | 4 +-
.../pattern/CachedSchemaPatternMatcherTest.java | 9 ++-
.../db/pipe/source/PipeRealtimeExtractTest.java | 10 ++--
.../relational/analyzer/ExtractExpressionTest.java | 7 +++
.../apache/iotdb/commons/conf/CommonConfig.java | 12 ++++
.../iotdb/commons/conf/CommonDescriptor.java | 2 +
.../commons/pipe/agent/plugin/PipePluginAgent.java | 8 +--
.../commons/pipe/agent/task/PipeTaskAgent.java | 14 ++---
.../pipe/agent/task/meta/PipeStaticMeta.java | 58 +++++++++----------
.../task/subtask/PipeAbstractSinkSubtask.java | 16 +++---
....java => PipeTaskSourceRuntimeEnvironment.java} | 9 ++-
.../iotdb/commons/pipe/source/IoTDBSource.java | 6 +-
50 files changed, 324 insertions(+), 250 deletions(-)
rename
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/config/plugin/env/{PipeTaskExtractorRuntimeEnvironment.java
=> PipeTaskSourceRuntimeEnvironment.java} (81%)
