[GitHub] [beam] damccorm opened a new issue, #20623: Beam job not executing through flink web portal

[GitBox <gi...@apache.org>]

damccorm opened a new issue, #20623:
URL: https://github.com/apache/beam/issues/20623

   Trying to submit jar from Flink web portal and it's throwing error-
   
    
   
   2020-10-09 23:10:09,535 ERROR org.apache.flink.runtime.webmonitor.handlers.JarPlanHandler [] - Unhandled exception.
    org.apache.flink.client.program.ProgramInvocationException: The main method caused an error: Argument 'localhost' does not begin with '\--'
    at org.apache.flink.client.program.PackagedProgram.callMainMethod(PackagedProgram.java:302) ~[flink-dist_2.11-1.11.2.jar:1.11.2]
    at org.apache.flink.client.program.PackagedProgram.invokeInteractiveModeForExecution(PackagedProgram.java:198) ~[flink-dist_2.11-1.11.2.jar:1.11.2]
    at org.apache.flink.client.program.PackagedProgramUtils.getPipelineFromProgram(PackagedProgramUtils.java:150) ~[flink-dist_2.11-1.11.2.jar:1.11.2]
    at org.apache.flink.client.program.PackagedProgramUtils.createJobGraph(PackagedProgramUtils.java:77) ~[flink-dist_2.11-1.11.2.jar:1.11.2]
    at org.apache.flink.runtime.webmonitor.handlers.utils.JarHandlerUtils$JarHandlerContext.toJobGraph(JarHandlerUtils.java:136) ~[flink-dist_2.11-1.11.2.jar:1.11.2]
    at org.apache.flink.runtime.webmonitor.handlers.JarPlanHandler.lambda$handleRequest$1(JarPlanHandler.java:100) ~[flink-dist_2.11-1.11.2.jar:1.11.2]
    at java.util.concurrent.CompletableFuture$AsyncSupply.run(CompletableFuture.java:1590) [?:1.8.0_131]
    at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) [?:1.8.0_131]
    at java.util.concurrent.FutureTask.run(FutureTask.java:266) [?:1.8.0_131]
    at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:180) [?:1.8.0_131]
    at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293) [?:1.8.0_131]
    at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142) [?:1.8.0_131]
    at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) [?:1.8.0_131]
    at java.lang.Thread.run(Thread.java:748) [?:1.8.0_131]
    Caused by: java.lang.IllegalArgumentException: Argument 'localhost' does not begin with '\--'
    at org.apache.beam.vendor.guava.v26_0_jre.com.google.common.base.Preconditions.checkArgument(Preconditions.java:216) ~[?:?]
    at org.apache.beam.sdk.options.PipelineOptionsFactory.parseCommandLine(PipelineOptionsFactory.java:1561) ~[?:?]
    at org.apache.beam.sdk.options.PipelineOptionsFactory.access$200(PipelineOptionsFactory.java:115) ~[?:?]
    at org.apache.beam.sdk.options.PipelineOptionsFactory$Builder.as(PipelineOptionsFactory.java:295) ~[?:?]
    at org.apache.beam.sdk.options.PipelineOptionsFactory$Builder.create(PipelineOptionsFactory.java:278) ~[?:?]
   
   Imported from Jira [BEAM-11054](https://issues.apache.org/jira/browse/BEAM-11054). Original Jira may contain additional context.
   Reported by: Jay583.


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: github-unsubscribe@beam.apache.org.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org