JobManager Web Frontend
配置场景
JobManager启动时,会在同一进程内启动web服务器。
- 用户可以访问web服务器获取当前Flink集群的信息,包括JobManager,TaskManager及集群内运行的Job。
 - 用户可以对web服务器参数进行配置。
 
配置描述
配置包括端口,临时目录,显示项目,错误重定向,安全相关等。
针对MRS 3.x之前版本,参数说明见表1。
| 
        参数  | 
      
        是否必选  | 
      
        默认值  | 
      
        描述  | 
     
|---|---|---|---|
| 
        jobmanager.web.port  | 
      
        否  | 
      
        32261-32325  | 
      
        web端口,支持范围:32261-32325。  | 
     
| 
        jobmanager.web.allow-access-address  | 
      
        是  | 
      
        *  | 
      
        web访问白名单,ip以逗号隔开。只有在白名单中的ip才能访问web。  | 
     
针对MRS 3.x及之后版本,参数说明见表2。
| 
        参数  | 
      
        描述  | 
      
        默认值  | 
      
        是否必选配置  | 
     
|---|---|---|---|
| 
        flink.security.enable  | 
      
        用户安装Flink集群时,需要选择“安全模式”或“普通模式”。 
 对于已经安装好的Flink集群,用户可以通过查看配置项“flink.security.enable”的值来区分当前安装的是安全模式还是普通模式。  | 
      
        按照集群的安装模式自动配置  | 
      
        否  | 
     
| 
        rest.bind-port  | 
      
        web端口,支持范围:32261-32325。  | 
      
        32261-32325  | 
      
        否  | 
     
| 
        jobmanager.web.history  | 
      
        显示“flink.security.enable”最近的job数目。  | 
      
        5  | 
      
        否  | 
     
| 
        jobmanager.web.checkpoints.disable  | 
      
        禁用checkpoint统计。  | 
      
        false  | 
      
        否  | 
     
| 
        jobmanager.web.checkpoints.history  | 
      
        Checkpoint统计记录数。  | 
      
        10  | 
      
        否  | 
     
| 
        jobmanager.web.backpressure.cleanup-interval  | 
      
        未访问反压记录清理周期。单位:ms。  | 
      
        600000  | 
      
        否  | 
     
| 
        jobmanager.web.backpressure.refresh-interval  | 
      
        反压记录刷新周期。单位:ms。  | 
      
        60000  | 
      
        否  | 
     
| 
        jobmanager.web.backpressure.num-samples  | 
      
        计算反压使用的堆栈跟踪记录数。  | 
      
        100  | 
      
        否  | 
     
| 
        jobmanager.web.backpressure.delay-between-samples  | 
      
        计算反压的采样间隔。单位:ms  | 
      
        50  | 
      
        否  | 
     
| 
        jobmanager.web.ssl.enabled  | 
      
        web是否使用SSL加密传输,仅在全局开关security.ssl开启时有。  | 
      
        false  | 
      
        是  | 
     
| 
        jobmanager.web.accesslog.enable  | 
      
        web操作日志使能开关,日志会存放在webaccess.log中。  | 
      
        true  | 
      
        是  | 
     
| 
        jobmanager.web.x-frame-options  | 
      
        http安全头X-Frame-Options的值,可选范围为:SAMEORIGIN、DENY、ALLOW-FROM uri。  | 
      
        DENY  | 
      
        是  | 
     
| 
        jobmanager.web.cache-directive  | 
      
        web页面是否支持缓存。  | 
      
        no-store  | 
      
        是  | 
     
| 
        jobmanager.web.expires-time  | 
      
        web页面缓存过期时长。单位:ms。  | 
      
        0  | 
      
        是  | 
     
| 
        jobmanager.web.allow-access-address  | 
      
        web访问白名单,ip以逗号隔开。只有在白名单中的ip才能访问web。  | 
      
        *  | 
      
        是  | 
     
| 
        jobmanager.web.access-control-allow-origin  | 
      
        网页同源策略,防止跨域攻击。  | 
      
        *  | 
      
        是  | 
     
| 
        jobmanager.web.refresh-interval  | 
      
        web网页刷新时间。单位:ms。  | 
      
        3000  | 
      
        是  | 
     
| 
        jobmanager.web.logout-timer  | 
      
        配置无操作情况下自动登出时间间隔。单位:ms。  | 
      
        600000  | 
      
        是  | 
     
| 
        jobmanager.web.403-redirect-url  | 
      
        web403页面,访问若遇到403错误,则会重定向到配置的页面。  | 
      
        自动配置  | 
      
        是  | 
     
| 
        jobmanager.web.404-redirect-url  | 
      
        web404页面,访问若遇到404错误,则会重定向到配置的页面。  | 
      
        自动配置  | 
      
        是  | 
     
| 
        jobmanager.web.415-redirect-url  | 
      
        web415页面,访问若遇到415错误,则会重定向到配置的页面。  | 
      
        自动配置  | 
      
        是  | 
     
| 
        jobmanager.web.500-redirect-url  | 
      
        web500页面,访问若遇到500错误,则会重定向到配置的页面。  | 
      
        自动配置  | 
      
        是  | 
     
| 
        rest.await-leader-timeout  | 
      
        客户端等待Leader地址的时间(以ms为单位)。  | 
      
        30000  | 
      
        否  | 
     
| 
        rest.client.max-content-length  | 
      
        客户端处理的最大内容长度(以字节为单位)。  | 
      
        104857600  | 
      
        否  | 
     
| 
        rest.connection-timeout  | 
      
        客户端建立TCP连接的最长时间(以ms为单位)。  | 
      
        15000  | 
      
        否  | 
     
| 
        rest.idleness-timeout  | 
      
        连接保持空闲状态的最长时间(以ms为单位)。  | 
      
        300000  | 
      
        否  | 
     
| 
        rest.retry.delay  | 
      
        客户端在连续重试之间等待的时间(以ms为单位)。  | 
      
        3000  | 
      
        否  | 
     
| 
        rest.retry.max-attempts  | 
      
        如果可重试算子操作失败,客户端将尝试重试的次数。  | 
      
        20  | 
      
        否  | 
     
| 
        rest.server.max-content-length  | 
      
        服务端处理的最大内容长度(以字节为单位)。  | 
      
        104857600  | 
      
        否  | 
     
| 
        rest.server.numThreads  | 
      
        异步处理请求的最大线程数。  | 
      
        4  | 
      
        否  | 
     
| 
        web.timeout  | 
      
        web监控超时时间(以ms为单位)。  | 
      
        10000  | 
      
        否  |