请问一下，Flink1.13.6 MERGE 这语法 有什么问题?

1. 问题描述： 您在使用Flink 1.13.6尝试执行一个MERGE INTO语句时遇到了编译错误，具体错误信息为org.apache.flink.sql.parser.impl.ParseException: Encountered "WHEN" at line 12, column 1. Was expecting one of: ")" ...。您想了解该MERGE语法存在的问题。

2. 查询背景：

   • 您正在使用的系统是Apache Flink 1.13.6。
   • MERGE INTO语句试图在Hudi表（stu4_sink_hudi）中根据源表（stu4）的数据进行更新、插入和删除操作。

3. 查询语句：

   MERGE INTO stu4_sink_hudi
   USING (SELECT * FROM stu4) source
   ON stu4_sink_hudi.id = source.id
   WHEN MATCHED THEN UPDATE SET
    stu4_sink_hudi.name = source.name,
    stu4_sink_hudi.school = source.school
   WHEN NOT MATCHED THEN INSERT
    (id, name, school)
    VALUES (source.id, source.name, source.school)
   WHEN NOT MATCHED BY SOURCE AND stu4_sink_hudi.school='school1' THEN DELETE;
   

4. 问题分析：

   • 错误信息表明解析器在遇到第二个“WHEN”时期望的是)，这通常意味着SQL语法不被当前版本的Flink SQL解析器所支持。
   • Flink 1.13.6对MERGE INTO的支持可能存在限制，特别是对于WHEN NOT MATCHED BY SOURCE这样的高级条件处理，这在某些数据库系统中可用但在Flink的特定版本中可能未实现或有不同语法。

5. 优化建议：

   • 检查Flink版本兼容性：确认Flink 1.13.6是否完全支持您所使用的MERGE INTO语法的所有特性。参考Flink官方文档以获取关于SQL支持的详细信息。
   • 调整语法：如果Flink当前版本不支持此语法，考虑分步骤实现相同逻辑，比如先执行UPDATE和INSERT操作，再单独处理DELETE逻辑。
   • 升级Flink版本：考虑升级到更高版本的Flink，新版本可能已经解决了此语法支持的问题。

6. 示例调整方案（假设直接执行DELETE不可行）：

   • 分步处理，首先执行更新和插入操作，然后通过一个独立的DELETE语句来处理需要删除的记录。

7. 注意事项：

   • 版本兼容性：在应用任何SQL操作前，务必确认所用Flink版本对该操作的支持情况。
   • 数据一致性：分步执行DML操作时，需注意事务边界，确保数据一致性。

8. 参考资料：

   • Flink官方文档关于SQL支持的部分

综上所述，您遇到的错误可能是由于Flink 1.13.6对MERGE INTO语句的高级用法支持不足所致。建议查阅官方文档以确认语法兼容性，并考虑调整策略或升级Flink版本以解决此问题。

注：上述回答中的角标仅作为示例引用标记，实际回答中应依据提供的知识库资料内容进行适当调整或直接省略，因为给出的知识库并未包含直接相关的Flink版本与功能支持细节。