, wenn ich meine Topo zu Nimbus Cluster in Sturm vorlegen, konnte es wegen:Topologie Senden, um Cluster aufgrund org.apache.storm.thrift.transport.TTransportException fehlgeschlagen Sturm: java.net.ConnectException: Connection refused
Exception in thread "main" java.lang.RuntimeException: org.apache.storm.thrift.transport.TTransportException: java.net.ConnectException: Connection refused
at org.apache.storm.security.auth.TBackoffConnect.retryNext(TBackoffConnect.java:64)
at org.apache.storm.security.auth.TBackoffConnect.doConnectWithRetry(TBackoffConnect.java:56)
at org.apache.storm.security.auth.ThriftClient.reconnect(ThriftClient.java:99)
at org.apache.storm.security.auth.ThriftClient.<init>(ThriftClient.java:69)
at org.apache.storm.utils.NimbusClient.<init>(NimbusClient.java:106)
at org.apache.storm.utils.NimbusClient.getConfiguredClientAs(NimbusClient.java:78)
at org.apache.storm.StormSubmitter.submitTopologyAs(StormSubmitter.java:228)
at org.apache.storm.StormSubmitter.submitTopology(StormSubmitter.java:288)
at org.apache.storm.StormSubmitter.submitTopologyWithProgressBar(StormSubmitter.java:324)
at org.apache.storm.StormSubmitter.submitTopologyWithProgressBar(StormSubmitter.java:305)
at com.shuruitech.telepathia.storm.topo.DRPCTopology.main(DRPCTopology.java:54)
Ich habe viel in Google gesucht, ich habe alle Bedingungen erfüllt, um den Topo vorzulegen.Aber es ist immer noch fehlgeschlagen. Und ich habe 'tcpdump' Tool verwendet, das die Pakete zwischen Nimbus-Server und Client im Port 6627 gefangen hat. Und es ist mir verwirrt ist, dass in meinem zugriffs nimbus.log, es aufzunehmen hat es die Anforderung vom Client empfangen:
2016-08-10 12:56:17.437 o.a.s.l.ThriftAccessLogger [INFO] Request ID: 4 access from: principal: operation: getClusterInfo
ich wissen, ob es Topo erfolgreich einreicht, die zugriffs nimbus.log wird Aufzeichnungen wie folgend:
2016-07-19 10: 10: 35,883 oaslThriftAccessLogger [INFO] Request ID: 19 Zugang aus: principal: Betrieb: getClusterInfo 2016.07.19 10: 10: 35,883 oaslThriftAccessLogger [ INFO] Request ID: 20 Zugriff von: Principal: Operation: getClusterInfo 2016-07-19 10: 10: 35.887 oaslThriftAccessLogger [INFO] Request ID: 21 Zugriff von: principal : operation: getClusterInfo 2016-07-19 10: 10: 35.887 oaslThriftAccessLogger [INFO] Request ID: 22 Zugriff von: principal: operation: getClusterInfo 2016-07-19 10: 10: 35.890 oaslThriftAccessLogger [INFO] Request ID : 23 Zugriff von: Principal: Operation: getNimbusConf 2016-07-19 10: 12: 24.989 oaslThriftAccessLogger [INFO] Request ID: 24 Zugriff von: Principal: Operation: getClusterInfo 2016-07-19 10: 12: 25.005 oasl ThriftAccessLogger [INFO] Request ID: 25 Zugriff von: principal: operation: getClusterInfo 2016-07-19 10: 12: 25.011 oaslThriftAccessLogger [INFO] Request ID: 26 Zugriff von: principal: operation: getClusterInfo 2016-07-19 10: 12: 25.020 oaslThriftAccessLogger [INFO] Anforderungs-ID: 27 Zugriff von: principal: operation: getClusterInfo 2016-07-19 10: 12: 25.077 oaslThriftAccessLogger [INFO] Request ID: 28 Zugriff von: Principal: Betrieb: fileUpload ... 2016-07-19 10: 12: 25.405 oaslThriftAccessLogger [INFO] Request ID: 31 Zugriff von: principal : Betrieb: Fileupload 2016.07.19 10: 12: 25,426 oaslThriftAccessLogger [INFO] Anfrage-ID: 32 Zugriff aus: principal: Betrieb: submitTopology
Also, was kann ich tun?
P.S. 1) Ich habe die Firewall des Servers
2) die Nimbus Hafen (6627) geschlossen auch
3) zugehört wird der Tierpfleger wird als normal läuft
Neustart des Clusters würde wahrscheinlich das Problem umgehen, aber das erklärt nicht, warum es an erster Stelle passiert ist oder wie man es vermeiden kann. – Charlie
Ja, Sie haben recht, ich habe gerade gelöst.Ich weiß wirklich nicht, wie ich arbeiten soll – Curiouser