This is an automated email from the ASF dual-hosted git repository. rong pushed a commit to branch fix-pipe-class-cast in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit fdca4af3a3ce4d8ced3ad9b27056556f30ed3d98 Author: Steve Yurong Su <[email protected]> AuthorDate: Mon Jun 12 10:24:01 2023 +0800 [hotfix] pipe: PipeTaskRuntimeConfiguration cannot be cast to PipeTaskCollectorRuntimEnvironment --- .../org/apache/iotdb/db/pipe/collector/IoTDBDataRegionCollector.java | 3 ++- .../org/apache/iotdb/db/pipe/task/stage/PipeTaskCollectorStage.java | 3 +-- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/server/src/main/java/org/apache/iotdb/db/pipe/collector/IoTDBDataRegionCollector.java b/server/src/main/java/org/apache/iotdb/db/pipe/collector/IoTDBDataRegionCollector.java index 7916e1d92fb..d1653b30c59 100644 --- a/server/src/main/java/org/apache/iotdb/db/pipe/collector/IoTDBDataRegionCollector.java +++ b/server/src/main/java/org/apache/iotdb/db/pipe/collector/IoTDBDataRegionCollector.java @@ -137,7 +137,8 @@ public class IoTDBDataRegionCollector implements PipeCollector { @Override public void customize(PipeParameters parameters, PipeCollectorRuntimeConfiguration configuration) throws Exception { - dataRegionId = ((PipeTaskCollectorRuntimeEnvironment) configuration).getRegionId(); + dataRegionId = + ((PipeTaskCollectorRuntimeEnvironment) configuration.getRuntimeEnvironment()).getRegionId(); historicalCollector.customize(parameters, configuration); realtimeCollector.customize(parameters, configuration); diff --git a/server/src/main/java/org/apache/iotdb/db/pipe/task/stage/PipeTaskCollectorStage.java b/server/src/main/java/org/apache/iotdb/db/pipe/task/stage/PipeTaskCollectorStage.java index 524b94eb604..6c6f2498b97 100644 --- a/server/src/main/java/org/apache/iotdb/db/pipe/task/stage/PipeTaskCollectorStage.java +++ b/server/src/main/java/org/apache/iotdb/db/pipe/task/stage/PipeTaskCollectorStage.java @@ -29,7 +29,6 @@ import org.apache.iotdb.db.pipe.config.plugin.configuraion.PipeTaskRuntimeConfig import org.apache.iotdb.db.pipe.config.plugin.env.PipeTaskCollectorRuntimeEnvironment; import org.apache.iotdb.db.pipe.task.connection.EventSupplier; import org.apache.iotdb.pipe.api.PipeCollector; -import org.apache.iotdb.pipe.api.customizer.configuration.PipeCollectorRuntimeConfiguration; import org.apache.iotdb.pipe.api.customizer.parameter.PipeParameterValidator; import org.apache.iotdb.pipe.api.customizer.parameter.PipeParameters; import org.apache.iotdb.pipe.api.exception.PipeException; @@ -61,7 +60,7 @@ public class PipeTaskCollectorStage extends PipeTaskStage { pipeCollector.validate(new PipeParameterValidator(collectorParameters)); // 2. customize collector - final PipeCollectorRuntimeConfiguration runtimeConfiguration = + final PipeTaskRuntimeConfiguration runtimeConfiguration = new PipeTaskRuntimeConfiguration( new PipeTaskCollectorRuntimeEnvironment( pipeName, creationTime, dataRegionId.getId(), pipeTaskMeta));
