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 | 9 months ago
tip
Click on the to mark the solution that helps you, Samebug will learn from it.
As a community member, you’ll be rewarded for you help.
  1. 0

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

    Stack Overflow | 9 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