Hi It works now. Thank you ☺
How to know what the imports are incompatible or something like that ? BR Esa From: Xingcan Cui [mailto:xingc...@gmail.com] Sent: Thursday, February 22, 2018 12:00 PM To: Esa Heikkinen <esa.heikki...@student.tut.fi> Cc: Fabian Hueske <fhue...@gmail.com>; user@flink.apache.org Subject: Re: Problems to use toAppendStream Hi Esa and Fabian, sorry for my inaccurate conclusion before, but I think the reason is clear now. The org.apache.flink.streaming.api.scala._ and org.apache.flink.api.scala._ should not be imported simultaneously due to conflict. Just remove either of them. Best, Xingcan On 22 Feb 2018, at 5:20 PM, Xingcan Cui <xingc...@gmail.com<mailto:xingc...@gmail.com>> wrote: Hi Fabian and Esa, I ran the code myself and also noticed the strange behavior. It seems that only I explicitly import the function i.e., org.apache.flink.streaming.api.scala.asScalaStream, can it works. In other words, the underscore import becomes useless. I also checked other package objects (e.g., org.apache.flink.table.api.scala._) and they are the same. @Esa, you can temporarily solve the problem by importing org.apache.flink.streaming.api.scala.asScalaStream in your code and we'll continue working on this issue. Best, Xingcan On 22 Feb 2018, at 4:47 PM, Esa Heikkinen <esa.heikki...@student.tut.fi<mailto:esa.heikki...@student.tut.fi>> wrote: Hi How to check versions ? In pom.xml there are lines: <properties> <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding> <flink.version>1.4.0</flink.version> <slf4j.version>1.7.7</slf4j.version> <log4j.version>1.2.17</log4j.version> <scala.binary.version>2.11</scala.binary.version> <scala.version>2.11.11</scala.version> </properties> BR Esa From: Fabian Hueske [mailto:fhue...@gmail.com] Sent: Thursday, February 22, 2018 10:35 AM To: Esa Heikkinen <esa.heikki...@student.tut.fi<mailto:esa.heikki...@student.tut.fi>> Cc: Xingcan Cui <xingc...@gmail.com<mailto:xingc...@gmail.com>>; user@flink.apache.org<mailto:user@flink.apache.org> Subject: Re: Problems to use toAppendStream Hi Esa, which Scala version do you use? Flink supports Scala 2.11 (and Scala 2.10 support was dropped with Flink 1.4.0). Fabian 2018-02-22 9:28 GMT+01:00 Esa Heikkinen <esa.heikki...@student.tut.fi<mailto:esa.heikki...@student.tut.fi>>: It should be ok. This is the list of my all imports. First part of it has been highlighted weaker. I don’t know why. import org.apache.flink.streaming.api.windowing.time.Time import org.apache.flink.api.java.utils.ParameterTool import org.apache.flink.streaming.api.scala.StreamExecutionEnvironment import org.apache.flink.streaming.api.windowing.time.Time import org.apache.flink.cep.scala.{CEP, PatternStream} import org.apache.flink.cep.scala.pattern.Pattern import org.apache.flink.cep.{PatternFlatSelectFunction, PatternFlatTimeoutFunction} import org.apache.flink.streaming.api.datastream.SingleOutputStreamOperator import org.apache.flink.streaming.api.functions.source.ParallelSourceFunction import org.apache.flink.streaming.api.functions.source.SourceFunction.SourceContext import org.apache.flink.util.Collector import org.apache.flink.streaming.api.scala._ import org.apache.flink.api.scala._ import org.apache.flink.table.api.scala._ import org.apache.flink.table.api.scala.StreamTableEnvironment import org.apache.flink.table.api.java.StreamTableEnvironment import org.apache.flink.types.Row import org.apache.flink.streaming.api.TimeCharacteristic import org.apache.flink.streaming.api.scala.{DataStream, StreamExecutionEnvironment} import org.apache.flink.table.api.TableEnvironment import org.apache.flink.table.sources.CsvTableSource import org.apache.flink.api.common.typeinfo.Types BR Esa From: Xingcan Cui [mailto:xingc...@gmail.com<mailto:xingc...@gmail.com>] Sent: Thursday, February 22, 2018 10:09 AM To: Esa Heikkinen <esa.heikki...@student.tut.fi<mailto:esa.heikki...@student.tut.fi>> Cc: user@flink.apache.org<mailto:user@flink.apache.org> Subject: Re: Problems to use toAppendStream Hi Esa, just to remind that don’t miss the dot and underscore. Best, Xingcan On 22 Feb 2018, at 3:59 PM, Esa Heikkinen <esa.heikki...@student.tut.fi<mailto:esa.heikki...@student.tut.fi>> wrote: Hi Actually I have also line “import org.apache.flink.streaming.api.scala” on my code, but this line seems to be highlighted weaker in window of IDEA IntelliJ editor. What does this mean ? But the same errors will still be generated. Esa From: Fabian Hueske [mailto:fhue...@gmail.com] Sent: Wednesday, February 21, 2018 9:41 PM To: Esa Heikkinen <esa.heikki...@student.tut.fi<mailto:esa.heikki...@student.tut.fi>> Cc: user@flink.apache.org<mailto:user@flink.apache.org> Subject: Re: Problems to use toAppendStream Hi Esa, whenever you observe the error "could not find implicit value for evidence parameter of type X" in a streaming program, you need to add the following import: import org.apache.flink.streaming.api.scala._ Best, Fabian 2018-02-21 19:49 GMT+01:00 Esa Heikkinen <heikk...@student.tut.fi<mailto:heikk...@student.tut.fi>>: Hi I have tried to solve below Errors for long time, but no succeed yet. Could you give some hint how to solve it ? Errors in compiling: ------------------ Error:(56, 46) could not find implicit value for evidence parameter of type org.apache.flink.api.common.typeinfo.TypeInformation[org.apache.flink.types.Row] val stream = tableEnv.toAppendStream[Row](tableTest) Error:(56, 46) not enough arguments for method toAppendStream: (implicit evidence$3: org.apache.flink.api.common.typeinfo.TypeInformation[org.apache.flink.types.Row])org.apache.flink.streaming.api.scala.DataStream[org.apache.flink.types.Row]. Unspecified value parameter evidence$3. val stream = tableEnv.toAppendStream[Row](tableTest) Code: ----------------- import org.apache.flink.types.Row import org.apache.flink.streaming.api.TimeCharacteristic import org.apache.flink.streaming.api.scala.{DataStream, StreamExecutionEnvironment} import org.apache.flink.table.api.TableEnvironment import org.apache.flink.table.sources.CsvTableSource import org.apache.flink.api.common.typeinfo.Types object CepTest2 { def main(args: Array[String]) { println("Start ...") val env = StreamExecutionEnvironment.getExecutionEnvironment env.setStreamTimeCharacteristic(TimeCharacteristic.EventTime) //val tableEnv = StreamTableEnvironment.getTableEnvironment(env) val tableEnv = TableEnvironment.getTableEnvironment(env) val csvtable = CsvTableSource .builder .path("/home/esa/Log_EX1_gen_track_5.csv") .ignoreFirstLine .fieldDelimiter(",") .field("time", Types.INT) .field("id", Types.STRING) .field("sources", Types.STRING) .field("targets", Types.STRING) .field("attr", Types.STRING) .field("data", Types.STRING) .build tableEnv.registerTableSource("test", csvtable) val tableTest = tableEnv.scan("test").where("id='5'").select("id,sources,targets") val stream = tableEnv.toAppendStream[Row](tableTest) stream.print env.execute() } } --------------------
