1515import java .util .List ;
1616
1717public class FlinkTests {
18-
19- // "/Users/mzitnik/clickhouse/dev/integrations/flink-connector-clickhouse/examples/maven/covid/target/covid-1.0-SNAPSHOT.jar";
18+ static int NUMBERS_OF_RECORDS = 100000 ;
2019 static String flinkVersion = "latest" ;
2120 @ BeforeAll
2221 public static void setUp () throws Exception {
@@ -101,10 +100,7 @@ void testFlinkCluster() throws Exception {
101100 .withFlinkVersion (flinkVersion );
102101
103102 Cluster cluster = builder .build ();
104- System .out .println (cluster .getDashboardPort ());
105- System .out .println (cluster .getDashboardUrl ());
106103 String jarId = cluster .uploadJar (jarLocation );
107- System .out .println (jarId );
108104 List <String > jars = cluster .listAllJars ();
109105 String jobId = cluster .runJob (jars .get (0 ),
110106 "com.clickhouse.example.covid.DataStreamJob" ,
@@ -125,15 +121,12 @@ void testFlinkCluster() throws Exception {
125121 String state = cluster .jobStatus (jobId );
126122 while (state .equalsIgnoreCase ("RUNNING" )) {
127123 state = cluster .jobStatus (jobId );
128- System .out .println (state );
129124 int count = ClickHouseServerForTests .countRows (tableName );
130- if (count == 100000 )
125+ if (count == NUMBERS_OF_RECORDS )
131126 break ;
132- System .out .println (count );
133127 Thread .sleep (2000 );
134128 }
135129 int count = ClickHouseServerForTests .countRows (tableName );
136- System .out .println (count );
137- Assert .assertEquals (100000 , count );
130+ Assert .assertEquals (NUMBERS_OF_RECORDS , count );
138131 }
139132}
0 commit comments