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 <twal...@apache.org>:
> 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.JDBCInputFormatimport
> org.apache.flink.api.table.Rowimport
> org.apache.flink.api.table.typeutils.RowTypeInfoimport
> 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")
> .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:[image: 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>:
>>
>> 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 Alberto Ramón <a.ramonporto...@gmail.com>:
>>>
>>> I want use CreateInput + buildJDBCInputFormat to acces to database on
>>> SCALA
>>> PB1:
>>>
>>> import org.apache.flink.api.scala.io.jdbc.JDBCInputFormatError:(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:[image: Imágenes integradas 1]
>>>
>>> I tried to download code from git and recompile, also
>>>
>>> --
> Freundliche Grüße / Kind Regards
>
> Timo Walther
>
> Follow me: @twalthrhttps://www.linkedin.com/in/twalthr
>
>
