Fix network creation for cloud

mzitnik · mzitnik · commit 4e8638352f5a · 2025-08-24T13:28:26.000+03:00
diff --git a/flink-connector-clickhouse-base/src/testFixtures/java/org/apache/flink/connector/test/embedded/clickhouse/ClickHouseServerForTests.java b/flink-connector-clickhouse-base/src/testFixtures/java/org/apache/flink/connector/test/embedded/clickhouse/ClickHouseServerForTests.java
@@ -86,6 +86,8 @@ public static void tearDown() {
     }
 
     public static Network getNetwork() {
+        if (isCloud())
+            return Network.newNetwork();
         return db.getNetwork();
     }
 

Original file line number	Diff line number	Diff line change
`@@ -86,6 +86,8 @@ public static void tearDown() {`
`86`	`86`	`}`
`87`	`87`
`88`	`88`	`public static Network getNetwork() {`
	`89`	`+ if (isCloud())`
	`90`	`+ return Network.newNetwork();`
`89`	`91`	`return db.getNetwork();`
`90`	`92`	`}`
`91`	`93`