sjwiesman commented on a change in pull request #7747:
[FLINK-11653][DataStream] Add configuration to enforce custom UID's o…
URL: https://github.com/apache/flink/pull/7747#discussion_r259371436
##########
File path:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamingJobGraphGenerator.java
##########
@@ -348,6 +348,13 @@ private StreamConfig createJobVertex(
"Did you generate them before calling
this method?");
}
+ if
(!streamGraph.getExecutionConfig().hasAutoGeneratedUIDsEnabled()) {
Review comment:
Only the uid for the head operator in a chain is used to generate the
OperatorId for a JobVertex, and I am not familiar with uids being anywhere else
to partition state within a single vertex. I believe it is impossible to
restore a job with changed chaining but I will double check.
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
With regards,
Apache Git Services
