Hi, I want to add the uid for my Kafka sink in such a way that I can still use the existing savepoint. The problem I'm having is that I cannot set the uid hash. If I try something like this:
``` output.sinkTo(outputSink).setUidHash("xyzbbbbbbbbbbbbbbbbbbbbbbbbbbbbb"); ``` I get the following error: ``` Exception in thread "main" java.lang.UnsupportedOperationException: Cannot set a custom UID hash on a non-legacy sink at org.apache.flink.streaming.api.datastream.DataStreamSink.setUidHash(DataStreamSink.java:163) ``` How can one set the operator id directly then for new (non-legacy) sinks? Kind regards, Salva