This is an automated email from the ASF dual-hosted git repository.
justinchen pushed a commit to branch pipeMeta-fix
in repository https://gitbox.apache.org/repos/asf/iotdb.git
The following commit(s) were added to refs/heads/pipeMeta-fix by this push:
new f818e4b8072 fix
f818e4b8072 is described below
commit f818e4b8072537fd4b2b46561477823465be20dd
Author: Caideyipi <[email protected]>
AuthorDate: Fri Dec 19 17:57:30 2025 +0800
fix
---
.../apache/iotdb/confignode/persistence/pipe/PipePluginInfo.java | 6 +++---
1 file changed, 3 insertions(+), 3 deletions(-)
diff --git
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/persistence/pipe/PipePluginInfo.java
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/persistence/pipe/PipePluginInfo.java
index 27cc3cc4cbf..d851f9e35e7 100644
---
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/persistence/pipe/PipePluginInfo.java
+++
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/persistence/pipe/PipePluginInfo.java
@@ -218,9 +218,6 @@ public class PipePluginInfo implements SnapshotProcessor {
// try to drop the old pipe plugin if exists to reduce the effect of the
inconsistency
dropPipePlugin(new DropPipePluginPlan(pluginName));
- pipePluginMetaKeeper.addPipePluginMeta(pluginName, pipePluginMeta);
- pipePluginMetaKeeper.addJarNameAndMd5(jarName,
pipePluginMeta.getJarMD5());
-
if (createPipePluginPlan.getJarFile() != null) {
pipePluginExecutableManager.savePluginToInstallDir(
ByteBuffer.wrap(createPipePluginPlan.getJarFile().getValues()),
pluginName, jarName);
@@ -238,6 +235,9 @@ public class PipePluginInfo implements SnapshotProcessor {
}
}
+ pipePluginMetaKeeper.addPipePluginMeta(pluginName, pipePluginMeta);
+ pipePluginMetaKeeper.addJarNameAndMd5(jarName,
pipePluginMeta.getJarMD5());
+
return new TSStatus(TSStatusCode.SUCCESS_STATUS.getStatusCode());
} catch (final Exception e) {
final String errorMessage =
