Flink web ui 自定义传参

朱雀 2023-10-06 18:44 62阅读 0赞

#### 前言 ####

目前flink 开发使用的是DatastreamApi,由于业务需要设置动态参数。  
这个不常用，再次记录下，便于需要时查找。

###### 1. 编码开发 ######

动态设置 收参代码如下：

StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
            // 获取传入的参数
            ParameterTool parameterTool = ParameterTool.fromArgs(args);
            // 注册给环境变量
            env.getConfig().setGlobalJobParameters(parameterTool);
            // 获取注册的配置
            ExecutionConfig.GlobalJobParameters parameters = env.getConfig().getGlobalJobParameters();
            Map<String, String> map = parameters.toMap();
            String markType = map.get("markType");
    
            // 设置任务失败重启 允许任务失败最大次数 3次
            env.setRestartStrategy(RestartStrategies.failureRateRestart(3,
                    // 任务失败的时间启动的间隔
                    Time.of(2, TimeUnit.SECONDS),
                    // 允许任务延迟时间 3s
                    Time.of(3, TimeUnit.SECONDS))
            );

###### 2.在web ui 上设置参数 ######

参数是 --参数名 值 （中间空格隔开）  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80Mzk3NTc3MQ_size_16_color_FFFFFF_t_70]

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80Mzk3NTc3MQ_size_16_color_FFFFFF_t_70]: https://img-blog.csdnimg.cn/d4d8c516d3464e1184643fbfa766f368.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80Mzk3NTc3MQ==,size_16,color_FFFFFF,t_70

发表评论取消回复

表情：

评论列表（有 0 条评论，62人围观）

还没有评论，来说两句吧...

相关阅读

相关 Flink web ui 自定义传参

前言目前flink 开发使用的是DatastreamApi,由于业务需要设置动态参数。这个不常用，再次记录下，便于需要时查找。 1. 编码开发动态设置

朱雀/ 2023年10月06日 18:44/ 0 赞/ 63 阅读

相关 Drone 自定义 UI

![format_png][] Drone 是一款开源的 CI/CD 工具，基于容器提供了强大的插件系统。多年前我有写过《基于Docker的CI工具——Drone》\[

缺乏、安全感/ 2022年12月18日 13:54/ 0 赞/ 74 阅读

相关 Java web 传参

一直分不清传参问题，现总结： 1. url传参，我认为不重要，除非传指定或特有参数（例如flag指定Struts的Action调用那个方法，像这类具有标记性的参数），还

曾经终败给现在/ 2022年09月28日 05:43/ 0 赞/ 95 阅读

相关 datasnap远程方法支持自定义对象传参

有同仁需要远程方法传输自定义的数据类型，他以为要自己写代码会很复杂，其实DATASNAP早就为我们想到了。 datasnap的数据序列和还原真是无与伦比的强大，其远程方法支持

痛定思痛。/ 2022年03月29日 07:51/ 0 赞/ 156 阅读

相关 mybatis自定义传参排序

mybatis自定义传参排序注意事项: 1. 注意事项: 1. <select id=“名字” 名字必须跟对应的mapper的方法名一致"

亦凉/ 2022年02月26日 10:40/ 0 赞/ 374 阅读

相关 Flink-04-Flink自定义Source

1、实现并行度为1 的自定义Source 实现SourceFunction接口–一定要指定数据类型 package com.test.streaming.cus

Myth丶恋晨/ 2022年02月25日 06:54/ 0 赞/ 247 阅读

相关 asp.net用户自定义控件传参

asp.net自定义控件传参的方式有2中： ①字段的方式在自定义控件的.ascx.cs中定义一个字段，然后在调用页面的page\_load方法里面传入参数。如在自定

- 日理万妓/ 2021年12月16日 02:47/ 0 赞/ 250 阅读

相关 Flink 自定义触发器

trigger接口有五个方法允许trigger对不同的事件做出反应： onElement():进入窗口的每个元素都会调用该方法。 onEventTime():事件时间

缺乏、安全感/ 2021年11月18日 01:48/ 0 赞/ 503 阅读

相关 Flink 自定义UDTF

> Flink自定义函数实现列传行，数据格式为Json数据：\[\{"key1":"value1","key2":"value2"...\}\] 代码 Java

柔情只为你懂/ 2021年09月25日 13:20/ 0 赞/ 985 阅读

相关 vue element-UI 自定义 Upload 上传

前端代码：action为必填，在下面的params中可以获取到，:http-request可以覆盖默认上传方式，调用自定义的上传方法 <el-tab-pane lab

柔情只为你懂/ 2021年07月27日 02:10/ 0 赞/ 519 阅读