snuyanzin commented on code in PR #25316:
URL: https://github.com/apache/flink/pull/25316#discussion_r1830498758
##########
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/calcite/FlinkCalciteSqlValidatorTest.java:
##########
@@ -109,7 +109,20 @@ void testInvalidNumberOfColumnsWhileInsertInto(String sql)
{
"INSERT INTO t2 (a, b) WITH cte AS (SELECT 1, 2) SELECT * FROM
cte",
"INSERT INTO t2 (a, b) WITH cte AS (SELECT * FROM t2_copy)
SELECT * FROM cte",
"INSERT INTO t2 (a, b) WITH cte AS (SELECT t1.a, t2_copy.b
FROM t1, t2_copy) SELECT * FROM cte",
- "INSERT INTO t2 (a, b) WITH cte1 AS (SELECT 1), cte2 AS
(SELECT 2) SELECT * FROM cte1, cte2"
+ "INSERT INTO t2 (a, b) WITH cte1 AS (SELECT 1), cte2 AS
(SELECT 2) SELECT * FROM cte1, cte2",
+ "INSERT INTO t2 (a, b) "
+ + "WITH cte1 AS (SELECT 1, 2), "
+ + "cte2 AS (SELECT 2, 3) "
+ + "SELECT * FROM cte1 UNION SELECT * FROM cte2",
Review Comment:
With latest commit all tests passed
so shouldn't be an issue I guess
--
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]
