1. ホーム
  2. 質問と答え
  3. Apacheの嵐 - 初期化時にエラー（労働者）

Apacheの嵐 - 初期化時にエラー（労働者）

2016-08-27 4 views
1

嵐-1.0.1Apacheの嵐 - 初期化時にエラー（労働者）

私storm.yaml：

2016-08-26 19:22:28.023 o.a.s.d.supervisor [INFO] e80983c3-1ec6-4b25-9ef1-f29eb42194ae still hasn't started 
2016-08-26 19:22:28.523 o.a.s.d.supervisor [INFO] e80983c3-1ec6-4b25-9ef1-f29eb42194ae still hasn't started 
2016-08-26 19:22:28.883 o.a.s.d.supervisor [INFO] Worker Process b4a402ba-458d-4c4e-b167-143bd9134200 exited with code: 13 
2016-08-26 19:22:28.956 o.a.s.d.supervisor [INFO] Worker Process c9718f4b-131f-4cfe-bce7-e3e448790a4e exited with code: 13 
2016-08-26 19:22:28.966 o.a.s.d.supervisor [INFO] Worker Process d30be8b6-6ed0-496e-9d23-6879df1f1bdd exited with code: 13 
2016-08-26 19:22:29.023 o.a.s.d.supervisor [INFO] e80983c3-1ec6-4b25-9ef1-f29eb42194ae still hasn't started 
2016-08-26 19:22:29.040 o.a.s.d.supervisor [INFO] Worker Process e80983c3-1ec6-4b25-9ef1-f29eb42194ae exited with code: 13 
2016-08-26 19:22:29.524 o.a.s.d.supervisor [INFO] e80983c3-1ec6-4b25-9ef1-f29eb42194ae still hasn't started 
2016-08-26 19:22:30.024 o.a.s.d.supervisor [INFO] e80983c3-1ec6-4b25-9ef1-f29eb42194ae still hasn't started 
2016-08-26 19:22:30.524 o.a.s.d.supervisor [INFO] e80983c3-1ec6-4b25-9ef1-f29eb42194ae still hasn't started 
2016-08-26 19:22:31.025 o.a.s.d.supervisor [INFO] e80983c3-1ec6-4b25-9ef1-f29eb42194ae still hasn't started 
2016-08-26 19:22:31.525 o.a.s.d.supervisor [INFO] e80983c3-1ec6-4b25-9ef1-f29eb42194ae still hasn't started 
2016-08-26 19:22:32.025 o.a.s.d.supervisor [INFO] e80983c3-1ec6-4b25-9ef1-f29eb42194ae still hasn't started 
2016-08-26 19:22:32.525 o.a.s.d.supervisor [INFO] e80983c3-1ec6-4b25-9ef1-f29eb42194ae still hasn't started

：上司ログの

storm.zookeper.servers: 
    - "zookeper" 

storm.zookeeper.port: 2181 
# nimbus.host: "nimbus" 
nimbus.seeds: ["nimbus"] 
storm.local.dir: "/var/log/storm" 
supervisor.slots.ports: 
    - 6700 
    - 6701 
    - 6702 
    - 6703 
worker.childopts: "-Xmx768m" 
nimbus.childopts: "-Xmx512m" 
supervisor.childopts: "-Xmx256m" 

storm.messaging.transport: "backtype.storm.messaging.netty.Context" 
storm.messaging.netty.server_worker_threads: 1 
storm.messaging.netty.client_worker_threads: 1 
storm.messaging.netty.buffer_size: 5242880 
storm.messaging.netty.max_retries: 100 
storm.messaging.netty.max_wait_ms: 1000 
storm.messaging.netty.min_wait_ms: 100

私はこれを見ます作業者ログには次のエラーが含まれます。

http://nimbus:8000/log?file=wordcount2-8-1472263925%2F6701%2Fworker.log

