Hello Experts,   We have HandleHttpRequests processor running with 16 concurrency. Container queue size configured is 1000. While running a load test suddenly HandleHttpRequests stopped emitting flowfiles recieved and started throwing error show in below image -  So we stopped the load test and now even after 30 mins when we send requests it will just emit 2 or 3 flow files and again shows same error and does not release/emit any request flowfiles. Ideally when no request is getting hit to that port (which HttpRequestListener is configured) container should get cleared and flow files should get created from queue and emit right? What could be the reason this processor is just trhowing container full error and not emitting any flow files ? It started working only when we manually cleanup all repositories (content, provenance, ff) and restart the nifi ! Any suggestion would be appreciated.   Thanks, Mahendra ... View more

Experts, I am continuously seeing this log in Nifi app log -   2022-07-25 06:12:40,788 INFO [Timer-Driven Process Thread-219] o.a.n.c.repository.FileSystemRepository Unable to write to container default due to archive file size constraints; waiting for archive cleanup   Any idea what is the reason and will there be any impact of this ? Thanks Mahendra ... View more

Hello Experts,   I am using org.apache.nifi.util.TestRunners in Nifi custom processor unit test cases, and code something like below..   testRunner = TestRunners.newTestRunner(O9QueueRouting.class); . . . . MockFlowFile ff = this.testRunner.enqueue(new ByteArrayInputStream(ffContents.getBytes(StandardCharsets.UTF_8))); Map<String, String> attrs = new HashMap<String, String>(); attrs.put("routingheader", "headervalue"); attrs.put("kafka.topic", "topic1"); ff.putAttributes(attrs); testRunner.run(); It was working earlier now started giving error like below - [ERROR] O9QueueRoutingTest.test:73 java.lang.RuntimeException: As of version 1.14.0, ProcessSession.commit() should be avoided when possible. See JavaDocs for explanations. Instead, use commitAsync(), commitAsync(Runnable), or commitAsync(Runnable, Consumer<Throwable>). However, if this is not possible, ProcessSession.commit() may still be used, but this must be explicitly enabled by calling TestRunner.   Any idea how this can be resolved ? How to explicitly enable by calling TestRunner ? Thanks Mahendra ... View more