org.apache.flink.api.common.InvalidProgramException: Specifying keys via field positions is only valid for tuple data types. Type: GenericType<scala.Tuple5>

Stack Overflow | houcros | 5 months ago
  1. 0

    Flink error: Specifying keys via field positions is only valid for tuple data types

    Stack Overflow | 5 months ago | houcros
    org.apache.flink.api.common.InvalidProgramException: Specifying keys via field positions is only valid for tuple data types. Type: GenericType<scala.Tuple5>
  2. 0

    [jira] [Created] (FLINK-3696) Some Union tests fail for TableConfigMode.EFFICIENT

    flink-dev | 8 months ago | Vasia Kalavri (JIRA)
    org.apache.flink.api.common.InvalidProgramException: Cannot union inputs of different types. Input1=scala.Tuple3(_1: Integer, _2: Long, _3: String), input2=Java Tuple3<Integer, Long, String>
  3. 0

    TypeSerializerInputFormat cannot determine its type automatically

    flink-user | 2 years ago | Alexander Alexandrov
    org.apache.flink.api.common.InvalidProgramException: The type returned by the input format could not be automatically determined. Please specify the TypeInformation of the produced type explicitly.
  4. Speed up your debug routine!

    Automated exception search integrated into your IDE

  5. 0

    Re: Using Kryo for serializing lambda closures

    flink-user | 1 year ago | Till Rohrmann
    org.apache.flink.client.program.ProgramInvocationException: The main method caused an error.
  6. 0

    Apache Flink: The RemoteEnvironment cannot be instantiated when running in a pre-defined context

    Stack Overflow | 1 year ago | A.Sa
    org.apache.flink.client.program.ProgramInvocationException: The main method caused an error.

    2 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. org.apache.flink.api.common.InvalidProgramException

      Specifying keys via field positions is only valid for tuple data types. Type: GenericType<scala.Tuple5>

      at org.apache.flink.api.common.operators.Keys$ExpressionKeys.<init>()
    2. flink-core
      Keys$ExpressionKeys.<init>
      1. org.apache.flink.api.common.operators.Keys$ExpressionKeys.<init>(Keys.java:217)
      2. org.apache.flink.api.common.operators.Keys$ExpressionKeys.<init>(Keys.java:208)
      2 frames
    3. org.apache.flink
      DataStream.keyBy
      1. org.apache.flink.streaming.api.datastream.DataStream.keyBy(DataStream.java:256)
      2. org.apache.flink.streaming.api.scala.DataStream.keyBy(DataStream.scala:289)
      2 frames