请教 Yarn Per-Job 模式下，多个 executeAsync() 与 execute() 的区别

Yarn Per-Job 模式下，如果一个 flink 的应用中有两个 execute()，第二个Job启动不了。但是如果换成 executeAsync()就可以，我还没有想清楚为什么... -- Sent from: http://apache-flink.147419.n8.nabble.com/

Re: 回复：现在的flink1.12支持批流混合的作业吗？

谢谢老哥的回复。 可能我举得例子不是很好。我其实还是单纯的想问 使用DataStream的API，支不支持同一个应用中批流混合的作业（比如一个应用多个job，job有流有批）... 就我目前看到的文档中来看，是支持的。但是指定execution.runtime-mode为批、流、自动模式后，作业的执行还是会依照批和流其中一种模式，所以在性能上不能很好的支持批流混合的作业。 不知道我理解的是否正确，学生狗一只。 祝好， 耳朵 -- Sent from: http://apache-flink.147419.n8.nabble.com/

现在的flink1.12支持批流混合的作业吗？

嗨，您好！ 比如我想在一个应用里同时跑实时数据清洗和历史数据清洗（批作业和流作业混合）？ 类似下图的应用。 祝好， 耳朵 -- Sent from: http://apache-flink.147419.n8.nabble.com/

batch模式broadcast hash join为什么会有数据丢失

Data loss exception using hash join in batch mode

Data loss exception using hash join in batch mode

batch模式broadcast hash join为什么会有数据丢失

batch模式broadcast hash join为什么会有数据丢失