Hi, Mich You can try adding "import org.apache.flink.table.api.scala._", so that the Symbol can be recognized as an Expression.
Best, Hequn On Wed, Aug 1, 2018 at 6:16 AM, Mich Talebzadeh <mich.talebza...@gmail.com> wrote: > Hi, > > I am following this example > > https://ci.apache.org/projects/flink/flink-docs- > release-1.5/dev/table/common.html#integration-with- > datastream-and-dataset-api > > This is my dataStream which is built on a Kafka topic > > // > //Create a Kafka consumer > // > val dataStream = streamExecEnv > .addSource(new FlinkKafkaConsumer011[String](topicsValue, new > SimpleStringSchema(), properties)) > // > // > val tableEnv = TableEnvironment.getTableEnvironment(streamExecEnv) > val table1: Table = tableEnv.fromDataStream(dataStream, 'key, 'ticker, > 'timeissued, 'price) > > While compiling it throws this error > > [error] /home/hduser/dba/bin/flink/md_streaming/src/main/scala/ > myPackage/md_streaming.scala:169: overloaded method value fromDataStream > with alternatives: > [error] [T](dataStream: > org.apache.flink.streaming.api.datastream.DataStream[T], > fields: String)org.apache.flink.table.api.Table <and> > [error] [T](dataStream: org.apache.flink.streaming. > api.datastream.DataStream[T])org.apache.flink.table.api.Table > [error] cannot be applied to > (org.apache.flink.streaming.api.datastream.DataStreamSource[String], > Symbol, Symbol, Symbol, Symbol) > [error] val table1: Table = tableEnv.fromDataStream(dataStream, 'key, > 'ticker, 'timeissued, 'price) > [error] ^ > [error] one error found > [error] (compile:compileIncremental) Compilation failed > > The topic is very simple, it is comma separated prices. I tried > mapFunction and flatMap but neither worked! > > Thanks, > > > Dr Mich Talebzadeh > > > > LinkedIn * > https://www.linkedin.com/profile/view?id=AAEAAAAWh2gBxianrbJd6zP6AcPCCdOABUrV8Pw > <https://www.linkedin.com/profile/view?id=AAEAAAAWh2gBxianrbJd6zP6AcPCCdOABUrV8Pw>* > > > > http://talebzadehmich.wordpress.com > > > *Disclaimer:* Use it at your own risk. Any and all responsibility for any > loss, damage or destruction of data or any other property which may arise > from relying on this email's technical content is explicitly disclaimed. > The author will in no case be liable for any monetary damages arising from > such loss, damage or destruction. > > >
