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

2021-09-22 Thread OpenInx
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

2021-09-22 Thread Russell Spitzer
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

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

2021-09-22 Thread Joshua Fan
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