RanJinh commented on code in PR #23000:
URL: https://github.com/apache/flink/pull/23000#discussion_r1307025612
##########
flink-streaming-java/src/test/java/org/apache/flink/streaming/api/graph/SinkTransformationTranslatorITCase.java:
##########
@@ -225,7 +225,8 @@ private StreamNode findWriter(StreamGraph streamGraph) {
}
private StreamNode findCommitter(StreamGraph streamGraph) {
- return findNodeName(streamGraph, name -> name.contains("Committer"));
+ return findNodeName(
Review Comment:
> Can you explain why we need this change?
This test is unstable when ITCase runs in IDEA that `Global Committer` node
could be wrongly found as `Committer`. This change may solve it to avoid risk.
Do you think it is necessary?
--
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]
