I will check it this nigth Thanks
2016-10-11 11:24 GMT+02:00 Timo Walther <twal...@apache.org>: > 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 the error locally. I will prepare a fix for it. > > Timo > > Am 10/10/16 um 11:54 schrieb 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 <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 >> >> -- > Freundliche Grüße / Kind Regards > > Timo Walther > > Follow me: @twalthrhttps://www.linkedin.com/in/twalthr > > -- > Freundliche Grüße / Kind Regards > > Timo Walther > > Follow me: @twalthrhttps://www.linkedin.com/in/twalthr > >
