org.apache.flink.client.program.ProgramInvocationException: The main method caused an error.

incubator-beam-user | William McCarthy | 9 months ago
  1. 0

    Re: Output from Beam (on Flink) to Kafka

    beam-user | 9 months ago | William McCarthy
    org.apache.flink.client.program.ProgramInvocationException: The main method caused an error.
  2. 0

    Re: Output from Beam (on Flink) to Kafka

    incubator-beam-user | 9 months ago | William McCarthy
    org.apache.flink.client.program.ProgramInvocationException: The main method caused an error.
  3. 0

    Re: Output from Beam (on Flink) to Kafka

    incubator-beam-user | 9 months ago | William McCarthy
    org.apache.flink.client.program.ProgramInvocationException: The main method caused an error.
  4. Speed up your debug routine!

    Automated exception search integrated into your IDE

  5. 0

    Re: Output from Beam (on Flink) to Kafka

    beam-user | 9 months ago | William McCarthy
    org.apache.flink.client.program.ProgramInvocationException: The main method caused an error.
  6. 0

    Re: Output from Beam (on Flink) to Kafka

    incubator-beam-user | 9 months ago | William McCarthy
    org.apache.flink.client.program.ProgramInvocationException: The main method caused an error.

    Not finding the right solution?
    Take a tour to get the most out of Samebug.

    Tired of useless tips?

    Automated exception search integrated into your IDE

    Root Cause Analysis

    1. java.lang.IllegalArgumentException

      Unknown 'runner' specified 'org.apache.beam.runners.flink.FlinkPipelineRunner', supported pipeline runners [BlockingDataflowPipelineRunner, DataflowPipelineRunner, DirectPipelineRunner]

      at com.google.cloud.dataflow.sdk.repackaged.com.google.common.base.Preconditions.checkArgument()
    2. com.google.cloud
      TopHashtagsExample.main
      1. com.google.cloud.dataflow.sdk.repackaged.com.google.common.base.Preconditions.checkArgument(Preconditions.java:146)
      2. com.google.cloud.dataflow.sdk.options.PipelineOptionsFactory.parseObjects(PipelineOptionsFactory.java:1445)
      3. com.google.cloud.dataflow.sdk.options.PipelineOptionsFactory.access$400(PipelineOptionsFactory.java:99)
      4. com.google.cloud.dataflow.sdk.options.PipelineOptionsFactory$Builder.as(PipelineOptionsFactory.java:284)
      5. com.google.cloud.dataflow.contrib.kafka.examples.TopHashtagsExample.main(TopHashtagsExample.java:117)
      5 frames
    3. Java RT
      Method.invoke
      1. sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
      2. sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
      3. sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
      4. java.lang.reflect.Method.invoke(Method.java:498)
      4 frames
    4. flink-clients
      CliFrontend.main
      1. org.apache.flink.client.program.PackagedProgram.callMainMethod(PackagedProgram.java:505)
      2. org.apache.flink.client.program.PackagedProgram.invokeInteractiveModeForExecution(PackagedProgram.java:403)
      3. org.apache.flink.client.program.Client.runBlocking(Client.java:248)
      4. org.apache.flink.client.CliFrontend.executeProgramBlocking(CliFrontend.java:866)
      5. org.apache.flink.client.CliFrontend.run(CliFrontend.java:333)
      6. org.apache.flink.client.CliFrontend.parseParameters(CliFrontend.java:1189)
      7. org.apache.flink.client.CliFrontend.main(CliFrontend.java:1239)
      7 frames