[I] [Bug] full-compaction wirte data of arry type is repeated [incubator-paimon]

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

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

   ### Search before asking
   
   - [X] I searched in the [issues](https://github.com/apache/incubator-paimon/issues) and found nothing similar.
   
   
   ### Paimon version
   
   master
   
   ### Compute Engine
   
   flink
   
   ### Minimal reproduce step
   
   here is my UT 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  (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?
   
   It must be print  
   
    +I[1, [+I[c, mark1], +I[d, mark2], +I[e, mark3]]]
   
   **but!!!! the result is** 
   
    +I[1, [+I[e, mark3], +I[e, mark3], +I[e, mark3]]]
   
   <img width="1047" alt="image" src="https://github.com/apache/incubator-paimon/assets/29896307/3be13e94-c988-4096-983b-2baec5a6edc9">
   
   
   ### Anything else?
   
   no
   
   ### 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] full-compaction wirte data of arry type is repeated [incubator-paimon]

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

MrTaozui closed issue #2347: [Bug]  full-compaction wirte data of arry type is repeated
URL: https://github.com/apache/incubator-paimon/issues/2347


-- 
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