public class StatefulStreamJobUpgradeTestProgram extends Object
The job is constructed of generic components from
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:
The cli job configuration options are described in
Job specific configuration options:
|Constructor and Description|
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.