Rhett CfZhuang

@melin I tested your case in class `org.apache.paimon.spark.SparkReadITCase` of branch master, and the issue cannot be reproduced. ```java @Test public void testCreateTableAsTmp() { spark.sql("CREATE TABLE paimon_order_pt_tag (\n" + " id...

@luowanghaoyun I tested the case in `org.apache.paimon.flink.PartialUpdateITCase`, and the result is [1, 4, 2, 2, 2] , as expected. I wonder if this issue's(and [#3020](https://github.com/apache/paimon/issues/3020)) status should be updated. ```java...

My understanding of aggregation for partial update is as follows: aggregate the specified fields using the aggregate function (fields.\.aggregate-function) after reordering the rows based on the sequence-group field (fields.\.sequence-group). If...

@fantasy2100 @LinMingQiang the case +I(1, 1, 1, 1); +I(1, 2, 2, 2); +I(1, 3, 3, 1); can be considered as aggregation in this order. +I(1, 3, 3, 1); +I(1, 1,...

@fantasy2100 +1, i have the same question. It may be related to the implementation… I’m not sure if it’s by design and would like to understand how it was considered.