JunRuiLee commented on code in PR #26180:
URL: https://github.com/apache/flink/pull/26180#discussion_r1967102985
##########
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptivebatch/util/VertexParallelismAndInputInfosDeciderUtils.java:
##########
@@ -658,4 +661,57 @@ public static long calculateDataVolumePerTaskForInput(
long globalDataVolumePerTask, long inputsGroupBytes, long
totalDataBytes) {
return (long) ((double) inputsGroupBytes / totalDataBytes *
globalDataVolumePerTask);
}
+
+ /**
+ * Logs the data distribution optimization info when a balanced data
distribution algorithm is
+ * effectively optimized compared to the num-based data distribution
algorithm.
+ *
+ * @param logger The logger instance used for logging output.
+ * @param jobVertexId The id for the job vertex.
+ * @param inputInfo The original input info
+ * @param optimizedJobVertexInputInfo The optimized job vertex input info.
+ */
+ public static void logBalancedDataDistributionOptimizationResult(
+ Logger logger,
+ JobVertexID jobVertexId,
+ BlockingInputInfo inputInfo,
+ JobVertexInputInfo optimizedJobVertexInputInfo) {
+ // Currently, we will not optimize inputs that have two types of
correlations at the same
Review Comment:
useless comment
--
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]
