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 macro
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:
>
> I could reproduce t
rg.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] =createTypeInformation[Int]
v
read data
import org.apache.flink.api.scala._
import org.apache.flink.api.java.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.
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 priority.
>
> Timo
>
> Am
)
BR, Alberto
2016-10-07 21:46 GMT+02:00 Fabian Hueske <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.apache.flink.api.java.io
&l
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 org.apache.flink.api.common.type
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 Alber
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 use
