Uploaded image for project: 'Beam'
  1. Beam
  2. BEAM-11054

Beam job not executing through flink web portal

    XMLWordPrintableJSON

    Details

    • Type: Bug
    • Status: Triage Needed
    • Priority: P1
    • Resolution: Unresolved
    • Affects Version/s: None
    • Fix Version/s: Not applicable
    • Component/s: runner-flink
    • Labels:
    • Environment:
      TEST
    • Flags:
      Important

      Description

      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) ~[?:?]

        Attachments

        1. FLINK_WEB_PORTAL_ERROR.JPG
          90 kB
          Jayraj Gupta

          Activity

            People

            • Assignee:
              Unassigned
              Reporter:
              Jay583 Jayraj Gupta
            • Votes:
              0 Vote for this issue
              Watchers:
              2 Start watching this issue

              Dates

              • Created:
                Updated: