Skip to content

Possible need to use flink's shaded classes in place of org.apache.flink.runtime.util.HadoopUtils #1462

@kbendick

Description

@kbendick

When looking through issues, I noticed from @openinx's issue #1437 that we are using org.apache.flink.runtime.util.HadoopUtils.

However, it appears that a hotfix has been applied in Flink by @JingsongLi which shades org.apache.flink.runtime.util to org.apache.flink.hive.shaded.util in this PR https://github.com/apache/flink/pull/12646/files (which shows merged to master in Github on June 15th).

Flink 1.11 was released in early July, so it's possible that we don't need to use the shaded package name. But I wanted to open this issue to track.

One place that I saw that we use it is here, though it's probably that it's possible that it's used in more places: https://github.com/apache/iceberg/blob/master/flink/src/main/java/org/apache/iceberg/flink/FlinkCatalogFactory.java#L122

If any of the interested parties tagged can confirm that we should or should not be using the new org.apache.flink.hive.shaded.util when using flink-connector-hive, I would be more than happy to put in a PR to make the change.

If I don't hear from anybody (hoping @JingsongLi will know off the top of his head), then I will do further investigation.

Metadata

Metadata

Assignees

No one assigned

    Labels

    No labels
    No labels

    Type

    No type

    Projects

    No projects

    Milestone

    No milestone

    Relationships

    None yet

    Development

    No branches or pull requests

    Issue actions