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)
