看异常其实问题已经比较明显了： 代码： keyBy用法keyBy(0)或者keyBy(item->ite… 继续阅读 Flink运行时报错：Specifying keys via field positions is only valid for tuple data types
kafka启动报错：Connection to node -1 (localhost/127.0.0.1:9092) could not be established
Java连接kafka超时报错
报错原因是因为连不上Kafka连不上的原因是因为Java连kafka，kafka需要添加一个配置：advert… 继续阅读 Java连接kafka超时报错
Flink运行时报错：Cannot reference field by position on PojoType
原因是Cannot reference field by position on PojoType，虽然编译器… 继续阅读 Flink运行时报错：Cannot reference field by position on PojoType
Flink运行时报错：could not be determined automatically, due to type erasure
代码： 原因：Lambda无法通过表达式推断出正确的类型 改造代码：1、第一种方法就是使用匿名类 输出结果： … 继续阅读 Flink运行时报错：could not be determined automatically, due to type erasure
Flink从入门到实战四[DataStream API]-11-Source-官网反欺诈自动生成Demo源码解读
自定义Source，官网有一个比较好的例子，用于生成信用卡交易数据，我们简单来看一下源码。源码主要的功能类有两… 继续阅读 Flink从入门到实战四[DataStream API]-11-Source-官网反欺诈自动生成Demo源码解读
Flink从入门到实战四[DataStream API]-10-Source-自定义数据源
自定义Source，最重要的一个步骤就是实现SourceFunction接口，定义一个Source类。在这个自… 继续阅读 Flink从入门到实战四[DataStream API]-10-Source-自定义数据源
Flink从入门到实战四[DataStream API]-9-Source-从MQ中读取数据
pom文件： 安装 RabbitMQ略 RabbitMQ SourceRMQSource 负责从 Rabbit… 继续阅读 Flink从入门到实战四[DataStream API]-9-Source-从MQ中读取数据
Flink从入门到实战四[DataStream API]-8-Source-从Socket中读取数据
基于Socket的数据源，在之前的demo中已经演示了，我们直接看代码： 测试数据 输出结果
Flink从入门到实战四[DataStream API]-7-Source-从Kafka中读取数据
添加pom依赖： 安装kafka前提是本机需要具备JDK1.8或以上的版本。1、下载kafkahttps://… 继续阅读 Flink从入门到实战四[DataStream API]-7-Source-从Kafka中读取数据
Flink从入门到实战四[DataStream API]-6-Source-从文件中读取数据
Flink 从文件中获取数据 输出结果：
Flink从入门到实战四[DataStream API]-5-Source-从集合中获取数据
Flink 从集合中获取数据，我们直接看代码： 输出结果：
Flink从入门到实战四[DataStream API]-4-Source数据源
Flink应用要计算,必须要有执行环境，有了执行环境，那么就需要将要数据输入到计算应用中了。Flink提供了丰… 继续阅读 Flink从入门到实战四[DataStream API]-4-Source数据源
Flink从入门到实战四[DataStream API]-3-3_StreamExecutionEnvironment API解析
StreamExecutionEnvironment内部的方法非常多，我们从整体功能上进行简单划分，主要包括：… 继续阅读 Flink从入门到实战四[DataStream API]-3-3_StreamExecutionEnvironment API解析
Flink从入门到实战四[DataStream API]-2-Environment运行时环境
Environment 是所有 Flink 程序的基础，每个 Flink 应用都需要有执行环境，Flink1.… 继续阅读 Flink从入门到实战四[DataStream API]-2-Environment运行时环境
Flink从入门到实战四[DataStream API]-1-DataStream API简介
DataStream API是Flink用于数据处理的API。是对有界数据和无界数据处理的API。 DataS… 继续阅读 Flink从入门到实战四[DataStream API]-1-DataStream API简介
Flink从入门到实战三[架构]-1_Flink运行时架构
Flink 运行时由两种类型的进程组成：一个 JobManager 和一个或者多个 TaskManager。 … 继续阅读 Flink从入门到实战三[架构]-1_Flink运行时架构
Flink从入门到实战二[部署]-1-Flink Standalone集群部署
前面章节已经过单机Standalone模式，接下来我们看一下Standalone的集群模式部署。我们以官网部署… 继续阅读 Flink从入门到实战二[部署]-1-Flink Standalone集群部署
Flink运行报错：java.lang.NoClassDefFoundError: org/apache/flink/streaming/api/functions/source/SourceFunction
本地IDE运行Flink代码，报错如下： 问题解决：问题出在pom文件中，其中引入的Flink包的scope为… 继续阅读 Flink运行报错：java.lang.NoClassDefFoundError: org/apache/flink/streaming/api/functions/source/SourceFunction
Flink从入门到实战一[快速上手]-8-Flink官方反欺诈项目版本3
官方网站使用了一个欺诈检测的项目来演示Flink的功能特性，但是这个项目对于之前完全没有接触过大数据计算框架的… 继续阅读 Flink从入门到实战一[快速上手]-8-Flink官方反欺诈项目版本3