[I] [Bug] after compactioned the array elements are duplicated [incubator-paimon]

["MrTaozui (via GitHub)" <gi...@apache.org>]

MrTaozui opened a new issue, #2353:
URL: https://github.com/apache/incubator-paimon/issues/2353

   ### Search before asking
   
   - [X] I searched in the [issues](https://github.com/apache/incubator-paimon/issues) and found nothing similar.
   
   
   ### Paimon version
   
   0.5 
   0.6
   master
   
   ### Compute Engine
   
   flink
   
   ### Minimal reproduce step
   
   here is my uint test code.
   ```java
   package org.apache.paimon.flink;
   
   import org.apache.paimon.utils.BlockingIterator;
   
   import org.apache.flink.types.Row;
   import org.junit.jupiter.api.BeforeEach;
   import org.junit.jupiter.api.Test;
   
   import java.io.IOException;
   
   /** SQL ITCase for continuous file store. */
   public class FullCompactionFileStoreITCase2 extends CatalogITCaseBase {
       private final String table = "test_array3";
   
       @Override
       @BeforeEach
       public void before() throws IOException {
           super.before();
           String options =
                   " WITH('changelog-producer'='full-compaction', 'changelog-producer.compaction-interval' = '1s')";
           tEnv.executeSql(
                   "create table test_array3\n"
                           + "(\n"
                           + "id int primary key not enforced,\n"
                           + "names array<row<name string,mark string>>\n"
                           + ")"
                           + options);
       }
   
       @Test
       public void testStreamingRead() throws Exception {
           BlockingIterator<Row, Row> iterator =
                   BlockingIterator.of(streamSqlIter("SELECT * FROM %s", table));
   
           sql("insert into %s  values(1, array[('c','mark1'), ('d','mark2'), ('e','mark3')]);", table);
           for (Row row : iterator.collect(1)) {
               System.out.println(row);
           }
       }
   }
   
   ``` 
   
   ### What doesn't meet your expectations?
   
   I expect it print : 
   +I[1, [+I[c, mark1], +I[d, mark2], +I[e, mark3]]]
   **but**
   it print : 
   +I[1, [+I[e, mark3], +I[e, mark3], +I[e, mark3]]]
   
   
   
   ![image](https://github.com/apache/incubator-paimon/assets/29896307/5fa8328d-2da0-404c-a230-951ca9a3f2bc)
   
   
   ### Anything else?
   
   _No response_
   
   ### Are you willing to submit a PR?
   
   - [ ] I'm willing to submit a PR!


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: issues-unsubscribe@paimon.apache.org.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org

Re: [I] [Bug] after compactioned the array elements are duplicated [incubator-paimon]

["JingsongLi (via GitHub)" <gi...@apache.org>]

JingsongLi closed issue #2353: [Bug] after compactioned the array elements  are duplicated
URL: https://github.com/apache/incubator-paimon/issues/2353


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: issues-unsubscribe@paimon.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org