JunRuiLee commented on code in PR #26149:
URL: https://github.com/apache/flink/pull/26149#discussion_r1952410202
##########
flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/runtime/batch/sql/adaptive/AdaptiveSkewedJoinITCase.scala:
##########
@@ -87,6 +87,13 @@ class AdaptiveSkewedJoinITCase extends AdaptiveJoinITCase {
checkResult(sql)
}
+ @Test
+ def testJoinWithHashOutput(): Unit = {
+ val sql =
+ "SELECT * FROM (SELECT * FROM T1, T2 WHERE T1.a1 = T2.a2) as T4 LEFT
JOIN T3 ON T3.b3 = T4.b1"
+ checkResult(sql)
Review Comment:
Since we are only checking whether the output result is correct, how can we
know if the update has taken effect when the configuration is set to AUTO？
--
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]
