[flink] 03/16: rebase

[chesnay]

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;