懂了,那我就大概知道怎么做了,感谢
在 2022-08-30 14:18:25,"yue ma" <mayuefi...@gmail.com> 写道: >hi >1) flink 内部的 state 算子之间是不可以共享的,所以你可能需要借助外部的存储(比如 redis)来做类似的事情 >2) 你可以看看 operatorState 的使用方式 >https://nightlies.apache.org/flink/flink-docs-master/docs/dev/datastream/fault-tolerance/state/#operator-state > > >曲洋 <quyanghao...@126.com> 于2022年8月30日周二 12:32写道: > >> 各位好, >> 我想请教两个问题: >> 1) flink的state是否可以在不同的算子共享,比如,第一个map我有一个state,到了第二个map我继续拿到这个state? >> 2) flink的state有没有不需要keyby的,因为想统计一个总量,还没有合适的key可以选择? >> >>