1

我在 Kerberized 环境中创建并部署了 Storm 拓扑。我们有一个可以在 HBase 和 HDFS 中写入数据的螺栓,但它无法获取 HBase 和 HDFS 凭据。

我之前遇到了同样的错误,但通过重新启动集群得到了解决。我怀疑这是否是正确的解决方案。

我也遇到过类似的情况,其中螺栓工作正常,但在集群几天未使用后突然出现异常。

这些凭据是否缓存在临时目录中?

请在下面找到相同的工作日志:

2016-03-23 08:38:19 bssaAuthUtils [INFO] 获得 AutoCreds [com.config.setup.storm.security.AutoHBase@71f139b7, com.config.setup.storm.security.AutoHDFS@51f6292b]
**2016-03-23 08:38:19 cchscssssAutoHBase [错误] 无法从凭证映射中获取凭证。
java.io.StreamCorruptedException:无效的流标头:64756D6D**
        在 java.io.ObjectInputStream.readStreamHeader(ObjectInputStream.java:804) ~[na:1.7.0_67]
        在 java.io.ObjectInputStream.(ObjectInputStream.java:299) ~[na:1.7.0_67]
        在 com.config.setup.storm.security.AutoHBase.getCredentials(AutoHBase.java:96) [config.jar:na]
        在 com.config.setup.storm.security.AutoHBase.addCredentialToSubject(AutoHBase.java:129) [config.jar:na]
        在 com.config.setup.storm.security.AutoHBase.populateSubject(AutoHBase.java:122) [config.jar:na]
        在 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]
        在 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]
        在 clojure.lang.AFn.applyToHelper(AFn.java:185) [clojure-1.5.1.jar:na]
        在 clojure.lang.AFn.applyTo(AFn.java:151) [clojure-1.5.1.jar:na]
        在 clojure.core$apply.invoke(core.clj:617) [clojure-1.5.1.jar:na]
        在 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]
        在 clojure.lang.RestFn.invoke(RestFn.java:512) [clojure-1.5.1.jar:na]
        在 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]
        在 clojure.lang.AFn.applyToHelper(AFn.java:172) [clojure-1.5.1.jar:na]
        在 clojure.lang.AFn.applyTo(AFn.java:151) [clojure-1.5.1.jar:na]
        在 backtype.storm.daemon.worker.main(未知来源) [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 cchscsssAutoHBase [INFO] 在凭证映射中找不到凭证。
2016-03-23 08:38:19 cchscsssAutoHDFS [错误] 无法从凭证映射中获取凭证。
java.io.StreamCorruptedException:无效的流标头:64756D6D
        在 java.io.ObjectInputStream.readStreamHeader(ObjectInputStream.java:804) ~[na:1.7.0_67]
        在 java.io.ObjectInputStream.(ObjectInputStream.java:299) ~[na:1.7.0_67]
        在 com.config.setup.storm.security.AutoHDFS.getCredentials(AutoHDFS.java:96) [config.jar:na]
        在 com.config.setup.storm.security.AutoHDFS.addCredentialToSubject(AutoHDFS.java:128) [config.jar:na]
        在 com.config.setup.storm.security.AutoHDFS.populateSubject(AutoHDFS.java:121) [config.jar:na]
        在 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]
        在 clojure.lang.AFn.applyToHelper(AFn.java:185) [clojure-1.5.1.jar:na]
        在 clojure.lang.AFn.applyTo(AFn.java:151) [clojure-1.5.1.jar:na]
        在 clojure.core$apply.invoke(core.clj:617) [clojure-1.5.1.jar:na]
        在 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]
        在 clojure.lang.RestFn.invoke(RestFn.java:512) [clojure-1.5.1.jar:na]
        在 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]
        在 clojure.lang.AFn.applyToHelper(AFn.java:172) [clojure-1.5.1.jar:na]
        在 clojure.lang.AFn.applyTo(AFn.java:151) [clojure-1.5.1.jar:na]
        在 backtype.storm.daemon.worker.main(未知来源) [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 cchscsssAutoHDFS [INFO] 在凭证中找不到凭证

4

0 回答 0