我已经编写了一个使用Guava缓存的Flink作业。缓存对象是在main()函数中调用的run()函数中创建和使用的。它类似于: run(some,params) //create and use Guava cache object here如果我以某种程度的并行性运行这个Flink作业,那么所有的并行任务会使用相同的缓
我使用广播模式连接两个流,并从一个到另一个读取数据。streamB.broadcast(broadcastStateDescriptor)
问题是在processElement函数中,状态有时是空的,有时不是。在将数据放入状态之前和之后,我尝试在processBroadcastElement中添加一些打印,结果如下1 - 2 .. all the way to