Thank you ufuk. Yes it helps alot. Yardımın için teşekkürler.
On Jul 4, 2016 2:02 PM, "Ufuk Celebi" wrote:
> The data exchange mode has been introduced recently as a replacement
> for the pipeline break logic, which was buggy. I'm not too familiar
> with the optimizer, but I would expect everythi
The data exchange mode has been introduced recently as a replacement
for the pipeline break logic, which was buggy. I'm not too familiar
with the optimizer, but I would expect everything that goes back to
the DataExchangeMode to be correct. The rest should be an artifact of
the old pipeline breaker
Hi everybody,
I am trying to understand flink optimizer in DataSet api. But i dont
understant tempMode and breakPipeline properties. TempMode enum also has a
breakPipeline property but they both accessed and set in different places.
DagConnection.breakPipeline is used to select network io DataExch
