[Bug]: UUID Issue from native iceberg library

[CatOrLeader]

What happened?

There is an error where Iceberg table that is bucketed (or partitioned) on the key with type UUID

Affects Versions

0.8.0

What table formats are you seeing the problem on?

Iceberg

What engines are you seeing the problem on?

Optimizer

How to reproduce

1. Create an iceberg table that Amoro can access for optimisation purposes

2. Create an optimiser and see the logs of the Amoro executor pod, which starts to optimise the table

Relevant log output

Anything else

java.lang.IllegalStateException: Not an instance of java.util.UUID: [B@247ddda
at org.apache.iceberg.data.GenericRecord.get(GenericRecord.java:123)
at org.apache.iceberg.data.InternalRecordWrapper.get(InternalRecordWrapper.java:101)
at org.apache.iceberg.Accessors$PositionAccessor.get(Accessors.java:71)
at org.apache.iceberg.Accessors$PositionAccessor.get(Accessors.java:58)
at org.apache.iceberg.StructTransform.wrap(StructTransform.java:78)
at org.apache.iceberg.PartitionKey.wrap(PartitionKey.java:30)
at org.apache.iceberg.PartitionKey.partition(PartitionKey.java:64)
at org.apache.amoro.io.writer.GenericIcebergPartitionedFanoutWriter.partition(GenericIcebergPartitionedFanoutWriter.java:65)
at org.apache.amoro.io.writer.GenericIcebergPartitionedFanoutWriter.partition(GenericIcebergPartitionedFanoutWriter.java:42)
at org.apache.iceberg.io.PartitionedFanoutWriter.write(PartitionedFanoutWriter.java:52)
at org.apache.amoro.optimizing.AbstractRewriteFilesExecutor.rewriterDataFiles(AbstractRewriteFilesExecutor.java:152)
at org.apache.amoro.table.TableMetaStore.call(TableMetaStore.java:268)
at org.apache.amoro.table.TableMetaStore.lambda$doAs$0(TableMetaStore.java:243)
at java.security.AccessController.doPrivileged(Native Method)
at javax.security.auth.Subject.doAs(Subject.java:360)
at org.apache.hadoop.security.UserGroupInformation.doAs(UserGroupInformation.java:1930)
at org.apache.amoro.table.TableMetaStore.doAs(TableMetaStore.java:243)
at org.apache.amoro.io.AuthenticatedHadoopFileIO.doAs(AuthenticatedHadoopFileIO.java:201)
at org.apache.amoro.optimizing.AbstractRewriteFilesExecutor.execute(AbstractRewriteFilesExecutor.java:108)
at org.apache.amoro.optimizing.AbstractRewriteFilesExecutor.execute(AbstractRewriteFilesExecutor.java:64)
at org.apache.amoro.optimizer.common.OptimizerExecutor.executeTask(OptimizerExecutor.java:150)
at org.apache.amoro.optimizer.common.OptimizerExecutor.executeTask(OptimizerExecutor.java:104)
at org.apache.amoro.optimizer.common.OptimizerExecutor.start(OptimizerExecutor.java:53)
at java.lang.Thread.run(Thread.java:750)

Are you willing to submit a PR?

• Yes I am willing to submit a PR!

Code of Conduct

• I agree to follow this project's Code of Conduct

[zhoujinsong]

Thanks for reporting this issue.

AFAIK, both Spark/Flink do not support creating an iceberg table with a UUID column type.
What engine was used to create your Iceberg table?

[CatOrLeader]

Thanks for reporting this issue.

AFAIK, both Spark/Flink do not support creating an iceberg table with a UUID column type.
What engine was used to create your Iceberg table?

Hello! We are currently stick with the Trino as main engine for iceberg table manipulations