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 e53ef00b30864..c7c138718f683 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 @@ -413,14 +413,14 @@ public void processLoadSnapshot(final File snapshotDir) throws IOException { pipePluginMetaKeeper.addPipePluginVisibility( pluginName, VisibilityUtils.calculateFromPluginClass(pluginClass)); classLoaderManager.addPluginAndClassLoader(pluginName, pipePluginClassLoader); - } catch (final Exception e) { + } catch (final Throwable e) { try { pipePluginClassLoader.close(); } catch (final Exception ignored) { } throw e; } - } catch (final Exception e) { + } catch (final Throwable e) { LOGGER.warn( "Failed to load plugin class for plugin [{}] when loading snapshot [{}] ", pluginName, diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/agent/runtime/PipeAgentLauncher.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/agent/runtime/PipeAgentLauncher.java index 01289109371fe..5a408a319e7f0 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/agent/runtime/PipeAgentLauncher.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/agent/runtime/PipeAgentLauncher.java @@ -90,7 +90,7 @@ public static synchronized void launchPipePluginAgent( } PipeDataNodeAgent.plugin().doRegister(meta); } - } catch (Exception e) { + } catch (Throwable e) { // Ignore the pipe plugin errors and continue to start LOGGER.warn("Failure when register pipe plugins, will ignore.", e); }