他的回复:
请教下,FusionInsight Manager 版本8.2.0.2;要实现flink写elasticsearch适配kerberos认证,参照上面提供的 HBaseAddES.zip 代码实现自定义的sink类;目前一直报HBase认证的问题(实际需求不需要读写hbase),后面把hbaseInit方法中代码加进去(指定core-site.xml,hdfs-site.xml,hbase-site.xml配置文件,调用LoginUtil.setZookeeperServerPrincipal、LoginUtil.login)还是报一样的错:Attempting to obtain Kerberos security token for HBase|org.apache.flink.yarn.Utils.obtainTokenForHBase(Utils.java:255)HBase security setting: kerberos|org.apache.flink.yarn.Utils.obtainTokenForHBase(Utils.java:264)Obtaining Kerberos security token for HBase|org.apache.flink.yarn.Utils.obtainTokenForHBase(Utils.java:273)failed for get of /hbase/hbaseid,code=SESSIONCLOSEDREQUIRESASLAUTH,retries=1....不停的重试