Skip to content

Commit 8d847d0

Browse files
committed
Merge remote-tracking branch 'origin/v1.8.0_dev_feature_impala' into v1.8.0_dev
# Conflicts: # README.md
2 parents d1748d2 + 012bfae commit 8d847d0

File tree

2 files changed

+5
-3
lines changed

2 files changed

+5
-3
lines changed

docs/impalaSide.md

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -89,6 +89,8 @@ create table sideTable(
8989

9090
## 6.分区样例
9191

92+
注:分区字段放在最后面,如下,name是分区字段,放在channel,xccount字段的后面
93+
9294
```
9395
create table sideTable(
9496
channel varchar,

impala/impala-side/impala-async-side/src/main/java/com/dtstack/flink/sql/side/impala/ImpalaAsyncReqRow.java

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -77,9 +77,9 @@ public JsonObject getClientConfig() {
7777
.put("driver_class", IMPALA_DRIVER)
7878
.put("max_pool_size", DEFAULT_MAX_DB_CONN_POOL_SIZE)
7979
.put("provider_class", DT_PROVIDER_CLASS)
80-
.put("preferred_test_query", PREFERRED_TEST_QUERY_SQL)
81-
.put("idle_connection_test_period", DEFAULT_IDLE_CONNECTION_TEST_PEROID)
82-
.put("test_connection_on_checkin", DEFAULT_TEST_CONNECTION_ON_CHECKIN);
80+
.put("idle_connection_test_period", 300)
81+
.put("test_connection_on_checkin", DEFAULT_TEST_CONNECTION_ON_CHECKIN)
82+
.put("max_idle_time", 600);
8383

8484
return impalaClientConfig;
8585
}

0 commit comments

Comments
 (0)