我目前正在使用apache flink作为我的硕士论文，我必须在一次迭代中对它进行多次分区。
我希望在处理时在相同的节点上有相同的数据，但我不知道如何才能做到这一点。我认为，flink总是会将数据再次任意发送到节点。
是否有可能多次调用，例如，partitionbyhash（…）并将数据放在同一节点上？
谢谢！