[
https://issues.apache.org/jira/browse/FLINK-35607?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17856679#comment-17856679
]
Rui Fan edited comment on FLINK-35607 at 6/21/24 7:49 AM:
----------------------------------------------------------
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.
was (Author: fanrui):
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.
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 Instructions: Verify FLIP-441: Show the JobType and remove
> Execution Mode on Flink WebUI
> ----------------------------------------------------------------------------------------------------------
>
> Key: FLINK-35607
> URL: https://issues.apache.org/jira/browse/FLINK-35607
> Project: Flink
> Issue Type: Sub-task
> Components: Runtime / Web Frontend
> Reporter: Rui Fan
> Assignee: Rui Fan
> Priority: Blocker
> Labels: release-testing
> Fix For: 1.20.0
>
> Attachments: image-2024-06-21-15-49-40-729.png
>
>
> Follow up the test for https://issues.apache.org/jira/browse/FLINK-29481
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
