flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From xie wei <jixia...@googlemail.com>
Subject how is data partitoned and distributed for connected stream
Date Tue, 22 Aug 2017 06:31:10 GMT
Hello Flinkļ¼Œ

assume there are two finite streams, stream1(s1)has only one event,
stream2(s2)have 100 events, the parallelism is 2.
Then doing stream1.connect(stream2).map().
How is the data partitioned and distributed to the CoMap instances? Is the
event from s1 only available in one of the CoMap instance?
Thank you!

Best regards

View raw message