Ok cool. Thanks BTW this seems a bit cumbersome...
.map(....).uid("some-id").name("some-id"); On Wed, 23 Oct 2019 at 21:13, Dian Fu <dian0511...@gmail.com> wrote: > Yes, you can use it in another job. The uid needs only to be unique within > a job. > > > 在 2019年10月24日,上午5:42,John Smith <java.dev....@gmail.com> 写道: > > > > When setting uid() of an operator does it have to be unique across all > jobs or just unique within a job? > > > > For example can I use > env.addSource(myKafkaConsumer).uid("kafka-consumer") in another job? > >