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

GitHub | GEOFBOT | 5 months ago
  1. 0

    GitHub comment 1#237422781

    GitHub | 5 months ago | magsol
    org.apache.flink.client.program.ProgramInvocationException: The main method caused an error.
  2. 0

    The result of .flat_map cannot be directly used to close bulk iterations

    GitHub | 5 months ago | GEOFBOT
    org.apache.flink.client.program.ProgramInvocationException: The main method caused an error.
  3. 0
    If the decompile process didn't work properly, try the Android APK Decompiler.
  4. Speed up your debug routine!

    Automated exception search integrated into your IDE

  5. 0
    You might have a JRockit JVM with the management agent started on the same port.
  6. 0
    I did this as root, and works dpkg --add-architecture i386 apt-get install libncurses5:i386 libstdc++6:i386 zlib1g:i386

    1 unregistered visitors
    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.RuntimeException

      Error while creating the data flow plan for the program: Unknown operator or data set type: null

      at org.apache.flink.api.java.operators.OperatorTranslation.translate()
    2. flink-java
      ExecutionEnvironment.createProgramPlan
      1. org.apache.flink.api.java.operators.OperatorTranslation.translate(OperatorTranslation.java:104)
      2. org.apache.flink.api.java.operators.OperatorTranslation.translateBulkIteration(OperatorTranslation.java:196)
      3. org.apache.flink.api.java.operators.OperatorTranslation.translate(OperatorTranslation.java:94)
      4. org.apache.flink.api.java.operators.OperatorTranslation.translateSingleInputOperator(OperatorTranslation.java:124)
      5. org.apache.flink.api.java.operators.OperatorTranslation.translate(OperatorTranslation.java:88)
      6. org.apache.flink.api.java.operators.OperatorTranslation.translateSingleInputOperator(OperatorTranslation.java:124)
      7. org.apache.flink.api.java.operators.OperatorTranslation.translate(OperatorTranslation.java:88)
      8. org.apache.flink.api.java.operators.OperatorTranslation.translate(OperatorTranslation.java:63)
      9. org.apache.flink.api.java.operators.OperatorTranslation.translateToPlan(OperatorTranslation.java:51)
      10. org.apache.flink.api.java.ExecutionEnvironment.createProgramPlan(ExecutionEnvironment.java:1035)
      11. org.apache.flink.api.java.ExecutionEnvironment.createProgramPlan(ExecutionEnvironment.java:1002)
      11 frames
    3. flink-clients
      ContextEnvironment.execute
      1. org.apache.flink.client.program.ContextEnvironment.execute(ContextEnvironment.java:58)
      1 frame
    4. flink-java
      ExecutionEnvironment.execute
      1. org.apache.flink.api.java.ExecutionEnvironment.execute(ExecutionEnvironment.java:896)
      1 frame
    5. org.apache.flink
      PythonPlanBinder.main
      1. org.apache.flink.python.api.PythonPlanBinder.runPlan(PythonPlanBinder.java:150)
      2. org.apache.flink.python.api.PythonPlanBinder.main(PythonPlanBinder.java:115)
      2 frames
    6. 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
    7. flink-clients
      CliFrontend.main
      1. org.apache.flink.client.program.PackagedProgram.callMainMethod(PackagedProgram.java:509)
      2. org.apache.flink.client.program.PackagedProgram.invokeInteractiveModeForExecution(PackagedProgram.java:403)
      3. org.apache.flink.client.program.ClusterClient.run(ClusterClient.java:331)
      4. org.apache.flink.client.CliFrontend.executeProgram(CliFrontend.java:775)
      5. org.apache.flink.client.CliFrontend.run(CliFrontend.java:251)
      6. org.apache.flink.client.CliFrontend.parseParameters(CliFrontend.java:1003)
      7. org.apache.flink.client.CliFrontend.main(CliFrontend.java:1046)
      7 frames