[jira] [Updated] (FLINK-33080) The checkpoint storage configured in the job level by config option will not take effect
[ https://issues.apache.org/jira/browse/FLINK-33080?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-33080: Affects Version/s: 1.17.1 1.18.0 1.19.0 > The checkpoint storage configured in the job level by config option will not > take effect > > > Key: FLINK-33080 > URL: https://issues.apache.org/jira/browse/FLINK-33080 > Project: Flink > Issue Type: Bug > Components: Runtime / Checkpointing, Runtime / Configuration >Affects Versions: 1.18.0, 1.17.1, 1.19.0 >Reporter: Junrui Li >Assignee: Junrui Li >Priority: Major > Labels: pull-request-available > Fix For: 1.19.0 > > > When we configure the checkpoint storage at the job level, it can only be > done through the following method: > {code:java} > StreamExecutionEnvironment env = > StreamExecutionEnvironment.getExecutionEnvironment(); > env.getCheckpointConfig().setCheckpointStorage(xxx); {code} > or configure filesystem storage by config option > CheckpointingOptions.CHECKPOINTS_DIRECTORY through the following method: > {code:java} > Configuration configuration = new Configuration(); > configuration.set(CheckpointingOptions.CHECKPOINTS_DIRECTORY, checkpointDir); > StreamExecutionEnvironment env = > StreamExecutionEnvironment.getExecutionEnvironment(configuration);{code} > However, configure the other type checkpoint storage by the job-side > configuration like the following will not take effect: > {code:java} > Configuration configuration = new Configuration(); > StreamExecutionEnvironment env = > StreamExecutionEnvironment.getExecutionEnvironment(configuration); > configuration.set(CheckpointingOptions.CHECKPOINT_STORAGE, > "aaa.bbb.ccc.CustomCheckpointStorage"); > configuration.set(CheckpointingOptions.CHECKPOINTS_DIRECTORY, checkpointDir); > {code} > This behavior is unexpected, we should allow this way will take effect. -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Updated] (FLINK-33080) The checkpoint storage configured in the job level by config option will not take effect
[ https://issues.apache.org/jira/browse/FLINK-33080?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-33080: Component/s: Runtime / Configuration > The checkpoint storage configured in the job level by config option will not > take effect > > > Key: FLINK-33080 > URL: https://issues.apache.org/jira/browse/FLINK-33080 > Project: Flink > Issue Type: Bug > Components: Runtime / Configuration, Runtime / State Backends >Reporter: Junrui Li >Assignee: Junrui Li >Priority: Major > Labels: pull-request-available > Fix For: 1.19.0 > > > When we configure the checkpoint storage at the job level, it can only be > done through the following method: > {code:java} > StreamExecutionEnvironment env = > StreamExecutionEnvironment.getExecutionEnvironment(); > env.getCheckpointConfig().setCheckpointStorage(xxx); {code} > or configure filesystem storage by config option > CheckpointingOptions.CHECKPOINTS_DIRECTORY through the following method: > {code:java} > Configuration configuration = new Configuration(); > configuration.set(CheckpointingOptions.CHECKPOINTS_DIRECTORY, checkpointDir); > StreamExecutionEnvironment env = > StreamExecutionEnvironment.getExecutionEnvironment(configuration);{code} > However, configure the other type checkpoint storage by the job-side > configuration like the following will not take effect: > {code:java} > Configuration configuration = new Configuration(); > StreamExecutionEnvironment env = > StreamExecutionEnvironment.getExecutionEnvironment(configuration); > configuration.set(CheckpointingOptions.CHECKPOINT_STORAGE, > "aaa.bbb.ccc.CustomCheckpointStorage"); > configuration.set(CheckpointingOptions.CHECKPOINTS_DIRECTORY, checkpointDir); > {code} > This behavior is unexpected, we should allow this way will take effect. -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Updated] (FLINK-33080) The checkpoint storage configured in the job level by config option will not take effect
[ https://issues.apache.org/jira/browse/FLINK-33080?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-33080: Component/s: Runtime / Checkpointing (was: Runtime / State Backends) > The checkpoint storage configured in the job level by config option will not > take effect > > > Key: FLINK-33080 > URL: https://issues.apache.org/jira/browse/FLINK-33080 > Project: Flink > Issue Type: Bug > Components: Runtime / Checkpointing, Runtime / Configuration >Reporter: Junrui Li >Assignee: Junrui Li >Priority: Major > Labels: pull-request-available > Fix For: 1.19.0 > > > When we configure the checkpoint storage at the job level, it can only be > done through the following method: > {code:java} > StreamExecutionEnvironment env = > StreamExecutionEnvironment.getExecutionEnvironment(); > env.getCheckpointConfig().setCheckpointStorage(xxx); {code} > or configure filesystem storage by config option > CheckpointingOptions.CHECKPOINTS_DIRECTORY through the following method: > {code:java} > Configuration configuration = new Configuration(); > configuration.set(CheckpointingOptions.CHECKPOINTS_DIRECTORY, checkpointDir); > StreamExecutionEnvironment env = > StreamExecutionEnvironment.getExecutionEnvironment(configuration);{code} > However, configure the other type checkpoint storage by the job-side > configuration like the following will not take effect: > {code:java} > Configuration configuration = new Configuration(); > StreamExecutionEnvironment env = > StreamExecutionEnvironment.getExecutionEnvironment(configuration); > configuration.set(CheckpointingOptions.CHECKPOINT_STORAGE, > "aaa.bbb.ccc.CustomCheckpointStorage"); > configuration.set(CheckpointingOptions.CHECKPOINTS_DIRECTORY, checkpointDir); > {code} > This behavior is unexpected, we should allow this way will take effect. -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Updated] (FLINK-33080) The checkpoint storage configured in the job level by config option will not take effect
[ https://issues.apache.org/jira/browse/FLINK-33080?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-33080: --- Labels: pull-request-available (was: ) > The checkpoint storage configured in the job level by config option will not > take effect > > > Key: FLINK-33080 > URL: https://issues.apache.org/jira/browse/FLINK-33080 > Project: Flink > Issue Type: Bug > Components: Runtime / State Backends >Reporter: Junrui Li >Assignee: Junrui Li >Priority: Major > Labels: pull-request-available > Fix For: 1.19.0 > > > When we configure the checkpoint storage at the job level, it can only be > done through the following method: > {code:java} > StreamExecutionEnvironment env = > StreamExecutionEnvironment.getExecutionEnvironment(); > env.getCheckpointConfig().setCheckpointStorage(xxx); {code} > or configure filesystem storage by config option > CheckpointingOptions.CHECKPOINTS_DIRECTORY through the following method: > {code:java} > Configuration configuration = new Configuration(); > configuration.set(CheckpointingOptions.CHECKPOINTS_DIRECTORY, checkpointDir); > StreamExecutionEnvironment env = > StreamExecutionEnvironment.getExecutionEnvironment(configuration);{code} > However, configure the other type checkpoint storage by the job-side > configuration like the following will not take effect: > {code:java} > Configuration configuration = new Configuration(); > StreamExecutionEnvironment env = > StreamExecutionEnvironment.getExecutionEnvironment(configuration); > configuration.set(CheckpointingOptions.CHECKPOINT_STORAGE, > "aaa.bbb.ccc.CustomCheckpointStorage"); > configuration.set(CheckpointingOptions.CHECKPOINTS_DIRECTORY, checkpointDir); > {code} > This behavior is unexpected, we should allow this way will take effect. -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Updated] (FLINK-33080) The checkpoint storage configured in the job level by config option will not take effect
[ https://issues.apache.org/jira/browse/FLINK-33080?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Junrui Li updated FLINK-33080: -- Description: When we configure the checkpoint storage at the job level, it can only be done through the following method: {code:java} StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment(); env.getCheckpointConfig().setCheckpointStorage(xxx); {code} or configure filesystem storage by config option CheckpointingOptions.CHECKPOINTS_DIRECTORY through the following method: {code:java} Configuration configuration = new Configuration(); configuration.set(CheckpointingOptions.CHECKPOINTS_DIRECTORY, checkpointDir); StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment(configuration);{code} However, configure the other type checkpoint storage by the job-side configuration like the following will not take effect: {code:java} Configuration configuration = new Configuration(); StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment(configuration); configuration.set(CheckpointingOptions.CHECKPOINT_STORAGE, "aaa.bbb.ccc.CustomCheckpointStorage"); configuration.set(CheckpointingOptions.CHECKPOINTS_DIRECTORY, checkpointDir); {code} This behavior is unexpected, we should allow this way will take effect. was: When we configure the checkpoint storage at the job level, it can only be done through the following method: {code:java} StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment(); env.getCheckpointConfig().setCheckpointStorage(xxx); {code} However, configure the checkpoint storage by the job-side configuration like the following will not take effect: {code:java} Configuration configuration = new Configuration(); StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment(configuration); configuration.set(CheckpointingOptions.CHECKPOINT_STORAGE, "filesystem"); configuration.set(CheckpointingOptions.CHECKPOINTS_DIRECTORY, checkpointDir); {code} This behavior is unexpected, we should allow this way will take effect. > The checkpoint storage configured in the job level by config option will not > take effect > > > Key: FLINK-33080 > URL: https://issues.apache.org/jira/browse/FLINK-33080 > Project: Flink > Issue Type: Bug > Components: Runtime / State Backends >Reporter: Junrui Li >Assignee: Junrui Li >Priority: Major > Fix For: 1.19.0 > > > When we configure the checkpoint storage at the job level, it can only be > done through the following method: > {code:java} > StreamExecutionEnvironment env = > StreamExecutionEnvironment.getExecutionEnvironment(); > env.getCheckpointConfig().setCheckpointStorage(xxx); {code} > or configure filesystem storage by config option > CheckpointingOptions.CHECKPOINTS_DIRECTORY through the following method: > {code:java} > Configuration configuration = new Configuration(); > configuration.set(CheckpointingOptions.CHECKPOINTS_DIRECTORY, checkpointDir); > StreamExecutionEnvironment env = > StreamExecutionEnvironment.getExecutionEnvironment(configuration);{code} > However, configure the other type checkpoint storage by the job-side > configuration like the following will not take effect: > {code:java} > Configuration configuration = new Configuration(); > StreamExecutionEnvironment env = > StreamExecutionEnvironment.getExecutionEnvironment(configuration); > configuration.set(CheckpointingOptions.CHECKPOINT_STORAGE, > "aaa.bbb.ccc.CustomCheckpointStorage"); > configuration.set(CheckpointingOptions.CHECKPOINTS_DIRECTORY, checkpointDir); > {code} > This behavior is unexpected, we should allow this way will take effect. -- This message was sent by Atlassian Jira (v8.20.10#820010)