Fix protobuf error at Windmill.persistDirect() when there is a removal

apache · Oct 23, 2024 · 8245b34 · 8245b34
1 parent 7e346ad
commit 8245b34
Showing 1 changed file with 1 addition and 3 deletions.
diff --git a/...ker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/state/WindmillMap.java b/...ker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/state/WindmillMap.java
@@ -140,9 +140,7 @@ protected Windmill.WorkItemCommitRequest persistDirectly(WindmillStateCache.ForK
       commitBuilder
           .addValueUpdatesBuilder()
           .setTag(keyBytes)
-          .setStateFamily(stateFamily)
-          .getValueBuilder()
-          .setTimestamp(Long.MAX_VALUE);
+          .setStateFamily(stateFamily);
 
       V cachedValue = cachedValues.remove(key);
       if (cachedValue != null) {