You are viewing a plain text version of this content. The canonical link for it is here.

Posted to user-zh@flink.apache.org by me <me...@lishiyu.cn> on 2020/10/09 06:59:36 UTC

flink1.11流式写入hive速度慢的问题

flink1.11 将datastream转为table之后，再流式的写入hive表中，发现写入速度只有几十条每秒
val chaitin_test = tableEnv.fromDataStream(dataStream,'test)
chaitin_test.printSchema()
tableEnv.executeSql("insert into chaitin_test select test from " + chaitin_test)