flink-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Stephan Ewen <se...@apache.org>
Subject Re: Option to disable chaining?
Date Mon, 08 Feb 2016 19:02:52 GMT
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 <code@greghogan.com> wrote:

> When is this useful in streaming?
>
> On Mon, Feb 8, 2016 at 1:46 PM, Nick Dimiduk <ndimiduk@apache.org> 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 <code@greghogan.com> wrote:
> >
> > > Is it possible to force operator chaining to be disabled? Similar to
> how
> > > object reuse can be enabled or disabled?
> > >
> > > Greg
> > >
> >
>

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