Apache Flink 中文用户邮件列表
Search
everywhere
only in this topic
Advanced Search
flink1.11流式写入hive速度慢的问题
Classic
List
Threaded
♦
♦
Locked
1 message
me
Reply
|
Threaded
Open this post in threaded view
♦
♦
|
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)
Free forum by Nabble
Edit this page