2016-08-26 19:28:39.016 o.a.s.s.o.a.z.ZooKeeper [INFO] Client environment:java.compiler=<NA> 
2016-08-26 19:28:39.016 o.a.s.s.o.a.z.ZooKeeper [INFO] Client environment:os.name=Linux 
2016-08-26 19:28:39.016 o.a.s.s.o.a.z.ZooKeeper [INFO] Client environment:os.arch=amd64 
2016-08-26 19:28:39.016 o.a.s.s.o.a.z.ZooKeeper [INFO] Client environment:os.version=4.6.5-300.fc24.x86_64 
2016-08-26 19:28:39.016 o.a.s.s.o.a.z.ZooKeeper [INFO] Client environment:user.name=dmitry 
2016-08-26 19:28:39.016 o.a.s.s.o.a.z.ZooKeeper [INFO] Client environment:user.home=/home/dmitry 
2016-08-26 19:28:39.016 o.a.s.s.o.a.z.ZooKeeper [INFO] Client environment:user.dir=/var/log/storm/workers/3abac0cb-5981-4a87-9ffb-ed2c8053108b 
2016-08-26 19:28:39.017 o.a.s.s.o.a.z.ZooKeeper [INFO] Initiating client connection, connectString=localhost:2181 sessionTimeout=20000 wa[email protected]79316f3a 
2016-08-26 19:28:39.067 o.a.s.s.o.a.z.ClientCnxn [INFO] Opening socket connection to server localhost/0:0:0:0:0:0:0:1:2181. Will not attempt to authenticate using SASL (unknown error) 
2016-08-26 19:28:39.163 o.a.s.s.o.a.z.ClientCnxn [INFO] Socket connection established to localhost/0:0:0:0:0:0:0:1:2181, initiating session 
2016-08-26 19:28:39.176 o.a.s.s.o.a.z.ClientCnxn [INFO] Session establishment complete on server localhost/0:0:0:0:0:0:0:1:2181, sessionid = 0x156c953110f00d8, negotiated timeout = 20000 
2016-08-26 19:28:39.180 o.a.s.s.o.a.c.f.s.ConnectionStateManager [INFO] State change: CONNECTED 
2016-08-26 19:28:39.181 o.a.s.zookeeper [INFO] Zookeeper state update: :connected:none 
2016-08-26 19:28:39.191 o.a.s.s.o.a.c.f.i.CuratorFrameworkImpl [INFO] backgroundOperationsLoop exiting 
2016-08-26 19:28:39.198 o.a.s.s.o.a.z.ZooKeeper [INFO] Session: 0x156c953110f00d8 closed 
2016-08-26 19:28:39.199 o.a.s.s.o.a.z.ClientCnxn [INFO] EventThread shut down 
2016-08-26 19:28:39.201 o.a.s.s.o.a.c.f.i.CuratorFrameworkImpl [INFO] Starting 
2016-08-26 19:28:39.201 o.a.s.s.o.a.z.ZooKeeper [INFO] Initiating client connection, connectString=localhost:2181/storm sessionTimeout=20000 wa[email protected]3dd4a6fa 
2016-08-26 19:28:39.212 o.a.s.s.o.a.z.ClientCnxn [INFO] Opening socket connection to server localhost/0:0:0:0:0:0:0:1:2181. Will not attempt to authenticate using SASL (unknown error) 
2016-08-26 19:28:39.213 o.a.s.s.o.a.z.ClientCnxn [INFO] Socket connection established to localhost/0:0:0:0:0:0:0:1:2181, initiating session 
2016-08-26 19:28:39.220 o.a.s.s.o.a.z.ClientCnxn [INFO] Session establishment complete on server localhost/0:0:0:0:0:0:0:1:2181, sessionid = 0x156c953110f00d9, negotiated timeout = 20000 
2016-08-26 19:28:39.220 o.a.s.s.o.a.c.f.s.ConnectionStateManager [INFO] State change: CONNECTED 
2016-08-26 19:28:39.250 o.a.s.s.a.AuthUtils [INFO] Got AutoCreds [] 
2016-08-26 19:28:39.254 o.a.s.d.worker [INFO] Reading Assignments. 
2016-08-26 19:28:39.310 o.a.s.m.TransportFactory [INFO] Storm peer transport plugin:backtype.storm.messaging.netty.Context 
2016-08-26 19:28:39.311 o.a.s.d.worker [ERROR] Error on initialization of server mk-worker 
java.lang.RuntimeException: Fail to construct messaging plugin from plugin backtype.storm.messaging.netty.Context 
    at org.apache.storm.messaging.TransportFactory.makeContext(TransportFactory.java:53) ~[storm-core-1.0.1.jar:1.0.1] 
    at org.apache.storm.daemon.worker$worker_data.invoke(worker.clj:266) ~[storm-core-1.0.1.jar:1.0.1] 
    at org.apache.storm.daemon.worker$fn__8450$exec_fn__2461__auto__$reify__8452.run(worker.clj:611) ~[storm-core-1.0.1.jar:1.0.1] 
    at java.security.AccessController.doPrivileged(Native Method) ~[?:1.8.0_101] 
    at javax.security.auth.Subject.doAs(Subject.java:422) ~[?:1.8.0_101] 
    at org.apache.storm.daemon.worker$fn__8450$exec_fn__2461__auto____8451.invoke(worker.clj:609) ~[storm-core-1.0.1.jar:1.0.1] 
    at clojure.lang.AFn.applyToHelper(AFn.java:178) ~[clojure-1.7.0.jar:?] 
    at clojure.lang.AFn.applyTo(AFn.java:144) ~[clojure-1.7.0.jar:?] 
    at clojure.core$apply.invoke(core.clj:630) ~[clojure-1.7.0.jar:?] 
    at org.apache.storm.daemon.worker$fn__8450$mk_worker__8545.doInvoke(worker.clj:583) [storm-core-1.0.1.jar:1.0.1] 
    at clojure.lang.RestFn.invoke(RestFn.java:512) [clojure-1.7.0.jar:?] 
    at org.apache.storm.daemon.worker$_main.invoke(worker.clj:771) [storm-core-1.0.1.jar:1.0.1] 
    at clojure.lang.AFn.applyToHelper(AFn.java:165) [clojure-1.7.0.jar:?] 
    at clojure.lang.AFn.applyTo(AFn.java:144) [clojure-1.7.0.jar:?] 
    at org.apache.storm.daemon.worker.main(Unknown Source) [storm-core-1.0.1.jar:1.0.1] 
