本篇教程将详细介绍 Flink-1.16.0 DataStream API 中常用的五种数据输入源（Source）。 下面我们依次展开讲解，帮助大家尽快掌握 Flink 的数据输入基础。 一、从集合读取数据 Flink 提供了直接从 Java 或 Scala 集合中读取数据的方法，主要适用于小规模数据以及测试场景。通过这种方式，我们可以直接在程序中定义数据，然后将这些数据转化为 DataStrea

一、Standalone 集群部署 1.集群节点规划 节点IP 节点名称 运行进程 192.168.220.30 hadoop101 JobManager,TaskManager 192.168.220.31 hadoop102 TaskManager 192.168.220.32 hadoop103 TaskManager 2.standalone 集群部署 1）上传安装包到hadoop101虚

一、基础环境准备 点击这里查看。在已搭建 Hadoop 完全分布式集群基础之上搭建 HA 模式。 关闭防火墙和SELinux 配置主机名解析 配置SSH免密登录 安装JDK 8 二、ZooKeeper 集群搭建 点击这里查看。 三、Hadoop HA 集群配置 1.核心配置文件 core-site.xml <!-- 全局文件系统URI --> <property> <

 一、集群规划 节点IP 角色 数据目录 服务端口 选举端口 通信端口 192.168.220.30 Leader $ZK_HOME/zkdata 2181 3888 2888 192.168.220.31 Follower $ZK_HOME/zkdata 2181 3888 2888 192.168.220.32 Follower $ZK_HOME/zkdata 2181 3888 2888

一、环境准备 1.系统要求 3台CentOS 7虚拟机（1 Master + 2 Slave） 推荐配置：2核CPU/4GB内存/50GB硬盘 网络互通（关闭防火墙或开放必要端口） 2.软件准备 CentOS-7-x86_64-Minimal-2009 VMware Workstation 16 Pro MobaXterm v23.2 hadoop-2.7.6 jdk-8u202-linux-x6

Centos 7 版本：CentOS-7-x86_64-Minimal-2009.iso 1、网卡配置（配置静态 IP） # 打开网卡配置文件 vi /etc/sysconfig/network-scripts/ifcfg-enp0s3 # ifcfg-enp0s3 网卡名称 # 修改原文件 ONBOOT=yes BOOTPROTO=static # 配置静态 IPv4 地址（IP地址和网关根据实

一、安装前环境准备 1、首先先检查一下 CentOS 7 是否已经安装过 MySQL 数据库，使用如下命令进行检查： # rpm -qa | grep mysql 从以上输出结果可以看出，当前系统并没有安装 MySQL。如果有则使用下面命令进行删除： # rpm -e --nodeps mysql-* 2、查找所有 mysql 对应的文件