Skip to content

Commit e616ba0

Browse files
committed
[FLINK-35854][table] JoinTest.testJoinUDTFWithInvalidJoinHint
1 parent e3d65b0 commit e616ba0

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/plan/stream/sql/join/JoinTest.scala

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -579,9 +579,9 @@ class JoinTest extends TableTestBase {
579579
// TODO the error message should be improved after we support extracting alias from table func
580580
util.addTemporarySystemFunction("TableFunc1", new TableFunc1)
581581
util.verifyExpectdException(
582-
"SELECT /*+ LOOKUP('table'='D') */ T.a FROM t AS T CROSS JOIN LATERAL TABLE(TableFunc1(c)) AS D(c1)",
582+
"SELECT /*+ LOOKUP('table'='DD') */ T.a FROM t AS T CROSS JOIN LATERAL TABLE(TableFunc1(c)) AS D(c1)",
583583
"The options of following hints cannot match the name of input tables or views: \n" +
584-
"`D` in `LOOKUP`"
584+
"`DD` in `LOOKUP`"
585585
)
586586
}
587587

0 commit comments

Comments
 (0)