MOBIN
MOBIN
@hameizi I merged this PR and did some testing and when I update a record, it actually inserts a new record Flink SQL> CREATE TABLE iceberg_table_upsert8( > id BIGINT, >...
> @MOBIN-F It's true, this PR translate update to -D and +I. It will query the record(1,qq). but this record is from before the update, Is that right?
> > > > > @MOBIN-F It's true, this PR translate update to -D and +I. > > > > > > > > > > > > It will...
I added some test cases, can you help review this pr? @JingsongLi
The pr will add the following jobs: When restarting the paimon job, if the field length changes, the schemaCompatible check is successful and schemaEvolution is performed at the same time.
@JingsongLi @yuzelin @zhongyujiang I updated the code and test cases, can you help review them?
Found some problems, I will close the PR and create a new PR for better review of the code
Does the ignored table have a schema change? You can set --ignore-incompatible false to check whether the table has schema changes, or check the log for "This table will be...
I reproduced the problem, and the reason is as stated in the official documentation: [If you do not have a PRIMARY KEY and an application asks for the PRIMARY KEY...