#flink

Flink Side Output 收集不到数据的问题

在 SideOutput 使用过程中，如果要想数据被收集到 OutputTag 中然后 getSideOutput() 获取一个新的流的话，在 context.output() 收集数据的算子之后不能再有算子，必须生成一个新的对象，不然不会有数据输出。在下面代码中，process1 的数据可以正常输出，但 process2 因为后面还有 map 函数，所以数据并没有被输出。 public class StreamingJob { public static void main(Strin...