Re: Flink state

Hi Banu, Rocksdb is intelligently built to clear any un-useful state from its purview. So you should be good and any required cleanup will be automatically done by RocksDb itself. >From the current documentation, it looks quite hard to relate Flink Internal DS activity to RocksDB DS activity. In m

Re: Flink Slot request bulk is not fulfillable!

Hi Li, The error suggests that Job is not able to acquire the required TaskManager TaskSlots within the configured time duration of 5 minutes. Job Runs on the TaskManagers (Worker Nodes). Helpful Link - https://nightlies.apache.org/flink/flink-docs-master/docs/concepts/flink-architecture/#anatomy-

Re: Taskslots usage

Hi Ky Alexandre, I would recommend reading this section which explains slot sharing b/w tasks. Link Quote - By default, Flink allows subtasks to share slots even if they are >

Query on ProcessingTime Triggers on EventTime based window

Hi Community, We have the below use case, - We have to use EventTime for Windowing (Tumbling Window) and Watermarking. - We use *TumbingEventTimeWindows* for this - We have to continuously emit the results for Window every 1 minute. - We are planning to use *ContinousProcessi

Re: Customisable Triggers on Table API (Java)

Gentle Reminder on the query. On Wed, Mar 1, 2023 at 8:32 PM Kartikey Pant wrote: > Hi, > > We are using Table API with Flink (Java). Our use case requires us to use > Multiple Aggregate Functions most of which the Table API already supports. > However, when we went ahead with the Table APIs, we