Re: can not use iceberg as a sql source in flink sql according to iceberg 0.12.0

Hi Joshua Can you check what's the parquet version you are using ? Looks like the line 112 in HadoopReadOptions is not the first line accessing the variables in ParquetInputFormat. [image: image.png] On Wed, Sep 22, 2021 at 11:07 PM Joshua Fan wrote: > Hi > I am glad to use iceberg as table

Re: Iceberg disaster recovery and relative path sync-up

During a sync with Yufei and Anurag I had some thought on this proposal that I wanted to share with the wider group. As Yufei has perviously noted, I'm worried about the alternative configuration parameters like (folder-storage, object-storage). Specifically i'm thinking about the issue of movin

can not use iceberg as a sql source in flink sql according to iceberg 0.12.0

Hi I am glad to use iceberg as table source in flink sql, flink version is 1.13.2, and iceberg version is 0.12.0. After changed the flink version from 1.12 to 1.13, and changed some codes in FlinkCatalogFactory, the project can be build successfully. First, I tried to write data into iceberg by f