Skip to content

Commit e64b8a6

Browse files
committed
[Fix][Connector-V2][ClickHouse] Fix ClickHouse Bug (#7897)
1、When the ClickHouse connector is set to multi parallelism, the task extraction is completed but cannot be stopped normally [(#7897)](#7897) 2、Added E2E test cases for this issue [(#7897)](#7897) 3、Local developers want to observe **Job Progress Information** in a timely manner, Need to modify the following configuration.The configuration in config is invalid ``` seatunnel engine/seatunnel-engineer-common/src/main/resources/seatunnely.yaml ```
1 parent 1b80667 commit e64b8a6

File tree

2 files changed

+3
-3
lines changed

2 files changed

+3
-3
lines changed

seatunnel-e2e/seatunnel-connector-v2-e2e/connector-clickhouse-e2e/src/test/java/org/apache/seatunnel/connectors/seatunnel/clickhouse/ClickhouseIT.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -103,9 +103,9 @@ public void testClickhouse(TestContainer container) throws Exception {
103103

104104
@TestTemplate
105105
public void testSourceParallelism(TestContainer container) throws Exception {
106-
System.out.println("=========多并行度测试===========");
106+
LOG.info("=========多并行度测试===========");
107107
Container.ExecResult execResult = container.executeJob("/clickhouse_to_console.conf");
108-
System.out.println(execResult.getExitCode());
108+
Assertions.assertEquals(0, execResult.getExitCode());
109109
}
110110

111111
@BeforeAll

seatunnel-e2e/seatunnel-connector-v2-e2e/connector-clickhouse-e2e/src/test/resources/clickhouse_to_console.conf

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -19,7 +19,7 @@
1919
######
2020

2121
env {
22-
parallelism = 2
22+
parallelism = 3
2323
job.mode = "BATCH"
2424
}
2525

0 commit comments

Comments
 (0)