You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@beam.apache.org by "Beam JIRA Bot (Jira)" <ji...@apache.org> on 2021/10/03 17:25:00 UTC

[jira] [Updated] (BEAM-12642) Flink's job server container attempts to invoke docker

     [ https://issues.apache.org/jira/browse/BEAM-12642?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Beam JIRA Bot updated BEAM-12642:
---------------------------------
    Priority: P3  (was: P2)

> Flink's job server container attempts to invoke docker
> ------------------------------------------------------
>
>                 Key: BEAM-12642
>                 URL: https://issues.apache.org/jira/browse/BEAM-12642
>             Project: Beam
>          Issue Type: Bug
>          Components: runner-flink
>    Affects Versions: 2.31.0
>         Environment: Linux
>            Reporter: Ignacio Taranto
>            Priority: P3
>              Labels: stale-P2
>
> I want to run a Java pipeline with {{--runner PortableRunner}}, so I do the following:
>  * Run the Flink's job server with:
> {code:java}
> docker run --rm --net=host apache/beam_flink1.13_job_server:latest
> {code}
>  * Run the pipeline with:
> {code:java}
> mvn exec:java -Dexec.mainClass=org.foo.bar.MyMainClass -Pportable-runner -Dexec.args="--runner=PortableRunner --jobEndpoint=localhost:8099"
> {code}
> After this I get the error:
> {code:java}
> java.lang.Exception: The user defined 'open()' method caused an exception: java.io.IOException: Cannot run program "docker": error=2, No such file or directory
> 	at org.apache.flink.runtime.operators.BatchTask.run(BatchTask.java:513)
> 	at org.apache.flink.runtime.operators.BatchTask.invoke(BatchTask.java:360)
> 	at org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:779)
> 	at org.apache.flink.runtime.taskmanager.Task.run(Task.java:566)
> 	at java.lang.Thread.run(Thread.java:748){code}
> What I did to workaround this is to use the {{gradlew}} script from the Git repository like this:
> {code:java}
> ./gradlew :runners:flink:1.13:job-server:runShadow
> {code}
> and it works without problem.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)