Hi Mich, Hequn is correct, click on the “Task Managers” menu located on the left side of the Flink web UI, select a TM from the TM list, and then click on the “Stdout” option in the TM Details tab.
Thanks, vino. 2018-08-07 9:42 GMT+08:00 Hequn Cheng <chenghe...@gmail.com>: > Hi Mich, > > When you print to stdout on cluster, you have to look at the taskmanager > .out file (also available in the UI). > > Best, Hequn > > On Tue, Aug 7, 2018 at 4:48 AM, Mich Talebzadeh <mich.talebza...@gmail.com > > wrote: > >> Hi, >> >> This is the streaming program I have for trade prices following the doc >> for result set for tables >> >> https://flink.apache.org/news/2017/03/29/table-sql-api-update.html >> >> val streamExecEnv = StreamExecutionEnvironment.get >> ExecutionEnvironment >> val ds = streamExecEnv >> .addSource(new FlinkKafkaConsumer011[String](topicsValue, new >> SimpleStringSchema(), properties)) >> val splitStream = ds.map(new MapFunction[String, Tuple4[String, >> String, String, Float]] { >> override def map(value: String): Tuple4[String, String, String, >> Float] = { >> var cols = value.split(',') >> return (cols(0).toString, cols(1).toString, cols(2).toString, >> cols(3).toFloat) >> } >> }) >> val tableEnv = TableEnvironment.getTableEnvironment(streamExecEnv) >> tableEnv.registerDataStream("priceTable", splitStream, 'key, >> 'ticker, 'timeissued, 'price) >> >> val result = tableEnv.scan("priceTable").fi >> lter('ticker.isNotNull).select('key, 'ticker, 'timeissued, 'price) >> val r = result.toDataStream[Row] >> r.print() >> >> This compiles and runs but I do not see any ouput to screen. >> >> This is the output from Flink GUI >> >> [image: image.png] >> >> I can verify that data being streamed in so there is no issue there. >> However, I don't see any output and Flink GUI does not look healthy >> (circles). >> >> Appreciate any input. >> >> 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. >> >> >> > >
