問題タブ [jzmq]

Hadoop クラスタのノードの 1 つで JZMQ コードを動作させようとしています。そのノードの /usr/local/lib ディレクトリの下に、必要なネイティブ jmzq ライブラリ ファイルがインストールされています。

ここにリストがあります - libjzmq.a libjzmq.la libjzmq.so libjzmq.so.0 libjzmq.so.0.0.0 libzmq.a libzmq.la libzmq.so libzmq.so.3 libzmq.so.3.0.0 pkgconfig

私のシェル スクリプトで、以下の Java コマンドを実行すると、まったく問題なく動作します -

しかし、以下のコマンドを実行すると、スレッド「メイン」で例外がスローされます

Export コマンドを使用して、Hadoop Classpath、Opts などに必要なファイル/Jar を明示的に設定します。

ソース コード JAR および jzmq-2.1.3.jar ファイルは、Hadoop ノードの /home/txtUser/analytics/lib/ フォルダーの下にあります。また、/usr/local/lib がシステム ld.conf に追加されます。

ここで私が間違っているかもしれないことについての情報を与えられて、誰かが提案できますか?

jzmq ラッパーの使用:

scala> import org.zeromq.ZMQ import org.zeromq.ZMQ

これはバージョン 3 で廃止されたようです:

https://github.com/zeromq/jzmq/blob/750f2eecaa4c71adf86c156fab5840a2f614d4ea/src/org/zeromq/ZMQ.java#L895-900

誰でも理由を知っていますか？jzqm + zmq3を使用してHWMを設定する代替手段は何ですか?

そのため、jzmq GIT マスター ブランチと ZeroMQ 3.2.3 を使用して独自のものを作成しています。

インストール後PUB/SUB、パブリッシャーとサブスクライバーが 1 つのプロセスで対話する次の簡単なプログラムをテストしようとしました。テストは Windows で行うため、TCP を使用しました。

ご覧のとおり、サブスクライバーで単純な.recv(ZMQ.DONTWAIT)方法を使用すると、完全に機能します。ただし、ダイレクト バイト バッファを使用している場合、何も返されませんでした。次の例外が発生しました。プログラムの終了時のようです。

ByteBufferまた、上記の例外をスローしない単純な (直接バッファーではない) を使用しようとしました。何も返してくれません。

上記を解決する方法を知っている人はいますか？

byte[]私はいくつかの高性能システムを実行しているので、オブジェクトをあちこちに作成したくありません。これが解決できない場合は、代わりに Unsafe を使用するだけです。でも本当は「あるべき姿」で働きたい。

前もって感謝します。

アレックス

ZMQプロジェクトに統合する方法を理解しようとしているのは初めてです。と. server is Java_ の使用client is C++に取り組んでいます。0MQ の内容は圧倒され、混乱を招きます。私が探しているのは、次の手順の簡単なリストです。WindowsVS2013 and Eclipse (STS)

1. 0MQ Java のダウンロード - 正確には何をダウンロードする必要があり、最新の安定バージョンの URL はどれですか。

2. コードで 0MQ の使用を開始できるように、Eclipse プロジェクトに入るには何 (場所とファイル) が必要ですか。

3. 0MQ C++ のダウンロード - 正確には何をダウンロードする必要があり、最新の安定バージョンの URL はどれですか。

4. コードで 0MQ の使用を開始できるように、VS プロジェクトに入る必要があるもの (場所とファイル) は何ですか。

ありがとう。

Nimbus ホストとスーパーバイザは正常に動作します。wordcount トポロジを Nimbus ホストに送信すると、正常にアップロードされます。トポロジー・スーパーバイザーをアップロードした後、エラーが発生しました

を確認するworker-6001.logと6002.log、次のエラーが見つかりました。

私の構成は

嵐.yaml

Java バージョン

例としてこのブログを使用しました。