[ https://issues.apache.org/jira/browse/BEAM-3287?focusedWorklogId=82129&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-82129 ]
ASF GitHub Bot logged work on BEAM-3287: ---------------------------------------- Author: ASF GitHub Bot Created on: 20/Mar/18 02:08 Start Date: 20/Mar/18 02:08 Worklog Time Spent: 10m Work Description: herohde commented on issue #4888: [BEAM-3287] Add Go support for universal runners, incl Flink URL: https://github.com/apache/beam/pull/4888#issuecomment-374448020 Now I get: ``` [flink-runner-job-server] ERROR org.apache.beam.runners.flink.FlinkRunner - Artifact registration failed java.lang.RuntimeException: Unexpected exception while writing artifact at org.apache.beam.runners.flink.FlinkPipelineExecutionEnvironment.loadStagedArtifacts(FlinkPipelineExecutionEnvironment.java:358) at org.apache.beam.runners.flink.FlinkRunner.run(FlinkRunner.java:121) at org.apache.beam.runners.flink.FlinkJobInvocation.lambda$start$0(FlinkJobInvocation.java:61) at org.apache.beam.util.concurrent.TrustedListenableFutureTask$TrustedFutureInterruptibleTask.runInterruptibly(TrustedListenableFutureTask.java:111) at org.apache.beam.util.concurrent.InterruptibleTask.run(InterruptibleTask.java:58) at org.apache.beam.util.concurrent.TrustedListenableFutureTask.run(TrustedListenableFutureTask.java:75) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) at java.lang.Thread.run(Thread.java:748) Caused by: java.util.concurrent.ExecutionException: io.grpc.StatusException: INVALID_ARGUMENT: No such artifact ARTIFACT_default_worker at org.apache.beam.util.concurrent.AbstractFuture.getDoneValue(AbstractFuture.java:500) at org.apache.beam.util.concurrent.AbstractFuture.get(AbstractFuture.java:459) at org.apache.beam.util.concurrent.AbstractFuture$TrustedFuture.get(AbstractFuture.java:76) at org.apache.beam.runners.flink.FlinkPipelineExecutionEnvironment.loadStagedArtifacts(FlinkPipelineExecutionEnvironment.java:352) ... 8 more Caused by: io.grpc.StatusException: INVALID_ARGUMENT: No such artifact ARTIFACT_default_worker at io.grpc.Status.asException(Status.java:548) at org.apache.beam.artifact.local.LocalArtifactSource.getArtifact(LocalArtifactSource.java:54) at org.apache.beam.runners.flink.FlinkPipelineExecutionEnvironment.loadStagedArtifacts(FlinkPipelineExecutionEnvironment.java:350) ... 8 more Caused by: java.io.FileNotFoundException: /tmp/beam-artifact-staging/go-job-1521511453974075000_1141769330/artifacts/ARTIFACT_default_worker (No such file or directory) at java.io.FileInputStream.open0(Native Method) at java.io.FileInputStream.open(FileInputStream.java:195) at java.io.FileInputStream.<init>(FileInputStream.java:138) at org.apache.beam.artifact.local.LocalArtifactSource.getArtifact(LocalArtifactSource.java:42) ... 9 more [flink-runner-job-server] ERROR org.apache.beam.runners.flink.FlinkJobInvocation - Error during job invocation go-job-1521511453974075000_1141769330_1342644097. java.lang.RuntimeException: Artifact registration failed at org.apache.beam.runners.flink.FlinkRunner.run(FlinkRunner.java:124) at org.apache.beam.runners.flink.FlinkJobInvocation.lambda$start$0(FlinkJobInvocation.java:61) at org.apache.beam.util.concurrent.TrustedListenableFutureTask$TrustedFutureInterruptibleTask.runInterruptibly(TrustedListenableFutureTask.java:111) at org.apache.beam.util.concurrent.InterruptibleTask.run(InterruptibleTask.java:58) at org.apache.beam.util.concurrent.TrustedListenableFutureTask.run(TrustedListenableFutureTask.java:75) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) at java.lang.Thread.run(Thread.java:748) Caused by: java.lang.RuntimeException: Unexpected exception while writing artifact at org.apache.beam.runners.flink.FlinkPipelineExecutionEnvironment.loadStagedArtifacts(FlinkPipelineExecutionEnvironment.java:358) at org.apache.beam.runners.flink.FlinkRunner.run(FlinkRunner.java:121) ... 7 more Caused by: java.util.concurrent.ExecutionException: io.grpc.StatusException: INVALID_ARGUMENT: No such artifact ARTIFACT_default_worker at org.apache.beam.util.concurrent.AbstractFuture.getDoneValue(AbstractFuture.java:500) at org.apache.beam.util.concurrent.AbstractFuture.get(AbstractFuture.java:459) at org.apache.beam.util.concurrent.AbstractFuture$TrustedFuture.get(AbstractFuture.java:76) at org.apache.beam.runners.flink.FlinkPipelineExecutionEnvironment.loadStagedArtifacts(FlinkPipelineExecutionEnvironment.java:352) ... 8 more Caused by: io.grpc.StatusException: INVALID_ARGUMENT: No such artifact ARTIFACT_default_worker at io.grpc.Status.asException(Status.java:548) at org.apache.beam.artifact.local.LocalArtifactSource.getArtifact(LocalArtifactSource.java:54) at org.apache.beam.runners.flink.FlinkPipelineExecutionEnvironment.loadStagedArtifacts(FlinkPipelineExecutionEnvironment.java:350) ... 8 more Caused by: java.io.FileNotFoundException: /tmp/beam-artifact-staging/go-job-1521511453974075000_1141769330/artifacts/ARTIFACT_default_worker (No such file or directory) at java.io.FileInputStream.open0(Native Method) at java.io.FileInputStream.open(FileInputStream.java:195) at java.io.FileInputStream.<init>(FileInputStream.java:138) at org.apache.beam.artifact.local.LocalArtifactSource.getArtifact(LocalArtifactSource.java:42) ... 9 more ``` It seems we're mangling the name. The correct file, named "worker", is indeed in this directory: ``` $ ls /tmp/beam-artifact-staging/go-job-1521511453974075000_1141769330/artifacts worker ``` ---------------------------------------------------------------- This is an automated message from the Apache Git Service. To respond to the message, please log on GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org Issue Time Tracking ------------------- Worklog Id: (was: 82129) Time Spent: 3h (was: 2h 50m) > Go SDK support for portable pipelines > ------------------------------------- > > Key: BEAM-3287 > URL: https://issues.apache.org/jira/browse/BEAM-3287 > Project: Beam > Issue Type: Improvement > Components: sdk-go > Reporter: Henning Rohde > Assignee: Henning Rohde > Priority: Major > Labels: portability > Time Spent: 3h > Remaining Estimate: 0h > > The Go SDK should participate in the portability framework, incl. job > submission w/ a docker container image. -- This message was sent by Atlassian JIRA (v7.6.3#76005)