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: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
