Re: Calculate a 4 hour time window for sum,count with sum and count output every 5 mins

No, there is no specific reason. I am using it because I am computing the HyperLogLog over a window. *--* *-- Felipe Gutierrez* *-- skype: felipe.o.gutierrez* *--* *https://felipeogutierrez.blogspot.com * On Mon, Jul 1, 2019 at 12:34 AM Vijay Balakrishnan

Re:Re: About "Flink 1.7.0 HA based on zookeepers "

Hi,Wang: Thank you very much for answering my question! I hope to start multiple jobmanagers on kubernete, because according to my understanding in the document of jobmanager_high_availability, the standalone mode should be that the jobmanager can be replaced seamlessly when the fault no

Re: Calculate a 4 hour time window for sum,count with sum and count output every 5 mins

Hi Felipe, Thanks for the example. I will try a variation of that for mine. Is there a specific reason to use the HyperLogLogState ? Vijay On Tue, Jun 18, 2019 at 3:00 AM Felipe Gutierrez < felipe.o.gutier...@gmail.com> wrote: > Hi Vijay, > > I managed by using > "ctx.timerService().registerProc

Connection refused while trying to query state

Hi, I am trying to query state (cluster 1.8.0 is running on my local machine) . I do see in the logs "Started the Queryable State Proxy Server @ ...". but when I am trying to query the state from the client , val descriptor = new ValueStateDescriptor("queryable-state", Types.CASE_CLASS[State]) cli

Flink question

I have four physical nodes with docker installed on each of them. I configured Mesos,Flink,Zookeeper,Hadoop and Marathon on docker of each one. I had already had three nodes,one slave and two masters, that I had run Flink on Marathon and its UI had been run without any problems. After that, I ch

Weekly Community Update 2019/26

Dear community, this weeks community digest with updates on Flink 1.8.1 & Flink 1.9.0, another thread on our development process and a few API related threads. I still include older threads from time to time. Enjoy! As always, please feel free to add additional updates and news to this thread! F