THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
| Page properties |
|---|
...
|
Discussion thread: http://apache-flink-mailing-list-archive.1008284.n3.nabble.com/DISCUSS-FLIP-59-Enable-execution-configuration-from-Configuration-object-td32359.html
JIRA:
...
|
Please keep the discussion on the mailing list rather than commenting on the wiki (wiki discussions get unwieldy fast).
...
- In class org.apache.flink.configuration.PipelineOptions:
| key | setting | type | Expected format |
|---|---|---|---|
| pipeline.auto-generate-uids | ExecutionConfig#enableAutoGeneratedUids | ConfigOption<Boolean> | |
| pipeline.auto-type-registration | ExecutionConfig#autoTypeRegistrationEnabled | ConfigOption<Boolean> | |
| pipeline.auto-watermark-interval | ExecutionConfig#autoWatermarkInterval | ConfigOption<Duration> | |
| pipeline.closure-cleaner-level | ExecutionConfig#closureCleanerLevel | ConfigOption<ExecutionConfig.ClosureCleanerLevel> | |
| pipeline.force-avro | ExecutionConfig#forceAvro | ConfigOption<Boolean> | |
| pipeline.force-kryo | ExecutionConfig#forceKryo | ConfigOption<Boolean> | |
| pipeline.generic-types | ExecutionConfig#disableGenericTypes | ConfigOption<Boolean> | |
| pipeline.global-job-parameters | ExecutionConfig#globalJobParameters | ConfigOption<Map<String, String>> | |
| pipeline.max-parallelism | ExecutionConfig#maxParallelism | ConfigOption<Integer> | |
| pipeline.object-reuse | ExecutionConfig#objectReuse | ConfigOption<Boolean> | |
| pipeline.default-kryo-serializers | ExecutionConfig#defaultKryoSerializerClasses | ConfigOption<List<String>> | semicolon separated list of pairs of class names and serializers class names. Example: class:org.apache.flink.api.common.ExecutionConfigTest,serializer:org.apache.flink.api.common.ExecutionConfigTest$TestSerializer1;class:org.apache.flink.api.common.ExecutionConfigTest$TestSerializer1,serializer:org.apache.flink.api.common.ExecutionConfigTest$TestSerializer2 |
| pipeline.registered-kryo-types | ExecutionConfig#registeredKryoTypes | ConfigOption<List<String>> | semicolon separated list of class names Example: org.apache.flink.api.common.ExecutionConfigTest;org.apache.flink.api.common.ExecutionConfigTest$TestSerializer1 |
| pipeline.registered-pojo-types | ExecutionConfig#registeredPojoTypes | ConfigOption<List<String>> | semicolon separated list of class names Example: org.apache.flink.api.common.ExecutionConfigTest;org.apache.flink.api.common.ExecutionConfigTest$TestSerializer1 |
| pipeline.operator-chaining | StreamExecutionEnvironment#isChainingEnabled | ConfigOption<Boolean> | |
| pipeline.cached-files | StreamExecutionEnvironment#cacheFile | ConfigOption<List<String>> | semicolon separated list of triples of cached file path, name, and executable flag(the executable flag is optional) Example: name:file1,path:/tmp1,executable:true;name:file2,path:/tmp2 |
In class org.apache.flink.streaming.api.environment.StreamPipelineOptions:
key setting type pipeline.time-characteristic StreamExecutionEnvironment#timeCharacteristic ConfigOption<TimeCharacteristic> In class org.apache.flink.streaming.api.environment.ExecutionCheckpointingOptions
key setting type execution.checkpointing.mode CheckpointConfig#checkpointingMode ConfigOption<CheckpointingMode> execution.checkpointing.interval CheckpointConfig#checkpointInterval ConfigOption<Duration> execution.checkpointing.timeout CheckpointConfig#checkpointTimeout ConfigOption<Duration> execution.checkpointing.max-concurrent-checkpoints CheckpointConfig#maxConcurrentCheckpoints ConfigOption<Integer> execution.checkpointing.min-pause CheckpointConfig#minPauseBetweenCheckpoints ConfigOption<Duration> execution.checkpointing.prefer-checkpoint-for-recovery CheckpointConfig#preferCheckpointForRecovery ConfigOption<Boolean> execution.checkpointing.tolerable-failed-checkpoints CheckpointConfig#tolerableCheckpointFailureNumber ConfigOption<Integer> execution.checkpointing.externalized-checkpoint CheckpointConfig#externalizedCheckpointCleanup ConfigOption<CheckpointConfig.ExternalizedCheckpointCleanup> - In class org.apache.flink.configuration.ExecutionOptionsWhere
key setting type execution.checkpointing.snapshot-compression ExecutionConfig#useSnapshotCompression ConfigOption<Boolean> execution.buffer-timeout StreamExecutionEnvironment#bufferTimeout ConfigOption<Duration>
Options not configurable from Configuration
...