Skip to content

Commit 225b252

Browse files
authored
Merge pull request #33146: #33145 cache namespace string key in FlinkStateInternals
2 parents 97de2ae + e91c46c commit 225b252

File tree

4 files changed

+64
-69
lines changed

4 files changed

+64
-69
lines changed
Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,4 @@
1+
{
2+
"comment": "Modify this file in a trivial way to cause this test suite to run",
3+
"runFor": "#33146"
4+
}
Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,4 @@
11
{
22
"comment": "Modify this file in a trivial way to cause this test suite to run",
3-
"https://github.com/apache/beam/pull/31156": "noting that PR #31156 should run this test",
4-
"https://github.com/apache/beam/pull/32648": "testing addition of Flink 1.19 support"
3+
"runFor": "#33146"
54
}

runners/core-java/src/main/java/org/apache/beam/runners/core/StateNamespaces.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -90,8 +90,8 @@ public void appendTo(Appendable sb) throws IOException {
9090
/** {@link StateNamespace} that is scoped to a specific window. */
9191
public static class WindowNamespace<W extends BoundedWindow> implements StateNamespace {
9292

93-
private Coder<W> windowCoder;
94-
private W window;
93+
private final Coder<W> windowCoder;
94+
private final W window;
9595

9696
private WindowNamespace(Coder<W> windowCoder, W window) {
9797
this.windowCoder = windowCoder;

0 commit comments

Comments
 (0)