This is an automated email from the ASF dual-hosted git repository. rong pushed a commit to branch test-4 in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit ab2067c146f3e6ee4e7dd98ac273f2c50ba8cb68 Author: Steve Yurong Su <[email protected]> AuthorDate: Fri Jun 20 15:49:26 2025 +0800 Update ClusterConfigTaskExecutor.java --- .../plan/execution/config/executor/ClusterConfigTaskExecutor.java | 5 ++--- 1 file changed, 2 insertions(+), 3 deletions(-) diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/config/executor/ClusterConfigTaskExecutor.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/config/executor/ClusterConfigTaskExecutor.java index 0ac2b515696..32ef65a6f1d 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/config/executor/ClusterConfigTaskExecutor.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/config/executor/ClusterConfigTaskExecutor.java @@ -597,7 +597,8 @@ public class ClusterConfigTaskExecutor implements IConfigTaskExecutor { } private static Optional<SettableFuture<ConfigTaskResult>> executeInThreadSandboxWithTimeout( - Callable<Optional<SettableFuture<ConfigTaskResult>>> task, long timeout, TimeUnit unit) { + Callable<Optional<SettableFuture<ConfigTaskResult>>> task, long timeout, TimeUnit unit) + throws Exception { ExecutorService executor = Executors.newSingleThreadExecutor(); Future<Optional<SettableFuture<ConfigTaskResult>>> future = executor.submit(task); @@ -607,8 +608,6 @@ public class ClusterConfigTaskExecutor implements IConfigTaskExecutor { future.cancel(true); throw new UDFException( "UDF validation timed out after " + timeout + " " + unit.toString().toLowerCase(), e); - } catch (Exception e) { - throw new UDFException("UDF validation failed", e); } finally { executor.shutdownNow(); }
