[GitHub] [iceberg] MrDannyWu opened a new issue, #6021: When I use flink sql to synchronize MySQL data to icerberg (hive catalog), an error is reported.

[GitBox]

MrDannyWu opened a new issue, #6021:
URL: https://github.com/apache/iceberg/issues/6021

   ### Query engine
   
   Flink CDC
   
   ### Question
   
   [ERROR] Could not execute SQL statement. Reason:
   java.lang.IllegalStateException: Equality field columns shouldn't be empty 
when configuring to use UPSERT data stream.
   table properties：
   
![image](https://user-images.githubusercontent.com/19458048/196848534-b168a11d-ac5f-420e-8a14-857a371098ce.png)
   
   


-- 
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: issues-unsubscr...@iceberg.apache.org.apache.org

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org


---------------------------------------------------------------------
To unsubscribe, e-mail: issues-unsubscr...@iceberg.apache.org
For additional commands, e-mail: issues-h...@iceberg.apache.org