Caused by: java.lang.ClassNotFoundException: backtype.storm.messaging.netty.Context 
    at java.net.URLClassLoader.findClass(URLClassLoader.java:381) ~[?:1.8.0_101] 
    at java.lang.ClassLoader.loadClass(ClassLoader.java:424) ~[?:1.8.0_101] 
    at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:331) ~[?:1.8.0_101] 
    at java.lang.ClassLoader.loadClass(ClassLoader.java:357) ~[?:1.8.0_101] 
    at java.lang.Class.forName0(Native Method) ~[?:1.8.0_101] 
    at java.lang.Class.forName(Class.java:264) ~[?:1.8.0_101] 
    at org.apache.storm.messaging.TransportFactory.makeContext(TransportFactory.java:38) ~[storm-core-1.0.1.jar:1.0.1] 
    ... 14 more 
2016-08-26 19:28:39.319 o.a.s.util [ERROR] Halting process: ("Error on initialization") 
java.lang.RuntimeException: ("Error on initialization") 
    at org.apache.storm.util$exit_process_BANG_.doInvoke(util.clj:341) [storm-core-1.0.1.jar:1.0.1] 
    at clojure.lang.RestFn.invoke(RestFn.java:423) [clojure-1.7.0.jar:?] 
    at org.apache.storm.daemon.worker$fn__8450$mk_worker__8545.doInvoke(worker.clj:583) [storm-core-1.0.1.jar:1.0.1] 
    at clojure.lang.RestFn.invoke(RestFn.java:512) [clojure-1.7.0.jar:?] 
    at org.apache.storm.daemon.worker$_main.invoke(worker.clj:771) [storm-core-1.0.1.jar:1.0.1] 
    at clojure.lang.AFn.applyToHelper(AFn.java:165) [clojure-1.7.0.jar:?] 
    at clojure.lang.AFn.applyTo(AFn.java:144) [clojure-1.7.0.jar:?] 
    at org.apache.storm.daemon.worker.main(Unknown Source) [storm-core-1.0.1.jar:1.0.1]

光背がアップし、エラーがクラスbacktype.storm.messaging.netty.Contextが見つからない示したよう

(petrel) [dmitry:~/Projects/experiments/storm/petrel/chapter3/example1]$ netstat -an | grep 6627 
69:tcp6  0  0 :::6627     :::*     LISTEN  
75:tcp6  0  0 192.168.14.164:48582 192.168.14.164:6627  ESTABLISHED 
77:tcp6  0  0 192.168.14.164:49154 192.168.14.164:6627  ESTABLISHED 
78:tcp6  0  0 192.168.14.164:48548 192.168.14.164:6627  ESTABLISHED 
80:tcp6  0  0 192.168.14.164:6627  192.168.14.164:49154 ESTABLISHED 
81:tcp6  0  0 192.168.14.164:48578 192.168.14.164:6627  ESTABLISHED 
82:tcp6  0  0 192.168.14.164:6627  192.168.14.164:48064 ESTABLISHED 
83:tcp6  0  0 192.168.14.164:6627  192.168.14.164:48484 ESTABLISHED 
85:tcp6  0  0 192.168.14.164:48560 192.168.14.164:6627  ESTABLISHED 
86:tcp6  0  0 192.168.14.164:49130 192.168.14.164:6627  ESTABLISHED 
87:tcp6  0  0 192.168.14.164:6627  192.168.14.164:49380 ESTABLISHED 
89:tcp6  0  0 192.168.14.164:6627  192.168.14.164:49148 ESTABLISHED 
90:tcp6  0  0 192.168.14.164:48058 192.168.14.164:6627  ESTABLISHED 
91:tcp6  0  0 192.168.14.164:49424 192.168.14.164:6627  TIME_WAIT 
92:tcp6  0  0 192.168.14.164:6627  192.168.14.164:48034 ESTABLISHED 
93:tcp6  0  0 192.168.14.164:6627  192.168.14.164:48498 ESTABLISHED

