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

[Shang Yuanchun (Jira)]

Maris created FLINK-19065:
-----------------------------

             Summary: java.lang.IllegalStateException: Auto generated UIDs have been disabled on join
                 Key: FLINK-19065
                 URL: https://issues.apache.org/jira/browse/FLINK-19065
             Project: Flink
          Issue Type: Bug
    Affects Versions: 1.11.1, 1.11.0
            Reporter: Maris


Join operation with AutoGeneratedUID disabled leads to
{code:java}
java.lang.IllegalStateException: Auto generated UIDs have been disabled but no UID or hash has been assigned to operator Map
{code}

code to reproduce
{code:java}
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
  }
}
{code}



--
This message was sent by Atlassian Jira
(v8.3.4#803005)