aljoscha commented on a change in pull request #14312:
URL: https://github.com/apache/flink/pull/14312#discussion_r545741434
##########
File path:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamNode.java
##########
@@ -84,7 +84,7 @@
private String transformationUID;
private String userHash;
- private boolean sortedInputs = false;
+ private Map<Integer, StreamConfig.InputRequirement> inputRequirements =
new HashMap<>();
Review comment:
None of the others are initialized in the constructor that's why I went
with this one. But yes, I would agree!
----------------------------------------------------------------
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.
For queries about this service, please contact Infrastructure at:
[email protected]
