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)