flink-cdc
flink-cdc copied to clipboard
Fix during the snapshot phase, projection is not being performed according to the user defined schema.
Purpose
Linked issue: close #2470
This is part 1, fixing the oracle module. If everything is okay, I'll proceed to submit pr for other modules, such as mysql, pg, and sqlserver. In this part, modifications were made to the non-oracle modules to ensure successful compilation.
Tests
OracleSourceITCase#testReadSingleTableWithSingleParallelismAndProjection
API and Format
Documentation
Hi @hzjhjjyy, thanks for your contribution! Could you please rebase your PR with latest master
branch before it could be merged? You may need to rename packages like from com.ververica.cdc
to org.apache.flink.cdc
.
Hi @hzjhjjyy, thanks for your contribution! Could you please rebase your PR with latest
master
branch before it could be merged? You may need to rename packages like fromcom.ververica.cdc
toorg.apache.flink.cdc
.
Yes, I'll do it within the next couple of days.
This pull request has been automatically marked as stale because it has not had recent activity for 60 days. It will be closed in 30 days if no further activity occurs.