Re: Flink job hangs using rocksDb as backend

Thanks Stefan/Stephan/Nico, Indeed there are 2 problem. For the 2nd problem ,I am almost certain that explanation given by Stephan is the true as in my case as there number of timers are in millions. (Each for different key so I guess coalescing is not an option for me). If I simplify my problem,

Re: Flink job hangs using rocksDb as backend

RocksDB-based timers right now. > > Best, > Stefan > > Am 12.07.2018 um 14:54 schrieb shishal singh : > > Thanks Stefan/Stephan/Nico, > > Indeed there are 2 problem. For the 2nd problem ,I am almost certain that > explanation given by Stephan is the true as in my case

Re: Flink job hangs using rocksDb as backend

runtime.tasks.StreamTask.invoke(StreamTask.java:264)* > * at org.apache.flink.runtime.taskmanager.Task.run(Task.java:718)* > * at java.lang.Thread.run(Thread.java:748)* > > * Locked ownable synchronizers:* > > > Regards, > Shishal > > > On Thu, Jul 12, 2018 at 4:11

Flink CEP pattern with multiple temporal constraint

Hi Team, I have a scenario where I need to detect following pattern for a transaction. My basic transaction event look like this => *Transaction(id,status, eventTime)* Transaction goes through following state. *BEGIN -> COMPLETE (within 5 day, if this comes then no need to wait for PROCESSING)*

design flink cep pattern for transaction life cycle

0down votefavorite I have a scenario where I need to detect following pattern for a transaction. My basic transaction event look like this => *Transaction(id,status, time)* Transaction goes through following

Flink Elasticsearch connector 7 with SSL

Hi Flink community members, In my flink job, I am trying to use *elasticsearch7* connector. I could not find a way to communicate over SSL when using *Elasticsearch7SinkBuilder* Am I missing something? Also there is an deprecated class *ElasticsearchSink.Builder* where it has *RestClientFactory*