[jira] [Commented] (FLINK-33679) RestoreMode uses NO_CLAIM as default instead of LEGACY

2024-01-15 Thread Zakelly Lan (Jira)


[ 
https://issues.apache.org/jira/browse/FLINK-33679?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17806730#comment-17806730
 ] 

Zakelly Lan commented on FLINK-33679:
-

Ah... I think the doc is misleading by the word 'so far', actually it is 
replaced by the NO_CLAIM since 1.15.
I'd like to fix the doc everywhere.

> RestoreMode uses NO_CLAIM as default instead of LEGACY
> --
>
> Key: FLINK-33679
> URL: https://issues.apache.org/jira/browse/FLINK-33679
> Project: Flink
>  Issue Type: Improvement
>  Components: Documentation, Runtime / State Backends
>Reporter: junzhong qin
>Priority: Minor
>
> RestoreMode uses NO_CLAIM as default instead of LEGACY.
> {code:java}
> public enum RestoreMode implements DescribedEnum {
> CLAIM(
> "Flink will take ownership of the given snapshot. It will clean 
> the"
> + " snapshot once it is subsumed by newer ones."),
> NO_CLAIM(
> "Flink will not claim ownership of the snapshot files. However it 
> will make sure it"
> + " does not depend on any artefacts from the restored 
> snapshot. In order to do that,"
> + " Flink will take the first checkpoint as a full one, 
> which means it might"
> + " reupload/duplicate files that are part of the 
> restored checkpoint."),
> LEGACY(
> "This is the mode in which Flink worked so far. It will not claim 
> ownership of the"
> + " snapshot and will not delete the files. However, it 
> can directly depend on"
> + " the existence of the files of the restored 
> checkpoint. It might not be safe"
> + " to delete checkpoints that were restored in legacy 
> mode ");
> private final String description;
> RestoreMode(String description) {
> this.description = description;
> }
> @Override
> @Internal
> public InlineElement getDescription() {
> return text(description);
> }
> public static final RestoreMode DEFAULT = NO_CLAIM;
> } {code}



--
This message was sent by Atlassian Jira
(v8.20.10#820010)


[jira] [Commented] (FLINK-33679) RestoreMode uses NO_CLAIM as default instead of LEGACY

2023-11-29 Thread junzhong qin (Jira)


[ 
https://issues.apache.org/jira/browse/FLINK-33679?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17791458#comment-17791458
 ] 

junzhong qin commented on FLINK-33679:
--

Hi [~masteryhx] , I confused with LEGACY which commented as "This is the mode 
in which Flink worked so far." But the default restore mode is "NO_CLAIM".

> RestoreMode uses NO_CLAIM as default instead of LEGACY
> --
>
> Key: FLINK-33679
> URL: https://issues.apache.org/jira/browse/FLINK-33679
> Project: Flink
>  Issue Type: Improvement
>  Components: Documentation, Runtime / State Backends
>Reporter: junzhong qin
>Priority: Minor
>
> RestoreMode uses NO_CLAIM as default instead of LEGACY.
> {code:java}
> public enum RestoreMode implements DescribedEnum {
> CLAIM(
> "Flink will take ownership of the given snapshot. It will clean 
> the"
> + " snapshot once it is subsumed by newer ones."),
> NO_CLAIM(
> "Flink will not claim ownership of the snapshot files. However it 
> will make sure it"
> + " does not depend on any artefacts from the restored 
> snapshot. In order to do that,"
> + " Flink will take the first checkpoint as a full one, 
> which means it might"
> + " reupload/duplicate files that are part of the 
> restored checkpoint."),
> LEGACY(
> "This is the mode in which Flink worked so far. It will not claim 
> ownership of the"
> + " snapshot and will not delete the files. However, it 
> can directly depend on"
> + " the existence of the files of the restored 
> checkpoint. It might not be safe"
> + " to delete checkpoints that were restored in legacy 
> mode ");
> private final String description;
> RestoreMode(String description) {
> this.description = description;
> }
> @Override
> @Internal
> public InlineElement getDescription() {
> return text(description);
> }
> public static final RestoreMode DEFAULT = NO_CLAIM;
> } {code}



--
This message was sent by Atlassian Jira
(v8.20.10#820010)


[jira] [Commented] (FLINK-33679) RestoreMode uses NO_CLAIM as default instead of LEGACY

2023-11-29 Thread Hangxiang Yu (Jira)


[ 
https://issues.apache.org/jira/browse/FLINK-33679?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17791403#comment-17791403
 ] 

Hangxiang Yu commented on FLINK-33679:
--

Hi, NO_CLAIM should be more production friendly than Legacy mode, so it's the 
better default option.

Do you have any other concerns about this ?

> RestoreMode uses NO_CLAIM as default instead of LEGACY
> --
>
> Key: FLINK-33679
> URL: https://issues.apache.org/jira/browse/FLINK-33679
> Project: Flink
>  Issue Type: Improvement
>  Components: Documentation, Runtime / State Backends
>Reporter: junzhong qin
>Priority: Minor
>
> RestoreMode uses NO_CLAIM as default instead of LEGACY.
> {code:java}
> public enum RestoreMode implements DescribedEnum {
> CLAIM(
> "Flink will take ownership of the given snapshot. It will clean 
> the"
> + " snapshot once it is subsumed by newer ones."),
> NO_CLAIM(
> "Flink will not claim ownership of the snapshot files. However it 
> will make sure it"
> + " does not depend on any artefacts from the restored 
> snapshot. In order to do that,"
> + " Flink will take the first checkpoint as a full one, 
> which means it might"
> + " reupload/duplicate files that are part of the 
> restored checkpoint."),
> LEGACY(
> "This is the mode in which Flink worked so far. It will not claim 
> ownership of the"
> + " snapshot and will not delete the files. However, it 
> can directly depend on"
> + " the existence of the files of the restored 
> checkpoint. It might not be safe"
> + " to delete checkpoints that were restored in legacy 
> mode ");
> private final String description;
> RestoreMode(String description) {
> this.description = description;
> }
> @Override
> @Internal
> public InlineElement getDescription() {
> return text(description);
> }
> public static final RestoreMode DEFAULT = NO_CLAIM;
> } {code}



--
This message was sent by Atlassian Jira
(v8.20.10#820010)