• 布兰特
    2020-09-05
    老师,在生产环境的话建议使用Session Mode 还是 Per-Job Mode啊? 那么如果从离线任务和实时7*24小时任务的角度来讲,应该使用哪种运行模式啊?

    作者回复: 主要还是看资源隔离,生产环境任务如果要求比较高,建议使用 Per-Job Mode,资源隔离相对充分,如果是普通的流式任务,则建议Session Mode会更好点。 离线任务的话则建议Per-Job Mode,实时任务相对比较稳定根据资源隔离要求具体视情况选择即可。

    
    6
  • 🎼 张ͮ子ͮ谋ͮ
    2020-09-12
    通过Flink UI 直接提交Jar,应该是在JobManger的机器上执行吧,这样也能降低客服端负载吧?

    作者回复: 可以这么理解,但是前提是每次需要上传Jar包,然后才能提交,上传Jar的过程实际就是Client做的事情,可以降低负载

    
    2
  • aof
    2020-09-14
    Application Mode的这种方式感觉和Spark on YARN cluster模式的原理差不多

    作者回复: 对的 可以这么理解,就是Driver在哪里的问题

    
    
  • kaka.
    2020-09-12
    老师,如果是普通的流式任务,为了节省资源选择Session Mode,资源配置和slot数量怎么去配置呢,可以动态增加集群资源吗

    作者回复: 关于资源配置,我们在后面章节有专门讲解的,可以关注下后面的章节,资源可以动态增加

    
    
  • free zyq
    2020-09-10
    上一节介绍了一些关键的组件:jm,tm,client,jg,job 这一节开篇提到的application,runtime,cluster分别对应的什么? 我理解是: application=包含一个main方法的job? runtime =tm+jm+client cluster = jm+很多tm?

    作者回复: 对的

    共 2 条评论
    
  • 小七
    2022-05-16
    老师,不同的job,是根据什么规则划分为同一个 “Application“ 的?
    
    
  • orangelin
    2022-01-18
    图里提交多job只画了一个jobmanager ,但是一个application又只对应一个jobmanager,这里是怎么理解的?
    共 1 条评论
    
  • Geek_58a455
    2021-10-10
    Application mode是每一个Applicaiton会生成一个jm和对应的tm吗?
    
    
  • hadoop_admin
    2021-09-01
    大佬,咨询下 现在flink 部署支持ipv6么,在jira上看到https://issues.apache.org/jira/browse/FLINK-9824和 https://issues.apache.org/jira/browse/FLINK-23206,是不是还不支持?社区有计划支持么?
    
    
  • 相遇太早~
    2021-03-30
    一个main方法对应一个job,一个application包含多个job是指有多个类,每个类一个main方法入口吗?
    
    