[beam] branch master updated: [BEAM-8293] prescriptive log message for artifact retrieval failure

[ro...@apache.org]

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

robertwb 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 340c320  [BEAM-8293] prescriptive log message for artifact retrieval failure
     new f07bd7a  Merge pull request #9646 from ibzib/retrieve-fail
340c320 is described below

commit 340c3202b1e5824b959f5f9f626e4c7c7842a3cb
Author: Kyle Weaver <kc...@google.com>
AuthorDate: Mon Sep 23 17:45:16 2019 -0700

    [BEAM-8293] prescriptive log message for artifact retrieval failure
---
 .../artifact/BeamFileSystemArtifactRetrievalService.java            | 6 +++++-
 1 file changed, 5 insertions(+), 1 deletion(-)

diff --git a/runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/artifact/BeamFileSystemArtifactRetrievalService.java b/runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/artifact/BeamFileSystemArtifactRetrievalService.java
index ff7e9ba..06f26f1 100644
--- a/runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/artifact/BeamFileSystemArtifactRetrievalService.java
+++ b/runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/artifact/BeamFileSystemArtifactRetrievalService.java
@@ -89,7 +89,11 @@ public class BeamFileSystemArtifactRetrievalService
       responseObserver.onNext(response);
       responseObserver.onCompleted();
     } catch (Exception e) {
-      LOG.info("GetManifest for {} failed", token, e);
+      LOG.warn(
+          "GetManifest for {} failed. Make sure the artifact staging directory (configurable "
+              + "via --artifacts-dir argument to the job server) is accessible to workers.",
+          token,
+          e);
       responseObserver.onError(e);
     }
   }