Flink Kudu Connector

2019-11-25 Thread Rahul Jain
Hi, We are trying to use the Flink Kudu connector. Is there any documentation available that we can read to understand how to use it ? We found some sample code but that was not very helpful. Thanks, -rahul

Re: flink 1.7.2 freezes, waiting indefinitely for the buffer availability

2019-04-09 Thread Rahul Jain
We are also seeing something very similar. Looks like a bug. It seems to get stuck in LocalBufferPool forever and the job has to be restarted. Is anyone else facing this too? On Tue, Apr 9, 2019 at 9:04 PM Indraneel R wrote: > Hi, > > We are trying to run a very simple flink pipeline, which is

Flink kinesis connector crashes with daemon exception

2019-03-18 Thread Rahul Jain
We are using flink 1.7.2 on debian slim, and kubernetes as the resource manager. But when we deploy it, it works for an hour or so without any issues and then starts failing with the following error: java.lang.RuntimeException: Exception occurred while processing valve output watermark: at or