Support Questions
Find answers, ask questions, and share your expertise

I have installed storm OHDR app on HDP2.6 cluster and started storm app, got following messages in console and see error messages in storm worker log, Connection refused 9808

New Contributor

we have 4 supervisors on blth169,blth170,blth171,blth172.

557 [main] WARN o.a.s.h.DefaultShader - Relocating backtype/storm/topology/base/BaseRichBolt to org/apache/storm/topology/base/BaseRichBolt in com/att/dcae

td/storm/ohdr/bolt/CucpOutputBolt.class. please modify your code to use the new namespace

3002 [main] WARN o.a.a.h.AtlasHook - Error in determining keytab for KafkaClient-JAAS config

java.lang.RuntimeException: java.lang.RuntimeException: class org.apache.hadoop.security.JniBasedUnixGroupsMappingWithFallback not org.apache.hadoop.security.GroupMappingServiceProvider

at org.apache.hadoop.conf.Configuration.getClass(Configuration.java:2273) ~[hadoop-common-2.7.3.2.6.1.0-129.jar:?]

at org.apache.hadoop.security.Groups.<init>(Groups.java:99) ~[hadoop-common-2.7.3.2.6.1.0-129.jar:?]

at org.apache.hadoop.security.Groups.<init>(Groups.java:95) ~[hadoop-common-2.7.3.2.6.1.0-129.jar:?]

at org.apache.hadoop.security.Groups.getUserToGroupsMappingService(Groups.java:420) ~[hadoop-common-2.7.3.2.6.1.0-129.jar:?]

at org.apache.hadoop.security.UserGroupInformation.initialize(UserGroupInformation.java:324) ~[hadoop-common-2.7.3.2.6.1.0-129.jar:?]

at org.apache.hadoop.security.UserGroupInformation.ensureInitialized(UserGroupInformation.java:291) ~[hadoop-common-2.7.3.2.6.1.0-129.jar:?]

at org.apache.hadoop.security.UserGroupInformation.loginUserFromSubject(UserGroupInformation.java:846) ~[hadoop-common-2.7.3.2.6.1.0-129.jar:?]

at org.apache.hadoop.security.UserGroupInformation.getLoginUser(UserGroupInformation.java:816) ~[hadoop-common-2.7.3.2.6.1.0-129.jar:?]

at org.apache.hadoop.security.UserGroupInformation.isLoginKeytabBased(UserGroupInformation.java:1376) ~[hadoop-common-2.7.3.2.6.1.0-129.jar:?]

at org.apache.atlas.hook.AtlasHook.isLoginKeytabBased(AtlasHook.java:225) [atlas-notification-0.8.0.2.6.1.0-129.jar:0.8.0.2.6.1.0-129]

at org.apache.atlas.hook.AtlasHook.<clinit>(AtlasHook.java:82) [atlas-notification-0.8.0.2.6.1.0-129.jar:0.8.0.2.6.1.0-129]

at java.lang.Class.forName0(Native Method) ~[?:1.8.0_66]

at java.lang.Class.forName(Class.java:348) [?:1.8.0_66]

at org.apache.atlas.storm.hook.StormAtlasHook.initialize(StormAtlasHook.java:77) [storm-bridge-shim-0.8.0.2.6.1.0-129.jar:0.8.0.2.6.1.0-129]

at org.apache.atlas.storm.hook.StormAtlasHook.<init>(StormAtlasHook.java:46) [storm-bridge-shim-0.8.0.2.6.1.0-129.jar:0.8.0.2.6.1.0-129]

at sun.reflect.NativeConstructorAccessorImpl.newInstance0(Native Method) ~[?:1.8.0_66]

at sun.reflect.NativeConstructorAccessorImpl.newInstance(NativeConstructorAccessorImpl.java:62) [?:1.8.0_66]

at sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45) [?:1.8.0_66]

at java.lang.reflect.Constructor.newInstance(Constructor.java:422) [?:1.8.0_66]

at java.lang.Class.newInstance(Class.java:442) [?:1.8.0_66]

at org.apache.storm.StormSubmitter.invokeSubmitterHook(StormSubmitter.java:361) [storm-core-1.1.0.2.6.1.0-129.jar:1.1.0.2.6.1.0-129]

at org.apache.storm.StormSubmitter.submitTopologyAs(StormSubmitter.java:278) [storm-core-1.1.0.2.6.1.0-129.jar:1.1.0.2.6.1.0-129]

at org.apache.storm.StormSubmitter.submitTopology(StormSubmitter.java:390) [storm-core-1.1.0.2.6.1.0-129.jar:1.1.0.2.6.1.0-129]

at org.apache.storm.StormSubmitter.submitTopology(StormSubmitter.java:162) [storm-core-1.1.0.2.6.1.0-129.jar:1.1.0.2.6.1.0-129]

at com.att.dcaetd.storm.ohdr.OhdrTopology.main(OhdrTopology.java:332) [54f8c57e2d3911e8a20e1402ec862995.jar:?]

Worker.log

java.net.ConnectException: Connection refused

2018-03-21 19:19:47.226 c.a.d.s.o.s.OhdrPullSpout [WARN] Restarted terminated receiver thread for blth171.xxx.com:9808

2018-03-21 19:19:47.227 c.a.d.s.o.u.StreamReader [ERROR] Couldn't get I/O for the connection to: blth170.xxxx.com:9808:

java.net.ConnectException: Connection refused