Hang Ruan comments

Results 79 comments of


                                            Hang Ruan

[common] Add Flink 1.15 support.

@tigrulya-exe I think we should add the test environment in cdc e2e tests to verify the flink version 1.15.

[postgres] Add changelog mode configuration with upsert/retract modes

I also consider if we should use the name `ALL` to replace `RETRACT`.

[oceanbase] fix npe in getTableSchema from UPDATE logmessage

@whhe Are there some tests that already produce this error?

fix startupOptions mode bug

These startup modes are not supported now.

when will flink cdc mysql 2.X support specific-offset

PR #1661 fixed this issue.

[MySQL] Caused by: io.debezium.DebeziumException: Received DML xxx binlog probably contains events generated with statement or mixed based replication format

This issue will be fixed by #1236.

[mysql] startup mode support of timestamp and earliest

This issue has be fixed in #1661.

[oracle] let oracle-cdc connect to PDB CDB old non-CDB successfully

cc @leonardBang this PR is in version 2.2.0, but not merge.

[mysql]update primary key，Rowkind does not match the actual operation

I think this behavior is reasonable. If we get update type changes when the primary key is changed.We will get changes like this: ``` -U[6,3] +U[7,3] ``` For downstream operators,...

[metric] fix flink cdc metric conflict with flink built in metric

Thanks for your work , @zhmin . I run the test `MySqlConnectorITCase#testConsumingAllEvents` in debug mode. It seems that both `sourceIdleTime` and `currentEmitEventTimeLag` will be ignored, which are registered in the...