flink流写入oracle非常慢,因为流写入使用的是自定的sinkFunction,所以也是用的jdbc,但是效率还不如java效率高
ps = conn.prepareStatement(mergerSql);
conn.setAutoCommit(false);
for(int i=0;i<3000;i++) {
fillPs(ps,random);
}
ps.executeBatch();
conn.commit();
ps.close();
在executebatch的时候非常慢,用java代码执行效率反而很高,这flink里是有什么机制影响吗?
在executebatch的时候非常慢,用java代码执行效率反而很高,这flink里是有什么机制影响吗?
写入前还做了其他处理,比如转换,以及窗口时间设置等,都会影响时间。
如有帮助,请采纳!