apache-nifi

0熱

1答えて

NIFI：EvaluateJsonPath Processorを使用してJSON配列から特定の値を抽出しますか？

私は以下を持っていますJSON structureと私は "すべてのUpdateCounterの"を含むコンテキストから値から "3"を抽出したいと思います。以下は私が試したもので、うまくいきませんでした。 $ .counters.aggregateSnapshot.counters。[context == "All UpdateCounter \ 's]。valueCount NIFIの表現は可

0熱

1答えて

NIFI：以前のすべてのプロセッサが実行を完了するのを待ってから、何か一度だけ何をするのですか？

NIFIには、さまざまなプロセッサで複雑なタスクが実行されるシナリオがあります。私はこの流れの最後にもう一つのプロセッサを追加したいと思います。このプロセッサは、すべてのプロセッサが終了してから実行するまで待つ必要があります（一度だけ！）。どのように達成することが可能でしょうか？

1熱

1答えて

NIFI：メモリ不足のエラーヒープサイズを増やすことに失敗しました

NIFIサービスが起動を拒否する問題が発生しました。私はnifi-app.logを監視し、OutOfMemoryエラーであることを発見しました。私はbootstap.confファイルのメモリを増やしました。しかし、このエラーは依然として持続しています。添付はnifi-app.log 2017-12-19 17:08:37,133 ERROR [ActiveMQ InactivityMonitor

0熱

1答えて

Apache Nifi InvokeHttpタイムアウトの問題

Apache NiFiのInvokeHttpプロセッサに問題があります。私はGETリクエストを介してREST APIに接続しようとしているときにタイムアウトが発生したときにメッセージを受け取りたい。障害の関係の文書によると：元のFlowFileは、あらゆるタイプの接続失敗、タイムアウトまたは一般的な例外でルーティングされます。要求を詳述する新しい属性が追加されます。私は20秒後に応答するテスト

0熱

1答えて

NIFI（S3 to HDFS）

ListS3、fetchS3object、PutHDFSを使用してS3からHDFSにデータをコピーしようとしています。 S3バケットのデータは次のように構成されています。同じフォルダ構造（フォルダ名は動的）でHDFSにコピーする必要があります。 bucketname /親のfolder1/subfolder1/filename1.txt bucketname /親のfolder1/subfolde

1熱

1答えて

Nifiプロセッサは、私の問題は、連結ソムフィールドにその必要性であると、それらを区切る '文字

私はPutHiveQLプロセッサに送信する前に、セミコロン上の単一のHQL文に複数の文のHQLファイルを分割するSPLITTEXTプロセッサを使用するエスケープSPLITTEXT。 splittextにその特定のセミコロンを無視させたいという意味です。例で逃げようとしました。 drop table my table if exits; create external table mytabl

0熱

1答えて

NiFiリモートプロセッサグループのURLでローカルホストを使用する

クラスタ化されたNiFiセットアップ（2ノード）を使用しており、RPG URLのノードのIPアドレスを明示的に指定すると、 //：8080/nifi）。問題はテンプレートでRPGを使用することにあります。そのRPGをそのクラスタ環境の新しいノード情報（Test-> Stage-> Prod）で再作成する必要があります。何らかの形でこのURLのアドレスとしてlocalhostを使用することができます

0熱

1答えて

Nifi - mysql dbテーブルに切り捨ててロードする

SFTPサイトからCSVファイルを読み込み、Nifiを使ってmysql dbにロードしています。以下のワークフローがうまくいきます。データロードを開始する前にテーブルを切り捨てる方法を理解するには、ちょっとした助けが必要です。 Nifiフロー： ListSFTP - > FetchSFTP - > InferAvroSchema - > ConvertCSVtoAvro - > ConvertA

1熱

1答えて

groovyコードで負のインデックスエラーを削除するには？

ログファイルを減らすnifiプロセッサー（executeScriptプロセッサー）の中にコードロジックがあります（この場合、ログファイルには同じテキストがあり、重複を削除したいので名前とファイルサイズで選択しようとします）。私は時々（常にではない）負のインデックスエラーを持っています私はそれを動作させるために私のコードで変更する必要がありますか？ import org.apache.nifi.pr

0熱

2答えて

NIFIのHTTP応答から最初の行をスラッシング

現在、HTTPエンドポイントを取り込み、InvokeHTTPプロセッサを使用してHDFSに取り込んでいます。私のHTTPエンドポイントはhttp://www.cbioportal.org/webservice.do?cmd=getMutationData&case_set_id=gbm_tcga_all&genetic_profile_id=gbm_tcga_mutations&gene_list