Re: Flink JDBCOutputFormat logs wrong WARN message

2016-09-22 Thread Swapnil Chougule
Thanks Marton !! On Thu, Sep 22, 2016 at 4:36 PM, Márton Balassi wrote: > Done. Go ahead, Swapnil. > > Best, > Marton > > On Thu, Sep 22, 2016 at 1:03 PM, Swapnil Chougule > wrote: > >> Hi Fabian/ Chesnay >> Can anybody give me permission to assign JIRA (created for same.)? >> >> Thanks, >> Swa

Re: Flink JDBCOutputFormat logs wrong WARN message

2016-09-22 Thread Márton Balassi
Done. Go ahead, Swapnil. Best, Marton On Thu, Sep 22, 2016 at 1:03 PM, Swapnil Chougule wrote: > Hi Fabian/ Chesnay > Can anybody give me permission to assign JIRA (created for same.)? > > Thanks, > Swapnil > > On Tue, Sep 20, 2016 at 6:18 PM, Swapnil Chougule > wrote: > >> Thanks Chesnay & Fa

Re: Flink JDBCOutputFormat logs wrong WARN message

2016-09-22 Thread Swapnil Chougule
Hi Fabian/ Chesnay Can anybody give me permission to assign JIRA (created for same.)? Thanks, Swapnil On Tue, Sep 20, 2016 at 6:18 PM, Swapnil Chougule wrote: > Thanks Chesnay & Fabian for update. > I will create JIRA issue & open a pull request to fix it. > > Thanks, > Swapnil > > On Tue, Sep

Re: Flink JDBCOutputFormat logs wrong WARN message

2016-09-20 Thread Swapnil Chougule
Thanks Chesnay & Fabian for update. I will create JIRA issue & open a pull request to fix it. Thanks, Swapnil On Tue, Sep 20, 2016 at 2:54 PM, Fabian Hueske wrote: > Yes, the condition needs to be fixed. > > @Swapnil, would you like to create a JIRA issue and open a pull request to > fix it? >

Re: Flink JDBCOutputFormat logs wrong WARN message

2016-09-20 Thread Fabian Hueske
Yes, the condition needs to be fixed. @Swapnil, would you like to create a JIRA issue and open a pull request to fix it? Thanks, Fabian 2016-09-20 11:22 GMT+02:00 Chesnay Schepler : > I would agree that the condition should be changed. > > > On 20.09.2016 10:52, Swapnil Chougule wrote: > >> I c

Re: Flink JDBCOutputFormat logs wrong WARN message

2016-09-20 Thread Chesnay Schepler
I would agree that the condition should be changed. On 20.09.2016 10:52, Swapnil Chougule wrote: I checked following code in Flink JDBCOutputFormat while I was using in my project work. I found following snippet: @Override public void writeRecord(Row row) throws IOException {

Flink JDBCOutputFormat logs wrong WARN message

2016-09-20 Thread Swapnil Chougule
I checked following code in Flink JDBCOutputFormat while I was using in my project work. I found following snippet: @Override public void writeRecord(Row row) throws IOException { if (typesArray != null && typesArray.length > 0 && typesArray.length == row.productArity()) {