Skip to content

Commit 5fae814

Browse files
author
lijie
committed
[Feature] Decouple SeaTunnel Client and Server SEATUNNEL_HOME
1 parent 85cca0b commit 5fae814

File tree

1 file changed

+7
-3
lines changed

1 file changed

+7
-3
lines changed

seatunnel-engine/seatunnel-engine-server/src/test/java/org/apache/seatunnel/engine/server/TaskExecutionServiceTest.java

Lines changed: 7 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -52,7 +52,9 @@
5252
import java.util.ArrayList;
5353
import java.util.Arrays;
5454
import java.util.Collections;
55+
import java.util.HashSet;
5556
import java.util.List;
57+
import java.util.Set;
5658
import java.util.concurrent.ConcurrentHashMap;
5759
import java.util.concurrent.CopyOnWriteArrayList;
5860
import java.util.concurrent.TimeUnit;
@@ -185,6 +187,10 @@ public void testClassloaderSplit() throws IOException {
185187
long jobId = System.currentTimeMillis();
186188

187189
TaskGroupLocation location = new TaskGroupLocation(jobId, 1, 1);
190+
Set<URL> sourceUrls = new HashSet<>();
191+
sourceUrls.add(new URL(fakeFile));
192+
Set<URL> sinkUrls = new HashSet<>();
193+
sinkUrls.add(new URL(consoleFile));
188194
TaskGroupImmutableInformation taskGroupImmutableInformation =
189195
new TaskGroupImmutableInformation(
190196
jobId,
@@ -195,9 +201,7 @@ public void testClassloaderSplit() throws IOException {
195201
Arrays.asList(
196202
nodeEngine.getSerializationService().toData(testTask1),
197203
nodeEngine.getSerializationService().toData(testTask2)),
198-
Arrays.asList(
199-
Collections.singleton(new URL(fakeFile)),
200-
Collections.singleton(new URL(consoleFile))),
204+
Arrays.asList(sourceUrls, sinkUrls),
201205
Arrays.asList(emptySet(), emptySet()));
202206

203207
Data data = nodeEngine.getSerializationService().toData(taskGroupImmutableInformation);

0 commit comments

Comments
 (0)