Skip to content

Commit 4464984

Browse files
committed
Fix port retrival
1 parent 74001a2 commit 4464984

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

flink-connector-clickhouse-base/src/test/java/org/apache/flink/connector/test/embedded/clickhouse/ClickHouseServerForTests.java

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -30,11 +30,11 @@ public class ClickHouseServerForTests {
3030

3131
public static void initConfiguration() {
3232
if (isCloud) {
33-
host = System.getenv("INTEGRATIONS_TEAM_TESTS_CLOUD_HOST_SMT");
34-
port = Integer.parseInt(System.getenv("INTEGRATIONS_TEAM_TESTS_CLOUD_PASSWORD_SMT"));
33+
host = System.getenv("CLICKHOUSE_CLOUD_HOST");
34+
port = Integer.parseInt(ClickHouseTestHelpers.HTTPS_PORT);
3535
database = System.getenv("CLICKHOUSE_DATABASE");
3636
username = System.getenv("CLICKHOUSE_USERNAME");
37-
password = System.getenv("CLICKHOUSE_PASSWORD");
37+
password = System.getenv("CLICKHOUSE_CLOUD_HOST");
3838
} else {
3939
host = db.getHost();
4040
port = db.getFirstMappedPort();

0 commit comments

Comments
 (0)