forward()

2016-06-26 Thread Marius Melzer
Hi, I was reading a bit of code about partitioning and I have two questions about the forward() method of DataStream: 1) I was before under the impression that forwarding means sending records between operators with same parallelism always from partition 1 to 1, 2 to 2 etc. But this doesn't seem

[jira] [Created] (FLINK-4120) Lightweight fault tolerance through recomputing lost state

2016-06-26 Thread JIRA
Dénes Vadász created FLINK-4120: --- Summary: Lightweight fault tolerance through recomputing lost state Key: FLINK-4120 URL: https://issues.apache.org/jira/browse/FLINK-4120 Project: Flink Issue