Updated Branches: refs/heads/master 97569d5b4 -> 8322522a5
Updated health stat network_partition_id Project: http://git-wip-us.apache.org/repos/asf/incubator-stratos/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-stratos/commit/f1bddab3 Tree: http://git-wip-us.apache.org/repos/asf/incubator-stratos/tree/f1bddab3 Diff: http://git-wip-us.apache.org/repos/asf/incubator-stratos/diff/f1bddab3 Branch: refs/heads/master Commit: f1bddab377821bc4929c1847c5ba92db89de4c25 Parents: e9b884b Author: Imesh Gunaratne <[email protected]> Authored: Fri Dec 13 13:50:24 2013 +0530 Committer: Imesh Gunaratne <[email protected]> Committed: Fri Dec 13 13:50:24 2013 +0530 ---------------------------------------------------------------------- .../artifacts/event-formatters/FaultMessageEventFormatter.xml | 2 +- .../cep/artifacts/execution-plans/AverageHeathRequest.xml | 6 +++--- 2 files changed, 4 insertions(+), 4 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-stratos/blob/f1bddab3/extensions/cep/artifacts/event-formatters/FaultMessageEventFormatter.xml ---------------------------------------------------------------------- diff --git a/extensions/cep/artifacts/event-formatters/FaultMessageEventFormatter.xml b/extensions/cep/artifacts/event-formatters/FaultMessageEventFormatter.xml index 9d91cef..c594b5a 100644 --- a/extensions/cep/artifacts/event-formatters/FaultMessageEventFormatter.xml +++ b/extensions/cep/artifacts/event-formatters/FaultMessageEventFormatter.xml @@ -3,7 +3,7 @@ statistics="disable" trace="enable" xmlns="http://wso2.org/carbon/eventformatter";> <from streamName="fault_message" version="1.0.0"/> <mapping customMapping="enable" type="json"> - <inline>{"member_fault":{"cluster_id":"{{cluster_id}}","partition_id":"{{partition_id}}","member_id":"{{member_id}}"}}</inline> + <inline>{"member_fault":{"cluster_id":"{{cluster_id}}","network_partition_id":"{{network_partition_id}}","member_id":"{{member_id}}"}}</inline> </mapping> <to eventAdaptorName="JMSOutputAdaptor" eventAdaptorType="jms"> <property name="transport.jms.Destination">summarized-health-stats</property> http://git-wip-us.apache.org/repos/asf/incubator-stratos/blob/f1bddab3/extensions/cep/artifacts/execution-plans/AverageHeathRequest.xml ---------------------------------------------------------------------- diff --git a/extensions/cep/artifacts/execution-plans/AverageHeathRequest.xml b/extensions/cep/artifacts/execution-plans/AverageHeathRequest.xml index 3e33f0b..8849385 100644 --- a/extensions/cep/artifacts/execution-plans/AverageHeathRequest.xml +++ b/extensions/cep/artifacts/execution-plans/AverageHeathRequest.xml @@ -9,9 +9,9 @@ <importedStreams> <stream as="healthStats1" name="cartridge_agent_health_stats" version="1.0.0"/> </importedStreams> - <queryExpressions><![CDATA[from healthStats1 [health_description == 'port_not_open'] select cluster_id,partition_id,member_id insert into fault_message; - from healthStats1 [health_description == 'load_average'] #window.timeBatch(1 min) select cluster_id,partition_id,avg(value) as average_load_average group by cluster_id,partition_id insert into average_load_average_stats; - from healthStats1 [health_description == 'memory_consumption'] #window.timeBatch(1 min) select cluster_id,partition_id,avg(value) as average_memory_consumption group by cluster_id,partition_id insert into average_memory_consumption_stats;]]></queryExpressions> + <queryExpressions><![CDATA[from healthStats1 [health_description == 'port_not_open'] select cluster_id,network_partition_id,member_id insert into fault_message; + from healthStats1 [health_description == 'load_average'] #window.timeBatch(1 min) select cluster_id,network_partition_id,avg(value) as average_load_average group by cluster_id,network_partition_id insert into average_load_average_stats; + from healthStats1 [health_description == 'memory_consumption'] #window.timeBatch(1 min) select cluster_id,network_partition_id,avg(value) as average_memory_consumption group by cluster_id,network_partition_id insert into average_memory_consumption_stats;]]></queryExpressions> <exportedStreams> <stream name="average_load_average_stats" passthroughFlow="disable" valueOf="average_load_average_stats" version="1.0.0"/>
