[
https://issues.apache.org/jira/browse/FLINK-35665?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rui Fan updated FLINK-35665:
----------------------------
Description:
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.
was:
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.
> 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
> Priority: Blocker
> 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-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)
