flink的datastream输出没有结果

代码如下:

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输出没有结果相关推荐

Flink FileSink 自定义输出路径——BucketingSink
今天看到有小伙伴在问,就想着自己实现一下. 问题: Flink FileSink根据输入数据指定输出位置,比如讲对应日期的数据输出到对应目录输入数据: 20190716 输出到路径 20190716 ...
Flink基于 DataStream API 实现欺诈检测
目录系列文章目录文章目录前言一.Flink基于 DataStream API 实现欺诈检测二.使用步骤 1.引入pom.xml 2.主类 3.欺诈逻辑判断类 4.运行结果: 总结前言在当 ...
flink的datastream进行join操作没有输出结果一例
代码如下: import org.apache.flink.api.scala._ import org.apache.flink.streaming.api.scala.StreamExecutio ...
flink中datastream和dataset各自print()的异同
根据[1] 负责输出的进程默认能打印到提交任务的终端吗? print()结果输出位置在WEB UI查看位置批处理(DataSet) Job Manager 能 Master节点的提交任务 ...
flink java旁路输出(Side Output)，对原始流进行分流、复制
flink通过ProcessFunction来分流,可以将一份流进行拆分.复制等操作,比如下面的代码通过读取一个基本的文本流,将流分别做处理后进行输出: 案例代码 package wordcount; ...
Flink数据流DataStream
准备 final StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment(); env. ...
Flink：DataStream Connectors 之 Kafka
本文主要介绍 Kafka 在 Apache Flink 中的使用,以一个简单的示例,向大家介绍在 Apache Flink 中如何使用 Kafka. 版本: kafka_2.11-2.1.0.tgz ...
大数据系列教程（4）Flink 使用 DataStream API 进行欺诈检测
目录使用 DataStream API 进行欺诈检测 **版本1** 版本2 版本3 使用 DataStream API 进行欺诈检测 Apache Flink 提供了一个 DataStream A ...
Flink教程4_Sink输出
文章目录 1.输出到File文件 2.输出到Kafka中 3.输出到Mysql中 4.输出到Redis中 5.输出到ElasticSearch中 1.输出到File文件 public class Si ...

flink的datastream输出没有结果

flink的datastream输出没有结果相关推荐

最新文章

热门文章