storm-autohbase[error]无法从凭据Map获取凭据

hrirmatl  于 2021-06-02  发布在  Hadoop
关注(0)|答案(0)|浏览(229)

我已经创建了风暴拓扑,并部署在一个kerberized环境。我们有一个螺栓在hbase和hdfs中写入数据,但它无法获得hbase和hdfs凭据。
我之前也遇到了同样的错误,但是通过重新启动集群解决了这个问题。我怀疑这是不是正确的解决办法。
我也遇到了类似的情况,在螺栓工作正常,但突然给出了异常后,集群被闲置了几天。
这些凭据是否缓存在临时目录中?
请在下面找到相同的工作日志:

2016-03-23 08:38:19 b.s.s.a.AuthUtils [INFO] Got AutoCreds [com.config.setup.storm.security.AutoHBase@71f139b7, com.config.setup.storm.security.AutoHDFS@51f6292b]

**2016-03-23 08:38:19 c.c.h.s.c.s.s.s.AutoHBase [ERROR] Could not obtain credentials from credentials map.

java.io.StreamCorruptedException: invalid stream header: 64756D6D**
        at java.io.ObjectInputStream.readStreamHeader(ObjectInputStream.java:804) ~[na:1.7.0_67]
        at java.io.ObjectInputStream.(ObjectInputStream.java:299) ~[na:1.7.0_67]
        at com.config.setup.storm.security.AutoHBase.getCredentials(AutoHBase.java:96) [config.jar:na]
        at com.config.setup.storm.security.AutoHBase.addCredentialToSubject(AutoHBase.java:129) [config.jar:na]
        at com.config.setup.storm.security.AutoHBase.populateSubject(AutoHBase.java:122) [config.jar:na]
        at backtype.storm.security.auth.AuthUtils.populateSubject(AuthUtils.java:189) [storm-core-0.9.3.2.2.9.0-3393.jar:0.9.3.2.2.9.0-3393]
        at backtype.storm.daemon.worker$fn__7701$exec_fn__1271__auto____7702.invoke(worker.clj:424) [storm-core-0.9.3.2.2.9.0-3393.jar:0.9.3.2.2.9.0-3393]
        at clojure.lang.AFn.applyToHelper(AFn.java:185) [clojure-1.5.1.jar:na]
        at clojure.lang.AFn.applyTo(AFn.java:151) [clojure-1.5.1.jar:na]
        at clojure.core$apply.invoke(core.clj:617) [clojure-1.5.1.jar:na]
        at backtype.storm.daemon.worker$fn__7701$mk_worker__7778.doInvoke(worker.clj:408) [storm-core-0.9.3.2.2.9.0-3393.jar:0.9.3.2.2.9.0-3393]
        at clojure.lang.RestFn.invoke(RestFn.java:512) [clojure-1.5.1.jar:na]
        at backtype.storm.daemon.worker$_main.invoke(worker.clj:540) [storm-core-0.9.3.2.2.9.0-3393.jar:0.9.3.2.2.9.0-3393]
        at clojure.lang.AFn.applyToHelper(AFn.java:172) [clojure-1.5.1.jar:na]
        at clojure.lang.AFn.applyTo(AFn.java:151) [clojure-1.5.1.jar:na]
        at backtype.storm.daemon.worker.main(Unknown Source) [storm-core-0.9.3.2.2.9.0-3393.jar:0.9.3.2.2.9.0-3393]
2016-03-23 08:38:19 c.c.h.s.c.s.s.s.AutoHBase [INFO] No credential found in credentials map.
2016-03-23 08:38:19 c.c.h.s.c.s.s.s.AutoHDFS [ERROR] Could not obtain credentials from credentials map.
java.io.StreamCorruptedException: invalid stream header: 64756D6D
        at java.io.ObjectInputStream.readStreamHeader(ObjectInputStream.java:804) ~[na:1.7.0_67]
        at java.io.ObjectInputStream.(ObjectInputStream.java:299) ~[na:1.7.0_67]
        at com.config.setup.storm.security.AutoHDFS.getCredentials(AutoHDFS.java:96) [config.jar:na]
        at com.config.setup.storm.security.AutoHDFS.addCredentialToSubject(AutoHDFS.java:128) [config.jar:na]
        at com.config.setup.storm.security.AutoHDFS.populateSubject(AutoHDFS.java:121) [config.jar:na]
        at backtype.storm.daemon.worker$fn__7701$exec_fn__1271__auto____7702.invoke(worker.clj:424) [storm-core-0.9.3.2.2.9.0-3393.jar:0.9.3.2.2.9.0-3393]
        at clojure.lang.AFn.applyToHelper(AFn.java:185) [clojure-1.5.1.jar:na]
        at clojure.lang.AFn.applyTo(AFn.java:151) [clojure-1.5.1.jar:na]
        at clojure.core$apply.invoke(core.clj:617) [clojure-1.5.1.jar:na]
        at backtype.storm.daemon.worker$fn__7701$mk_worker__7778.doInvoke(worker.clj:408) [storm-core-0.9.3.2.2.9.0-3393.jar:0.9.3.2.2.9.0-3393]
        at clojure.lang.RestFn.invoke(RestFn.java:512) [clojure-1.5.1.jar:na]
        at backtype.storm.daemon.worker$_main.invoke(worker.clj:540) [storm-core-0.9.3.2.2.9.0-3393.jar:0.9.3.2.2.9.0-3393]
        at clojure.lang.AFn.applyToHelper(AFn.java:172) [clojure-1.5.1.jar:na]
        at clojure.lang.AFn.applyTo(AFn.java:151) [clojure-1.5.1.jar:na]
        at backtype.storm.daemon.worker.main(Unknown Source) [storm-core-0.9.3.2.2.9.0-3393.jar:0.9.3.2.2.9.0-3393]
2016-03-23 08:38:19 c.c.h.s.c.s.s.s.AutoHDFS [INFO] No credential found in credentials

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题