Jane Chan created FLINK-28552: --------------------------------- Summary: GenerateUtils#generateCompare supports MULTISET and MAP Key: FLINK-28552 URL: https://issues.apache.org/jira/browse/FLINK-28552 Project: Flink Issue Type: New Feature Components: Table Store Affects Versions: table-store-0.2.0 Reporter: Jane Chan Fix For: table-store-0.2.0
Currently, changelog mode cannot support map and multiset as the field type. Stacktrace java.lang.UnsupportedOperationException at org.apache.flink.table.store.codegen.GenerateUtils$.generateCompare(GenerateUtils.scala:139) at org.apache.flink.table.store.codegen.GenerateUtils$.$anonfun$generateRowCompare$1(GenerateUtils.scala:289) at scala.collection.IndexedSeqOptimized.foreach(IndexedSeqOptimized.scala:32) at scala.collection.IndexedSeqOptimized.foreach$(IndexedSeqOptimized.scala:29) at scala.collection.mutable.ArrayOps$ofRef.foreach(ArrayOps.scala:194) at org.apache.flink.table.store.codegen.GenerateUtils$.generateRowCompare(GenerateUtils.scala:263) at org.apache.flink.table.store.codegen.ComparatorCodeGenerator$.gen(ComparatorCodeGenerator.scala:45) at org.apache.flink.table.store.codegen.ComparatorCodeGenerator.gen(ComparatorCodeGenerator.scala) at org.apache.flink.table.store.codegen.CodeGeneratorImpl.generateRecordComparator(CodeGeneratorImpl.java:53) at org.apache.flink.table.store.codegen.CodeGenUtils.generateRecordComparator(CodeGenUtils.java:66) at org.apache.flink.table.store.file.utils.KeyComparatorSupplier.<init>(KeyComparatorSupplier.java:40) at org.apache.flink.table.store.file.KeyValueFileStore.<init>(KeyValueFileStore.java:59) at org.apache.flink.table.store.table.ChangelogValueCountFileStoreTable.<init>(ChangelogValueCountFileStoreTable.java:73) at org.apache.flink.table.store.table.FileStoreTableFactory.create(FileStoreTableFactory.java:70) at org.apache.flink.table.store.table.FileStoreTableFactory.create(FileStoreTableFactory.java:50) at org.apache.flink.table.store.spark.SimpleTableTestHelper.<init>(SimpleTableTestHelper.java:58) at org.apache.flink.table.store.spark.SparkReadITCase.startMetastoreAndSpark(SparkReadITCase.java:93) -- This message was sent by Atlassian Jira (v8.20.10#820010)