Adding timeout

Author: mzitnik

.github/workflows/tests.yaml

@@ -37,10 +37,4 @@ jobs:
           CLICKHOUSE_CLOUD_HOST: ${{ secrets.INTEGRATIONS_TEAM_TESTS_CLOUD_HOST_SMT }}
           CLICKHOUSE_CLOUD_PASSWORD: ${{ secrets.INTEGRATIONS_TEAM_TESTS_CLOUD_PASSWORD_SMT }}
         with:
-          arguments: test
-      - name: Upload Test Report
-        if: failure()  # Only upload if tests fail (optional)
-        uses: actions/upload-artifact@v4
-        with:
-          name: test-report
-          path: file:///home/runner/work/flink-connector-clickhouse/flink-connector-clickhouse/flink-connector-clickhouse-base/build/reports/tests/test/index.html
+          arguments: test

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

@@ -34,7 +34,7 @@ public static void initConfiguration() {
             host = System.getenv("CLICKHOUSE_CLOUD_HOST");
             port = Integer.parseInt(ClickHouseTestHelpers.HTTPS_PORT);
             database = String.format("flink_connector_test_%s", System.currentTimeMillis());
-            username = System.getenv("CLICKHOUSE_USERNAME");
+            username = ClickHouseTestHelpers.USERNAME_DEFAULT;
             password = System.getenv("CLICKHOUSE_CLOUD_PASSWORD");
         } else {
             LOG.info("Init ClickHouse Docker Configuration");

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

@@ -19,8 +19,8 @@ public class ClickHouseTestHelpers {
     public static final String DATABASE_DEFAULT = "default";
     public static final String USERNAME_DEFAULT = "default";
 
-    private static final int CLOUD_TIMEOUT_VALUE = 900;
-    private static final TimeUnit CLOUD_TIMEOUT_UNIT = TimeUnit.SECONDS;
+    private static final int TIMEOUT_VALUE = 60;
+    private static final TimeUnit TIMEOUT_UNIT = TimeUnit.SECONDS;
 
     public static String getClickhouseVersion() {
         String clickHouseVersion = System.getenv("CLICKHOUSE_VERSION");
@@ -39,6 +39,7 @@ public static Client getClient(boolean isCloud, String host, int port, boolean s
         return new Client.Builder().addEndpoint(Protocol.HTTP, host, port, ssl)
                                    .setUsername(username)
                                    .setPassword(password)
+                                   .setConnectTimeout(TIMEOUT_VALUE, TIMEOUT_UNIT.toChronoUnit())
                                    .build();
     }