Member since
10-16-2018
1
Post
0
Kudos Received
0
Solutions
10-16-2018
04:22 PM
Hi @Dmitry K Just curious to know if you were able to figure out what is happening with PutKudu Processor. I'm facing a similar issue where my NiFi Processor runs fine, the logs look clean and no errors in Kudu logs but there is no record posted to Kudu table. Logs given below. Also just curious to know if you were able to handle Kudu Updates from NiFi. 2018-10-16 12:02:19,639 INFO [pool-10-thread-1] o.a.n.c.r.WriteAheadFlowFileRepository Initiating checkpoint of FlowFile Repository
2018-10-16 12:02:19,639 INFO [pool-10-thread-1] o.a.n.c.r.WriteAheadFlowFileRepository Successfully checkpointed FlowFile Repository with 737 records in 0 milliseconds
2018-10-16 12:03:03,147 INFO [Flow Service Tasks Thread-1] o.a.nifi.controller.StandardFlowService Saved flow controller org.apache.nifi.controller.FlowController@2e993868 // Another save pending = false
2018-10-16 12:03:04,705 INFO [Flow Service Tasks Thread-2] o.a.nifi.controller.StandardFlowService Saved flow controller org.apache.nifi.controller.FlowController@2e993868 // Another save pending = false
2018-10-16 12:03:08,029 INFO [Provenance Query-1] o.a.nifi.provenance.StandardQueryResult Completed Query[ [01661009-bea9-1475-b35c-86134aa20ef6] ] comprised of 1 steps in 74 millis
2018-10-16 12:03:08,029 INFO [Provenance Query-1] o.a.n.provenance.index.lucene.QueryTask Successfully queried index /u01/nifi/data/provenance_repository/index-1532552783325 for query +processorId:01661009-bea9-1475-b35c-86134aa20ef6; retrieved 35 events with a total of 61 hits in 47 millis
2018-10-16 12:03:18,681 INFO [NiFi Web Server-307] o.a.n.c.s.StandardProcessScheduler Starting PutKudu[id=01661009-bea9-1475-b35c-86134aa20ef6]
2018-10-16 12:03:18,735 INFO [Timer-Driven Process Thread-9] o.a.n.c.s.TimerDrivenSchedulingAgent Scheduled PutKudu[id=01661009-bea9-1475-b35c-86134aa20ef6] to run with 1 threads
2018-10-16 12:03:18,787 INFO [Flow Service Tasks Thread-2] o.a.nifi.controller.StandardFlowService Saved flow controller org.apache.nifi.controller.FlowController@2e993868 // Another save pending = false
2018-10-16 12:03:19,271 INFO [NiFi Web Server-317] o.a.n.c.s.StandardProcessScheduler Stopping PutKudu[id=01661009-bea9-1475-b35c-86134aa20ef6]
2018-10-16 12:03:19,271 INFO [NiFi Web Server-317] o.a.n.controller.StandardProcessorNode Stopping processor: class org.apache.nifi.processors.kudu.PutKudu
2018-10-16 12:03:19,274 INFO [Timer-Driven Process Thread-1] o.a.n.c.s.TimerDrivenSchedulingAgent Stopped scheduling PutKudu[id=01661009-bea9-1475-b35c-86134aa20ef6] to run
2018-10-16 12:03:19,351 INFO [Flow Service Tasks Thread-1] o.a.nifi.controller.StandardFlowService Saved flow controller org.apache.nifi.controller.FlowController@2e993868 // Another save pending = false
Thanks
... View more