[jira] [Created] (FLINK-7910) Generalize TestEnvironment/TestStreamEnvironment to be used with Flip-6 MiniCluster

Till Rohrmann created FLINK-7910: Summary: Generalize TestEnvironment/TestStreamEnvironment to be used with Flip-6 MiniCluster Key: FLINK-7910 URL: https://issues.apache.org/jira/browse/FLINK-7910 Pro

[jira] [Created] (FLINK-7909) Unify cluster creation for test bases

Till Rohrmann created FLINK-7909: Summary: Unify cluster creation for test bases Key: FLINK-7909 URL: https://issues.apache.org/jira/browse/FLINK-7909 Project: Flink Issue Type: Improvement

Re: Minimal HA Setup for Apache Flink

Hi, Your assumptions are mostly correct. 1. This is correct, but you can also run a non-YARN setup where you only have one JobManager if you have a system that will make sure to restart/keep alive this JobManager. This could either be some supervisor, or Kubernetes, or Mesos. You also probably

Re: Pattern change on runtime

Hi Aljoscha, Thank you for information 24 Eki 2017 17:32 tarihinde "Aljoscha Krettek" yazdı: Hi, Yes, currently the pattern of a CEP operator cannot be changed. You could manually implement this by using a ConnectedStream with a CoProcessFunction where the first input carries events and the se

Re: Pattern change on runtime

Hi, Yes, currently the pattern of a CEP operator cannot be changed. You could manually implement this by using a ConnectedStream with a CoProcessFunction where the first input carries events and the second input carries commands that change the patterns that you monitor. Best, Aljoscha > On 1

[jira] [Created] (FLINK-7908) Restructure the QS module to reduce client deps.

Kostas Kloudas created FLINK-7908: - Summary: Restructure the QS module to reduce client deps. Key: FLINK-7908 URL: https://issues.apache.org/jira/browse/FLINK-7908 Project: Flink Issue Type: