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

the hadoop-mapreduce-client-core-2.7.3.jar to the classpath. It goes well. Thanks to Openinx. Josh Joshua Fan 于2021年9月26日周日 下午3:40写道： > Hi openinx > > I do not get you. what do you mean by 'Looks like the line 112 in > HadoopReadOptions is not the first line accessing the varia

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

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 source in flink sql, flink version is >> 1.

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