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 <kcwea...@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); } }