Hey Geoffrey,
that's great to hear!
Random.nextInt() should suffice; but this is only done twice per
operator anyway so i wouldn't worry too much about it.
Regards,
Chesnay
On 25.10.2016 17:52, Geoffrey Mon wrote:
Hello Chesnay,
Thank you, this solves the last problem that I had with my pr
Hello Chesnay,
Thank you, this solves the last problem that I had with my project!
I added code to append a random UUID to each data channel. (see
https://github.com/GEOFBOT/flink/commit/b94b1249c4a014d8d1e412f7647ff192f3621b10)
However, is a UUID overkill? We only need the channel to be unique f
Hey Geoffrey,
I believe what we got here is that multiple operators are sending data
over the same channel.
The data transfer between the java and python processes uses
memory-mapped files. The file
name is based on the ID of the set and the subtask index of the operator
and thus determinist
