[
https://issues.apache.org/jira/browse/BEAM-4666?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16525769#comment-16525769
]
Henning Rohde commented on BEAM-4666:
-------------------------------------
Fixed a semantic typo in runnerlib.Stage. Now, I see:
$ go run examples/wordcount/wordcount.go --runner=flink
--endpoint=localhost:8099 --output=/tmp/asd
2018/06/27 17:25:04 No container image specified. Using dev image:
'herohde-docker-apache.bintray.io/beam/go:latest'
2018/06/27 17:25:04 Prepared job with id:
go-job-1-1530145504041190151_6c897a9e-7878-4158-ba93-14a9c10543bd and staging
token:
{"sessionId":"go-job-1-1530145504041190151_6c897a9e-7878-4158-ba93-14a9c10543bd","basePath":"/tmp/flink-artifacts"}
2018/06/27 17:25:04 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-1530145504049683707
2018/06/27 17:25:15 Failed to execute job: failed to stage artifacts: failed to
stage
/var/folders/s2/97strbs55_353t_t7r24yf94009w4s/T/beam-go-1530145504049683707 in
3 attempts: failed to close stream for
/var/folders/s2/97strbs55_353t_t7r24yf94009w4s/T/beam-go-1530145504049683707:
EOF; failed to close stream for
/var/folders/s2/97strbs55_353t_t7r24yf94009w4s/T/beam-go-1530145504049683707:
EOF; failed to close stream for
/var/folders/s2/97strbs55_353t_t7r24yf94009w4s/T/beam-go-1530145504049683707:
EOF; failed to close stream for
/var/folders/s2/97strbs55_353t_t7r24yf94009w4s/T/beam-go-1530145504049683707:
EOF
> 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)
