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 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] =createTypeInformation[Int]
val DB_ROWTYPE =new RowTypeInfo(Seq(stringColum))
val inputFormat = JDBCInputFormat.buildJDBCInputFormat()
.setDrivername("org.apache.kylin.jdbc.Driver")
.setDBUrl("jdbc:kylin://172.17.0.2:7070/learn_kylin
<http://172.17.0.2:7070/learn_kylin>")
.setUsername("ADMIN")
.setPassword("KYLIN")
.setQuery("select count(distinct seller_id) as sellers from kylin_sales group by
part_dt order by part_dt")
.setRowTypeInfo(DB_ROWTYPE)
.finish()
val dataset =env.createInput(inputFormat)
dataset.print()
The error is:
Imágenes integradas 1
(I checked that queries and config are correct with SQuirriel)
(Isn't a connection problem, Because if I turn off database the error is different
"Reused Connection")
Can you see a problem in my code? (I found Flink 4108 unsolved issue,I don't
know if is related)
BR, Alberto
2016-10-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.apache.flink.api.java.io
<http://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 Alberto Ramón
<a.ramonporto...@gmail.com <mailto:a.ramonporto...@gmail.com>>:
I want use CreateInput + buildJDBCInputFormat to acces to
database on SCALA
PB1:
import org.apache.flink.api.scala.io
<http://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
<http://org.apache.flink.api.java.io> import
org.apache.flink.api.java.io
<http://org.apache.flink.api.java.io>.jdbc.JDBCInputFormat
Then, I can't use:
Imágenes integradas 1
I tried to download code from git and recompile, also
--
Freundliche Grüße / Kind Regards
Timo Walther
Follow me: @twalthr
https://www.linkedin.com/in/twalthr
