zhuzhurk commented on code in PR #26163:
URL: https://github.com/apache/flink/pull/26163#discussion_r1960865281
##########
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/strategy/AdaptiveBroadcastJoinOptimizationStrategy.java:
##########
@@ -162,7 +162,22 @@ protected void tryOptimizeAdaptiveJoin(
broadcastThreshold,
leftInputSize,
rightInputSize);
+ } else {
+ LOG.info(
+ "Modified stream edges for the join node [{}]
failed.",
Review Comment:
maybe "Modification to stream edges for the join node [{}] failed. Keep the
join node as is."
This is to prevent users from misinterpreting the situation as an unexpected
error.
--
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
