Rui Fan created FLINK-35665: ------------------------------- Summary: 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 Fix For: 1.20.0 Attachments: image-2024-06-21-15-51-53-480.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-49-40-729.png|width=1581,height=662! 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)