|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 implicitvalue forevidence parameter of typeorg.apache.flink.api.common.typeinfo.TypeInformation[org.apache.flink.types.Row]valstream =tableEnv.toAppendStream[Row](tableTest)Error:(56,46)not enough arguments formethod toAppendStream:(implicitevidence$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].Unspecifiedvalue parameter evidence$3.valstream =tableEnv.toAppendStream[Row](tableTest)| Code: ----------------- importorg.apache.flink.types.Rowimportorg.apache.flink.streaming.api.TimeCharacteristicimportorg.apache.flink.streaming.api.scala.{DataStream,StreamExecutionEnvironment}importorg.apache.flink.table.api.TableEnvironmentimportorg.apache.flink.table.sources.CsvTableSourceimportorg.apache.flink.api.common.typeinfo.TypesobjectCepTest2{defmain(args:Array[String]){println("Start ...")valenv =StreamExecutionEnvironment.getExecutionEnvironment env.setStreamTimeCharacteristic(TimeCharacteristic.EventTime)//val tableEnv = StreamTableEnvironment.getTableEnvironment(env)valtableEnv =TableEnvironment.getTableEnvironment(env)valcsvtable =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)valtableTest =tableEnv.scan("test").where("id='5'").select("id,sources,targets")valstream =tableEnv.toAppendStream[Row](tableTest)stream.print env.execute()}}-------------------- |

Reply via email to