Skip to content

Commit 012bfae

Browse files
committed
修改c3p0的相关参数,避免impala频繁连接报错问题
1 parent 09f9537 commit 012bfae

File tree

3 files changed

+7
-5
lines changed

3 files changed

+7
-5
lines changed

README.md

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -186,7 +186,7 @@ sh submit.sh -sql D:\sideSql.txt -name xctest -remoteSqlPluginPath /opt/dtstack
186186
* [kudu 结果表插件](docs/kuduSink.md)
187187
* [postgresql 结果表插件](docs/postgresqlSink.md)
188188
* [clickhouse 结果表插件](docs/clickhouseSink.md)
189-
* [impalahouse 结果表插件](docs/impalaSink.md)
189+
* [impala 结果表插件](docs/impalaSink.md)
190190

191191
### 2.3 维表插件
192192
* [hbase 维表插件](docs/hbaseSide.md)
@@ -198,7 +198,7 @@ sh submit.sh -sql D:\sideSql.txt -name xctest -remoteSqlPluginPath /opt/dtstack
198198
* [kudu 维表插件](docs/kuduSide.md)
199199
* [postgresql 维表插件](docs/postgresqlSide.md)
200200
* [clickhouse 维表插件](docs/clickhouseSide.md)
201-
* [impalahouse 维表插件](docs/impalaSide.md)
201+
* [impala 维表插件](docs/impalaSide.md)
202202

203203
## 3 性能指标(新增)
204204

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)