org.apache.flink.streaming.tests

Class StatefulStreamJobUpgradeTestProgram

java.lang.Object

org.apache.flink.streaming.tests.StatefulStreamJobUpgradeTestProgram

public class StatefulStreamJobUpgradeTestProgram
extends Object

Test upgrade of generic stateful job for Flink's DataStream API operators and primitives.

The job is constructed of generic components from DataStreamAllroundTestJobFactory. The goal is to test successful state restoration after taking savepoint and recovery with new job version. It can be configured with '--test.job.variant' to run different variants of it:

• original: includes 2 custom stateful map operators
• upgraded: changes order of 2 custom stateful map operators and adds one more

The cli job configuration options are described in DataStreamAllroundTestJobFactory.

Job specific configuration options:

• test.job.variant (String, default - 'original'): This configures the job variant to test. Can be 'original' or 'upgraded'.

Constructor Summary

Constructors

Constructor and Description
StatefulStreamJobUpgradeTestProgram()

Method Summary

Modifier and Type	Method and Description
static void	main(String[] args)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

StatefulStreamJobUpgradeTestProgram

public StatefulStreamJobUpgradeTestProgram()

Method Detail

main

public static void main(String[] args)
                 throws Exception

Throws:

Exception