最近有项目需求,flink写hive,暂不考虑性能要求。用hive jdbc简单封装了个sinkToHive,在开启kerberos的环境中,遇到如题的错误。
还有一个现象就是,首次hive操作是成功的,之后才是java.sql.SQLException: org.apache.thrift.transport.TTransportException: SASL authentication not complete
问题就出在:
PreparedStatement
ResultSet
这两项应该先于Connection close