From fa645647d8a20f91c7599ebf9136ff3864e32eae Mon Sep 17 00:00:00 2001 From: hailin0 Date: Fri, 19 Jul 2024 14:30:53 +0800 Subject: [PATCH] fix --- .../engine/e2e/JobClientJobProxyIT.java | 7 ---- .../engine/e2e/SinkPlaceholderIT.java | 34 +++++++++++++++++++ 2 files changed, 34 insertions(+), 7 deletions(-) create mode 100644 seatunnel-e2e/seatunnel-engine-e2e/connector-seatunnel-e2e-base/src/test/java/org/apache/seatunnel/engine/e2e/SinkPlaceholderIT.java diff --git a/seatunnel-e2e/seatunnel-engine-e2e/connector-seatunnel-e2e-base/src/test/java/org/apache/seatunnel/engine/e2e/JobClientJobProxyIT.java b/seatunnel-e2e/seatunnel-engine-e2e/connector-seatunnel-e2e-base/src/test/java/org/apache/seatunnel/engine/e2e/JobClientJobProxyIT.java index 5d1e1471208..3d871adb5a9 100644 --- a/seatunnel-e2e/seatunnel-engine-e2e/connector-seatunnel-e2e-base/src/test/java/org/apache/seatunnel/engine/e2e/JobClientJobProxyIT.java +++ b/seatunnel-e2e/seatunnel-engine-e2e/connector-seatunnel-e2e-base/src/test/java/org/apache/seatunnel/engine/e2e/JobClientJobProxyIT.java @@ -126,11 +126,4 @@ public void testJobFailedWillThrowException() throws IOException, InterruptedExc .contains( "org.apache.seatunnel.engine.server.resourcemanager.NoEnoughResourceException")); } - - @Test - public void testSinkPlaceholder() throws IOException, InterruptedException { - Container.ExecResult execResult = - executeSeaTunnelJob("/fake_to_inmemory_with_sink_placeholder.conf"); - Assertions.assertNotEquals(0, execResult.getExitCode()); - } } diff --git a/seatunnel-e2e/seatunnel-engine-e2e/connector-seatunnel-e2e-base/src/test/java/org/apache/seatunnel/engine/e2e/SinkPlaceholderIT.java b/seatunnel-e2e/seatunnel-engine-e2e/connector-seatunnel-e2e-base/src/test/java/org/apache/seatunnel/engine/e2e/SinkPlaceholderIT.java new file mode 100644 index 00000000000..eee3705452f --- /dev/null +++ b/seatunnel-e2e/seatunnel-engine-e2e/connector-seatunnel-e2e-base/src/test/java/org/apache/seatunnel/engine/e2e/SinkPlaceholderIT.java @@ -0,0 +1,34 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You under the Apache License, Version 2.0 + * (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +package org.apache.seatunnel.engine.e2e; + +import org.junit.jupiter.api.Assertions; +import org.junit.jupiter.api.Test; +import org.testcontainers.containers.Container; + +import java.io.IOException; + +public class SinkPlaceholderIT extends SeaTunnelContainer { + + @Test + public void testSinkPlaceholder() throws IOException, InterruptedException { + Container.ExecResult execResult = + executeSeaTunnelJob("/fake_to_inmemory_with_sink_placeholder.conf"); + Assertions.assertNotEquals(0, execResult.getExitCode()); + } +}