lvyanquan commented on code in PR #3894: URL: https://github.com/apache/flink-cdc/pull/3894#discussion_r1929687870
########## docs/content.zh/docs/connectors/flink-sources/mysql-cdc.md: ########## @@ -422,6 +434,11 @@ Flink SQL> SELECT * FROM orders; <td>TIMESTAMP_LTZ(3) NOT NULL</td> <td>当前记录表在数据库中更新的时间。 <br>如果从表的快照而不是 binlog 读取记录,该值将始终为0。</td> </tr> + <tr> + <td>row_kind</td> + <td>STRING NOT NULL</td> + <td>这表示着 changelog 的类型。注意: 下游的 SQL 算子可能会因为添加了 'row_kind' 列而导致数据回撤失败。如果源算子选择输出'row_kind'列,则下游的SQL算子可能会因为无法比较'row_kind'列而失败。建议仅在简单的同步作业中使用此元数据列。<br>'+I' 代表着 INSERT 数据,'-D' 代表着 DELETE 数据,'-U' 代表着 UPDATE_BEFORE 数据以及 '+U' 代表着 UPDATE_AFTER 数据。</td> Review Comment: Addressed it. -- 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...@flink.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org