出典

2016-08-27 DmitrySemenov

答えて

0

問題を参照してください私のJAVA_HOMEののenv varが間違ったフォルダを指していたということでした。後

JAVA_HOME =は/ usr/libに/ JVM/javaの-1.8.0-OpenJDKの-1.8.0.101-1.b14.fc24.x86_64/JRE/

：前

：

JAVA_HOME =は/ usr/libに/ JVM/javaの-1.8.0-オラクル-1.8.0.92.x86_64/

は私が来るサンプルJavaトポロジーを実行することによって、その嵐が正しくインストールされてチェックするの推薦を得ました暴風雨でレズ。

私はこの公式に従いましたtutorial。すぐに私はいた/usr/lib/jvm/java-1.8.0-oracle-1.8.0.92.x86_64/にJAVA_HOMEを切り替えるよう

[INFO] ------------------------------------------------------------------------ 
[INFO] BUILD FAILURE 
[INFO] ------------------------------------------------------------------------ 
[INFO] Total time: 49.281 s 
[INFO] Finished at: 2016-08-27T19:16:54-07:00 
[INFO] Final Memory: 21M/391M 
[INFO] ------------------------------------------------------------------------ 
[ERROR] Failed to execute goal on project storm-starter: Could not resolve dependencies for project org.apache.storm:storm-starter:jar:1.0.1: Could not find artifact jdk.tools:jdk.tools:jar:1.7 at specified path /usr/lib/jvm/java-1.8.0-openjdk-1.8.0.101-1.b14.fc24.x86_64/jre/../lib/tools.jar -> [Help 1] 
[ERROR] 
[ERROR] To see the full stack trace of the errors, re-run Maven with the -e switch. 
[ERROR] Re-run Maven using the -X switch to enable full debug logging. 
[ERROR] 
[ERROR] For more information about the errors and possible solutions, please read the following articles: 
[ERROR] [Help 1] http://cwiki.apache.org/confluence/display/MAVEN/DependencyResolutionException 


(petrel) [dmitry:/storm-starter]$ dnf list installed | grep java 

55:abrt-java-connector.x86_64   1.1.0-8.fc24    @koji-override-0 
749:java-1.8.0-openjdk.x86_64   1:1.8.0.101-1.b14.fc24  @updates   
750:java-1.8.0-openjdk-headless.x86_64 1:1.8.0.101-1.b14.fc24  @updates   
751:java-1.8.0-oracle.x86_64   1.8.0.92-1.fc24.R   @russianfedora-nonfree 
752:java-1.8.0-oracle-devel.x86_64  1.8.0.92-1.fc24.R   @russianfedora-nonfree 
753:java-1.8.0-oracle-headless.x86_64 1.8.0.92-1.fc24.R   @russianfedora-nonfree 
754:javapackages-tools.noarch   4.6.0-14.fc24    @koji-override-0 
1846:python3-javapackages.noarch  4.6.0-14.fc24    @koji-override-0 
2431:tzdata-java.noarch     2016f-1.fc24    @updates

：

cd ~/Development/storm/examples/storm-starter 
mvn package

は私にこれを与えましたサンプルクラスタをリモートクラスタにコンパイルして提出することができます（これはまだローカルにインストールされていますが、ストームと動物園/看守/監督/ ui /ログビューアはローカルに実行されます）

また、 'を輸送手段とし、以下のv alues：

#storm.messaging.transport: "backtype.storm.messaging.netty.Context" 
#storm.messaging.netty.server_worker_threads: 1 
#storm.messaging.netty.client_worker_threads: 1 
#storm.messaging.netty.buffer_size: 5242880 
#storm.messaging.netty.max_retries: 100 
#storm.messaging.netty.max_wait_ms: 1000 
#storm.messaging.netty.min_wait_ms: 100

嵐1.0+が自分のクラスの構造の変化を得たとして、このが、否定的な方法であなたのシステムに影響を与えることができます。

クラスはbacktype.stormから1.0.1でorg.apache.stormに再パッケージされました。

出典

2016-08-28 03:18:15 DmitrySemenov

1

を実行しています。

は嵐1.0.0では多くのパッケージの名前を変更する主要なリファクタリングました。今はorg.apache.storm.messaging.netty.Contextを使いたいと思う。

storm.messaging.transport: "org.apache.storm.messaging.netty.Context"

https://storm.apache.org/releases/1.0.0/index.html

出典

2016-08-27 15:35:41

関連する問題

 関連する問題