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。