[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:

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

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

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

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.

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,

[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:

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