[
https://issues.apache.org/jira/browse/BEAM-642?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Maximilian Michels resolved BEAM-642.
-------------------------------------
Resolution: Fixed
Assignee: Sumit Chawla (was: Amit Sela)
Fix Version/s: 0.3.0-incubating
Resolved with 843275210b12ebf35b45d5f4d98c689dfb0820b1
[~sumitkchawla] was so kind to fix this. I hope you don't mind assigning him,
[~amitsela].
> FlinkRunner does not support Detached Mode
> ------------------------------------------
>
> Key: BEAM-642
> URL: https://issues.apache.org/jira/browse/BEAM-642
> Project: Beam
> Issue Type: Bug
> Components: runner-flink
> Reporter: Sumit Chawla
> Assignee: Sumit Chawla
> Fix For: 0.3.0-incubating
>
>
> FlinkRunner gives exception when job is submitted in detached mode.
> Following code will throw exception:
> {code}
> LOG.info("Execution finished in {} msecs", result.getNetRuntime());
> {code}
> {code}
> org.apache.flink.api.common.InvalidProgramException: Job was submitted in
> detached mode. Results of job execution, such as accumulators, runtime, job
> id etc. are not available.
> at
> org.apache.flink.client.program.DetachedEnvironment$DetachedJobExecutionResult.getNetRuntime(DetachedEnvironment.java:98)
> ~[flink-clients_2.10-1.1.2.jar:1.1.2]
> at org.apache.beam.runners.flink.FlinkRunner.run(FlinkRunner.java:116)
> ~[beam-runners-flink_2.10-0.2.0-incubating.jar:0.2.0-incubating]
> at org.apache.beam.runners.flink.FlinkRunner.run(FlinkRunner.java:48)
> ~[beam-runners-flink_2.10-0.2.0-incubating.jar:0.2.0-incubating]
> at org.apache.beam.sdk.Pipeline.run(Pipeline.java:183)
> ~[beam-sdks-java-core-0.2.0-incubating.jar:0.2.0-incubating]
> at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
> ~[?:1.8.0_92]
> at
> sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
> ~[?:1.8.0_92]
> at
> sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
> ~[?:1.8.0_92]
> at java.lang.reflect.Method.invoke(Method.java:498) ~[?:1.8.0_92]
> at
> org.apache.flink.client.program.PackagedProgram.callMainMethod(PackagedProgram.java:509)
> [flink-clients_2.10-1.1.2.jar:1.1.2]
> at
> org.apache.flink.client.program.PackagedProgram.invokeInteractiveModeForExecution(PackagedProgram.java:403)
> [flink-clients_2.10-1.1.2.jar:1.1.2]
> at
> org.apache.flink.client.program.ClusterClient.run(ClusterClient.java:320)
> [flink-clients_2.10-1.1.2.jar:1.1.2]
> at
> org.apache.flink.client.CliFrontend.executeProgram(CliFrontend.java:777)
> [flink-clients_2.10-1.1.2.jar:1.1.2]
> at org.apache.flink.client.CliFrontend.run(CliFrontend.java:253)
> [flink-clients_2.10-1.1.2.jar:1.1.2]
> {code}
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
