(beam) branch master updated: don't log missing computation state as error (#32942)

[scwhittle]

This is an automated email from the ASF dual-hosted git repository.

scwhittle pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git


The following commit(s) were added to refs/heads/master by this push:
     new be7537a2abf don't log missing computation state as error (#32942)
be7537a2abf is described below

commit be7537a2abf77e834e4e7f4e68bb52a303c09bf6
Author: martin trieu <marti...@google.com>
AuthorDate: Mon Oct 28 04:14:50 2024 -0600

    don't log missing computation state as error (#32942)
---
 .../runners/dataflow/worker/streaming/ComputationStateCache.java    | 6 ++++--
 1 file changed, 4 insertions(+), 2 deletions(-)

diff --git 
a/runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/streaming/ComputationStateCache.java
 
b/runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/streaming/ComputationStateCache.java
index 199ad26aed0..4b4acb73f4a 100644
--- 
a/runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/streaming/ComputationStateCache.java
+++ 
b/runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/streaming/ComputationStateCache.java
@@ -147,8 +147,10 @@ public final class ComputationStateCache implements 
StatusDataProvider {
         | 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 {