apache-apex

2熱

1答えて

私は、Apache ApexアプリケーションでKafkaログを消費し、HDFSに書き込んでいます。 DAGは、 "MyWriter extends AbstractFileOutputOperator"にストリームで接続されたKafkaコンシューマー（オペレータ用に2GBのメモリ20個のパーティション）があるほど簡単です。問題： 1.同じサイズと同じデータの複数の.tmpファイルを何度も繰り返し

3熱

2答えて

Apacheのアペックス - カフカ0.9安全なカフカのトピック

誰かがplsは私が理解することができ、はapacheの頂点はカフカ0.9安全なカフカのトピックから読み取るための任意の作り付けのカフカ入力演算子を持っていますか？

3熱

2答えて

Apache Apexのapplication.javaクラスに引数を渡すには？

Application.javaクラスに引数を渡すにはどうすればよいですか？私たちがjavaのメインメソッドで(String[] args)をどのように渡すか？参照が見つかりませんでした。誰かがこれに関する知識を共有できますか？ありがとうございます。

2熱

3答えて

DataTorrentなしでApexを使用するRTS

DataTorrent RTSなしでApache Apexを使用できますか？可能であれば、私はapexソースの独自のビルド（実行するにはleas apexバイナリが必要）に関するチュートリアルを見つけることができませんでした。私は、アペックスのCLIは./engine/src/main/scripts/apexのビルド後に利用可能ですが、おそらくいくつかの作品をより簡単な方法で構築するよりも参照し

2熱

1答えて

実行中のアプリケーションのアプリケーション概要ページを取得できません

ほとんどの場合、私はアプリケーションのアプリケーションモニタページのアプリケーション概要に行くことができません。時々私が行くと、論理プラン、物理プランのタブなどのページ上のすべての統計は全く存在せず、統計も表示されません。しかし、私はアプリケーションが終了した後にアプリケーションの概要に行く問題はありません。私は、アプリケーションOveriviewページに行くことができない時はいつでもここでは

1熱

1答えて

hadoopクラスタで設定された時間以外に、長時間実行されているアプリケーションの委任トークンを更新する方法

Hadoop環境で動作するApache Apexアプリケーションがあります。私はアプリケーションに問題はありませんが、7日後には問題がありません。そして、私はそれがどのアプリケーションのクラスターレベルの設定のためであることに気付きました。何らかの手段がありますが、何らかの間隔で委任トークンを定期的に更新して、ジョブが連続して実行されるようにします。私はhdfs委任トークンを更新する方法につ

3熱

1答えて

DataTorrent/Apache Apex with sbt

しばらくの間、DataTorrent/Apexで作業していました。 SBTを使用してDataTorrent（Java）アプリケーションを作成できますか？ DataTorrentアプリケーションのrootディレクトリにsbt clean assemblyを実行中にビルドの成功が発生しました。ただし、.jarファイルのみが作成され、.apaファイルが作成されていません。続きはbuild.sbt na

2熱

2答えて

κアーキテクチャでdatatorrentを使用するには？

私は、Apache SparkまたはApache Stormのいずれかを使用する必要のあるラムダとカッパのアーキテクチャについてたくさん読んでいます。バッチ処理とリアルタイム処理ができるDataTorrentという新しいツールが見つかりました。 DataTorrentがラムダ（またはカッパ）アーキテクチャのバッチとスピードレイヤを同時に実行できるかどうか疑問に思っていましたか？乾杯、