首页 > 其他分享 >Flink 1.17教程:集群角色及集群启动

Flink 1.17教程:集群角色及集群启动

时间:2023-09-02 11:35:04浏览次数:43  
标签:1.17 flink Flink host 集群 atguigu node001 Starting


集群角色

Flink 1.17教程:集群角色及集群启动_hadoop

集群启动

如果是部署在本地,本地访问,无需进行任何配置,直接启动即可。

如果是部署在服务器,需要远程访问,则需要将flink.conf中的localhost修改为服务器IP地址或是0.0.0.0

节点服务器

hadoop102

hadoop103

hadoop104

角色

JobManagerTaskManager

TaskManager

TaskManager

[atguigu@node001 module]$ cd flink
[atguigu@node001 flink]$ cd flink-1.17.0/
[atguigu@node001 flink-1.17.0]$ bin/start-cluster.sh
Starting cluster.
Starting standalonesession daemon on host node001.
Starting taskexecutor daemon on host node001.
Starting taskexecutor daemon on host node002.
Starting taskexecutor daemon on host node003.
[atguigu@node001 flink-1.17.0]$ jpsall 
================ node001 ================
3408 Jps
2938 StandaloneSessionClusterEntrypoint
3276 TaskManagerRunner
================ node002 ================
2852 TaskManagerRunner
2932 Jps
================ node003 ================
2864 TaskManagerRunner
2944 Jps
[atguigu@node001 flink-1.17.0]$

Flink 1.17教程:集群角色及集群启动_大数据_02


标签:1.17,flink,Flink,host,集群,atguigu,node001,Starting
From: https://blog.51cto.com/zhangxueliang/7331350

相关文章

  • Flink 1.17教程:wordcount maven工程java代码示例(批、流实现方式)
    批、流实现wordcount代码示例pom.xml<properties><flink.version>1.17.0</flink.version></properties><dependencies><dependency><groupId>org.apache.flink</groupId><......
  • Flink 1.17教程:DataStream实现Wordcount——读socket(无界流)
    pom.xml<properties><flink.version>1.17.0</flink.version></properties><dependencies><dependency><groupId>org.apache.flink</groupId><artifactId>fli......
  • Java代码:flink wordcount代码示例及解读
    WordCountWordCountPojo.java代码packagewordCount;importorg.apache.flink.api.common.functions.FlatMapFunction;importorg.apache.flink.api.common.functions.ReduceFunction;importorg.apache.flink.api.java.DataSet;importorg.apache.flink.api.java.Executio......
  • Redis高可用集群之水平扩展(3.2)
    Redis3.0以后的版本虽然有了集群功能,提供了比之前版本的哨兵模式更高的性能与可用性,但是集群的水平扩展却比较麻烦,今天就来带大家看看redis高可用集群如何做水平扩展,原始集群(见下图)由6个节点组成,6个节点分布在三台机器上,采用三主三从的模式1、启动集群#启动整个集群/usr......
  • 分布式存储FusionStorage将搬迁走的计算节点踢出集群
    1、登录DeviceManager管理界面,在服务-vbs页面下,选中已经异常的VBS,将异常的VBS进行强制删除。2、通过第三方远程连接工具,连接进FSM后台,IP为浮动IP,用fsadmin用户进入,切换到root用户。fsadmin默认密码:IaaS@OS-CLOUD9!2.1执行su- rootroot默认密码:IaaS@OS-CLOUD8!3、执行ism......
  • 为什么创建 Redis 集群时会自动错开主从节点?
    哈喽大家好,我是咸鱼在《一台服务器上部署Redis伪集群》这篇文章中,咸鱼在创建Redis集群时并没有明确指定哪个Redis实例将担任master,哪个将担任slave/usr/local/redis-4.0.9/src/redis-trib.rbcreate--replicas1192.168.149.131:6379192.168.149.131:26379192.168.1......
  • Flink On K8s实战课程2023
    点击下载:FlinkOnK8s实战课程2023  提取码:2y46目前项目中用到Flink作为离线ETL处理构建相关的特征系统,而特征系统主要是为数据科学家、数据工程师、机器学习工程师去使用,用来去构建AI特征库,用来做模型的训练、用来做数据测试以及一些数据的预测及模型的在线服务,主要特征系统是......
  • DockerCompose-部署微服务集群
                                 ......
  • 16、Flink 的table api与sql之连接外部系统_ 读写外部系统的连接器和格式以及Apache H
    (文章目录)本文介绍了ApacheHive连接器的使用,以具体的示例演示了通过java和flinksqlcli创建catalog。本文依赖环境是hadoop、zookeeper、hive、flink环境好用,本文内容以flink1.17版本进行介绍的,具体示例是在1.13版本中运行的(因为hadoop集群环境是基于jdk8的,flink1.17版本需......
  • Flink的3中API
    DataStream/DataSet/TableAPI是ApacheFlink提供的三种不同的API,用于处理不同类型的数据和实现不同的计算模型。1.DataStreamAPI:DataStreamAPI是基于流式数据的API,用于处理连续不断到达的数据流。它适用于实时数据处理和流式计算场景。DataStreamAPI提供了丰富的操作符和函......