From issues-return-100081-archive-asf-public=cust-asf.ponee.io@nifi.apache.org Fri Jul 10 16:29:02 2020 Return-Path: X-Original-To: archive-asf-public@cust-asf.ponee.io Delivered-To: archive-asf-public@cust-asf.ponee.io Received: from mail.apache.org (hermes.apache.org [207.244.88.153]) by mx-eu-01.ponee.io (Postfix) with SMTP id 8500D180663 for ; Fri, 10 Jul 2020 18:29:02 +0200 (CEST) Received: (qmail 78297 invoked by uid 500); 10 Jul 2020 16:29:02 -0000 Mailing-List: contact issues-help@nifi.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@nifi.apache.org Delivered-To: mailing list issues@nifi.apache.org Received: (qmail 78209 invoked by uid 99); 10 Jul 2020 16:29:01 -0000 Received: from mailrelay1-us-west.apache.org (HELO mailrelay1-us-west.apache.org) (209.188.14.139) by apache.org (qpsmtpd/0.29) with ESMTP; Fri, 10 Jul 2020 16:29:01 +0000 Received: from jira-he-de.apache.org (static.172.67.40.188.clients.your-server.de [188.40.67.172]) by mailrelay1-us-west.apache.org (ASF Mail Server at mailrelay1-us-west.apache.org) with ESMTP id ED88E41078 for ; Fri, 10 Jul 2020 16:29:00 +0000 (UTC) Received: from jira-he-de.apache.org (localhost.localdomain [127.0.0.1]) by jira-he-de.apache.org (ASF Mail Server at jira-he-de.apache.org) with ESMTP id 3AEE878031B for ; Fri, 10 Jul 2020 16:29:00 +0000 (UTC) Date: Fri, 10 Jul 2020 16:29:00 +0000 (UTC) From: "Peter Turcsanyi (Jira)" To: issues@nifi.apache.org Message-ID: In-Reply-To: References: Subject: [jira] [Comment Edited] (NIFI-6437) a lot of connections from ConsumerAMQP MIME-Version: 1.0 Content-Type: text/plain; charset=utf-8 Content-Transfer-Encoding: quoted-printable X-JIRA-FingerPrint: 30527f35849b9dde25b450d4833f0394 [ https://issues.apache.org/jira/browse/NIFI-6437?page=3Dcom.atlassian.= jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=3D17155= 595#comment-17155595 ]=20 Peter Turcsanyi edited comment on NIFI-6437 at 7/10/20, 4:28 PM: ----------------------------------------------------------------- The non-existing queue problem has been resolved in NIFI-6997. was (Author: turcsanyip): The non-existing queue problem the been resolved in NIFI-6997. > a lot of connections from ConsumerAMQP > -------------------------------------- > > Key: NIFI-6437 > URL: https://issues.apache.org/jira/browse/NIFI-6437 > Project: Apache NiFi > Issue Type: Bug > Components: Core Framework > Affects Versions: 1.9.2 > Reporter: Piotr > Priority: Critical > > hi, when I try to connect to not existing queue on rabbitmq via ConsumerA= MQP, nifi was creating more and more connection to rabbitmq. after few minu= tes rabbitmq "explode". i saw this error in logs: > {code:java} > 2019-07-12 13:20:29,853 INFO [Timer-Driven Process Thread-3] o.a.n.c.s.Ti= merDrivenSchedulingAgent Stopped scheduling ConsumeAMQP[id=3De5e84018-016b-= 1000-edd7-e0de56297dd9] to run > 2019-07-12 13:20:29,856 INFO [Timer-Driven Process Thread-1] o.a.nifi.amq= p.processors.AMQPConsumer Successfully connected AMQPConsumer to amqp://gue= st@172.17.0.4:5672/ and 'test_queue' queue > 2019-07-12 13:20:29,860 ERROR [Timer-Driven Process Thread-1] o.a.nifi.am= qp.processors.ConsumeAMQP ConsumeAMQP[id=3De5e84018-016b-1000-edd7-e0de5629= 7dd9] Failed to process session due to org.apache.nifi.processor.exception.= ProcessException: Failed to connect to AMQP Broker: org.apache.nifi.process= or.exception.ProcessException: Failed to connect to AMQP Broker > org.apache.nifi.processor.exception.ProcessException: Failed to connect t= o AMQP Broker > =C2=A0=C2=A0 =C2=A0at org.apache.nifi.amqp.processors.ConsumeAMQP.createA= MQPWorker(ConsumeAMQP.java:197) > =C2=A0=C2=A0 =C2=A0at org.apache.nifi.amqp.processors.ConsumeAMQP.createA= MQPWorker(ConsumeAMQP.java:47) > =C2=A0=C2=A0 =C2=A0at org.apache.nifi.amqp.processors.AbstractAMQPProcess= or.createResource(AbstractAMQPProcessor.java:202) > =C2=A0=C2=A0 =C2=A0at org.apache.nifi.amqp.processors.AbstractAMQPProcess= or.onTrigger(AbstractAMQPProcessor.java:156) > =C2=A0=C2=A0 =C2=A0at org.apache.nifi.processor.AbstractProcessor.onTrigg= er(AbstractProcessor.java:27) > =C2=A0=C2=A0 =C2=A0at org.apache.nifi.controller.StandardProcessorNode.on= Trigger(StandardProcessorNode.java:1162) > =C2=A0=C2=A0 =C2=A0at org.apache.nifi.controller.tasks.ConnectableTask.in= voke(ConnectableTask.java:209) > =C2=A0=C2=A0 =C2=A0at org.apache.nifi.controller.scheduling.TimerDrivenSc= hedulingAgent$1.run(TimerDrivenSchedulingAgent.java:117) > =C2=A0=C2=A0 =C2=A0at org.apache.nifi.engine.FlowEngine$2.run(FlowEngine.= java:110) > =C2=A0=C2=A0 =C2=A0at java.util.concurrent.Executors$RunnableAdapter.call= (Executors.java:511) > =C2=A0=C2=A0 =C2=A0at java.util.concurrent.FutureTask.runAndReset(FutureT= ask.java:308) > =C2=A0=C2=A0 =C2=A0at java.util.concurrent.ScheduledThreadPoolExecutor$Sc= heduledFutureTask.access$301(ScheduledThreadPoolExecutor.java:180) > =C2=A0=C2=A0 =C2=A0at java.util.concurrent.ScheduledThreadPoolExecutor$Sc= heduledFutureTask.run(ScheduledThreadPoolExecutor.java:294) > =C2=A0=C2=A0 =C2=A0at java.util.concurrent.ThreadPoolExecutor.runWorker(T= hreadPoolExecutor.java:1149) > =C2=A0=C2=A0 =C2=A0at java.util.concurrent.ThreadPoolExecutor$Worker.run(= ThreadPoolExecutor.java:624) > =C2=A0=C2=A0 =C2=A0at java.lang.Thread.run(Thread.java:748) > Caused by: java.io.IOException: null > =C2=A0=C2=A0 =C2=A0at com.rabbitmq.client.impl.AMQChannel.wrap(AMQChannel= .java:126) > =C2=A0=C2=A0 =C2=A0at com.rabbitmq.client.impl.AMQChannel.wrap(AMQChannel= .java:122) > =C2=A0=C2=A0 =C2=A0at com.rabbitmq.client.impl.ChannelN.basicConsume(Chan= nelN.java:1378) > =C2=A0=C2=A0 =C2=A0at com.rabbitmq.client.impl.recovery.AutorecoveringCha= nnel.basicConsume(AutorecoveringChannel.java:540) > =C2=A0=C2=A0 =C2=A0at com.rabbitmq.client.impl.recovery.AutorecoveringCha= nnel.basicConsume(AutorecoveringChannel.java:494) > =C2=A0=C2=A0 =C2=A0at com.rabbitmq.client.impl.recovery.AutorecoveringCha= nnel.basicConsume(AutorecoveringChannel.java:472) > =C2=A0=C2=A0 =C2=A0at org.apache.nifi.amqp.processors.AMQPConsumer.= (AMQPConsumer.java:77) > =C2=A0=C2=A0 =C2=A0at org.apache.nifi.amqp.processors.ConsumeAMQP.createA= MQPWorker(ConsumeAMQP.java:193) > =C2=A0=C2=A0 =C2=A0... 15 common frames omitted > Caused by: com.rabbitmq.client.ShutdownSignalException: channel error; pr= otocol method: #method(reply-code=3D404, reply-text=3DNOT_FO= UND - no queue 'test_queue' in vhost '/', class-id=3D60, method-id=3D20) > =C2=A0=C2=A0 =C2=A0at com.rabbitmq.utility.ValueOrException.getValue(Valu= eOrException.java:66) > =C2=A0=C2=A0 =C2=A0at com.rabbitmq.utility.BlockingValueOrException.unint= erruptibleGetValue(BlockingValueOrException.java:36) > =C2=A0=C2=A0 =C2=A0at com.rabbitmq.client.impl.AMQChannel$BlockingRpcCont= inuation.getReply(AMQChannel.java:494) > =C2=A0=C2=A0 =C2=A0at com.rabbitmq.client.impl.ChannelN.basicConsume(Chan= nelN.java:1372) > =C2=A0=C2=A0 =C2=A0... 20 common frames omitted > Caused by: com.rabbitmq.client.ShutdownSignalException: channel error; pr= otocol method: #method(reply-code=3D404, reply-text=3DNOT_FO= UND - no queue 'test_queue' in vhost '/', class-id=3D60, method-id=3D20) > =C2=A0=C2=A0 =C2=A0at com.rabbitmq.client.impl.ChannelN.asyncShutdown(Cha= nnelN.java:516) > =C2=A0=C2=A0 =C2=A0at com.rabbitmq.client.impl.ChannelN.processAsync(Chan= nelN.java:346) > =C2=A0=C2=A0 =C2=A0at com.rabbitmq.client.impl.AMQChannel.handleCompleteI= nboundCommand(AMQChannel.java:178) > =C2=A0=C2=A0 =C2=A0at com.rabbitmq.client.impl.AMQChannel.handleFrame(AMQ= Channel.java:111) > =C2=A0=C2=A0 =C2=A0at com.rabbitmq.client.impl.AMQConnection.readFrame(AM= QConnection.java:670) > =C2=A0=C2=A0 =C2=A0at com.rabbitmq.client.impl.AMQConnection.access$300(A= MQConnection.java:48) > =C2=A0=C2=A0 =C2=A0at com.rabbitmq.client.impl.AMQConnection$MainLoop.run= (AMQConnection.java:597) > =C2=A0=C2=A0 =C2=A0... 1 common frames omitted{code} -- This message was sent by Atlassian Jira (v8.3.4#803005)