hortonworks-dataflow

0熱

1答えて

アンバリメトリックコレクタAPIを使用してHDFおよびHDPクラスタに関する情報を取得していますが、使用可能なメトリック、そのユニットの単位、平均化された期間誰も私がそのようなリソースを見つけることができるか知っていますか？あなたが探しているドキュメントかもしれ

1熱

2答えて

Hortonworks：ユーザーの管理方法

私はHadoop管理とHortonworks Hadoopの新機能です。私の質問は、Hortonworksのユーザーを管理する一般的な方法です。 Ambariは私がユーザーを作成することを可能にしますが、企業はどのようにAmbariのユーザーをユーザーにマッピングしますか？私はHortonworksでKerberosを有効にできます。これは、企業ユーザ（LDAPなど）がHortonworksにログ

1熱

1答えて

NiFi PutHiveStreamingプロセッサ（ハイブ付）：エンドポイントへの接続に失敗しました

Nifi 1.3.0とHiveでは、誰かがこの問題を解決するのに役立ちます。私はハイブ1.2とハイブ2.1.1で同じエラーが発生します。ハイブテーブルは、パーティクルド,バケットであり、ORCの形式で格納されています。パーティションがhdfs上に作成されましたが、書き込みステージでデータが失敗しました。以下のようにログを確認してください： [5:07 AM] papesdiop: Failed

1熱

1答えて

NiFiで消耗品を入手する

一部のプロセッサにGetXXXとConsumeXXXの両方の変形があります（GetKafkaとConsumeKafkaなど）。 ConsumeXXXの上にGetXXXを持つプロセッサーに名前を付けるのはいつですか？注：technical differences between ConsumeKafka and GetKafkaを理解しています。私の質問は、主に命名規則です。

0熱

1答えて

Nifiサービスを再起動しないでNifiライブラリをリロードする

サービスを再起動せずにnifiライブラリをリフレッシュ/リロードする方法があるかどうかを知る必要がありますか？私たちは、異なる国々で共有されている大きなNifi Centralクラスタを持っており、クラスタの変更は誰にも影響します。どんなテストでもダウンタイムを取ることは困難です。誰かが解決する方法がありますか？

0熱

1答えて

コントローラサービスの内部500エラー：3ノードクラスタのHDF Nifi

3ノードNifi 1.1クラスタでHDF 2.1.2をインストールしましたが、コントローラサービスを設定しようとしています。 ThriftConnectionPoolコントローラサービスに依存する単純なExecuteHQLプロセッサを作成しました。私はExecuteProcessorをキャンバス上にドラッグしました。コントローラーサービスを設定するための歯車アイコンをクリックすると、実行時例外が

0熱

1答えて

Nifi - Rest APIによるリモートプロセスグループの更新

テンプレートを使用して、2つのnifiクラスタ間でデータ転送ジョブをパッケージ化しています.1つは送信者、もう1つは受信者です。私たちの仕事の1つにはリモートプロセスグループが含まれていて、テンプレートが作成された時点で問題なく動作していました。私たちの環境（dev、test、pre、prod）を使ってテンプレートをデプロイすると、手動で削除して、ユーザーインターフェイスでリモートプロセスグルー

0熱

1答えて

HDF NIfi - NifiはHDPノードの出所/データを書きますか？

こんにちは私はHDPクラスタ上でジョブ（Hive/Spark）をランチする3つのNifiインスタンスを持つHDFクラスタを持っています。通常、nifiはすべての情報をローカルマシン上の異なるリポジトリに書き込みます。私の質問は - HDFS、ハイブ、またはスパークサービスにアクセスしている間、nifiはHDPノード（HDPクラスタのデータノードなど）にデータ、起源情報を書き込んでいますか？お

0熱

1答えて

NifiからAPIを消費する

以下は、セキュリティ保護された残りのAPIを消費するための私のnifiの仕事です。私はinvokeHttpプロセッサを実行すると私は次の例外を取得しています：ヘッダが欠落しているよう 2017-09-19 07:58:59,744 ERROR [Timer-Driven Process Thread-3] o.a.nifi.processors.standard.InvokeHTTP java

0熱

1答えて

KafkaによるNiFiワークフローのボトルネック

私は、バッファリングシステムとしてKafkaを使用して、Apache NiFiでデータ取り込みワークフローを作成しています。私は同じワークフローを実行する3ノードクラスタを設定しており、各ノードには4つのコアがあります。私は、異なるカフカのトピック間でデータを移動するいくつかの例に頼っていますが、これはワークフローの中で最も遅い部分であり、2つの同一のテストで100％期間の増加。パブリッシュと