flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Timo Walther <twal...@apache.org>
Subject Re: jdbc.JDBCInputFormat
Date Mon, 10 Oct 2016 09:04:17 GMT
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 <fhueske@gmail.com 
> <mailto:fhueske@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.ramonportoles@gmail.com <mailto:a.ramonportoles@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

Mime
View raw message