reswqa commented on code in PR #21977:
URL: https://github.com/apache/flink/pull/21977#discussion_r1113785798
##########
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamNode.java:
##########
@@ -402,7 +402,7 @@ public Optional<OperatorCoordinator.Provider>
getCoordinatorProvider(
}
}
- boolean isParallelismConfigured() {
+ public boolean isParallelismConfigured() {
Review Comment:
Ah, At the beginning, I relied on it for the assertion of streamGraph's
parallelism. Later, I changed the test logical, and really no longer needed it
to be public now. The reason why not revert this is that I noticed that most of
the other get methods on `StreamNode` are also public, and it will not change
the internal state of the object. I prefer to keep this change for future
convenience.
--
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: issues-unsubscr...@flink.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
