请教union算子union多个source 流时的健壮性如何保证

[Fisher Xiang]

请问大家在使用 union算子union多个 stream时，比如 stream1.union(stream2, stream3, … stream
n) ，其中1到n分别来自不同的MQ 集群MQ1, MQ2… MQ n, 当其中几个集群挂掉时，
整个flink 应用都会重启，那么该场景下怎么可以做到 某几条stream 异常挂掉后，而不影响其他流的 union，让整个 flink继续运行呢？

[image: image.png]

BR
Fisher