beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From al...@apache.org
Subject [beam] branch master updated: Change Discarding Invalid Work Item log to debug
Date Sat, 16 Feb 2019 02:48:33 GMT
This is an automated email from the ASF dual-hosted git repository.

altay 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 8194758  Change Discarding Invalid Work Item log to debug
     new 162013d  Merge pull request #7854 from ajamato/logging
8194758 is described below

commit 8194758789eab287e8068e1277b164a5dcc8d3ef
Author: Alex Amato <ajamato@google.com>
AuthorDate: Fri Feb 15 10:46:32 2019 -0800

    Change Discarding Invalid Work Item log to debug
---
 .../org/apache/beam/runners/dataflow/worker/DataflowWorkUnitClient.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/DataflowWorkUnitClient.java
b/runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/DataflowWorkUnitClient.java
index 7f76639..3370856 100644
--- a/runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/DataflowWorkUnitClient.java
+++ b/runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/DataflowWorkUnitClient.java
@@ -109,7 +109,7 @@ class DataflowWorkUnitClient implements WorkUnitClient {
       return Optional.absent();
     }
     if (workItem.isPresent() && workItem.get().getId() == null) {
-      logger.warn("Discarding invalid work item {}", workItem.orNull());
+      logger.debug("Discarding invalid work item {}", workItem.orNull());
       return Optional.absent();
     }
 


Mime
View raw message