大家好: 我在flink中看到可以注册一个分布式缓存文件StreamExecutionEnvironment.registerCachedFile()然后可以广播到每个tm上给算子使用,那么我想问问,这个文件可以检测到文件更新了,然后会重新广播过去嘛?因为ip会可能会每天都有改变,所以ip库要每天都更新。
- 注册缓存文件的热更新问题 戴嘉诚
- Re: 注册缓存文件的热更新问题 Xintong Song
- Re: 注册缓存文件的热更新问题 Biao Liu
- 答复: 注册缓存文件的热更新问题 戴嘉诚
- Re: 注册缓存文件的热更新问题 Biao Liu
- 答复: 注册缓存文件的热更新问题 戴嘉诚