Hi. The TableResult.print() only prints the result to the client console. How do you redirect the output to the .out file? Can you get the output without redirection?
Best, Shengkai Xuyang <xyzhong...@163.com> 于2022年6月2日周四 21:17写道： > Could you find that the input amount of the node `sink` is > being accumulated in Flink UI? Is it possible that there are no data > actually after join. > > If you have checked the above and everything seems ok, you can try again > with a connector named `print` as the sink table and check whether the out > file has data. > > > -- > Best！ > Xuyang > > > At 2022-06-02 18:10:28, "Zain Haider Nemati" <zain.hai...@retailo.co> > wrote: > > Hi, > We are using table apis to integrate and transform data sources and > converting them to datastream. We want to see the data formatting and > adding a .print() sink to the datastream but the .out files do not show any > output. > We do see records coming in from the metrics in flink UI though. > Suggestions on where to look at for potential issues? > > code: > tEnv.executeSql(“CREATE TABLE orders (\n” + > ” id BIGINT,\n” + > ” customer_id BIGINT\n” + > “) WITH (\n” + > ” ‘connector’ = ‘kafka’,\n” + > ” ‘topic’ = ‘orders’,\n” + > ” ‘properties.bootstrap.servers’ = ‘...’,\n” + > ” ‘scan.startup.mode’ = ‘earliest-offset’,\n” + > ” ‘format’ = ‘json’\n” + > “)”); > Table result = tEnv.sqlQuery(“SELECT o.id AS order_id,\n” + > ” dbo.batch_id AS batch_id,\n” + > ” o.customer_id AS customer_id,\n” + > ” dbo.delivery_priority AS delivery_priority\n” + > ” FROM orders o\n” + > ” INNER JOIN delivery_batch_orders dbo ON o.id = > dbo.order_id\n” > ); > > tEnv.toAppendStream(result, StringValue.class).print(); > env.execute(); > > Flink Version : 1.13.1 > >
