Hi,可以向社区jira[1]报告一下这个bug,详细记录下flink版本、错误信息等。
可以通过手动修改flink源码下hbase connector pom文件,并重新编译打包的方式来快速fix这个bug。




[1] https://issues.apache.org/jira/projects/FLINK/issues




--

    Best!
    Xuyang





在 2022-09-16 09:34:02,"junjie.m...@goupwith.com" <junjie.m...@goupwith.com> 写道:
>flink-sql-connector-hbase-2.2模块在shade打包时遗漏了commons-io依赖,导致当使用hbase 
>connector时开启lookup.async=true后,当执行结束时调用HBaseRowDataAsyncLookupFunction类的close()方法时调用asyncConnection.close()内部报错java.lang.ClassNotFoundException:
> org.apache.flink.hbase.shaded.org.apache.commons.io.IOUtils。

回复