Hi Salva,
Which version is this?
BR,
G
On Mon, Sep 23, 2024 at 8:46 PM Salva Alcántara <salcantara...@gmail.com>
wrote:
> I have a pipeline where I'm trying to add a new operator. The problem is
> that originally I forgot to specify the uid for one source. To remedy this,
> I'm using setUidHash, providing the operator id to match that in my
> savepoints / current job graph.
>
> Unless I'm doing something wrong, what I've observed is that the value
> provided to setUidHash is completely ignored by Flink. I've tried to
> summarize it in the following test:
>
> ```java
> @Test
> public void testSetUidHash() throws Exception {
> var uidHash = "cbc357ccb763df2852fee8c4fc7d55f2";
> env.fromElements(1, 2, 3)
> .name("123")
> .setUidHash(uidHash)
> //.uid("123")
> .print()
> .name("print")
> .uid("print");
>
> var vertex = StreamSupport
>
> .stream(env.getStreamGraph().getJobGraph().getVertices().spliterator(),
> false)
> .filter(v -> v.getName().equals("Source: 123"))
> .findFirst()
> .orElseThrow();
>
> assertEquals(uidHash, vertex.getID());
> // Fails with java.lang.AssertionError (if setUidHash is used):
> // expected:<cbc357ccb763df2852fee8c4fc7d55f2> but
> was:<bc764cd8ddf7a0cff126f51c16239658>
> // Interestingly, the actual value does not even depend on the
> provided value (uidHash)!
>
> // assertEquals("6a7f660d1b2d5b9869cf0ecee3a17e42", vertex.getID());
> // Passes (if uid is used instead)
> }
> ```
>
> Can anyone confirm whether this is a bug?
>
> Regards,
>
> Salva
>
