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
io <http://org.apache.flink.api.java.io>.jdbc.JDBCInputFormat import org.apache.flink.api.table.Row import org.apache.flink.api.table.typeutils.RowTypeInfo import org.apache.flink.api.common.typeinfo.{BasicTypeInfo, TypeInformation} var stringColum: TypeInformation[Int] =createTypeInform

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
-07 21:46 GMT+02:00 Fabian Hueske <fhue...@gmail.com <mailto:fhue...@gmail.com>>: As the exception says the class org.apache.flink.api.scala.io <http://org.apache.flink.api.scala.io>.jdbc.JDBCInputFormat does not exist. You have to do: import org.apa

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

jdbc.JDBCInputFormat

2016-10-07 Thread Alberto Ramón
I want use CreateInput + buildJDBCInputFormat to acces to database on SCALA PB1: import org.apache.flink.api.scala.io.jdbc.JDBCInputFormat Error:(25, 37) object jdbc is not a member of package org.apache.flink.api.java.io import org.apache.flink.api.java.io.jdbc.JDBCInputFormat Then, I can't