Skip to content

Commit 5591bb9

Browse files
committed
Skip too many parts test on the cloud
1 parent 84412ce commit 5591bb9

File tree

1 file changed

+4
-1
lines changed

1 file changed

+4
-1
lines changed

flink-connector-clickhouse-base/src/test/java/org/apache/flink/connector/clickhouse/sink/ClickHouseSinkTests.java

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -30,6 +30,7 @@
3030
import java.util.List;
3131

3232
import static org.apache.flink.connector.test.embedded.clickhouse.ClickHouseServerForTests.countMerges;
33+
import static org.apache.flink.connector.test.embedded.clickhouse.ClickHouseServerForTests.isCloud;
3334

3435
public class ClickHouseSinkTests extends FlinkClusterTests {
3536

@@ -445,7 +446,9 @@ In this test, we lower the parts_to_throw_insert setting (https://clickhouse.com
445446
*/
446447
@Test
447448
void SimplePOJODataTooManyPartsTest() throws Exception {
448-
// TODO: needs to be extended to all types
449+
// this test is not running on cloud
450+
if (isCloud())
451+
return;
449452
String tableName = "simple_too_many_parts_pojo";
450453

451454
String dropTable = String.format("DROP TABLE IF EXISTS `%s`.`%s`", getDatabase(), tableName);

0 commit comments

Comments
 (0)