Flink web ui 自定义传参

朱雀 2023-10-06 18:44 115阅读 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 条评论，115人围观）

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

相关阅读

相关 Flink web ui 自定义传参

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

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

相关 vue 自定义事件传参

先来简单看个例子： TodoList.vue : <template> <ul> <li> <todo-item v

逃离我推掉我的手/ 2023年07月09日 13:25/ 0 赞/ 44 阅读

相关 element-ui自定义文件上传

小哥今天心情好在抄一篇文章啦啦啦！ html name上传文件参数名 files data 上传参数 <el-upload ref="upload

我不是女神ヾ/ 2023年02月19日 07:29/ 0 赞/ 44 阅读

相关 Java web 传参

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

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

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

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

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

相关 mybatis自定义传参排序

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

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

相关 Flink-04-Flink自定义Source

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

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

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

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

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

相关 Flink 自定义UDTF

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

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

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

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

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