Open miaogr86 opened 4 years ago
hi,云邪大神: 问题1:实现交易按类别分组全量统计的需求。我想问下历史数据怎么处理?历史数据有几千万难道都要重新发到kafka吗?怎么处理历史数据并平滑的迁移到flink sql有什么好建议吗? https://flink.apache.org/2020/07/28/flink-sql-demo-building-e2e-streaming-application.html
问题2:接问题1,很多不同维度的统计需求,但是source都是一样的,可以同时输出不同维度的sink吗,多个sink好像会报错?
问题3:使用sql client怎么配置checkpoints?
非常感谢
hi,云邪大神: 问题1:实现交易按类别分组全量统计的需求。我想问下历史数据怎么处理?历史数据有几千万难道都要重新发到kafka吗?怎么处理历史数据并平滑的迁移到flink sql有什么好建议吗? https://flink.apache.org/2020/07/28/flink-sql-demo-building-e2e-streaming-application.html
问题2:接问题1,很多不同维度的统计需求,但是source都是一样的,可以同时输出不同维度的sink吗,多个sink好像会报错?
问题3:使用sql client怎么配置checkpoints?
非常感谢