don't log missing computation state as error (#32942)

apache · Oct 28, 2024 · be7537a · be7537a
1 parent 8cd3e54
commit be7537a
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/...rc/main/java/org/apache/beam/runners/dataflow/worker/streaming/ComputationStateCache.java b/...rc/main/java/org/apache/beam/runners/dataflow/worker/streaming/ComputationStateCache.java
@@ -147,8 +147,10 @@ public Optional<ComputationState> get(String computationId) {
         | ComputationStateNotFoundException e) {
       if (e.getCause() instanceof ComputationStateNotFoundException
           || e instanceof ComputationStateNotFoundException) {
-        LOG.error(
-            "Trying to fetch unknown computation={}, known computations are {}.",
+        LOG.warn(
+            "Computation {} is currently unknown, "
+                + "known computations are {}. "
+                + "This is transient and will get retried.",
             computationId,
             ImmutableSet.copyOf(computationCache.asMap().keySet()));
       } else {