0

Amazon EC2 インスタンスにストーム クラスターを作成しました。ローカル環境 (疑似分散環境) でコードをテストしたところ、問題なく動作しました。しかし、分散環境でコードを実行すると、コードが機能しないようです。クラスターのセットアップ中に、ここで欠けている技術的なものはありますか?

すべてのスーパーバイザー ノードのCPU 使用率を確認したところ、いずれも 1% を超えていませんでしたが、マスター (ニンバス) は、コードの実行が終了しました。

また、スーパーバイザー ノードで実行されている Java プロセスも確認しましたが、"jps"にトポロジが表示されません。

注: クラスターは、ニンバス上で実行されている UI に 2 つのスーパーバイザーを示しています。これは、クラスターが分散環境でセットアップされていることを示しています。

4

1 に答える 1

1

私の問題の解決策:

以前は、のLocalCluster代わりにを使用して実行していましたStormSubmitter

これを使って：

StormSubmitter.submitTopologyWithProgressBar(args[0], conf, builder.createTopology());

それ以外の：

LocalCluster cluster = new LocalCluster();
cluster.submitTopology("test", conf, builder.createTopology());
Utils.sleep(10000);
cluster.killTopology("test");
cluster.shutdown();
于 2015-10-20T05:34:30.530 に答える