RE: Flink-Iceberg Table Sink failing with org.apache.hadoop.fs.s3a.S3AStorageStatistics Cast exception

I solved this problem by removing the Hadoop classpath from Flink cluster deployment. On 2022/04/28 09:04:50 Terry Heathcote wrote: > Hi > > We are running a Flink job that delivers Kafka data to an Iceberg table. > The job uses the *org.apache.iceberg.flink.CatalogLoader* and >

Flink-Iceberg Table Sink failing with org.apache.hadoop.fs.s3a.S3AStorageStatistics Cast exception

Hi We are running a Flink job that delivers Kafka data to an Iceberg table. The job uses the *org.apache.iceberg.flink.CatalogLoader* and *org.apache.iceberg.flink.TableLoader *interfaces in combination with *org.apache.iceberg.flink.sink.FlinkSink *where the catalog type is Hive. We have had