[
https://issues.apache.org/jira/browse/FLINK-19432?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17202750#comment-17202750
]
tinny cat commented on FLINK-19432:
-----------------------------------
In fact, I have already mentioned a pull request in
[flink-cdc|[https://github.com/ververica/flink-cdc-connectors/pull/41]] ,
but `canal-json` currently cannot use the simply equals of `before` and
`after`, because in canal, `before` is not a full field. As long as the field
is indeed null before the update, `before` and `after` will be equals.
> Whether to capture the updates which don't change any monitored columns
> -----------------------------------------------------------------------
>
> Key: FLINK-19432
> URL: https://issues.apache.org/jira/browse/FLINK-19432
> Project: Flink
> Issue Type: Improvement
> Components: Formats (JSON, Avro, Parquet, ORC, SequenceFile)
> Affects Versions: 1.11.2
> Reporter: tinny cat
> Priority: Major
> Fix For: 1.11.3
>
>
> with `debezium-json` and `canal-json`:
> Whether to capture the updates which don't change any monitored columns. This
> may happen if the monitored columns (columns defined in Flink SQL DDL) is a
> subset of the columns in database table. We can provide an optional option，
> default 'true', which means all the updates will be captured. You can set to
> 'false' to only capture changed updates, but note this may increase some
> comparison overhead for each update event.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
