[
https://issues.apache.org/jira/browse/BEAM-4666?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16525772#comment-16525772
]
Henning Rohde commented on BEAM-4666:
-------------------------------------
Treating EOF as not an error, I see:
$ go run examples/wordcount/wordcount.go --runner=flink
--endpoint=localhost:8099 --output=/tmp/asd
2018/06/27 17:28:25 No container image specified. Using dev image:
'herohde-docker-apache.bintray.io/beam/go:latest'
2018/06/27 17:28:25 Prepared job with id:
go-job-1-1530145705832886785_dde07b19-7287-4be7-86c5-6954435ce872 and staging
token:
{"sessionId":"go-job-1-1530145705832886785_dde07b19-7287-4be7-86c5-6954435ce872","basePath":"/tmp/flink-artifacts"}
2018/06/27 17:28:25 Cross-compiling
/Users/herohde/go/src/github.com/apache/beam/sdks/go/examples/wordcount/wordcount.go
as /var/folders/s2/97strbs55_353t_t7r24yf94009w4s/T/beam-go-1530145705841150809
2018/06/27 17:28:28 Staged binary artifact with token:
/tmp/flink-artifacts/go-job-1-1530145705832886785_dde07b19-7287-4be7-86c5-6954435ce872/MANIFEST
2018/06/27 17:28:28 Failed to execute job: failed to submit job: rpc error:
code = InvalidArgument desc =
exit status 1
> Go SDK fails to stage artifacts on Flink
> ----------------------------------------
>
> Key: BEAM-4666
> URL: https://issues.apache.org/jira/browse/BEAM-4666
> Project: Beam
> Issue Type: Bug
> Components: sdk-go
> Reporter: Henning Rohde
> Assignee: Henning Rohde
> Priority: Major
>
> $ go run examples/wordcount/wordcount.go --runner=flink
> --endpoint=localhost:8099 --output=/tmp/asd
> 2018/06/27 17:17:02 No container image specified. Using dev image:
> 'herohde-docker-apache.bintray.io/beam/go:latest'
> 2018/06/27 17:17:02 Prepared job with id:
> go-job-1-1530145022009357193_b49f59e5-4dfc-4b82-aa67-cad62a3f7d6a and staging
> token:
> {"sessionId":"go-job-1-1530145022009357193_b49f59e5-4dfc-4b82-aa67-cad62a3f7d6a","basePath":"/tmp/flink-artifacts"}
> 2018/06/27 17:17:02 Cross-compiling
> /Users/herohde/go/src/github.com/apache/beam/sdks/go/examples/wordcount/wordcount.go
> as
> /var/folders/s2/97strbs55_353t_t7r24yf94009w4s/T/beam-go-1530145022019779968
> 2018/06/27 17:17:12 Failed to execute job: failed to stage artifacts: failed
> to stage
> {"sessionId":"go-job-1-1530145022009357193_b49f59e5-4dfc-4b82-aa67-cad62a3f7d6a","basePath":"/tmp/flink-artifacts"}
> in 3 attempts: stat
> {"sessionId":"go-job-1-1530145022009357193_b49f59e5-4dfc-4b82-aa67-cad62a3f7d6a","basePath":"/tmp/flink-artifacts"}:
> no such file or directory; stat
> {"sessionId":"go-job-1-1530145022009357193_b49f59e5-4dfc-4b82-aa67-cad62a3f7d6a","basePath":"/tmp/flink-artifacts"}:
> no such file or directory; stat
> {"sessionId":"go-job-1-1530145022009357193_b49f59e5-4dfc-4b82-aa67-cad62a3f7d6a","basePath":"/tmp/flink-artifacts"}:
> no such file or directory; stat
> {"sessionId":"go-job-1-1530145022009357193_b49f59e5-4dfc-4b82-aa67-cad62a3f7d6a","basePath":"/tmp/flink-artifacts"}:
> no such file or directory
> exit status 1
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
