Re: jdbc.JDBCInputFormat

2016-10-12 Thread sunny patel
Hi guys, I am facing following error message in flink scala JDBC wordcount. could you please advise me on this? *Information:12/10/2016, 10:43 - Compilation completed with 2 errors and 0 warnings in 1s 903ms* */Users/janaidu/faid/src/main/scala/fgid/JDBC.scala* *Error:(17, 67) can't expand

Re: jdbc.JDBCInputFormat

2016-10-11 Thread Alberto Ramón
I will check it this nigth Thanks 2016-10-11 11:24 GMT+02:00 Timo Walther : > I have opened a PR (https://github.com/apache/flink/pull/2619). Would be > great if you could try it and comment if it solves you problem. > > Timo > > Am 10/10/16 um 17:48 schrieb Timo Walther: >

Re: jdbc.JDBCInputFormat

2016-10-11 Thread Timo Walther
I have opened a PR (https://github.com/apache/flink/pull/2619). Would be great if you could try it and comment if it solves you problem. Timo Am 10/10/16 um 17:48 schrieb Timo Walther: I could reproduce the error locally. I will prepare a fix for it. Timo Am 10/10/16 um 11:54 schrieb

Re: jdbc.JDBCInputFormat

2016-10-10 Thread Alberto Ramón
It's from Jun and Unassigned :( Is There a Workarround? I'm will try to contact with the reporter , Martin Scholl ) 2016-10-10 11:04 GMT+02:00 Timo Walther : > I think you already found the correct issue describing your problem ( > FLINK-4108). This should get higher

Re: jdbc.JDBCInputFormat

2016-10-10 Thread Timo Walther
I think you already found the correct issue describing your problem ( FLINK-4108). This should get higher priority. Timo Am 09/10/16 um 13:27 schrieb Alberto Ramón: After solved some issues, I connected with Kylin, but I can't read data import org.apache.flink.api.scala._ import

Re: jdbc.JDBCInputFormat

2016-10-09 Thread Alberto Ramón
After solved some issues, I connected with Kylin, but I can't read data import org.apache.flink.api.scala._ import org.apache.flink.api.java.io.jdbc.JDBCInputFormat import org.apache.flink.api.table.Row import org.apache.flink.api.table.typeutils.RowTypeInfo import

Re: jdbc.JDBCInputFormat

2016-10-07 Thread Fabian Hueske
As the exception says the class org.apache.flink.api.scala.io.jdbc.JDBCInputFormat does not exist. You have to do: import org.apache.flink.api.java.io.jdbc.JDBCInputFormat There is no Scala implementation of this class but you can also use Java classes in Scala. 2016-10-07 21:38 GMT+02:00