Re: Option to disable chaining?

Posted by Greg Hogan on Feb 08, 2016; 7:19pm
URL: http://deprecated-apache-flink-mailing-list-archive.368.s1.nabble.com/Option-to-disable-chaining-tp10209p10214.html

Is there a reason to not also implement this for batch processing? This
would allow object reuse to be truly disabled.

On Mon, Feb 8, 2016 at 2:02 PM, Stephan Ewen <[hidden email]> wrote:

> It may be useful for example when you have two MapFunctions and each does
> something CPU intensive, or communicates with an external service.
>
> Without chaining, you will have two threads and an elastic channel between
> the functions to buffer some records, which may help in such a case.
>
>
> On Mon, Feb 8, 2016 at 7:57 PM, Greg Hogan <[hidden email]> wrote:
>
> > When is this useful in streaming?
> >
> > On Mon, Feb 8, 2016 at 1:46 PM, Nick Dimiduk <[hidden email]>
> wrote:
> >
> > >
> > >
> >
> https://ci.apache.org/projects/flink/flink-docs-release-0.10/api/java/org/apache/flink/streaming/api/environment/StreamExecutionEnvironment.html#disableOperatorChaining()
> > >
> > > On Mon, Feb 8, 2016 at 10:34 AM, Greg Hogan <[hidden email]>
> wrote:
> > >
> > > > Is it possible to force operator chaining to be disabled? Similar to
> > how
> > > > object reuse can be enabled or disabled?
> > > >
> > > > Greg
> > > >
> > >
> >
>