Skip to content

Commit

Permalink
[FLINK-23738][state] Hide ChangelogBackend config options
Browse files Browse the repository at this point in the history
The feature won't be released in the upcoming release.

 # Please enter the commit message for your changes. Lines starting
  • Loading branch information
rkhachatryan committed Aug 15, 2021
1 parent d7794b8 commit 67dd493
Show file tree
Hide file tree
Showing 4 changed files with 4 additions and 24 deletions.
12 changes: 0 additions & 12 deletions docs/layouts/shortcodes/generated/checkpointing_configuration.html
Original file line number Diff line number Diff line change
Expand Up @@ -8,18 +8,6 @@
</tr>
</thead>
<tbody>
<tr>
<td><h5>state.backend.changelog.enabled</h5></td>
<td style="word-wrap: break-word;">false</td>
<td>Boolean</td>
<td>Whether to enable state backend to write state changes to StateChangelog. If this config is not set explicitly, it means no preference for enabling the change log, and the value in lower config level will take effect. The default value 'false' here means if no value set (job or cluster), the change log will not be enabled.</td>
</tr>
<tr>
<td><h5>state.backend.changelog.storage</h5></td>
<td style="word-wrap: break-word;">"memory"</td>
<td>String</td>
<td>The storage to be used to store state changelog.<br />The implementation can be specified via their shortcut name.<br />The list of recognized shortcut names currently includes 'memory' and 'filesystem'.</td>
</tr>
<tr>
<td><h5>state.backend.incremental</h5></td>
<td style="word-wrap: break-word;">false</td>
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -32,18 +32,6 @@
<td>String</td>
<td>The default directory for savepoints. Used by the state backends that write savepoints to file systems (HashMapStateBackend, EmbeddedRocksDBStateBackend).</td>
</tr>
<tr>
<td><h5>state.backend.changelog.enabled</h5></td>
<td style="word-wrap: break-word;">false</td>
<td>Boolean</td>
<td>Whether to enable state backend to write state changes to StateChangelog. If this config is not set explicitly, it means no preference for enabling the change log, and the value in lower config level will take effect. The default value 'false' here means if no value set (job or cluster), the change log will not be enabled.</td>
</tr>
<tr>
<td><h5>state.backend.changelog.storage</h5></td>
<td style="word-wrap: break-word;">"memory"</td>
<td>String</td>
<td>The storage to be used to store state changelog.<br />The implementation can be specified via their shortcut name.<br />The list of recognized shortcut names currently includes 'memory' and 'filesystem'.</td>
</tr>
<tr>
<td><h5>state.backend.incremental</h5></td>
<td style="word-wrap: break-word;">false</td>
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -102,6 +102,7 @@ public class CheckpointingOptions {

/** Whether to enable state change log. */
@Documentation.Section(value = Documentation.Sections.COMMON_STATE_BACKENDS)
@Documentation.ExcludeFromDocumentation("ChangelogBackend is under development")
public static final ConfigOption<Boolean> ENABLE_STATE_CHANGE_LOG =
ConfigOptions.key("state.backend.changelog.enabled")
.booleanType()
Expand All @@ -121,6 +122,7 @@ public class CheckpointingOptions {
* InMemoryStateChangelogStorageFactory.getIdentifier()}, which is also the default value.
*/
@Documentation.Section(value = Documentation.Sections.COMMON_STATE_BACKENDS)
@Documentation.ExcludeFromDocumentation("ChangelogBackend is under development")
public static final ConfigOption<String> STATE_CHANGE_LOG_STORAGE =
ConfigOptions.key("state.backend.changelog.storage")
.stringType()
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -18,6 +18,7 @@
package org.apache.flink.changelog.fs;

import org.apache.flink.annotation.Experimental;
import org.apache.flink.annotation.docs.Documentation;
import org.apache.flink.configuration.ConfigOption;
import org.apache.flink.configuration.ConfigOptions;
import org.apache.flink.configuration.MemorySize;
Expand All @@ -28,6 +29,7 @@

/** {@link ConfigOptions} for {@link FsStateChangelogStorage}. */
@Experimental
@Documentation.ExcludeFromDocumentation("ChangelogBackend is under development")
public class FsStateChangelogOptions {

public static final ConfigOption<String> BASE_PATH =
Expand Down

0 comments on commit 67dd493

Please sign in to comment.