Skip to content

Commit f818e4b

Browse files
committed
fix
1 parent fd7a3f2 commit f818e4b

File tree

1 file changed

+3
-3
lines changed
  • iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/persistence/pipe

1 file changed

+3
-3
lines changed

iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/persistence/pipe/PipePluginInfo.java

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -218,9 +218,6 @@ public TSStatus createPipePlugin(final CreatePipePluginPlan createPipePluginPlan
218218
// try to drop the old pipe plugin if exists to reduce the effect of the inconsistency
219219
dropPipePlugin(new DropPipePluginPlan(pluginName));
220220

221-
pipePluginMetaKeeper.addPipePluginMeta(pluginName, pipePluginMeta);
222-
pipePluginMetaKeeper.addJarNameAndMd5(jarName, pipePluginMeta.getJarMD5());
223-
224221
if (createPipePluginPlan.getJarFile() != null) {
225222
pipePluginExecutableManager.savePluginToInstallDir(
226223
ByteBuffer.wrap(createPipePluginPlan.getJarFile().getValues()), pluginName, jarName);
@@ -238,6 +235,9 @@ public TSStatus createPipePlugin(final CreatePipePluginPlan createPipePluginPlan
238235
}
239236
}
240237

238+
pipePluginMetaKeeper.addPipePluginMeta(pluginName, pipePluginMeta);
239+
pipePluginMetaKeeper.addJarNameAndMd5(jarName, pipePluginMeta.getJarMD5());
240+
241241
return new TSStatus(TSStatusCode.SUCCESS_STATUS.getStatusCode());
242242
} catch (final Exception e) {
243243
final String errorMessage =

0 commit comments

Comments
 (0)