Hi,
there is no guarantee on the order in which the elements are processed. So
it can happen that most elements from input one get processed before
elements from the feedback get processed. In case of an infinite first
input this will not happen, of of course.
For understanding what's going on it
Can anyone help me understand how the out.collect() and the corresponding
broadcast) is working?
--
View this message in context:
http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Unexpected-behaviour-in-datastream-broadcast-tp6848p6925.html
Sent from the Apache Flink User Mai
Hi,
I am running this following sample code to understand how iteration and
broadcast works in streaming context.
final StreamExecutionEnvironment env =
StreamExecutionEnvironment.getExecutionEnvironment();
env.setParallelism(4);
long i = 5;
Data
