[jira] [Created] (FLINK-9175) Flink CEP with Checkpointing alway failed

godfrey johnson created FLINK-9175: -- Summary: Flink CEP with Checkpointing alway failed Key: FLINK-9175 URL: https://issues.apache.org/jira/browse/FLINK-9175 Project: Flink Issue Type: Impro

Flink 1.3.2 with CEP Pattern, Memory usage increases results in OOM

I am using Flink 1.3.2 CEP pattern to detect a frequently occurring condition. On scale testing this pattern with 10k events per minute, memory leak happens finally OOM. I found a related JIRA FLINK-7606 where it mentioned to specifiying EventTime as streamTimeCharacteristic. I have also config

Re: Documentation glitch w/AsyncFunction?

Sounds good to me. On Sat, Apr 14, 2018 at 9:55 AM, Ken Krugler wrote: > Hi Ted, > > Thanks - yes regarding renaming the variable, and changing the type. > > The other issue is that most clients return a Future, not a > CompletableFuture. > > So should I do the bit of extra code to show using a

Re: Documentation glitch w/AsyncFunction?

Hi Ted, Thanks - yes regarding renaming the variable, and changing the type. The other issue is that most clients return a Future, not a CompletableFuture. So should I do the bit of extra code to show using a CompletableFuture with a Future? — Ken > On Apr 14, 2018, at 9:13 AM, Ted Yu wrote:

Re: Documentation glitch w/AsyncFunction?

bq. resultFuture.thenAccept( (String result) -> { I think the type of variable for the above call should be CompletableFuture. Meaning, the variable currently named resultFuture should be renamed so that the intention is clearer. bq. resultFuture.complete(Collections.singlet

Documentation glitch w/AsyncFunction?

Hi devs, https://ci.apache.org/projects/flink/flink-docs-release-1.4/dev/stream/operators/asyncio.html Has this example of asyncInvoke: > @Override > public void asyncInvoke(final String str, fi

[jira] [Created] (FLINK-9174) The type of state created in ProccessWindowFunction.proccess() is inconsistency

Sihua Zhou created FLINK-9174: - Summary: The type of state created in ProccessWindowFunction.proccess() is inconsistency Key: FLINK-9174 URL: https://issues.apache.org/jira/browse/FLINK-9174 Project: Flin

Re: Support for out-of-the-box external catalog for SQL Client

Great, Thank you Shuyi and Rong! 2018-04-14 3:03 GMT+02:00 Rong Rong : > Thanks Peter, Fabian & Shuyi for the input. > > I have also created a task https://issues.apache.org/ > jira/browse/FLINK-9172. > Then we can have external catalog factory support on SQL-Client that works > with the abstract