Re: Flink Session Window to enrich Event with unique id

Please help me to implement the above logic. On Mon, Mar 2, 2020 at 4:47 PM aj wrote: > Hi, > Is using the session window to implement the above logic is good idea or i > should use process function. > > On Sun, Mar 1, 2020 at 11:39 AM aj wrote: > >> Hi , >> >> I am working on a use case where

Re: History server UI not working

Hey Peter, I tried reproducing the error, and for a second, I though the 1.10 release really broke the web ui, because I saw a pretty similar error. However after clearing the cache, the error was gone. Are you sure that you cleared the cache of your browser? I have also asked the main contributo

Re: Backpressure and 99th percentile latency

Thanks for the feedback Felipe! Regarding with your below concern: > Although I think it is better to use outPoolUsage and inPoolUsage according > to [1]. However, in your opinion is it better (faster to see) to use > inputQueueLength and > outputQueueLength or outPoolUsage and inPoolUsage to m

Deploy flink-dist_2.11 fail in flink-10.0.0

I am testing flink-1.10.0. When I deploy it to our repositories for snapshot, the build is failing in flink-dist_2.11. The error is as follows. Can anyone help me? [2020-03-07T10:03:19.619Z] [WARNING] Assembly file: /home/jenkins/slave/flink-1-10-0-release-2593/SRC/flink-dist/target/flink-1.