[FLINK-24784][runtime] Enable state.backend.latency-track.state-name-…

…as-variable by default
tongcheng-elong · Nov 15, 2021 · 07d2585 · 07d2585
1 parent a66a876
commit 07d2585
Show file tree

Hide file tree

Showing 4 changed files with 6 additions and 3 deletions.
diff --git a/docs/layouts/shortcodes/generated/state_backend_configuration.html b/docs/layouts/shortcodes/generated/state_backend_configuration.html
@@ -34,7 +34,7 @@
  </tr>
  <tr>
  <td><h5>state.backend.latency-track.state-name-as-variable</h5></td>
- <td style="word-wrap: break-word;">false</td>
+ <td style="word-wrap: break-word;">true</td>
  <td>Boolean</td>
  <td>Whether to expose state name as a variable if tracking latency.</td>
  </tr>

diff --git a/docs/layouts/shortcodes/generated/state_backend_latency_tracking_section.html b/docs/layouts/shortcodes/generated/state_backend_latency_tracking_section.html
@@ -28,7 +28,7 @@
  </tr>
  <tr>
  <td><h5>state.backend.latency-track.state-name-as-variable</h5></td>
- <td style="word-wrap: break-word;">false</td>
+ <td style="word-wrap: break-word;">true</td>
  <td>Boolean</td>
  <td>Whether to expose state name as a variable if tracking latency.</td>
  </tr>

diff --git a/flink-core/src/main/java/org/apache/flink/configuration/StateBackendOptions.java b/flink-core/src/main/java/org/apache/flink/configuration/StateBackendOptions.java
@@ -93,7 +93,7 @@ public class StateBackendOptions {
  public static final ConfigOption<Boolean> LATENCY_TRACK_STATE_NAME_AS_VARIABLE =
  ConfigOptions.key("state.backend.latency-track.state-name-as-variable")
  .booleanType()
- .defaultValue(false)
+ .defaultValue(true)
  .withDescription(
  "Whether to expose state name as a variable if tracking latency.");
 }
diff --git a/.../src/test/java/org/apache/flink/runtime/state/metrics/LatencyTrackingStateConfigTest.java b/.../src/test/java/org/apache/flink/runtime/state/metrics/LatencyTrackingStateConfigTest.java
@@ -50,6 +50,9 @@ public void testDefaultEnabledLatencyTrackingStateConfig() {
  Assert.assertEquals(
  (long) StateBackendOptions.LATENCY_TRACK_HISTORY_SIZE.defaultValue(),
  latencyTrackingStateConfig.getHistorySize());
+ Assert.assertEquals(
+ StateBackendOptions.LATENCY_TRACK_STATE_NAME_AS_VARIABLE.defaultValue(),
+ latencyTrackingStateConfig.isStateNameAsVariable());
  }
 
  @Test