This is an automated email from the ASF dual-hosted git repository.
wanghailin pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/seatunnel.git
The following commit(s) were added to refs/heads/dev by this push:
new a50a8b925f [Chore] delete chinese desc in code (#8306)
a50a8b925f is described below
commit a50a8b925fe6a0e88e9588eabfc646b6ba8be5b9
Author: Jast <[email protected]>
AuthorDate: Mon Dec 16 19:15:27 2024 +0800
[Chore] delete chinese desc in code (#8306)
---
.../seatunnel/connectors/seatunnel/clickhouse/util/ClickhouseProxy.java | 1 -
1 file changed, 1 deletion(-)
diff --git
a/seatunnel-connectors-v2/connector-clickhouse/src/main/java/org/apache/seatunnel/connectors/seatunnel/clickhouse/util/ClickhouseProxy.java
b/seatunnel-connectors-v2/connector-clickhouse/src/main/java/org/apache/seatunnel/connectors/seatunnel/clickhouse/util/ClickhouseProxy.java
index a75c73f716..4074760c23 100644
---
a/seatunnel-connectors-v2/connector-clickhouse/src/main/java/org/apache/seatunnel/connectors/seatunnel/clickhouse/util/ClickhouseProxy.java
+++
b/seatunnel-connectors-v2/connector-clickhouse/src/main/java/org/apache/seatunnel/connectors/seatunnel/clickhouse/util/ClickhouseProxy.java
@@ -398,7 +398,6 @@ public class ClickhouseProxy {
}
public boolean isExistsData(String tableName) throws ExecutionException,
InterruptedException {
- // 定义查询数据的SQL语句
String queryDataSql = "SELECT count(*) FROM " + tableName;
try (ClickHouseResponse response =
clickhouseRequest.query(queryDataSql).executeAndWait()) {
return response.firstRecord().getValue(0).asInteger() > 0;