极客观点
研发管理
HarmonyOS
我在第一个map需要用到变量currentCenter，然后我输出的结果需要更新currentCenter（最后一个map），但是没办法更新，有什么办法更新吗？
flink DataStream算子中如何实时更新变量？
阅读 2.8k
撰写回答
你尚未登录，登录后可以
- 和开发者交流问题的细节
- 关注并接收问题和回答的更新提醒
- 参与内容的编辑和改进，让解决方法与时俱进
推荐问题
flink作业提交pyflink作业到yarn application报找不到python任务脚本,是我哪里配置错了吗？
flink作业提交pyflink作业到yarn application报找不到python任务脚本,我用下列命令启动：./flink run-application -t yarn-application \-Dyarn.application.name=flinkcdctestpython \-Dyarn.provided.lib.dirs="hdfs://nameservice1/pyflink/flink-dist-181" \-pyarch hdfs://nameservice1/pyflink/pyflink181.zip \-p...772 阅读
Shuffle错误对MapReduce数据处理结果是否会有影响？
发现在特定天的数据存在两种问题：1、表中部分记录重复2、表中部分记录缺失，同逻辑重跑后表的数据恢复以下为mr写的etl，正常情况下只有一个stage，最近一年也只发现这一次shuffle errors430 阅读
宣传栏
使用数据库、文件都可以解决此问题。但使得算法退化成频繁的io读取算法，所以最后采用了迭代流+广播流的解决方法，动态更新变量！更多介绍看文章：https://segmentfault.com/a/11...