代碼如下:

import org.apache.flink.api.common.functions.MapFunction; import org.apache.flink.streaming.api.datastream.DataStream; import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;public class Map {public static void main(String[] args) throws Exception{StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();DataStream<Integer> dataStream = env.fromElements(1, 2, 3, 4, 5);dataStream=dataStream.map(new MapFunction<Integer, Integer>(){@Overridepublic Integer map(Integer value) throws Exception{return 2 * value;}});dataStream.print();}}

原因：

忘記寫執行函數execute();

解決方案：

dataStream.print();后面加上:

env.execute();

總結

以上是生活随笔為你收集整理的flink的datastream输出没有结果的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。