SinBex commented on code in PR #21695:
URL: https://github.com/apache/flink/pull/21695#discussion_r1081130568
##########
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptivebatch/AbstractBlockingResultInfo.java:
##########
@@ -72,4 +73,15 @@ public void resetPartitionInfo(int partitionIndex) {
int getNumOfRecordedPartitions() {
return subpartitionBytesByPartitionIndex.size();
}
+
+ /**
+ * Aggregate the input number bytes of a subtask according to the index
range for partition and
+ * subpartition.
+ *
+ * @param partitionIndexRange Range of the index of the consumed partition.
+ * @param subpartitionIndexRange Range of the index of the consumed
subpartition.
+ * @return Aggregated input number bytes of current result info.
+ */
+ public abstract long getExecutionVertexInputNumBytes(
Review Comment:
Fix this. I have renamed it as `getNumBytesProduced` and moved it to
`BlockingResultInfo`.
--
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
