[flink] #33145 cache StateNamespace#stringKey in FlinkStateInternals

apache · Nov 18, 2024 · 27aa65e · 27aa65e
1 parent 0682edc
commit 27aa65e
Show file tree

Hide file tree

Showing 2 changed files with 59 additions and 67 deletions.
diff --git a/runners/core-java/src/main/java/org/apache/beam/runners/core/StateNamespaces.java b/runners/core-java/src/main/java/org/apache/beam/runners/core/StateNamespaces.java
@@ -90,8 +90,8 @@ public void appendTo(Appendable sb) throws IOException {
   /** {@link StateNamespace} that is scoped to a specific window. */
   public static class WindowNamespace<W extends BoundedWindow> implements StateNamespace {
 
-    private Coder<W> windowCoder;
-    private W window;
+    private final Coder<W> windowCoder;
+    private final W window;
 
     private WindowNamespace(Coder<W> windowCoder, W window) {
       this.windowCoder = windowCoder;