• KoalaRun1024
    2021-01-08
    老师，感觉您的语言组织上需要简练和准确一下。

    作者回复: 好的，后面好很多，前面不太适应

    
    3
  • Geek_9e8288
    2020-09-03
    老师，能不能考虑增加一些Python的示例呢？我们数据分析比较熟悉pyspark，jupyter，对java不太熟悉。

    作者回复: 可以的，后面单独有一张讲PyFlink的使用，但是大部分学员还是以Java，Scala为主，语言不是难点，重点是能理解Flink的原理，接口基本上都差不多

    
    1
  • Geek_0a139e
    2020-08-29
    想到了spark on yarn的两种提交作业模式，yarn client 和 yarn cluster，分别对应flink 的 per-job 和 Application Mode模式

    作者回复: 嗯 不同的模式都有各自的优势，但是Flink相对比较灵活点，需要注意Yarn Client里面的Spark Driver还会和Executor之间进行通信，但是Flink里面Client不会，Job提交上去了之后会在Master节点中启动JobMaster来管理和协调Task的执行。

    
    1
  • 张子涵
    2020-08-27
    看下来，只记住了，yarn和k8s常用

    作者回复: yarn和k8s确实比较常用，因此也是大部分公司的首选

    
    1
  • 逃离舒适圈
    2020-08-27
    大佬 平时咋学习的？

    作者回复: 我们后面留一个番外篇，专门来讲讲如何更高效的学习Flink？

    
    1
  • Radar
    2020-10-19
    - 单机/分布式多台物理主机部署，不支持高可用 - 依赖Java 8或Java 11JDK环境 - 支持Linux/MacOSX/WSL - 仅支持Session模式提交job - 部署流程： https://flink.apache.org/downloads.html - ./bin/start-cluster.sh - ./jps - ./bin/stop-cluster.sh - 监控 - http://9.134.76.111:8081/#/overview JobManager/Log - flink-1.11.2/log - 多机： - conf/flink-conf.yaml 修改 jobmanager.rpc.address - conf/master 配置ip地址 - conf/worker 配置worker - run: - ./bin/flink run ./examples/batch/WordCount.jar

    作者回复: 整理的不做

    
    
  • 李锦武
    2022-08-14 来自广东
    这里讲到了 native 集群部署， 但是却缺乏什么是 native 的定义，native 对应的概念是非 native 吗？ 怎么区分的？
    
    2
  • bingoabin
    2022-10-30 来自浙江
    native是啥
    
    
  • 双椒叔叔
    2021-03-24
    Native模式跟Per Job模式有啥区别嘞，还是很模糊
    共 1 条评论
    