[Bug] aggregate function in partial update inconsistency

[fantasy2100]

Search before asking

• I searched in the issues and found nothing similar.

Paimon version

1.0.0

Compute Engine

Flink

Minimal reproduce step

CREATE TABLE t1
(
k INT,
a INT,
b INT,
g_1 INT,
PRIMARY KEY (k) NOT ENFORCED
) WITH (
'merge-engine' = 'partial-update',
'fields.a.aggregate-function' = 'sum',
'fields.b.aggregate-function' = 'last_non_null_value',
'fields.g_1.sequence-group' = 'a,b'
);

INSERT INTO t1 VALUES (1, 1, 1, 1);
INSERT INTO t1 VALUES (1, 2, 2, 2);
INSERT INTO t1 VALUES (1, 3, 3, 1);

What doesn't meet your expectations?

when g_1 of third record is smaller, third record should be ignored。
I expect the result to be: 1,3,2,2

Anything else?

No response

Are you willing to submit a PR?

• I'm willing to submit a PR!

[fantasy2100]

"SELECT * FROM t1"
current output: 1,6,2,2
expect output: 1,3,2,2

[JingsongLi]

It is sum... should be 6...