做实时数仓，sql怎么保证分topic区有序
就是我用 flink sql 通过ddl读取和写入kafka怎么设置并行度呢？ flink sql 通过ddl写入kafka怎么自定义分区呢？
这样才能保证提高消费能力。和保证数据有序。 但是好像没有发现再table模式 或者sql 语句上设置 或者做自定义分区。*来自志愿者整理的flink邮件归档
展开
收起
1
条回答
写回答
写回答
-
sql似乎不支持相关的设置，可以通过env或配置文件设置所有蒜子的并行度。
你可以试试流转表，可以做到细粒度的控制。*来自志愿者整理的flink邮件归档
2021-12-07 16:17:22赞同 展开评论 打赏
版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
相关问答
