Return-Path: X-Original-To: apmail-stratos-dev-archive@minotaur.apache.org Delivered-To: apmail-stratos-dev-archive@minotaur.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id 7ED9E10F8B for ; Sat, 11 Jan 2014 17:17:27 +0000 (UTC) Received: (qmail 24586 invoked by uid 500); 11 Jan 2014 17:17:15 -0000 Delivered-To: apmail-stratos-dev-archive@stratos.apache.org Received: (qmail 24552 invoked by uid 500); 11 Jan 2014 17:17:11 -0000 Mailing-List: contact dev-help@stratos.incubator.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@stratos.incubator.apache.org Delivered-To: mailing list dev@stratos.incubator.apache.org Received: (qmail 24530 invoked by uid 99); 11 Jan 2014 17:17:09 -0000 Received: from athena.apache.org (HELO athena.apache.org) (140.211.11.136) by apache.org (qpsmtpd/0.29) with ESMTP; Sat, 11 Jan 2014 17:17:09 +0000 X-ASF-Spam-Status: No, hits=1.7 required=5.0 tests=FREEMAIL_ENVFROM_END_DIGIT,HTML_MESSAGE,RCVD_IN_DNSWL_LOW,SPF_PASS X-Spam-Check-By: apache.org Received-SPF: pass (athena.apache.org: domain of nirmal070125@gmail.com designates 74.125.82.44 as permitted sender) Received: from [74.125.82.44] (HELO mail-wg0-f44.google.com) (74.125.82.44) by apache.org (qpsmtpd/0.29) with ESMTP; Sat, 11 Jan 2014 17:17:06 +0000 Received: by mail-wg0-f44.google.com with SMTP id l18so4213272wgh.11 for ; Sat, 11 Jan 2014 09:16:44 -0800 (PST) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=gmail.com; s=20120113; h=mime-version:in-reply-to:references:date:message-id:subject:from:to :content-type; bh=RzGjY27USKnD2E84hv21MhC5CVVjLAZmDrdDJYLuqHY=; b=Rs5VMj/3T2OYR78sSMbggKK/6wiOHb0i2jE7KV7ViC29Ln1Bz0K+y5QjYklHFMuP5z lJExqZjpAqwg6Z4PQme9cFdu6pEaOQ7Dq66Eg1lg/RG+RkMTTxYVkNtXdadDUn4H71ql XQ2irlL6hfur1PcMCvlWx4BkB2kyfplkaOHPErQtPwJhM0qQagVx9ru83/EATQCzCEHW /l9ZZPAVxeU9SHTp3YhLUXR0fJcJk/TayH8iWPHsjzhS3TB4lbI/HtmHObrTes+cBDSR HZ9H0yj2flP/ry0SH0Bf/U6jRID8OCnm1ip/BcS+/mKoVP3ZqQRRBwE4P8TJctyrmARL DcEA== MIME-Version: 1.0 X-Received: by 10.194.93.3 with SMTP id cq3mr14470299wjb.26.1389460604865; Sat, 11 Jan 2014 09:16:44 -0800 (PST) Received: by 10.194.76.197 with HTTP; Sat, 11 Jan 2014 09:16:44 -0800 (PST) In-Reply-To: References: Date: Sat, 11 Jan 2014 22:46:44 +0530 Message-ID: Subject: Re: CEP seems to be emiting stats even though there are no incoming requests... From: Nirmal Fernando To: "dev@stratos.incubator.apache.org" Content-Type: multipart/alternative; boundary=047d7bb04822c8540d04efb50173 X-Virus-Checked: Checked by ClamAV on apache.org --047d7bb04822c8540d04efb50173 Content-Type: text/plain; charset=ISO-8859-1 There's a possibility that CEP would emit an event in this scenario (since CEP aggregates events came in a specific time period). This cannot be solved at CEP end, I think the solution would be to discard events that are not relevant at Auto-scaler end. Wdyt? On Sat, Jan 11, 2014 at 10:11 PM, Lahiru Sandaruwan wrote: > $subject. > > For e.g. there is no instances in the cluster > "lahiru123.isuruh.lk.php.domain " since the user has unsubscribed. > But Autoscaler has received a stat event [1].. > > [1] > TID: [0] [Agent] [2014-01-11 16:34:39,696] ERROR > {org.apache.stratos.autoscaler.message.receiver.health.AutoscalerHealthStatReceiver} > - A cluster monitor is not found in autoscaler context [cluster] > lahiru123.isuruh.lk.php.domain > {org.apache.stratos.autoscaler.message.receiver.health.AutoscalerHealthStatReceiver} > TID: [0] [Agent] [2014-01-11 16:34:39,696] ERROR > {org.apache.stratos.messaging.message.receiver.health.stat.HealthStatEventMessageDelegator} > - Failed to retrieve instance notifier event message > {org.apache.stratos.messaging.message.receiver.health.stat.HealthStatEventMessageDelegator} > java.lang.RuntimeException: A monitor is not found for this cluster > at > org.apache.stratos.autoscaler.message.receiver.health.AutoscalerHealthStatReceiver.handleMemberFaultEvent(AutoscalerHealthStatReceiver.java:1084) > at > org.apache.stratos.autoscaler.message.receiver.health.AutoscalerHealthStatReceiver.access$300(AutoscalerHealthStatReceiver.java:49) > at > org.apache.stratos.autoscaler.message.receiver.health.AutoscalerHealthStatReceiver$9.onEvent(AutoscalerHealthStatReceiver.java:753) > at > org.apache.stratos.messaging.listener.EventListener.update(EventListener.java:42) > at java.util.Observable.notifyObservers(Observable.java:142) > at > org.apache.stratos.messaging.event.EventObservable.notifyEventListeners(EventObservable.java:51) > at > org.apache.stratos.messaging.message.processor.health.stat.MemberFaultMessageProcessor.process(MemberFaultMessageProcessor.java:50) > at > org.apache.stratos.messaging.message.processor.health.stat.SecondDerivativeOfMemoryConsumptionMessageProcessor.process(SecondDerivativeOfMemoryConsumptionMessageProcessor.java:59) > at > org.apache.stratos.messaging.message.processor.health.stat.GradientOfMemoryConsumptionMessageProcessor.process(GradientOfMemoryConsumptionMessageProcessor.java:58) > at > org.apache.stratos.messaging.message.processor.health.stat.AverageMemoryConsumptionMessageProcessor.process(AverageMemoryConsumptionMessageProcessor.java:59) > at > org.apache.stratos.messaging.message.processor.health.stat.SecondDerivativeOfLoadAverageMessageProcessor.process(SecondDerivativeOfLoadAverageMessageProcessor.java:59) > at > org.apache.stratos.messaging.message.processor.health.stat.GradientOfLoadAverageMessageProcessor.process(GradientOfLoadAverageMessageProcessor.java:59) > at > org.apache.stratos.messaging.message.processor.health.stat.AverageLoadAverageMessageProcessor.process(AverageLoadAverageMessageProcessor.java:59) > at > org.apache.stratos.messaging.message.processor.health.stat.SecondDerivativeOfRequestsInFlightMessageProcessor.process(SecondDerivativeOfRequestsInFlightMessageProcessor.java:59) > at > org.apache.stratos.messaging.message.processor.health.stat.GradientOfRequestsInFlightMessageProcessor.process(GradientOfRequestsInFlightMessageProcessor.java:59) > at > org.apache.stratos.messaging.message.processor.health.stat.AverageRequestsInFlightMessageProcessor.process(AverageRequestsInFlightMessageProcessor.java:59) > at > org.apache.stratos.messaging.message.processor.health.stat.MemberSecondDerivativeOfMemoryConsumptionMessageProcessor.process(MemberSecondDerivativeOfMemoryConsumptionMessageProcessor.java:59) > at > org.apache.stratos.messaging.message.processor.health.stat.MemberGradientOfMemoryConsumptionMessageProcessor.process(MemberGradientOfMemoryConsumptionMessageProcessor.java:60) > at > org.apache.stratos.messaging.message.processor.health.stat.MemberAverageMemoryConsumptionMessageProcessor.process(MemberAverageMemoryConsumptionMessageProcessor.java:59) > at > org.apache.stratos.messaging.message.processor.health.stat.MemberSecondDerivativeOfLoadAverageMessageProcessor.process(MemberSecondDerivativeOfLoadAverageMessageProcessor.java:59) > at > org.apache.stratos.messaging.message.processor.health.stat.MemberGradientOfLoadAverageMessageProcessor.process(MemberGradientOfLoadAverageMessageProcessor.java:59) > at > org.apache.stratos.messaging.message.processor.health.stat.MemberAverageLoadAverageMessageProcessor.process(MemberAverageLoadAverageMessageProcessor.java:59) > at > org.apache.stratos.messaging.message.processor.MessageProcessorChain.process(MessageProcessorChain.java:60) > at > org.apache.stratos.messaging.message.receiver.health.stat.HealthStatEventMessageDelegator.run(HealthStatEventMessageDelegator.java:79) > at java.lang.Thread.run(Thread.java:662) > > > -- > -- > Lahiru Sandaruwan > Software Engineer, > Platform Technologies, > WSO2 Inc., http://wso2.com > lean.enterprise.middleware > > email: lahirus@wso2.com cell: (+94) 773 325 954 > blog: http://lahiruwrites.blogspot.com/ > twitter: http://twitter.com/lahirus > linked-in: http://lk.linkedin.com/pub/lahiru-sandaruwan/16/153/146 > > -- Best Regards, Nirmal Nirmal Fernando. PPMC Member & Committer of Apache Stratos, Senior Software Engineer, WSO2 Inc. Blog: http://nirmalfdo.blogspot.com/ --047d7bb04822c8540d04efb50173 Content-Type: text/html; charset=ISO-8859-1 Content-Transfer-Encoding: quoted-printable
There's a possibility that CEP would emit an event in = this scenario (since CEP aggregates events came in a specific time period).= This cannot be solved at CEP end, I think the solution would be to discard= events that are not relevant at Auto-scaler end. Wdyt?


