This is an automated email from the ASF dual-hosted git repository. rong pushed a commit to branch IOTDB-5788 in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 6aeba86aad0fc83f4d46b405d4a53cf738e922ee Author: Steve Yurong Su <[email protected]> AuthorDate: Sun Apr 23 22:23:50 2023 +0800 handle builtin pipe plugin registration properly --- server/src/main/java/org/apache/iotdb/db/service/DataNode.java | 6 ++++++ 1 file changed, 6 insertions(+) diff --git a/server/src/main/java/org/apache/iotdb/db/service/DataNode.java b/server/src/main/java/org/apache/iotdb/db/service/DataNode.java index 365eae6310..3e0f39ac4f 100644 --- a/server/src/main/java/org/apache/iotdb/db/service/DataNode.java +++ b/server/src/main/java/org/apache/iotdb/db/service/DataNode.java @@ -861,6 +861,9 @@ public class DataNode implements DataNodeMBean { // create instances of pipe plugins and do registration try { for (PipePluginMeta meta : resourcesInformationHolder.getPipePluginMetaList()) { + if (meta.isBuiltin()) { + continue; + } PipeAgent.plugin().doRegister(meta); } } catch (Exception e) { @@ -881,6 +884,9 @@ public class DataNode implements DataNodeMBean { private List<PipePluginMeta> getJarListForPipePlugin() { List<PipePluginMeta> res = new ArrayList<>(); for (PipePluginMeta pipePluginMeta : resourcesInformationHolder.getPipePluginMetaList()) { + if (pipePluginMeta.isBuiltin()) { + continue; + } // If jar does not exist, add current pipePluginMeta to list if (!PipePluginExecutableManager.getInstance() .hasFileUnderInstallDir(pipePluginMeta.getJarName())) {
