morozov commented on PR #3977:
URL: https://github.com/apache/flink-cdc/pull/3977#issuecomment-2822839323
> Do you think we need an IT case to verify if operator UIDs are correctly
set by examining Flink execution plan JSON (like #3887)?
@yuxiqian, it doesn't look like the execution plan JSON contains operator
UIDs. It contains *ID*s (the numeric identifiers that start with 1 and
increment by 1). For example (from the test you referenced):
```json
{
"nodes" : [ {
"id" : 1,
"type" : "Source: Distributed Source",
"pact" : "Data Source",
"contents" : "Source: Distributed Source",
"parallelism" : 9
}, {
"id" : 2,
"type" : "Partitioning",
"pact" : "Operator",
"contents" : "Partitioning",
"parallelism" : 4,
"predecessors" : [ {
"id" : 1,
"ship_strategy" : "REBALANCE",
"side" : "second"
} ]
}, {
"id" : 4,
"type" : "SchemaMapper",
"pact" : "Operator",
"contents" : "SchemaMapper",
"parallelism" : 4,
"predecessors" : [ {
"id" : 2,
"ship_strategy" : "CUSTOM",
"side" : "second"
} ]
}, {
"id" : 5,
"type" : "Sink: Sink Writer: Value Sink",
"pact" : "Data Sink",
"contents" : "Sink: Sink Writer: Value Sink",
"parallelism" : 10,
"predecessors" : [ {
"id" : 4,
"ship_strategy" : "REBALANCE",
"side" : "second"
} ]
} ]
}
```
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
