[FLINK-19065] java.lang.IllegalStateException: Auto generated UIDs have been disabled on join

• Type: Bug
• Status: Open
• Priority: Not a Priority
• Resolution: Unresolved
• Affects Version/s: 1.11.0, 1.11.1
• Component/s: API / DataStream
• Labels: auto-deprioritized-major auto-deprioritized-minor pull-request-available
• Assignee: Unassigned
• Reporter: Maris
• Created: 27/Aug/20 13:35
• Updated: 10/Feb/23 19:54

Description

Join operation with AutoGeneratedUID disabled leads to

java.lang.IllegalStateException: Auto generated UIDs have been disabled but no UID or hash has been assigned to operator Map

code to reproduce

class JoinSpec extends AnyFlatSpec with Matchers with Serializable {
  it should "be able to join streams" in {
    val env = StreamExecutionEnvironment.getExecutionEnvironment
    env.getConfig.disableAutoGeneratedUIDs()

    val a = env.fromCollection(List("1", "2", "3")).name("a").uid("source-uid")
    val b = env.fromCollection(List("1", "2", "3")).name("b").uid("source-uid2")
    val c = a
      .join(b)
      .where(identity)
      .equalTo(identity)
      .window(TumblingProcessingTimeWindows.of(Time.seconds(30)))((a, b) => a+b)
      .uid("joined").name("joined")

    c.addSink(s => println(s))
      .name("ab")
      .uid("ab")

    println(env.getExecutionPlan)
    env.execute
    succeed
  }
}

Issue Links

• links to: GitHub Pull Request #21911