This is an automated email from the ASF dual-hosted git repository. chesnay pushed a commit to branch pull/19923/head in repository https://gitbox.apache.org/repos/asf/flink.git
commit df9c887445a1e22550d3216ebe37d8d73c953e98 Author: Chesnay Schepler <ches...@apache.org> AuthorDate: Wed Sep 14 15:34:39 2022 +0200 rebase --- .../src/test/java/SqlClientITCase.java | 18 ++++++++++++------ 1 file changed, 12 insertions(+), 6 deletions(-) diff --git a/flink-end-to-end-tests/flink-sql-client-test/src/test/java/SqlClientITCase.java b/flink-end-to-end-tests/flink-sql-client-test/src/test/java/SqlClientITCase.java index 1f8dd6dd8c1..894c581fded 100644 --- a/flink-end-to-end-tests/flink-sql-client-test/src/test/java/SqlClientITCase.java +++ b/flink-end-to-end-tests/flink-sql-client-test/src/test/java/SqlClientITCase.java @@ -16,10 +16,12 @@ * limitations under the License. */ +import org.apache.flink.connector.testframe.container.FlinkContainers; +import org.apache.flink.connector.testframe.container.FlinkContainersSettings; +import org.apache.flink.connector.testframe.container.TestcontainersSettings; import org.apache.flink.connector.upserttest.sink.UpsertTestFileUtil; +import org.apache.flink.test.util.SQLJobSubmission; import org.apache.flink.tests.util.TestUtils; -import org.apache.flink.tests.util.flink.SQLJobSubmission; -import org.apache.flink.tests.util.flink.container.FlinkContainers; import org.apache.flink.util.DockerImageVersions; import org.apache.kafka.clients.producer.KafkaProducer; @@ -75,10 +77,14 @@ public class SqlClientITCase { public final FlinkContainers flink = FlinkContainers.builder() - .setNumTaskManagers(1) - .setNetwork(NETWORK) - .setLogger(LOG) - .dependsOn(KAFKA) + .withFlinkContainersSettings( + FlinkContainersSettings.builder().numTaskManagers(1).build()) + .withTestcontainersSettings( + TestcontainersSettings.builder() + .network(NETWORK) + .logger(LOG) + .dependsOn(KAFKA) + .build()) .build(); @TempDir private File tempDir;