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 2022/03/16 17:26:00 UTC

[jira] [Commented] (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:comment-tabpanel&focusedCommentId=17507758#comment-17507758 ] 

Beam JIRA Bot commented on BEAM-12642:
--------------------------------------

This issue is P2 but has been unassigned without any comment for 60 days so it has been labeled "stale-P2". If this issue is still affecting you, we care! Please comment and remove the label. Otherwise, in 14 days the issue will be moved to P3.

Please see https://beam.apache.org/contribute/jira-priorities/ for a detailed explanation of what these priorities mean.


> 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: P2
>              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.20.1#820001)