Skip to content

Commit 78f5131

Browse files
committed
[禁用vertx缓存][flinkSQL任务,设置结果表,提交运行中,停止该任务修改结果表,再次提交运行中,数据曲线变成两条,且新的结果表数据不正确][18063]
1 parent 267cd3f commit 78f5131

File tree

3 files changed

+10
-3
lines changed

3 files changed

+10
-3
lines changed

mysql/mysql-side/mysql-async-side/src/main/java/com/dtstack/flink/sql/side/mysql/MysqlAsyncReqRow.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -69,11 +69,12 @@ public void open(Configuration parameters) throws Exception {
6969
.put("idle_connection_test_period", DEFAULT_IDLE_CONNECTION_TEST_PEROID)
7070
.put("test_connection_on_checkin", DEFAULT_TEST_CONNECTION_ON_CHECKIN);
7171

72-
72+
System.setProperty("vertx.disableFileCPResolving", "true");
7373

7474
VertxOptions vo = new VertxOptions();
7575
vo.setEventLoopPoolSize(DEFAULT_VERTX_EVENT_LOOP_POOL_SIZE);
7676
vo.setWorkerPoolSize(DEFAULT_VERTX_WORKER_POOL_SIZE);
77+
vo.setFileResolverCachingEnabled(false);
7778
Vertx vertx = Vertx.vertx(vo);
7879
setRdbSQLClient(JDBCClient.createNonShared(vertx, mysqlClientConfig));
7980
}

oracle/oracle-side/oracle-async-side/src/main/java/com/dtstack/flink/sql/side/oracle/OracleAsyncReqRow.java

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -59,11 +59,14 @@ public void open(Configuration parameters) throws Exception {
5959
.put("provider_class", DT_PROVIDER_CLASS)
6060
.put("preferred_test_query", PREFERRED_TEST_QUERY_SQL)
6161
.put("idle_connection_test_period", DEFAULT_IDLE_CONNECTION_TEST_PEROID)
62-
.put("test_connection_on_checkin", DEFAULT_TEST_CONNECTION_ON_CHECKIN);;
62+
.put("test_connection_on_checkin", DEFAULT_TEST_CONNECTION_ON_CHECKIN);
63+
64+
System.setProperty("vertx.disableFileCPResolving", "true");
6365

6466
VertxOptions vo = new VertxOptions();
6567
vo.setEventLoopPoolSize(DEFAULT_VERTX_EVENT_LOOP_POOL_SIZE);
6668
vo.setWorkerPoolSize(DEFAULT_VERTX_WORKER_POOL_SIZE);
69+
vo.setFileResolverCachingEnabled(false);
6770
Vertx vertx = Vertx.vertx(vo);
6871
setRdbSQLClient(JDBCClient.createNonShared(vertx, oracleClientConfig));
6972
}

sqlserver/sqlserver-side/sqlserver-async-side/src/main/java/com/dtstack/flink/sql/side/sqlserver/SqlserverAsyncReqRow.java

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -57,11 +57,14 @@ public void open(Configuration parameters) throws Exception {
5757
.put("provider_class", DT_PROVIDER_CLASS)
5858
.put("preferred_test_query", PREFERRED_TEST_QUERY_SQL)
5959
.put("idle_connection_test_period", DEFAULT_IDLE_CONNECTION_TEST_PEROID)
60-
.put("test_connection_on_checkin", DEFAULT_TEST_CONNECTION_ON_CHECKIN);;
60+
.put("test_connection_on_checkin", DEFAULT_TEST_CONNECTION_ON_CHECKIN);
61+
62+
System.setProperty("vertx.disableFileCPResolving", "true");
6163

6264
VertxOptions vo = new VertxOptions();
6365
vo.setEventLoopPoolSize(DEFAULT_VERTX_EVENT_LOOP_POOL_SIZE);
6466
vo.setWorkerPoolSize(DEFAULT_VERTX_WORKER_POOL_SIZE);
67+
vo.setFileResolverCachingEnabled(false);
6568
Vertx vertx = Vertx.vertx(vo);
6669
setRdbSQLClient(JDBCClient.createNonShared(vertx, sqlserverClientConfig));
6770
}

0 commit comments

Comments
 (0)