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 | 8 months ago
tip
Your exception is missing from the Samebug knowledge base.
Here are the best solutions we found on the Internet.
Click on the to mark the helpful solution and get rewards for you help.
  1. 0

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

    Stack Overflow | 8 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 unregistered visitors

    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