You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
When the column name of the Iceberg metadata file record is an uppercase field, executing ANALYZE TABLE will report that the column cannot be found.
#14583
Closed
zhengxingmao opened this issue
Oct 12, 2022
· 0 comments
· Fixed by #14585
Flink SQL create iceberg table with an uppercase column name:
create table b (B int) ;
and Trino which version I used is v397 executes ANALYZE b,met this error.
Query 20221012_053136_00006_fw48v failed: Column not found in table: [b]
com.google.common.base.VerifyException: Column not found in table: [b]
at com.google.common.base.Verify.verifyNotNull(Verify.java:503)
at io.trino.plugin.iceberg.IcebergMetadata.finishStatisticsCollection(IcebergMetadata.java:1538)
at io.trino.plugin.base.classloader.ClassLoaderSafeConnectorMetadata.finishStatisticsCollection(ClassLoaderSafeConnectorMetadata.java:166)
at io.trino.metadata.MetadataManager.finishStatisticsCollection(MetadataManager.java:812)
at io.trino.sql.planner.LocalExecutionPlanner$Visitor.lambda$visitStatisticsWriterNode$44(LocalExecutionPlanner.java:3218)
at io.trino.operator.StatisticsWriterOperator.getOutput(StatisticsWriterOperator.java:133)
at io.trino.operator.Driver.processInternal(Driver.java:411)
at io.trino.operator.Driver.lambda$process$10(Driver.java:314)
at io.trino.operator.Driver.tryWithLock(Driver.java:706)
at io.trino.operator.Driver.process(Driver.java:306)
at io.trino.operator.Driver.processForDuration(Driver.java:277)
at io.trino.execution.SqlTaskExecution$DriverSplitRunner.processFor(SqlTaskExecution.java:736)
at io.trino.execution.executor.PrioritizedSplitRunner.process(PrioritizedSplitRunner.java:164)
at io.trino.execution.executor.TaskExecutor$TaskRunner.run(TaskExecutor.java:515)
at io.trino.$gen.Trino_397____20221011_085503_2.run(Unknown Source)
at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136)
at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635)
at java.base/java.lang.Thread.run(Thread.java:833)
The text was updated successfully, but these errors were encountered:
Flink SQL create iceberg table with an uppercase column name:
and Trino which version I used is v397 executes ANALYZE b,met this error.
The text was updated successfully, but these errors were encountered: