Re: Flink 1.2-SNAPSHOT Bucketing Sink problem

2016-10-26 Thread Fabian Hueske
ucketingSink function in stable version? > > > Gönderen: Fabian Hueske <fhue...@gmail.com> > Gönderildi: 26 Ekim 2016 Çarşamba 20:38:56 > Kime: dev@flink.apache.org > Konu: Re: Flink 1.2-SNAPSHOT Bucketing Sink problem > > Hi Ozan, > > a NoSuchMethodError indica

Ynt: Flink 1.2-SNAPSHOT Bucketing Sink problem

2016-10-26 Thread Ozan DENİZ
. Is there any plan to release the BucketingSink function in stable version? Gönderen: Fabian Hueske <fhue...@gmail.com> Gönderildi: 26 Ekim 2016 Çarşamba 20:38:56 Kime: dev@flink.apache.org Konu: Re: Flink 1.2-SNAPSHOT Bucketing Sink problem H

Re: Flink 1.2-SNAPSHOT Bucketing Sink problem

2016-10-26 Thread Fabian Hueske
Hi Ozan, a NoSuchMethodError indicates a version mismatch. Since you are using a SNAPSHOT build it is likely that dependencies changed when you recompiled Flink or your job. You should make sure that you are using the same version (on SNAPSHOT the same commit) for jobs and cluster. Best, Fabian

Flink 1.2-SNAPSHOT Bucketing Sink problem

2016-10-26 Thread Ozan DENİZ
Hi everyone, We are currently using BucketingSink (Flink 1.2-SNAPSHOT) function for sink operation. The BucketingSink function was working correctly. However today, when I put the job on cluster I got this error; java.lang.NoSuchMethodError: