AHeise commented on a change in pull request #13735:
URL: https://github.com/apache/flink/pull/13735#discussion_r517176106
##########
File path:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamingJobGraphGenerator.java
##########
@@ -692,6 +692,8 @@ private void connect(Integer headOfChain, StreamEdge edge) {
}
// set strategy name so that web interface can show it.
jobEdge.setShipStrategyName(partitioner.toString());
+
jobEdge.setDownstreamChannelStateRescaler(partitioner.getUpstreamChannelStateRescaler());
+
jobEdge.setUpstreamChannelStateRescaler(partitioner.getDownstreamChannelStateRescaler());
Review comment:
There is no good reason except me screwing up. I did a couple of
renamings prior to republishing PR and apparently renamed things asymetrically.
I adjusted it (so upstream is now set to upstream).
Sorry for the confusion and good catch.
----------------------------------------------------------------
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:
us...@infra.apache.org
