flink key by 的粒度问题 ，key by 是否可以带业务 ？
我们在开发flink job 的时候，用的算子来开发的。
有一个业务场景，需要使用 flink 按照 门店、商品维度 几十万个商品进行聚合计算销售数量(累加)
我们有一个开发是 通过 门店-商品 拼接为key进行 key by 然后进行聚合 ，这种就是key 就很细，运行不久就挂掉了
然后我们另一个开发 通过 key by 到 门店维度，然后在process 内部进行 拼接 门店_商品 到state ，这样子就稍微稳定一点。
问题：
key by 在这种场景应该怎么用比较好？ key by 能够带业务吗？ 如果这里随机key by 路由， 是否还能 进到一个 process ，然后 能够 按照 门店 商品 累加成功
展开
收起
版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
相关问答
