AI 助理
备案控制台
开发者社区 问答 正文

flink sql 写入hive问题

我用flink sql实时写入hive表时发现sink的并行度为1？ 我看了FileSystemTableSink类的226行，确实设置了1，这是为什么呢？ 并行度1的写入速度很慢*来自志愿者整理的flink

展开
收起
毛毛虫雨 2021-12-06 15:28:34 632 分享 版权

版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。

1 条回答
写回答
取消 提交回答
  • 雪哥哥

    writer的并行度是根据上游并行度来的

    committer的并行度才是1*来自志愿者整理的flink

    2021-12-06 16:02:00
    赞同 展开评论
问答分类：
SQL HIVE 流计算 实时计算 Flink版
问答标签：
实时计算 Flink版hive 实时计算 Flink版SQL flink SQL SQL hive SQL flink
问答地址：
开发者社区 > 大数据 > 问答
相关问答
E-MapReduce通过hive jdbc方式向集群提交多条不同类型的sql任务会偶发报错 ...
135
1
0
阿里云E-MapReduce用自己搭建的DS，调用hive执行sql时，报这个错，是什么原因呢？
127
0
0
大数据计算MaxCompute 执行 Hive Sql 时，用的什么引擎啊，是Spark 吗？
101
1
0
hive ddl语句格式化报错com.alibaba.druid.sql.parser.Parser
384
2
0
druid解析hive数据库sql不支持set
195
1
0
E-MapReduce在beeline访问thriftserver执行sql查询hive数据报错
101
1
0
想问下有没有大佬尝试过Flink SQL，在kinit场景下批写hive表的呢？
67
1
0
flink读取kafka写入hive，sql和datastream混合写的，有谁遇到过吗？
159
0
0
请问是否有sql语句之间相互转换的应用，比如mysql到oracle，或者oracle到hive。
1246
9
0
我用flink sql 的like，居然报不支持，用了hive方言还是报错？
312
1
0