Hello people, As suggested in the following, it seems it is recommended to set 'uid' for operators.
https://ververica.zendesk.com/hc/en-us/articles/360010248879-Should-I-call-uid-after-addSource-or-addSink- Currently there is an existing personal project which uses 'FlinkKafkaConsumer'(it is a deprecated feature) to consume data from Kafka, which 'uid' is not configured. ''' ... FlinkKafkaConsumer kc = ... ; DataStream<T> ds = env.addSource(kc, "flink-kafka-source"); ''' - AFAIK, uid will be set up as a random value if not defined. How can I find the current uid? - What will happen if I set up a new uid in the code above? - When I want to migrate 'FlinkKafkaConsumer' to 'KafkaSource', is it okay not to set up 'uid'? Thanks.
