[INLONG-6636][Sort] Keep metric computing consistent for source MySQL and sink HBase

[gong]

Prepare a Pull Request

• [INLONG-6636][Sort] Keep metric computing consistent for source MySQL and sink HBase

• Fixes [Improve][Sort] Keep metric computing consistent for source MySQL and sink HBase #6636

Motivation

It generates four RowKind data: insert, update_before, update_after, delete when source is mysql cdc.
We will count all RowKind data when computing metric of mysql cdc. HBase use upsert to write data and only need three RowKind data: insert, update_after, delete. Flink runtime will optimize code when sync mysql-cdc to HBase. Flink will use DropUpdateBeforeFunction#filter to drop update_before data. We need HBase computing four RowKind data to keep consistent with mysql-cdc. So we will change return value to all RowKind type of HBaseDynamicTableSink#getChangelogMode.

Modifications

• Modify HBaseDynamicTableSink#getChangelogMode.
• HBase skip update_before data .
• MySQL cdc metric computing four Rowkind data.