Re: Flink Couchbase

2020-08-24 Thread Vijayendra Yadav
Thanks Yang that helped. Sent from my iPhone > On Aug 24, 2020, at 8:44 PM, Yang Wang wrote: > >  > I think at least you have two different exceptions. > > > java.lang.Exception: Container released on a *lost* node > This usually means a Yarn nodemanager is down. So all the containers running

Re: Flink Couchbase

2020-08-24 Thread Yang Wang
I think at least you have two different exceptions. > java.lang.Exception: Container released on a *lost* node This usually means a Yarn nodemanager is down. So all the containers running on this node will be released and rescheduled to a new one. If you want to figure out the root cause, you need

Re: Flink Couchbase

2020-08-24 Thread Vijayendra Yadav
Another one - Exception in thread "FileCache shutdown hook" Exception: java.lang.OutOfMemoryError thrown from the UncaughtExceptionHandler in thread "FileCache shutdown hook" Regards, Vijay On Mon, Aug 24, 2020 at 1:04 PM Vijayendra Yadav wrote: > Actually got this message in rolledover contai

Re: Flink Couchbase

2020-08-24 Thread Vijayendra Yadav
Actually got this message in rolledover container logs: [org.slf4j.impl.Log4jLoggerFactory] Exception in thread "cb-timer-1-1" java.lang.OutOfMemoryError: Metaspace Exception in thread "Thread-16" java.lang.OutOfMemoryError: Metaspace Exception in thread "TransientBlobCache shutdown hook" java.lan

Flink Couchbase

2020-08-24 Thread Vijayendra Yadav
Hi Team, Running a flink job on Yarn, I am trying to make connections to couchbase DB in one of my map functions in Flink Streaming job. But my task manager containers keep failing and keep assigning new containers and not giving me an opportunity to get any useful logs. val cluster = Cluster.co

Re: flink couchbase sink

2020-04-29 Thread Robert Metzger
I saw there is a flink sink for couchbase: > https://github.com/isopropylcyanide/flink-couchbase-data-starter > > But it was for flink 1.6.0, and not got updated for some months. > > Do you know if there is another available flink sink for couchbase? > > Thank you. > > regards, > 令狐 >

flink couchbase sink

2020-04-22 Thread 令狐月弦
Greetings, We have been using couchbase for large scale data storage. I saw there is a flink sink for couchbase: https://github.com/isopropylcyanide/flink-couchbase-data-starter But it was for flink 1.6.0, and not got updated for some months. Do you know if there is another available flink