2022年3月 – 编程技术之美-IT之美

kafka启动报错：Connection to node -1 (localhost/127.0.0.1:9092) could not be established

报错原因是因为连不上Kafka连不上的原因是因为Java连kafka，kafka需要添加一个配置：advert… 继续阅读 Java连接kafka超时报错

代码：原因：Lambda无法通过表达式推断出正确的类型改造代码：1、第一种方法就是使用匿名类输出结果： … 继续阅读 Flink运行时报错：could not be determined automatically, due to type erasure

自定义Source，官网有一个比较好的例子，用于生成信用卡交易数据，我们简单来看一下源码。源码主要的功能类有两… 继续阅读 Flink从入门到实战四[DataStream API]-11-Source-官网反欺诈自动生成Demo源码解读

自定义Source，最重要的一个步骤就是实现SourceFunction接口，定义一个Source类。在这个自… 继续阅读 Flink从入门到实战四[DataStream API]-10-Source-自定义数据源

基于Socket的数据源，在之前的demo中已经演示了，我们直接看代码：测试数据输出结果

添加pom依赖：安装kafka前提是本机需要具备JDK1.8或以上的版本。1、下载kafkahttps://… 继续阅读 Flink从入门到实战四[DataStream API]-7-Source-从Kafka中读取数据

Flink 从文件中获取数据输出结果：

Flink 从集合中获取数据，我们直接看代码：输出结果：

发表于2022年3月9日2023年7月22日作者 IT之美

Flink应用要计算,必须要有执行环境，有了执行环境，那么就需要将要数据输入到计算应用中了。Flink提供了丰… 继续阅读 Flink从入门到实战四[DataStream API]-4-Source数据源

发表于2022年3月7日2023年7月22日作者 IT之美

StreamExecutionEnvironment内部的方法非常多，我们从整体功能上进行简单划分，主要包括：… 继续阅读 Flink从入门到实战四[DataStream API]-3-3_StreamExecutionEnvironment API解析

发表于2022年3月5日2023年7月22日作者 IT之美

Environment 是所有 Flink 程序的基础，每个 Flink 应用都需要有执行环境，Flink1.… 继续阅读 Flink从入门到实战四[DataStream API]-2-Environment运行时环境

发表于2022年3月3日2023年7月22日作者 IT之美

DataStream API是Flink用于数据处理的API。是对有界数据和无界数据处理的API。 DataS… 继续阅读 Flink从入门到实战四[DataStream API]-1-DataStream API简介

发表于2022年3月1日2023年7月22日作者 IT之美

Flink 运行时由两种类型的进程组成：一个 JobManager 和一个或者多个 TaskManager。 … 继续阅读 Flink从入门到实战三[架构]-1_Flink运行时架构