Re: dynamic streams and patterns

On Mon, Jul 25, 2016 at 10:09 AM, Claudia Wegmann wrote: > To 3) Would an approach similar to King/RBEA even be possible combined with > Flink CEP? As I understand, Patterns have to be defined in Java code and > therefore have to be recompiled? Do I overlook something

WG: dynamic streams and patterns

to be recompiled? Do I overlook something important? Thx for some input. Best, Claudia Von: Claudia Wegmann Gesendet: Freitag, 15. Juli 2016 12:58 An: 'user@flink.apache.org' <user@flink.apache.org> Betreff: AW: dynamic streams and patterns Hey Robert, thanks for the valuable input.

AW: dynamic streams and patterns

Flink to stand upside down ;)? To 4) What do you think would an upper limit for the number of streams in one job be? Thx again and best wishes, Claudia Von: Robert Metzger [mailto:rmetz...@apache.org] Gesendet: Donnerstag, 14. Juli 2016 16:26 An: user@flink.apache.org Betreff: Re: dynamic streams

Re: dynamic streams and patterns

Hi Claudia, 1) What do you mean by dynamically adding? In standalone mode (which you would probably use with Docker images), you can just start additional TaskManagers, which will connect to a JobManager. So you could implement some monitoring to start new TaskManagers as soon as they are needed.

dynamic streams and patterns

Hey everyone, I'm quite new to Apache Flink. I'm trying to build a system with Flink and wanted to hear your opinion and whether the proposed architecture is even possible with Flink. The environment for the system will be a microservice architecture handling messaging via async events. I