apache-storm

0熱

1答えて

は正しいでしょうか？それ以外の場合、-wフラグの使い方は？ wait-time-secsでストームトポロジーを強制終了する例を挙げてください。

1熱

1答えて

spoutクラスの私の失敗メソッドは、最初のボルトに対してのみ働き、2番目のボルト以降では機能しません。

注： Bolt1は、最初の3つの素数（2,3,5）のリストが含まれています。 Bolt2には、素数（7,11,13）の2番目の3つのセットのリストが含まれています。 Bolt3では、番号がプライムであるかどうかをチェックするだけです。最初のボルトから、私はspoutクラスからFail（）を呼び出すことができますが、2番目のボルト以降では、spoutクラスからFail（）を呼び出すことができません

2熱

1答えて

Twitter HeronとStorm Fluxの使い方

私はapache-stormからtwitter-heronにプロジェクトを移行しようとしています。多くの苦闘の末、className: "storm.kafka.ZkHosts"の代わりにclassName: "org.apache.storm.kafka.ZkHosts"を使用するなど、ほとんどのエラーを取り除くことができました。しかし、私はトポロジを提出することに悩まされています。 Fluxを

0熱

1答えて

ストームトポロジをローカルで実行しているときにエラーが発生しています

localmodeでストームトポロジを実行してテストします。プロジェクトは本質的にカフカの噴出口からいくつかのログを採取し、いくつかの前処理操作を行い、スクリーン上に内容を印刷する。次は私のトポロジーコードです： import org.apache.storm.*; import org.apache.storm.generated.*; import org.apache.storm.ka

0熱

1答えて

カフカ注ぎ口の構成エラー

システム環境：1.7.0_55、ベンダー：オラクル・コーポレーション OS名のApache Mavenの3.0.5 Javaのバージョンをインキュベート嵐0.9.2： "linux"、バージョン： "3.13.0-24-ジェネリック"、アーチ： "i386"、ファミリー： "unix" ここは私のコードです： Config conf = new Config(); conf.se

1熱

1答えて

HBaseに接続するときのNoSuchMethodError例外

ScalaコードからHBaseにアクセスしようとすると、例外が発生します。私は私のマシン（Ubuntuの16.04）上でスタンドアロンモードでのHBase 1.2.6インストール：ここはその話のロングバージョンです。次は、私は次のコードを実行してみました：私は、これらのコマンドを使用してSBTからコードを実行 name := "myapp" version := "1.0" scal

-1熱

1答えて

Storm1.1.0 + kafka0.10.2.1：NoSuchMethodError＆ExceptionInInitializerError

私は嵐やカフカに慣れていません。私はオープンソースプロジェクトを実行したい：github:cestella:streaming_outliers このプロジェクトはstorm0.10.0を使用しています。しかし、私の嵐のクラスタはstorm1.0.3です。これはstorm0.10.0では機能しません。したがって、嵐のバージョンといくつかの関連パッケージを変更する必要があります。このトポロジを実

2熱

1答えて

嵐の背圧

私たちの嵐1.0.2アプリケーションでは、メモリ例外が発生しています。デバッグのとき、カフカの噴出口がボルトにあまりにも多くのメッセージを出していたことがわかりました。ボルトはほぼ4.0の容量で走っていた。それで、スパウトがボルトの容量に応じて放出するように、嵐の背圧を可能にする方法があります。 topology.backpressure.enableを有効にしようとしましたが、この問題はhttp

0熱

1答えて

ストーム・トライデントのネットワーク・パーティショニングおよび/または障害シナリオでの一度の保証

したがって、Apache Storm + Tridentは正確に一度のセマンティクスを提供します。リモートストレージ/データベースへの最終的な値を保存する必要がありSaveMoneyBoltに結果を渡し、メモリ内 TridentSpout -> SumMoneyBolt -> SaveMoneyBolt -> Persistent Storage. CalculateMoneyBolt合計金額

0熱

1答えて

storm nimbusデーモンでエラーが発生しました

私のubuntuにapache stormを実行しようとしています。このためには、nimbusデーモンを実行する必要があります。問題は、私は、コマンド嵐の光背を入力すると、それは私にエラーを与えている： ERROR StatusLogger File not found in file system or classpath: /usr/lib/storm/cluster.xml ERROR S