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)
