flink-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From CPC <acha...@gmail.com>
Subject Re: DagConnection tempMode vs breakPipeline property
Date Mon, 04 Jul 2016 15:19:31 GMT
Thank you ufuk. Yes it helps alot. Yardımın için teşekkürler.
On Jul 4, 2016 2:02 PM, "Ufuk Celebi" <uce@apache.org> 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 everything that goes back to
> the DataExchangeMode to be correct. The rest should be an artifact of
> the old pipeline breaker logic and not be used any more. Does this
> help in any way?
>
> On Thu, Jun 16, 2016 at 4:46 PM, CPC <achalil@gmail.com> wrote:
> > 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
> DataExchangeMode.
> > Though i dont understand DagConnection.TempMode and also tempMode in
> > Channel. Could somebody explain why there is two different breakPipeline
> > property and the duty of TempMode. Thank you in advance.
>

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message