On Sat,= Jan 11, 2014 at 10:11 PM, Lahiru Sandaruwan <lahirus@wso2.com> wrote:
$subject.=A0

=
For e.g. there is no instances in the cluster "lahiru123.isuruh.l= k.php.domain=A0" since the user has unsubscribed.
But Autoscaler has received a stat event [1]..

[1]
TID: [0] [Agent] [2014-01-11 16= :34:39,696] ERROR {org.apache.stratos.autoscaler.message.receiver.health.Au= toscalerHealthStatReceiver} - =A0A cluster monitor is not found in autoscal= er context [cluster] lahiru123.isuruh.lk.php.domain {org.apache.stratos.aut= oscaler.message.receiver.health.AutoscalerHealthStatReceiver}
TID: [0] [Agent] [2014-01-11 16:34:39,696] ERROR {org.apache.stratos.m= essaging.message.receiver.health.stat.HealthStatEventMessageDelegator} - = =A0Failed to retrieve instance notifier event message {org.apache.stratos.m= essaging.message.receiver.health.stat.HealthStatEventMessageDelegator}
java.lang.RuntimeException: A monitor is not found for this cluster
at org.apache.stratos.= autoscaler.message.receiver.health.AutoscalerHealthStatReceiver.handleMembe= rFaultEvent(AutoscalerHealthStatReceiver.java:1084)
at org.apache.stratos.aut= oscaler.message.receiver.health.AutoscalerHealthStatReceiver.access$300(Aut= oscalerHealthStatReceiver.java:49)
at org.apache.stratos.autoscaler.message.receiver.health.Aut= oscalerHealthStatReceiver$9.onEvent(AutoscalerHealthStatReceiver.java:753)<= /div>
at org.apache.stratos.mes= saging.listener.EventListener.update(EventListener.java:42)
at java.util.Observable.notifyObser= vers(Observable.java:142)
at org.apache.stratos.mes= saging.event.EventObservable.notifyEventListeners(EventObservable.java:51)<= /div>
at org.apache.strato= s.messaging.message.processor.health.stat.MemberFaultMessageProcessor.proce= ss(MemberFaultMessageProcessor.java:50)
at org.apache.stratos.mes= saging.message.processor.health.stat.SecondDerivativeOfMemoryConsumptionMes= sageProcessor.process(SecondDerivativeOfMemoryConsumptionMessageProcessor.j= ava:59)
at org.apache.stratos.mes= saging.message.processor.health.stat.GradientOfMemoryConsumptionMessageProc= essor.process(GradientOfMemoryConsumptionMessageProcessor.java:58)
at org.apache.stratos.mes= saging.message.processor.health.stat.AverageMemoryConsumptionMessageProcess= or.process(AverageMemoryConsumptionMessageProcessor.java:59)
at org.apache.stratos.messagin= g.message.processor.health.stat.SecondDerivativeOfLoadAverageMessageProcess= or.process(SecondDerivativeOfLoadAverageMessageProcessor.java:59)
at org.apache.stratos.mes= saging.message.processor.health.stat.GradientOfLoadAverageMessageProcessor.= process(GradientOfLoadAverageMessageProcessor.java:59)
at org.apache.stratos.messaging.message.= processor.health.stat.AverageLoadAverageMessageProcessor.process(AverageLoa= dAverageMessageProcessor.java:59)
at org.apache.stratos.mes= saging.message.processor.health.stat.SecondDerivativeOfRequestsInFlightMess= ageProcessor.process(SecondDerivativeOfRequestsInFlightMessageProcessor.jav= a:59)
at org.apache.stratos.mes= saging.message.processor.health.stat.GradientOfRequestsInFlightMessageProce= ssor.process(GradientOfRequestsInFlightMessageProcessor.java:59)
at org.apache.stratos.mes= saging.message.processor.health.stat.AverageRequestsInFlightMessageProcesso= r.process(AverageRequestsInFlightMessageProcessor.java:59)
at org.apache.stratos.messagin= g.message.processor.health.stat.MemberSecondDerivativeOfMemoryConsumptionMe= ssageProcessor.process(MemberSecondDerivativeOfMemoryConsumptionMessageProc= essor.java:59)
at org.apache.stratos.mes= saging.message.processor.health.stat.MemberGradientOfMemoryConsumptionMessa= geProcessor.process(MemberGradientOfMemoryConsumptionMessageProcessor.java:= 60)
at org.apache.stratos.mes= saging.message.processor.health.stat.MemberAverageMemoryConsumptionMessageP= rocessor.process(MemberAverageMemoryConsumptionMessageProcessor.java:59)
at org.apache.stratos.mes= saging.message.processor.health.stat.MemberSecondDerivativeOfLoadAverageMes= sageProcessor.process(MemberSecondDerivativeOfLoadAverageMessageProcessor.j= ava:59)
at org.apache.stratos.mes= saging.message.processor.health.stat.MemberGradientOfLoadAverageMessageProc= essor.process(MemberGradientOfLoadAverageMessageProcessor.java:59)
at org.apache.stratos.mes= saging.message.processor.health.stat.MemberAverageLoadAverageMessageProcess= or.process(MemberAverageLoadAverageMessageProcessor.java:59)
at org.apache.stratos.messagin= g.message.processor.MessageProcessorChain.process(MessageProcessorChain.jav= a:60)
at org.apache.= stratos.messaging.message.receiver.health.stat.HealthStatEventMessageDelega= tor.run(HealthStatEventMessageDelegator.java:79)
at java.lang.Thread.run(T= hread.java:662)

--
--
Lahiru Sandaruwan
Software Engineer,
Platform Technologies,
WSO2 Inc., http://wso2.com
lean.enterprise.middleware

email: lahirus@wso2.com cel= l: (+94) 773 325 954
blog: http:= //lahiruwrites.blogspot.com/
twitter: http://twitter.com/lahirus
linked-in: http://lk.linkedin.com/pub/lahiru-sandaruwan/16/153/146<= div>



--
Best R= egards,
Nirmal

Nirmal Fernando.
PPMC Member & Committer of= Apache Stratos,
Senior Software Engineer, WSO2 Inc.

--047d7bb04822c8540d04efb50173--