2017-08-30 9 views
0

3つのプロセッサを持つNifiワークフローを作成しました。詳細はこちらです。 問題はNifiでワークフローを実行してもうまく動作しているときですが、Kyloで同じテンプレートをインポートしてフィードから実行しているときにエラーが発生しています.Kyloテンプレートに問題があるようです。あなたはそれで私を助けてくれますか?また、Nifiログでは何のエラーも表示されません。Kyloテンプレートが失敗する

おかげで、

Kylo仕事の失敗 Kylo Job Failure

Nifiワークフロー Nifi Workflow

Kyloテンプレート-1 Kylo Template-1

Kylo Template -2

Nifi log: 

    2017-08-30 10:11:49,764 INFO [pool-8-thread-1] org.wali.MinimalLockingWriteAheadLog [email protected] checkpointed with 1 Records and 0 Swap Files in 34 milliseconds (Stop-the-world time = 16 milliseconds, Clear Edit Logs time = 15 millis), max Transaction ID 37082 
    2017-08-30 10:11:49,764 INFO [pool-8-thread-1] o.a.n.c.r.WriteAheadFlowFileRepository Successfully checkpointed FlowFile Repository with 1 records in 34 milliseconds 
    2017-08-30 10:13:47,109 INFO [Write-Ahead Local State Provider Maintenance] org.wali.MinimalLockingWriteAheadLog [email protected] checkpointed with 2326 Records and 0 Swap Files in 18 milliseconds (Stop-the-world time = 1 milliseconds, Clear Edit Logs time = 1 millis), max Transaction ID 6977 
    2017-08-30 10:13:49,764 INFO [pool-8-thread-1] o.a.n.c.r.WriteAheadFlowFileRepository Initiating checkpoint of FlowFile Repository 
    2017-08-30 10:13:49,799 INFO [pool-8-thread-1] org.wali.MinimalLockingWriteAheadLog [email protected] checkpointed with 1 Records and 0 Swap Files in 34 milliseconds (Stop-the-world time = 16 milliseconds, Clear Edit Logs time = 15 millis), max Transaction ID 37082 
    2017-08-30 10:13:49,799 INFO [pool-8-thread-1] o.a.n.c.r.WriteAheadFlowFileRepository Successfully checkpointed FlowFile Repository with 1 records in 34 milliseconds 
    2017-08-30 10:14:05,620 INFO [StandardProcessScheduler Thread-3] o.a.n.c.s.TimerDrivenSchedulingAgent Scheduled ExecuteSQL[id=ef6f1e38-682f-4300-d33f-ceb1839cdf61] to run with 1 threads 
    2017-08-30 10:14:06,147 INFO [Flow Service Tasks Thread-2] o.a.nifi.controller.StandardFlowService Saved flow controller [email protected] // Another save pending = false 
    2017-08-30 10:14:08,057 INFO [FeedStatisticsManager-SendStats-2] c.t.n.p.j.ProvenanceEventActiveMqWriter SENDING Batch Events to JMS ProvenanceEventRecordDTOHolder{events=3} 
    2017-08-30 10:14:14,951 INFO [Provenance Maintenance Thread-1] o.a.n.p.PersistentProvenanceRepository Created new Provenance Event Writers for events starting with ID 46037 
    2017-08-30 10:14:14,965 INFO [Provenance Repository Rollover Thread-2] o.a.n.p.PersistentProvenanceRepository Successfully merged 16 journal files (4 records) into single Provenance Log File /opt/data/provenance_repository/46033.prov in 18 milliseconds 
    2017-08-30 10:14:14,965 INFO [Provenance Repository Rollover Thread-2] o.a.n.p.PersistentProvenanceRepository Successfully Rolled over Provenance Event file containing 3 records 
    2017-08-30 10:14:38,057 INFO [FeedStatisticsManager-SendStats-0] c.t.n.p.j.ProvenanceEventActiveMqWriter SENDING Batch Events to JMS ProvenanceEventRecordDTOHolder{events=3} 
    2017-08-30 10:14:44,959 INFO [Provenance Maintenance Thread-3] o.a.n.p.PersistentProvenanceRepository Created new Provenance Event Writers for events starting with ID 46041 
    2017-08-30 10:14:44,999 INFO [Provenance Repository Rollover Thread-1] o.a.n.p.PersistentProvenanceRepository Successfully merged 16 journal files (4 records) into single Provenance Log File /opt/data/provenance_repository/46037.prov in 39 milliseconds 
    2017-08-30 10:14:44,999 INFO [Provenance Repository Rollover Thread-1] o.a.n.p.PersistentProvenanceRepository Successfully Rolled over Provenance Event file containing 3 records 
+0

ログのタイムスタンプは、Kylo UIの失敗時間に対応していません。あなたは2つを一致させることができますか? Nifiログに何かがある必要があります –

+0

厳密にはプログラミングの種類の質問ではないので、このタイプの質問はKylo Googleグループでよく聞かれます。 GoogleグループでKyloコミュニティを見つけることができますhttps://groups.google.com/forum/#!forum/kylo-community –

+0

Googleグループの次の会話もご覧ください:https://groups.google.com/forum/? utm_medium = email&utm_source =フッター#!トピック/ kylo-community/WyCN_YWPQo8 –

答えて

3

Kyloは、接続名を調べてフローファイルが失敗したかどうかを判断します。あなたが失敗と成功のために同じ接続を使用しているので、Kyloは失敗か成功かを判断できません。

これを変更するにはいくつかの方法があります:

  1. は、障害のためにPUTFILEまたはLogAttributeプロセッサを追加し、既存の障害の接続を削除します。これにより、障害が発生してもフローファイルの進行が停止します。

  2. 障害接続を自動終了し、既存の障害接続を削除します。これにより、フローファイルの進行が停止しますが、失敗接続がないため、Kyloはすべてを成功として表示します。

  3. 名前を「成功」に変更します。これによりフローファイルは継続され、Kyloはすべてを成功として表示します。

関連する問題