From 86d36c14b7354d81a961e02ac6994a5abce2ce9a Mon Sep 17 00:00:00 2001 From: jarvis Date: Wed, 17 Jul 2024 09:41:40 +0800 Subject: [PATCH] debug --- .../engine/core/parse/MultipleTableJobConfigParser.java | 8 +++++++- 1 file changed, 7 insertions(+), 1 deletion(-) diff --git a/seatunnel-engine/seatunnel-engine-core/src/main/java/org/apache/seatunnel/engine/core/parse/MultipleTableJobConfigParser.java b/seatunnel-engine/seatunnel-engine-core/src/main/java/org/apache/seatunnel/engine/core/parse/MultipleTableJobConfigParser.java index 40a6640c3583..5ce641a45d4c 100644 --- a/seatunnel-engine/seatunnel-engine-core/src/main/java/org/apache/seatunnel/engine/core/parse/MultipleTableJobConfigParser.java +++ b/seatunnel-engine/seatunnel-engine-core/src/main/java/org/apache/seatunnel/engine/core/parse/MultipleTableJobConfigParser.java @@ -402,7 +402,13 @@ private void parseTransform( final String factoryId = getFactoryId(readonlyConfig); // get jar urls Set jarUrls = new HashSet<>(); - jarUrls.addAll(getTransformPluginJarPaths(config)); + List transformPluginJarPaths = getTransformPluginJarPaths(config); + log.info( + "transformPluginJarPaths is : [{}]", + transformPluginJarPaths.stream() + .map(URL::getPath) + .collect(Collectors.joining(", "))); + jarUrls.addAll(transformPluginJarPaths); final List inputIds = getInputIds(readonlyConfig); List> inputs =