(iotdb) branch plugin-fix updated: plugin

[justinchen]

This is an automated email from the ASF dual-hosted git repository.

justinchen pushed a commit to branch plugin-fix
in repository https://gitbox.apache.org/repos/asf/iotdb.git


The following commit(s) were added to refs/heads/plugin-fix by this push:
     new e150d2ac938 plugin
e150d2ac938 is described below

commit e150d2ac938272980a006027154fb3f4ee2672c3
Author: Caideyipi <87789683+caidey...@users.noreply.github.com>
AuthorDate: Mon Dec 8 10:25:35 2025 +0800

    plugin
---
 .../confignode/persistence/pipe/PipePluginInfo.java    | 18 +++++++-----------
 1 file changed, 7 insertions(+), 11 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 9c299d219fd..e02deefab37 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
@@ -228,17 +228,13 @@ public class PipePluginInfo implements SnapshotProcessor {
       } else {
         final String existed = 
pipePluginMetaKeeper.getPluginNameByJarName(jarName);
         if (Objects.nonNull(existed)) {
-          if (pipePluginMetaKeeper
-                  .getPipePluginMeta(existed)
-                  .getClassName()
-                  .equals(pipePluginMeta.getClassName())
-              && 
pipePluginMetaKeeper.getPipePluginNameToVisibilityMap().containsKey(existed)) {
-            pipePluginMetaKeeper.addPipePluginVisibility(
-                pluginName, 
pipePluginMetaKeeper.getPipePluginNameToVisibilityMap().get(existed));
-          } else {
-            pipePluginExecutableManager.linkExistedPlugin(existed, pluginName, 
jarName);
-            computeFromPluginClass(pluginName, className);
-          }
+          pipePluginExecutableManager.linkExistedPlugin(existed, pluginName, 
jarName);
+          computeFromPluginClass(pluginName, className);
+        } else {
+          throw new PipeException(
+              String.format(
+                  "The %s's creation has not passed in jarName, which does not 
exists in other pipePlugins. Please check",
+                  pluginName));
         }
       }