[
https://issues.apache.org/jira/browse/FLINK-35665?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17863677#comment-17863677
]
Zakelly Lan commented on FLINK-35665:
-------------------------------------
Verified via:
# Download flink-1.20-rc0 from
[https://dist.apache.org/repos/dist/dev/flink/flink-1.20.0-rc0/]
# Compile the JobTypeDemo as Rui provided.
# Submit a job on yarn in per-job mode, via flink cli.
# Open the Flink UI and check the Job Type.
When applying {{env.setRuntimeMode(RuntimeExecutionMode.STREAMING)}} it shows:
!image-2024-07-08-14-52-32-778.png!
When applying {{env.setRuntimeMode(RuntimeExecutionMode.BATCH)}} it shows:
!image-2024-07-08-14-51-11-241.png!
When applying {{env.setRuntimeMode(RuntimeExecutionMode.AUTOMATIC)}} it shows:
!image-2024-07-08-14-51-35-796.png!
So it seems work as expected.
> Release Testing: FLIP-441: Show the JobType and remove Execution Mode on
> Flink WebUI
> --------------------------------------------------------------------------------------
>
> Key: FLINK-35665
> URL: https://issues.apache.org/jira/browse/FLINK-35665
> Project: Flink
> Issue Type: Sub-task
> Components: Runtime / Web Frontend
> Reporter: Rui Fan
> Assignee: Zakelly Lan
> Priority: Blocker
> Fix For: 1.20.0
>
> Attachments: image-2024-06-21-15-51-53-480.png,
> image-2024-07-08-14-51-11-241.png, image-2024-07-08-14-51-35-796.png,
> image-2024-07-08-14-52-32-778.png
>
>
> Test suggestion:
>
> 1. Using this following job to check the jobType
> {code:java}
> import org.apache.flink.api.common.RuntimeExecutionMode;
> import org.apache.flink.api.common.eventtime.WatermarkStrategy;
> import org.apache.flink.api.common.functions.MapFunction;
> import org.apache.flink.api.common.typeinfo.Types;
> import
> org.apache.flink.api.connector.source.util.ratelimit.RateLimiterStrategy;
> import org.apache.flink.configuration.Configuration;
> import org.apache.flink.configuration.RestOptions;
> import org.apache.flink.connector.datagen.source.DataGeneratorSource;
> import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;
> /** Test for showing job type in Flink WebUI. */
> public class JobTypeDemo {
> public static void main(String[] args) throws Exception {
> Configuration conf = new Configuration();
> StreamExecutionEnvironment env =
> StreamExecutionEnvironment.getExecutionEnvironment(conf);
> env.setRuntimeMode(RuntimeExecutionMode.STREAMING);
> // env.setRuntimeMode(RuntimeExecutionMode.BATCH);
> // env.setRuntimeMode(RuntimeExecutionMode.AUTOMATIC);
> DataGeneratorSource<Long> generatorSource =
> new DataGeneratorSource<>(
> value -> value,
> 600,
> RateLimiterStrategy.perSecond(10),
> Types.LONG);
> env.fromSource(generatorSource, WatermarkStrategy.noWatermarks(),
> "Data Generator")
> .map((MapFunction<Long, Long>) value -> value)
> .name("Map___1")
> .print();
> env.execute(JobTypeDemo.class.getSimpleName());
> }
> } {code}
> 2. Start it and check if the jobType is Streaming in Flink web UI.
> !image-2024-06-21-15-51-53-480.png|width=1835,height=768!
> 3. Applying the env.setRuntimeMode(RuntimeExecutionMode.BATCH);, and check if
> the jobType is Batch in Flink web UI.
> 4. Applying the env.setRuntimeMode(RuntimeExecutionMode.AUTOMATIC);, and
> check if the jobType is Batch in Flink web UI.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
