Re: java.io.IOException: Couldn't access resultSet

2016-06-06 Thread Chesnay Schepler
Thanks On 5 June 2016 at 18:26, David Olsen mailto:davidolsen4...@gmail.com>> wrote: I remove the open method when constructing jdbc input format, but I still obtain "couldn't access resultSet" erro

Re: java.io.IOException: Couldn't access resultSet

2016-06-06 Thread David Olsen
eable). Are there any additional functions required to be >>> executed before StreamExecutionEnvironment creates jdbc input? >>> >>> Thanks >>> >>> >>> On 5 June 2016 at 18:26, David Olsen < >

Re: java.io.IOException: Couldn't access resultSet

2016-06-06 Thread Chesnay Schepler
I remove the open method when constructing jdbc input format, but I still obtain "couldn't access resultSet" error. Caused by: java.io.IOException: Couldn't access resultSet at org.apache.flink.api.java.io.jdbc.JDBCI

Re: java.io.IOException: Couldn't access resultSet

2016-06-06 Thread Aljoscha Krettek
jdbc input? >> >> Thanks >> >> >> On 5 June 2016 at 18:26, David Olsen wrote: >> >>> I remove the open method when constructing jdbc input format, but I >>> still obtain "couldn't access resultSet" error. >>> >>&

Re: java.io.IOException: Couldn't access resultSet

2016-06-05 Thread Stephan Ewen
ns required to be > executed before StreamExecutionEnvironment creates jdbc input? > > Thanks > > > On 5 June 2016 at 18:26, David Olsen wrote: > >> I remove the open method when constructing jdbc input format, but I still >> obtain "couldn't access resu

Re: java.io.IOException: Couldn't access resultSet

2016-06-05 Thread David Olsen
before StreamExecutionEnvironment creates jdbc input? Thanks On 5 June 2016 at 18:26, David Olsen wrote: > I remove the open method when constructing jdbc input format, but I still > obtain "couldn't access resultSet" error. > > Caused by: java.io.IOException: Cou

Re: java.io.IOException: Couldn't access resultSet

2016-06-05 Thread David Olsen
I remove the open method when constructing jdbc input format, but I still obtain "couldn't access resultSet" error. Caused by: java.io.IOException: Couldn't access resultSet at org.apache.flink.api.java.io.jdbc.JDBCInputFormat.nextRecord(JDBCInpu

Re: java.io.IOException: Couldn't access resultSet

2016-06-05 Thread Chesnay Schepler
you are not supposed to call open yourselves. On 05.06.2016 11:05, David Olsen wrote: Following the sample on the flink website[1] to test jdbc I encountered an error "Couldn't access resultSet". It looks like the nextRecord is called before open() function. However I've called open() when I c

java.io.IOException: Couldn't access resultSet

2016-06-05 Thread David Olsen
Following the sample on the flink website[1] to test jdbc I encountered an error "Couldn't access resultSet". It looks like the nextRecord is called before open() function. However I've called open() when I construct jdbc input format. Any functions I should call before job submission? def jdbc()=