eagle-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From h..@apache.org
Subject [30/84] [partial] eagle git commit: Clean repo for eagle site
Date Mon, 03 Apr 2017 11:54:38 GMT
http://git-wip-us.apache.org/repos/asf/eagle/blob/6fd95d5c/eagle-core/eagle-alert-parent/eagle-alert/alert-coordinator/src/test/java/org/apache/alert/coordinator/mock/TestTopologyMgmtService.java
----------------------------------------------------------------------
diff --git a/eagle-core/eagle-alert-parent/eagle-alert/alert-coordinator/src/test/java/org/apache/alert/coordinator/mock/TestTopologyMgmtService.java b/eagle-core/eagle-alert-parent/eagle-alert/alert-coordinator/src/test/java/org/apache/alert/coordinator/mock/TestTopologyMgmtService.java
deleted file mode 100644
index 80990a5..0000000
--- a/eagle-core/eagle-alert-parent/eagle-alert/alert-coordinator/src/test/java/org/apache/alert/coordinator/mock/TestTopologyMgmtService.java
+++ /dev/null
@@ -1,100 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements.  See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License.  You may obtain a copy of the License at
- *
- *    http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-package org.apache.alert.coordinator.mock;
-
-import java.util.List;
-
-import org.apache.commons.lang3.tuple.Pair;
-import org.apache.eagle.alert.coordination.model.internal.Topology;
-import org.apache.eagle.alert.coordinator.TopologyMgmtService;
-import org.apache.eagle.alert.coordinator.model.AlertBoltUsage;
-import org.apache.eagle.alert.coordinator.model.GroupBoltUsage;
-import org.apache.eagle.alert.coordinator.model.TopologyUsage;
-
-@org.junit.Ignore
-public class TestTopologyMgmtService extends TopologyMgmtService {
-
-    public static final int ROUTER_BOLT_NUMBER = 6;
-    public static final int BOLT_NUMBER = 7;
-
-    private int boltNumber;
-    private int routerNumber;
-    private int i = 0;
-    private String namePrefix = "Topology";
-
-    // a config used to check if createTopology is enabled. FIXME: another class of mgmt service might be better
-    private boolean enableCreateTopology = false;
-
-    public TestTopologyMgmtService() {
-        boltNumber = BOLT_NUMBER;// default behaivor
-        this.routerNumber = ROUTER_BOLT_NUMBER;
-    }
-
-    public TestTopologyMgmtService(int routerNumber, int boltNumber) {
-        this.routerNumber = routerNumber;
-        this.boltNumber = boltNumber;
-    }
-
-    public TestTopologyMgmtService(int routerNumber, int boltNumber, String prefix, boolean enable) {
-        this.routerNumber = routerNumber;
-        this.boltNumber = boltNumber;
-        this.namePrefix = prefix;
-        this.enableCreateTopology = enable;
-    }
-
-    @Override
-    public TopologyMeta creatTopology() {
-        if (enableCreateTopology) {
-            TopologyMeta tm = new TopologyMeta();
-            tm.topologyId = namePrefix + (i++);
-            tm.clusterId = "default-cluster";
-            tm.nimbusHost = "localhost";
-            tm.nimbusPort = "3000";
-            Pair<Topology, TopologyUsage> pair = createEmptyTopology(tm.topologyId);
-            tm.topology = pair.getLeft();
-            tm.usage = pair.getRight();
-            return tm;
-        } else {
-            throw new UnsupportedOperationException("not supported yet!");
-        }
-    }
-
-    @Override
-    public List<TopologyMeta> listTopologies() {
-        return super.listTopologies();
-    }
-
-    public Pair<Topology, TopologyUsage> createEmptyTopology(String topoName) {
-        Topology t = new Topology(topoName, routerNumber, boltNumber);
-        for (int i = 0; i < t.getNumOfGroupBolt(); i++) {
-            t.getGroupNodeIds().add(t.getName() + "-grp-" + i);
-        }
-        for (int i = 0; i < t.getNumOfAlertBolt(); i++) {
-            t.getAlertBoltIds().add(t.getName() + "-alert-" + i);
-        }
-
-        TopologyUsage u = new TopologyUsage(topoName);
-        for (String gnid : t.getGroupNodeIds()) {
-            u.getGroupUsages().put(gnid, new GroupBoltUsage(gnid));
-        }
-        for (String anid : t.getAlertBoltIds()) {
-            u.getAlertUsages().put(anid, new AlertBoltUsage(anid));
-        }
-
-        return Pair.of(t, u);
-    }
-}
\ No newline at end of file

http://git-wip-us.apache.org/repos/asf/eagle/blob/6fd95d5c/eagle-core/eagle-alert-parent/eagle-alert/alert-coordinator/src/test/resources/application-multiplestreams.conf
----------------------------------------------------------------------
diff --git a/eagle-core/eagle-alert-parent/eagle-alert/alert-coordinator/src/test/resources/application-multiplestreams.conf b/eagle-core/eagle-alert-parent/eagle-alert/alert-coordinator/src/test/resources/application-multiplestreams.conf
deleted file mode 100644
index 9389d9b..0000000
--- a/eagle-core/eagle-alert-parent/eagle-alert/alert-coordinator/src/test/resources/application-multiplestreams.conf
+++ /dev/null
@@ -1,53 +0,0 @@
-# Licensed to the Apache Software Foundation (ASF) under one or more
-# contributor license agreements.  See the NOTICE file distributed with
-# this work for additional information regarding copyright ownership.
-# The ASF licenses this file to You under the Apache License, Version 2.0
-# (the "License"); you may not use this file except in compliance with
-# the License.  You may obtain a copy of the License at
-#
-#    http://www.apache.org/licenses/LICENSE-2.0
-#
-# Unless required by applicable law or agreed to in writing, software
-# distributed under the License is distributed on an "AS IS" BASIS,
-# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-# See the License for the specific language governing permissions and
-# limitations under the License.
-
-{
-  "coordinator": {
-    "policiesPerBolt": 5,
-    "boltParallelism": 5,
-    "policyDefaultParallelism": 5,
-    "boltLoadUpbound": 0.8,
-    "topologyLoadUpbound": 0.8,
-    "numOfAlertBoltsPerTopology": 5,
-    "reuseBoltInStreams": true,
-    "streamsPerBolt": 2,
-    "zkConfig": {
-      "zkQuorum": "localhost:2181",
-      "zkRoot": "/alert",
-      "zkSessionTimeoutMs": 10000,
-      "connectionTimeoutMs": 10000,
-      "zkRetryTimes": 3,
-      "zkRetryInterval": 3000
-    }
-    "metadataService": {
-      "host": "localhost",
-      "port": 8080,
-      "context": "/rest"
-    }
-    "metadataDynamicCheck": {
-      "initDelayMillis": 1000,
-      "delayMillis": 30000
-    },
-    "kafkaProducer": {
-      "bootstrapServers": "localhost:9092"
-    },
-    "email": {
-      "sender": "eagle@eagle.com",
-      "recipients": "test@eagle.com",
-      "mailSmtpHost": "test.eagle.com",
-      "mailSmtpPort": "25"
-    }
-  }
-}
\ No newline at end of file

http://git-wip-us.apache.org/repos/asf/eagle/blob/6fd95d5c/eagle-core/eagle-alert-parent/eagle-alert/alert-coordinator/src/test/resources/application-multiplestreams2.conf
----------------------------------------------------------------------
diff --git a/eagle-core/eagle-alert-parent/eagle-alert/alert-coordinator/src/test/resources/application-multiplestreams2.conf b/eagle-core/eagle-alert-parent/eagle-alert/alert-coordinator/src/test/resources/application-multiplestreams2.conf
deleted file mode 100644
index d75ccc4..0000000
--- a/eagle-core/eagle-alert-parent/eagle-alert/alert-coordinator/src/test/resources/application-multiplestreams2.conf
+++ /dev/null
@@ -1,52 +0,0 @@
-# Licensed to the Apache Software Foundation (ASF) under one or more
-# contributor license agreements.  See the NOTICE file distributed with
-# this work for additional information regarding copyright ownership.
-# The ASF licenses this file to You under the Apache License, Version 2.0
-# (the "License"); you may not use this file except in compliance with
-# the License.  You may obtain a copy of the License at
-#
-#    http://www.apache.org/licenses/LICENSE-2.0
-#
-# Unless required by applicable law or agreed to in writing, software
-# distributed under the License is distributed on an "AS IS" BASIS,
-# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-# See the License for the specific language governing permissions and
-# limitations under the License.
-
-{
-  "coordinator": {
-    "policiesPerBolt": 5,
-    "boltParallelism": 5,
-    "policyDefaultParallelism": 5,
-    "boltLoadUpbound": 0.8,
-    "topologyLoadUpbound": 0.8,
-    "numOfAlertBoltsPerTopology": 5,
-    "streamsPerBolt": 5,
-    "zkConfig": {
-      "zkQuorum": "localhost:2181",
-      "zkRoot": "/alert",
-      "zkSessionTimeoutMs": 10000,
-      "connectionTimeoutMs": 10000,
-      "zkRetryTimes": 3,
-      "zkRetryInterval": 3000
-    }
-    "metadataService": {
-      "host": "localhost",
-      "port": 8080,
-      "context": "/rest"
-    }
-    "metadataDynamicCheck": {
-      "initDelayMillis": 1000,
-      "delayMillis": 30000
-    },
-    "kafkaProducer": {
-      "bootstrapServers": "localhost:9092"
-    },
-    "email": {
-      "sender": "eagle@eagle.com",
-      "recipients": "test@eagle.com",
-      "mailSmtpHost": "test.eagle.com",
-      "mailSmtpPort": "25"
-    }
-  }
-}
\ No newline at end of file

http://git-wip-us.apache.org/repos/asf/eagle/blob/6fd95d5c/eagle-core/eagle-alert-parent/eagle-alert/alert-coordinator/src/test/resources/application.conf
----------------------------------------------------------------------
diff --git a/eagle-core/eagle-alert-parent/eagle-alert/alert-coordinator/src/test/resources/application.conf b/eagle-core/eagle-alert-parent/eagle-alert/alert-coordinator/src/test/resources/application.conf
deleted file mode 100644
index 5d4da38..0000000
--- a/eagle-core/eagle-alert-parent/eagle-alert/alert-coordinator/src/test/resources/application.conf
+++ /dev/null
@@ -1,58 +0,0 @@
-# Licensed to the Apache Software Foundation (ASF) under one or more
-# contributor license agreements.  See the NOTICE file distributed with
-# this work for additional information regarding copyright ownership.
-# The ASF licenses this file to You under the Apache License, Version 2.0
-# (the "License"); you may not use this file except in compliance with
-# the License.  You may obtain a copy of the License at
-#
-#    http://www.apache.org/licenses/LICENSE-2.0
-#
-# Unless required by applicable law or agreed to in writing, software
-# distributed under the License is distributed on an "AS IS" BASIS,
-# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-# See the License for the specific language governing permissions and
-# limitations under the License.
-
-{
-  "coordinator": {
-    "policiesPerBolt": 5,
-    "boltParallelism": 5,
-    "policyDefaultParallelism": 5,
-    "boltLoadUpbound": 0.8,
-    "topologyLoadUpbound": 0.8,
-    "numOfAlertBoltsPerTopology": 5,
-    "zkConfig": {
-      "zkQuorum": "localhost:2181",
-      "zkRoot": "/alert",
-      "zkSessionTimeoutMs": 10000,
-      "connectionTimeoutMs": 10000,
-      "zkRetryTimes": 3,
-      "zkRetryInterval": 3000
-    }
-    "metadataService": {
-      "host": "localhost",
-      "port": 8080,
-      "context": "/rest",
-      mailSmtpServer = "localhost",
-      mailSmtpPort = 25,
-      mailSmtpAuth = "false"
-      //mailSmtpConn = "plaintext",
-      //mailSmtpUsername = ""
-      //mailSmtpPassword = ""
-      //mailSmtpDebug = false
-    }
-    "metadataDynamicCheck": {
-      "initDelayMillis": 1000,
-      "delayMillis": 30000
-    },
-    "kafkaProducer": {
-      "bootstrapServers": "localhost:9092"
-    },
-    "email": {
-      "sender": "eagle@eagle.com",
-      "recipients": "test@eagle.com",
-      "mailSmtpHost": "test.eagle.com",
-      "mailSmtpPort": "25"
-    }
-  }
-}
\ No newline at end of file

http://git-wip-us.apache.org/repos/asf/eagle/blob/6fd95d5c/eagle-core/eagle-alert-parent/eagle-alert/alert-coordinator/src/test/resources/log4j.properties
----------------------------------------------------------------------
diff --git a/eagle-core/eagle-alert-parent/eagle-alert/alert-coordinator/src/test/resources/log4j.properties b/eagle-core/eagle-alert-parent/eagle-alert/alert-coordinator/src/test/resources/log4j.properties
deleted file mode 100644
index 53f091e..0000000
--- a/eagle-core/eagle-alert-parent/eagle-alert/alert-coordinator/src/test/resources/log4j.properties
+++ /dev/null
@@ -1,19 +0,0 @@
-# Licensed to the Apache Software Foundation (ASF) under one or more
-# contributor license agreements.  See the NOTICE file distributed with
-# this work for additional information regarding copyright ownership.
-# The ASF licenses this file to You under the Apache License, Version 2.0
-# (the "License"); you may not use this file except in compliance with
-# the License.  You may obtain a copy of the License at
-#
-#    http://www.apache.org/licenses/LICENSE-2.0
-#
-# Unless required by applicable law or agreed to in writing, software
-# distributed under the License is distributed on an "AS IS" BASIS,
-# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-# See the License for the specific language governing permissions and
-# limitations under the License.
-log4j.rootLogger=INFO, stdout
-# standard output
-log4j.appender.stdout=org.apache.log4j.ConsoleAppender
-log4j.appender.stdout.layout=org.apache.log4j.PatternLayout
-log4j.appender.stdout.layout.ConversionPattern=%d{ISO8601} %p [%t] %c{2}[%L]: %m%n

http://git-wip-us.apache.org/repos/asf/eagle/blob/6fd95d5c/eagle-core/eagle-alert-parent/eagle-alert/alert-coordinator/src/test/resources/multi/datasources.json
----------------------------------------------------------------------
diff --git a/eagle-core/eagle-alert-parent/eagle-alert/alert-coordinator/src/test/resources/multi/datasources.json b/eagle-core/eagle-alert-parent/eagle-alert/alert-coordinator/src/test/resources/multi/datasources.json
deleted file mode 100644
index ef697f8..0000000
--- a/eagle-core/eagle-alert-parent/eagle-alert/alert-coordinator/src/test/resources/multi/datasources.json
+++ /dev/null
@@ -1,19 +0,0 @@
-[
-  {
-    "name": "network_syslog_datasource",
-    "type": "KAFKA",
-    "properties": {
-    },
-    "topic": "logoutput",
-    "schemeCls": "org.apache.eagle.alert.engine.extension.SherlockEventScheme",
-    "codec": {
-      "streamNameSelectorProp": {
-        "fieldNamesToInferStreamName": "namespace",
-        "streamNameFormat": "stream_%s"
-      },
-      "streamNameSelectorCls": "org.apache.eagle.alert.engine.scheme.JsonStringStreamNameSelector",
-      "timestampColumn": null,
-      "timestampFormat": ""
-    }
-  }
-]

http://git-wip-us.apache.org/repos/asf/eagle/blob/6fd95d5c/eagle-core/eagle-alert-parent/eagle-alert/alert-coordinator/src/test/resources/multi/policies.json
----------------------------------------------------------------------
diff --git a/eagle-core/eagle-alert-parent/eagle-alert/alert-coordinator/src/test/resources/multi/policies.json b/eagle-core/eagle-alert-parent/eagle-alert/alert-coordinator/src/test/resources/multi/policies.json
deleted file mode 100644
index ba7d120..0000000
--- a/eagle-core/eagle-alert-parent/eagle-alert/alert-coordinator/src/test/resources/multi/policies.json
+++ /dev/null
@@ -1,52 +0,0 @@
-[
-  {
-    "name": "syslog_severity_check_stream_demons1",
-    "description": "syslog demons1",
-    "inputStreams": [
-      "stream_demons1"
-    ],
-    "outputStreams": [
-      "syslog_severity_check_output"
-    ],
-    "definition": {
-      "type": "siddhi",
-      "value": "from syslog_stream[dims_severity == \"NOTICE\"] select 'alert' as name, namespace, epochMillis, timestamp, interface,state,version,type,origmsg, dims_severity, dims_facility, dims_hostname, dims_msgid insert into syslog_severity_check_output;"
-    },
-    "partitionSpec": [
-      {
-        "streamId": "stream_demons1",
-        "type": "GROUPBY",
-        "columns": [
-          "dims_hostname"
-        ],
-        "sortSpec": null
-      }
-    ],
-    "parallelismHint": 5
-  },
-  {
-    "name": "syslog_severity_check_stream_umpns2",
-    "description": "syslog umpn2",
-    "inputStreams": [
-      "stream_umpns2"
-    ],
-    "outputStreams": [
-      "syslog_severity_check_output"
-    ],
-    "definition": {
-      "type": "siddhi",
-      "value": "from syslog_stream[dims_severity == \"NOTICE\"] select 'alert' as name, namespace, epochMillis, program, message,  dims_severity, dims_facility, dims_hostname, dims_msgid  insert into syslog_severity_check_output;"
-    },
-    "partitionSpec": [
-      {
-        "streamId": "stream_umpns2",
-        "type": "GROUPBY",
-        "columns": [
-          "dims_hostname"
-        ],
-        "sortSpec": null
-      }
-    ],
-    "parallelismHint": 5
-  }
-]

http://git-wip-us.apache.org/repos/asf/eagle/blob/6fd95d5c/eagle-core/eagle-alert-parent/eagle-alert/alert-coordinator/src/test/resources/multi/publishments.json
----------------------------------------------------------------------
diff --git a/eagle-core/eagle-alert-parent/eagle-alert/alert-coordinator/src/test/resources/multi/publishments.json b/eagle-core/eagle-alert-parent/eagle-alert/alert-coordinator/src/test/resources/multi/publishments.json
deleted file mode 100644
index 9e8b0d3..0000000
--- a/eagle-core/eagle-alert-parent/eagle-alert/alert-coordinator/src/test/resources/multi/publishments.json
+++ /dev/null
@@ -1,32 +0,0 @@
-[
-  {
-    "type": "org.apache.eagle.alert.engine.publisher.impl.AlertKafkaPublisher",
-    "name": "network-syslog-publish",
-    "policyIds": [
-      "syslog_severity_check_stream_demons1",
-      "syslog_severity_check_stream_umpns2"
-    ],
-    "dedupIntervalMin": "PT0M",
-    "properties": {
-      "kafka_broker": "127.0.0.1:9092",
-      "topic": "syslog_alerts",
-      "value_deserializer": "org.apache.kafka.common.serialization.ByteArrayDeserializer",
-      "value_serializer": "org.apache.kafka.common.serialization.ByteArraySerializer"
-    },
-    "serializer": "org.apache.eagle.alert.engine.extension.SherlockAlertSerializer"
-  },
-  {
-    "type": "org.apache.eagle.alert.engine.publisher.impl.AlertKafkaPublisher",
-    "name": "network-syslog-publish_rawjson",
-    "policyIds": [
-      "syslog_severity_check_stream_demons1",
-      "syslog_severity_check_stream_umpns2"
-    ],
-    "dedupIntervalMin": "PT0M",
-    "properties": {
-      "kafka_broker": "127.0.0.1:9092",
-      "topic": "syslog_alerts_json"
-    },
-    "serializer": "org.apache.eagle.alert.engine.publisher.impl.JsonEventSerializer"
-  }
-]
\ No newline at end of file

http://git-wip-us.apache.org/repos/asf/eagle/blob/6fd95d5c/eagle-core/eagle-alert-parent/eagle-alert/alert-coordinator/src/test/resources/multi/streamdefinitions.json
----------------------------------------------------------------------
diff --git a/eagle-core/eagle-alert-parent/eagle-alert/alert-coordinator/src/test/resources/multi/streamdefinitions.json b/eagle-core/eagle-alert-parent/eagle-alert/alert-coordinator/src/test/resources/multi/streamdefinitions.json
deleted file mode 100644
index a4ecb79..0000000
--- a/eagle-core/eagle-alert-parent/eagle-alert/alert-coordinator/src/test/resources/multi/streamdefinitions.json
+++ /dev/null
@@ -1,152 +0,0 @@
-[
-  {
-    "streamId": "stream_demons1",
-    "dataSource": "network_syslog_datasource",
-    "description": "the data stream for syslog events",
-    "validate": false,
-    "timeseries": false,
-    "columns": [
-      {
-        "name": "dims_facility",
-        "type": "STRING",
-        "defaultValue": "",
-        "required": true
-      },
-      {
-        "name": "dims_severity",
-        "type": "STRING",
-        "defaultValue": "",
-        "required": true
-      },
-      {
-        "name": "dims_hostname",
-        "type": "STRING",
-        "defaultValue": "",
-        "required": true
-      },
-      {
-        "name": "dims_msgid",
-        "type": "STRING",
-        "defaultValue": "",
-        "required": true
-      },
-      {
-        "name": "timestamp",
-        "type": "STRING",
-        "defaultValue": "",
-        "required": true
-      },
-      {
-        "name": "state",
-        "type": "STRING",
-        "defaultValue": "",
-        "required": true
-      },
-      {
-        "name": "interface",
-        "type": "STRING",
-        "defaultValue": "",
-        "required": true
-      },
-      {
-        "name": "version",
-        "type": "STRING",
-        "defaultValue": "",
-        "required": true
-      },
-      {
-        "name": "type",
-        "type": "STRING",
-        "defaultValue": "",
-        "required": true
-      },
-      {
-        "name": "origmsg",
-        "type": "STRING",
-        "defaultValue": "",
-        "required": true
-      },
-      {
-        "name": "name",
-        "type": "STRING",
-        "defaultValue": "",
-        "required": true
-      },
-      {
-        "name": "namespace",
-        "type": "STRING",
-        "defaultValue": "",
-        "required": true
-      },
-      {
-        "name": "epochMillis",
-        "type": "LONG",
-        "defaultValue": 0,
-        "required": true
-      }
-    ]
-  },
-  {
-    "streamId": "stream_umpns2",
-    "dataSource": "network_syslog_datasource",
-    "description": "the data stream for syslog events",
-    "validate": false,
-    "timeseries": false,
-    "columns": [
-      {
-        "name": "dims_facility",
-        "type": "STRING",
-        "defaultValue": "",
-        "required": true
-      },
-      {
-        "name": "dims_severity",
-        "type": "STRING",
-        "defaultValue": "",
-        "required": true
-      },
-      {
-        "name": "dims_hostname",
-        "type": "STRING",
-        "defaultValue": "",
-        "required": true
-      },
-      {
-        "name": "dims_msgid",
-        "type": "STRING",
-        "defaultValue": "",
-        "required": true
-      },
-      {
-        "name": "program",
-        "type": "STRING",
-        "defaultValue": "",
-        "required": true
-      },
-      {
-        "name": "message",
-        "type": "STRING",
-        "defaultValue": "",
-        "required": true
-      },
-      {
-        "name": "name",
-        "type": "STRING",
-        "defaultValue": "",
-        "required": true
-      },
-      {
-        "name": "namespace",
-        "type": "STRING",
-        "defaultValue": "",
-        "required": true
-      },
-      {
-        "name": "epochMillis",
-        "type": "LONG",
-        "defaultValue": 0,
-        "required": true
-      }
-    ]
-  }
-]
\ No newline at end of file

http://git-wip-us.apache.org/repos/asf/eagle/blob/6fd95d5c/eagle-core/eagle-alert-parent/eagle-alert/alert-coordinator/src/test/resources/multi/topologies.json
----------------------------------------------------------------------
diff --git a/eagle-core/eagle-alert-parent/eagle-alert/alert-coordinator/src/test/resources/multi/topologies.json b/eagle-core/eagle-alert-parent/eagle-alert/alert-coordinator/src/test/resources/multi/topologies.json
deleted file mode 100644
index 4b53233..0000000
--- a/eagle-core/eagle-alert-parent/eagle-alert/alert-coordinator/src/test/resources/multi/topologies.json
+++ /dev/null
@@ -1,31 +0,0 @@
-[
-  {
-    "name": "alertUnitTopology_1",
-    "numOfSpout": 1,
-    "numOfGroupBolt": 4,
-    "numOfAlertBolt": 10,
-    "spoutId": "alertEngineSpout",
-    "groupNodeIds": [
-      "streamRouterBolt0",
-      "streamRouterBolt1",
-      "streamRouterBolt2",
-      "streamRouterBolt3"
-    ],
-    "alertBoltIds": [
-      "alertBolt0",
-      "alertBolt1",
-      "alertBolt2",
-      "alertBolt3",
-      "alertBolt4",
-      "alertBolt5",
-      "alertBolt6",
-      "alertBolt7",
-      "alertBolt8",
-      "alertBolt9"
-    ],
-    "pubBoltId": "alertPublishBolt",
-    "spoutParallelism": 1,
-    "groupParallelism": 1,
-    "alertParallelism": 1
-  }
-]
\ No newline at end of file

http://git-wip-us.apache.org/repos/asf/eagle/blob/6fd95d5c/eagle-core/eagle-alert-parent/eagle-alert/alert-coordinator/src/test/resources/test-application.conf
----------------------------------------------------------------------
diff --git a/eagle-core/eagle-alert-parent/eagle-alert/alert-coordinator/src/test/resources/test-application.conf b/eagle-core/eagle-alert-parent/eagle-alert/alert-coordinator/src/test/resources/test-application.conf
deleted file mode 100644
index 566dc83..0000000
--- a/eagle-core/eagle-alert-parent/eagle-alert/alert-coordinator/src/test/resources/test-application.conf
+++ /dev/null
@@ -1,51 +0,0 @@
-# Licensed to the Apache Software Foundation (ASF) under one or more
-# contributor license agreements.  See the NOTICE file distributed with
-# this work for additional information regarding copyright ownership.
-# The ASF licenses this file to You under the Apache License, Version 2.0
-# (the "License"); you may not use this file except in compliance with
-# the License.  You may obtain a copy of the License at
-#
-#    http://www.apache.org/licenses/LICENSE-2.0
-#
-# Unless required by applicable law or agreed to in writing, software
-# distributed under the License is distributed on an "AS IS" BASIS,
-# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-# See the License for the specific language governing permissions and
-# limitations under the License.
-
-{
-  "coordinator": {
-    "policiesPerBolt": 5,
-    "boltParallelism": 5,
-    "policyDefaultParallelism": 5,
-    "boltLoadUpbound": 0.8,
-    "topologyLoadUpbound": 0.8,
-    "numOfAlertBoltsPerTopology": 5,
-    "zkConfig": {
-      "zkQuorum": "localhost:2181",
-      "zkRoot": "/alert",
-      "zkSessionTimeoutMs": 10000,
-      "connectionTimeoutMs": 5000,
-      "zkRetryTimes": 5,
-      "zkRetryInterval": 1000
-    },
-    "metadataService": {
-      "context": "/api",
-      "host": "localhost",
-      "port": 8080
-    },
-    "metadataDynamicCheck": {
-      "initDelayMillis": 1000,
-      "delayMillis": 600000
-    },
-    "kafkaProducer": {
-      "bootstrapServers": "localhost:9092"
-    },
-    "email": {
-      "sender": "eagle@eagle.com",
-      "recipients": "test@eagle.com",
-      "mailSmtpHost": "test.eagle.com",
-      "mailSmtpPort": "25"
-    }
-  }
-}
\ No newline at end of file

http://git-wip-us.apache.org/repos/asf/eagle/blob/6fd95d5c/eagle-core/eagle-alert-parent/eagle-alert/alert-coordinator/src/test/resources/validation/datasources.json
----------------------------------------------------------------------
diff --git a/eagle-core/eagle-alert-parent/eagle-alert/alert-coordinator/src/test/resources/validation/datasources.json b/eagle-core/eagle-alert-parent/eagle-alert/alert-coordinator/src/test/resources/validation/datasources.json
deleted file mode 100644
index 840cee6..0000000
--- a/eagle-core/eagle-alert-parent/eagle-alert/alert-coordinator/src/test/resources/validation/datasources.json
+++ /dev/null
@@ -1,86 +0,0 @@
-[
-  {
-    "type":"KAFKA",
-    "name":"network_syslog_event_datasource",
-    "properties":{
-
-    },
-    "topic":"preprocess.network-syslog.events",
-    "schemeCls":"EventSignalScheme",
-    "codec":{
-      "activeStreamNames":[
-
-      ],
-      "streamNameSelectorProp":{
-        "userProvidedStreamName":"syslogEventStream",
-        "streamNameFormat":"%s"
-      },
-      "streamNameSelectorCls":"org.apache.eagle.alert.engine.scheme.JsonStringStreamNameSelector",
-      "timestampColumn":"timestamp",
-      "timestampFormat":""
-    }
-  },
-  {
-    "type":"KAFKA",
-    "name":"network_NC_alert_datasource",
-    "properties":{
-
-    },
-    "topic":"preprocess.network-nervecenter.events",
-    "schemeCls":"EventSignalScheme",
-    "codec":{
-      "activeStreamNames":[
-
-      ],
-      "streamNameSelectorProp":{
-        "userProvidedStreamName":"ncAlertStream",
-        "streamNameFormat":"%s"
-      },
-      "streamNameSelectorCls":"org.apache.eagle.alert.engine.scheme.JsonStringStreamNameSelector",
-      "timestampColumn":"timestamp",
-      "timestampFormat":""
-    }
-  },
-  {
-    "type":"KAFKA",
-    "name":"network_sherlock_alert_datasource",
-    "properties":{
-
-    },
-    "topic":"preprocess.network-sherlock.events",
-    "schemeCls":"EventSignalScheme",
-    "codec":{
-      "activeStreamNames":[
-
-      ],
-      "streamNameSelectorProp":{
-        "userProvidedStreamName":"sherlockAlertStream",
-        "streamNameFormat":"%s"
-      },
-      "streamNameSelectorCls":"org.apache.eagle.alert.engine.scheme.JsonStringStreamNameSelector",
-      "timestampColumn":"timestamp",
-      "timestampFormat":""
-    }
-  },
-  {
-    "type":"KAFKA",
-    "name":"network_aggregate_alert_output_datasource",
-    "properties":{
-
-    },
-    "topic":"process.network.alerts",
-    "schemeCls":"EventSignalScheme",
-    "codec":{
-      "activeStreamNames":[
-
-      ],
-      "streamNameSelectorProp":{
-        "fieldNamesToInferStreamName":"streamName",
-        "streamNameFormat":"%s"
-      },
-      "streamNameSelectorCls":"org.apache.eagle.alert.engine.scheme.JsonStringStreamNameSelector",
-      "timestampColumn":"timestamp",
-      "timestampFormat":""
-    }
-  }
-]
\ No newline at end of file

http://git-wip-us.apache.org/repos/asf/eagle/blob/6fd95d5c/eagle-core/eagle-alert-parent/eagle-alert/alert-coordinator/src/test/resources/validation/policies.json
----------------------------------------------------------------------
diff --git a/eagle-core/eagle-alert-parent/eagle-alert/alert-coordinator/src/test/resources/validation/policies.json b/eagle-core/eagle-alert-parent/eagle-alert/alert-coordinator/src/test/resources/validation/policies.json
deleted file mode 100644
index f7aa44e..0000000
--- a/eagle-core/eagle-alert-parent/eagle-alert/alert-coordinator/src/test/resources/validation/policies.json
+++ /dev/null
@@ -1,572 +0,0 @@
-[
-  {
-    "name":"nerveCenter_port_down",
-    "description":"",
-    "inputStreams":[
-      "ncAlertStream"
-    ],
-    "outputStreams":[
-      "ncAlertOutputStream"
-    ],
-    "definition":{
-      "type":"siddhi",
-      "value":"from ncAlertStream[status=='active'] select 'nerveCenterAlert' as name, 'network' as namespace, UUID() as docId, timestamp, str:concat(cause, ':', entity, ':', dims_component) as alertKey, '' as parentKey, dims_component, dims_pod, dims_bubble, dims_entity, dims_dc, severity, componentType, entityType, source, message, key, linkedSwitch, localPort, pod, 'nerveCenter' as alertSource, ip, linkedPort, bubble, state, entity, status, dc, 0l as dedupCount, 0l as dedupFirstOccurrence, 'ncAlertOutputStream' as streamName, monitor, cause insert into ncAlertOutputStream;",
-      "properties":{
-
-      },
-      "inputStreams":[
-
-      ],
-      "outputStreams":[
-
-      ]
-    },
-    "policyStatus":"ENABLED",
-    "partitionSpec":[
-      {
-        "streamId":"ncAlertStream",
-        "type":"GROUPBY",
-        "columns":[
-          "entity"
-        ]
-      }
-    ],
-    "parallelismHint":0
-  },
-  {
-    "name":"sherlock_metric_updown",
-    "description":"",
-    "inputStreams":[
-      "sherlockAlertStream"
-    ],
-    "outputStreams":[
-      "sherlockAlertOutputStream"
-    ],
-    "definition":{
-      "type":"siddhi",
-      "value":"from sherlockAlertStream[status=='active'] select 'sherlockAlert' as name, 'network' as namespace, UUID() as docId, timestamp, str:concat(cause, ':', entity, ':', component) as alertKey, '' as parentKey, dims_device, dims_ifAlias, dims_bubble, dims_pod, dims_dc, source, currState, msg, prevState, type, kind, switchtype, debouncer_type, debouncer_value, current_value, current_execursion, threshold_execursion, operation, severity, componentType, linkedSwitch, localPort, pod, 'sherlockAlert' as alertSource, entityType, ip, component, linkedPort, bubble, state, entity, status,dc, 0l as dedupCount, 0l as dedupFirstOccurrence, 'sherlockAlertOutputStream' as streamName, cause, message insert into sherlockAlertOutputStream;",
-      "properties":{
-
-      },
-      "inputStreams":[
-
-      ],
-      "outputStreams":[
-
-      ]
-    },
-    "policyStatus":"ENABLED",
-    "partitionSpec":[
-      {
-        "streamId":"sherlockAlertStream",
-        "type":"GROUPBY",
-        "columns":[
-          "entity"
-        ]
-      }
-    ],
-    "parallelismHint":0
-  },
-  {
-    "name":"network_aggregate",
-    "description":"aggregate alerts into parent alerts",
-    "inputStreams":[
-      "syslogAlertOutputStream",
-      "ncAlertOutputStream",
-      "sherlockAlertOutputStream"
-    ],
-    "outputStreams":[
-      "aggregatedAlertStream"
-    ],
-    "definition":{
-      "type":"Custom",
-      "value":"",
-      "handlerClass":"org.apache.eagle.alert.engine.evaluator.aggregate.AlertAggregateHandler",
-      "properties":{
-        "aggregateKey":{
-          "syslogAlertOutputStream":{
-            "pattern":"%s",
-            "columns":[
-              "alertKey"
-            ]
-          },
-          "ncAlertOutputStream":{
-            "pattern":"%s",
-            "columns":[
-              "alertKey"
-            ]
-          },
-          "sherlockAlertOutputStream":{
-            "pattern":"%s",
-            "columns":[
-              "alertKey"
-            ]
-          }
-        },
-        "fixFields":{
-          "name":"networkAggregateAlert",
-          "namespace":"network",
-          "streamName":"aggregatedAlertStream",
-          "alertSource":"aggregateAlert"
-        }
-      },
-      "inputStreams":[
-
-      ],
-      "outputStreams":[
-
-      ]
-    },
-    "policyStatus":"ENABLED",
-    "partitionSpec":[
-      {
-        "streamId":"syslogAlertOutputStream",
-        "type":"GROUPBY",
-        "columns":[
-          "entity"
-        ]
-      },
-      {
-        "streamId":"ncAlertOutputStream",
-        "type":"GROUPBY",
-        "columns":[
-          "entity"
-        ]
-      },
-      {
-        "streamId":"sherlockAlertOutputStream",
-        "type":"GROUPBY",
-        "columns":[
-          "entity"
-        ]
-      }
-    ],
-    "parallelismHint":0
-  },
-  {
-    "name":"network_correlate",
-    "description":"correlate alerts for circuit down",
-    "inputStreams":[
-      "aggregatedAlertStream"
-    ],
-    "outputStreams":[
-      "correlatedAlertStream"
-    ],
-    "definition":{
-      "type":"Custom",
-      "value":"",
-      "handlerClass":"org.apache.eagle.alert.engine.evaluator.aggregate.AlertAggregateHandler",
-      "properties":{
-        "aggregateKey":{
-          "aggregatedAlertStream":{
-            "pattern":"%s",
-            "columns":[
-              "linkedPort"
-            ]
-          }
-        },
-        "fixFields":{
-          "name":"networkCorrelateAlert",
-          "namespace":"network",
-          "streamName":"correlatedAlertStream",
-          "alertSource":"correlateAlert"
-        },
-        "filters":{
-          "aggregatedAlertStream":"cause == 'Port_Down'"
-        }
-      },
-      "inputStreams":[
-
-      ],
-      "outputStreams":[
-
-      ]
-    },
-    "policyStatus":"DISABLED",
-    "partitionSpec":[
-      {
-        "streamId":"aggregatedAlertStream",
-        "type":"GROUPBY",
-        "columns":[
-          "linkedPort"
-        ]
-      }
-    ],
-    "parallelismHint":0
-  },
-  {
-    "name":"network_symptomatic",
-    "description":"Correlate circuit down alerts into a symptomatic alert",
-    "inputStreams":[
-      "correlatedAlertStream"
-    ],
-    "outputStreams":[
-      "deviceDownAlertStream",
-      "symptomaticAlertOutputStream"
-    ],
-    "definition":{
-      "type":"siddhi",
-      "value":"from correlatedAlertStream#window.time(10 min) select \"networkDeviceDownAlert\" as name, namespace, UUID() as docId, linkedSwitch as entity, pod, bubble, dc, severity, state, cause, message, firstOccurenceTime, timestamp, \"deviceDownOutputStream\" as streamName group by linkedSwitch having count() > 6 insert into deviceDownAlertStream; from correlatedAlertStream#window.time(10 min) as left join deviceDownAlertStream#window.time(10 min) as right on left.linkedSwitch = right.linkedSwitch select left.name, left.streamId, left.pod, left.docId, left.cause, left.firstOccurenceTime, left.bubble, left.state, left.timestamp, left.severity, left.componentType, left.linkedSwitch, left.alertSource, left.entityType, left.ip, left.alertKey, left.message, left.streamName, left.createBy, left.component, left.linkedPort, left.policyId, left.createTime, left.namespace, left.endTime, left.entity, left.dc, left.status, right.docId as parentKey insert into symptomaticAlertOutputStream;"
 ,
-      "properties":{
-
-      },
-      "inputStreams":[
-
-      ],
-      "outputStreams":[
-
-      ]
-    },
-    "policyStatus":"DISABLED",
-    "partitionSpec":[
-      {
-        "streamId":"correlatedAlertStream",
-        "type":"GROUPBY",
-        "columns":[
-          "linkedSwitch"
-        ]
-      }
-    ],
-    "parallelismHint":0
-  },
-  {
-    "name":"critical_temperature",
-    "description":"CRITICAL system overheating msg",
-    "inputStreams":[
-      "syslogEventStream"
-    ],
-    "outputStreams":[
-      "syslogAlertOutputStream"
-    ],
-    "definition":{
-      "type":"siddhi",
-      "value":"from syslogEventStream[(severity_name == \"EMERG\" or severity_name == \"ALERT\" or severity_name ==\"CRIT\") and (regex:find(\"The system is overheating\", msg))] select 'syslogAlert' as name, 'CRITICAL' as severity, namespace, facility_name, facility_code, severity_code,severity_name ,entity, dims_appname, msgid,  msg, timestamp, ip, status, component, componentType, linkedPort, linkedSwitch, localPort, message, pod, bubble,dc,entityType,productionLevel, 'syslogAlert' as name, 'network' as namespace, 'Temp_Status' as cause, str:concat('Temp_Status', ':', dims_hostname, ':', component) as alertKey, '' as parentKey, UUID() as docId, 'CRITICAL' as severity,  'open' as state,0l as dedupCount, 0l as dedupFirstOccurrence, 'syslogAlertOutputStream' as streamName insert into syslogAlertOutputStream;",
-      "properties":{
-
-      },
-      "inputStreams":[
-
-      ],
-      "outputStreams":[
-
-      ]
-    },
-    "policyStatus":"DISABLED",
-    "partitionSpec":[
-      {
-        "streamId":"syslogEventStream",
-        "type":"GROUPBY",
-        "columns":[
-          "entity"
-        ]
-      }
-    ],
-    "parallelismHint":0
-  },
-  {
-    "name":"critical_power_supply",
-    "description":"CRITICAL power supply severity msgs",
-    "inputStreams":[
-      "syslogEventStream"
-    ],
-    "outputStreams":[
-      "syslogAlertOutputStream"
-    ],
-    "definition":{
-      "type":"siddhi",
-      "value":"from syslogEventStream[(severity_name == \"EMERG\" or severity_name == \"ALERT\" or severity_name ==\"CRIT\") and (regex:find(\"Power Supply is not responding\",msg))] select 'syslogAlert' as name, 'CRITICAL' as severity, namespace, facility_name, facility_code, severity_code,severity_name ,entity, dims_appname, msgid,  msg, timestamp, ip, status, component, componentType, linkedPort, linkedSwitch, localPort, message, pod, bubble,dc,entityType,productionLevel, 'syslogAlert' as name, 'network' as namespace, 'Power_Supply_Health' as cause, str:concat('Power_Supply_Health', ':', dims_hostname, ':', component) as alertKey, '' as parentKey, UUID() as docId, 'CRITICAL' as severity,  'open' as state,0l as dedupCount, 0l as dedupFirstOccurrence, 'syslogAlertOutputStream' as streamName insert into syslogAlertOutputStream;",
-      "properties":{
-
-      },
-      "inputStreams":[
-
-      ],
-      "outputStreams":[
-
-      ]
-    },
-    "policyStatus":"DISABLED",
-    "partitionSpec":[
-      {
-        "streamId":"syslogEventStream",
-        "type":"GROUPBY",
-        "columns":[
-          "entity"
-        ]
-      }
-    ],
-    "parallelismHint":0
-  },
-  {
-    "name":"critical_memory",
-    "description":"CRITICAL memory inconsistency  msgs",
-    "inputStreams":[
-      "syslogEventStream"
-    ],
-    "outputStreams":[
-      "syslogAlertOutputStream"
-    ],
-    "definition":{
-      "type":"siddhi",
-      "value":"from syslogEventStream[(severity_name == \"EMERG\" or severity_name == \"ALERT\" or severity_name ==\"CRIT\") and (regex:find(\"Memory inconsistency detected\", msg))] select 'syslogAlert' as name, 'CRITICAL' as severity, namespace, facility_name, facility_code, severity_code,severity_name ,entity, dims_appname, msgid,  msg, timestamp, ip, status, component, componentType, linkedPort, linkedSwitch, localPort, message, pod, bubble,dc,entityType,productionLevel, 'syslogAlert' as name, 'network' as namespace, 'Memory_Health' as cause, str:concat('Memory_Health', ':', dims_hostname, ':', component) as alertKey, '' as parentKey, UUID() as docId, 'CRITICAL' as severity,  'open' as state,0l as dedupCount, 0l as dedupFirstOccurrence, 'syslogAlertOutputStream' as streamName insert into syslogAlertOutputStream;",
-      "properties":{
-
-      },
-      "inputStreams":[
-
-      ],
-      "outputStreams":[
-
-      ]
-    },
-    "policyStatus":"DISABLED",
-    "partitionSpec":[
-      {
-        "streamId":"syslogEventStream",
-        "type":"GROUPBY",
-        "columns":[
-          "entity"
-        ]
-      }
-    ],
-    "parallelismHint":0
-  },
-  {
-    "name":"critical_chassis",
-    "description":" chassis critical alerts  ",
-    "inputStreams":[
-      "syslogEventStream"
-    ],
-    "outputStreams":[
-      "syslogAlertOutputStream"
-    ],
-    "definition":{
-      "type":"siddhi",
-      "value":"from syslogEventStream[severity_name == \"ERR\" and (regex:find(\"CB color=YELLOW, class=CHASSIS, reason=Check\", msg))] select 'syslogAlert' as name, 'CRITICAL' as severity, namespace, facility_name, facility_code, severity_code,severity_name ,entity, dims_appname, msgid,  msg, timestamp, ip, status, component, componentType, linkedPort, linkedSwitch, localPort, message, pod, bubble,dc,entityType,productionLevel, 'syslogAlert' as name, 'network' as namespace, 'Chassis_Health' as cause, str:concat('Chassis_Health', ':', dims_hostname, ':', component) as alertKey, '' as parentKey, UUID() as docId, 'CRITICAL' as severity,  'open' as state,0l as dedupCount, 0l as dedupFirstOccurrence, 'syslogAlertOutputStream' as streamName insert into syslogAlertOutputStream;",
-      "properties":{
-
-      },
-      "inputStreams":[
-
-      ],
-      "outputStreams":[
-
-      ]
-    },
-    "policyStatus":"DISABLED",
-    "partitionSpec":[
-      {
-        "streamId":"syslogEventStream",
-        "type":"GROUPBY",
-        "columns":[
-          "entity"
-        ]
-      }
-    ],
-    "parallelismHint":0
-  },
-  {
-    "name":"warning_disk",
-    "description":"warning temporary directory warning alert msgs",
-    "inputStreams":[
-      "syslogEventStream"
-    ],
-    "outputStreams":[
-      "syslogAlertOutputStream"
-    ],
-    "definition":{
-      "type":"siddhi",
-      "value":"from syslogEventStream[(severity_name == \"EMERG\" or severity_name == \"ALERT\" or severity_name ==\"CRIT\") and (regex:find(\"System temporary directory usage is unexpectedly high\", msg) or regex: find(\"Re enabling dynamic learning on all interfaces\", msg))] select 'syslogAlert' as name, 'WARNING' as severity, namespace, facility_name, facility_code, severity_code,severity_name ,entity, dims_appname, msgid,  msg, timestamp, ip, status, component, componentType, linkedPort, linkedSwitch, localPort, message, pod, bubble,dc,entityType,productionLevel, 'syslogAlert' as name, 'network' as namespace, 'Disk_Status' as cause, str:concat('Disk_Status', ':', dims_hostname, ':', component) as alertKey, '' as parentKey, UUID() as docId, 'CRITICAL' as severity,  'open' as state,0l as dedupCount, 0l as dedupFirstOccurrence, 'syslogAlertOutputStream' as streamName insert into syslogAlertOutputStream;",
-      "properties":{
-
-      },
-      "inputStreams":[
-
-      ],
-      "outputStreams":[
-
-      ]
-    },
-    "policyStatus":"DISABLED",
-    "partitionSpec":[
-      {
-        "streamId":"syslogEventStream",
-        "type":"GROUPBY",
-        "columns":[
-          "entity"
-        ]
-      }
-    ],
-    "parallelismHint":0
-  },
-  {
-    "name":"warning_stmlearning",
-    "description":"warning reenabling learning warning alert msgs",
-    "inputStreams":[
-      "syslogEventStream"
-    ],
-    "outputStreams":[
-      "syslogAlertOutputStream"
-    ],
-    "definition":{
-      "type":"siddhi",
-      "value":"from syslogEventStream[(severity_name == \"EMERG\" or severity_name == \"ALERT\" or severity_name ==\"CRIT\") and (regex: find(\"Re enabling dynamic learning on all interfaces\", msg))] select 'syslogAlert' as name, 'WARNING' as severity, namespace, facility_name, facility_code, severity_code,severity_name ,entity, dims_appname, msgid,  msg, timestamp, ip, status, component, componentType, linkedPort, linkedSwitch, localPort, message, pod, bubble,dc,entityType,productionLevel, 'syslogAlert' as name, 'network' as namespace, 'STM_Learning' as cause, str:concat('STM_Learning', ':', dims_hostname, ':', component) as alertKey, '' as parentKey, UUID() as docId, 'CRITICAL' as severity,  'open' as state,0l as dedupCount, 0l as dedupFirstOccurrence, 'syslogAlertOutputStream' as streamName insert into syslogAlertOutputStream;",
-      "properties":{
-
-      },
-      "inputStreams":[
-
-      ],
-      "outputStreams":[
-
-      ]
-    },
-    "policyStatus":"DISABLED",
-    "partitionSpec":[
-      {
-        "streamId":"syslogEventStream",
-        "type":"GROUPBY",
-        "columns":[
-          "entity"
-        ]
-      }
-    ],
-    "parallelismHint":0
-  },
-  {
-    "name":"warning_snmpd",
-    "description":"snmp daemon issue minor alert",
-    "inputStreams":[
-      "syslogEventStream"
-    ],
-    "outputStreams":[
-      "syslogAlertOutputStream"
-    ],
-    "definition":{
-      "type":"siddhi",
-      "value":"from syslogEventStream[(severity_name == \"EMERG\" or severity_name == \"ALERT\" or severity_name ==\"CRIT\") and (regex:find(\"Service \"snmpd\" (PID [0-9]+]) hasn't caught signal 6 (core will be saved)\", msg))] select 'syslogAlert' as name, 'WARNING' as severity, namespace, facility_name, facility_code, severity_code,severity_name ,entity, dims_appname, msgid,  msg, timestamp, ip, status, component, componentType, linkedPort, linkedSwitch, localPort, message, pod, bubble,dc,entityType,productionLevel, 'syslogAlert' as name, 'network' as namespace, 'SNMP_Health' as cause, str:concat('SNMP_Health', ':', dims_hostname, ':', component) as alertKey, '' as parentKey, UUID() as docId, 'CRITICAL' as severity,  'open' as state,0l as dedupCount, 0l as dedupFirstOccurrence, 'syslogAlertOutputStream' as streamName insert into syslogAlertOutputStream;",
-      "properties":{
-
-      },
-      "inputStreams":[
-
-      ],
-      "outputStreams":[
-
-      ]
-    },
-    "policyStatus":"DISABLED",
-    "partitionSpec":[
-      {
-        "streamId":"syslogEventStream",
-        "type":"GROUPBY",
-        "columns":[
-          "entity"
-        ]
-      }
-    ],
-    "parallelismHint":0
-  },
-  {
-    "name":"warning_temperature",
-    "description":"warning temperature  minor alarm msgs",
-    "inputStreams":[
-      "syslogEventStream"
-    ],
-    "outputStreams":[
-      "syslogAlertOutputStream"
-    ],
-    "definition":{
-      "type":"siddhi",
-      "value":"from syslogEventStream[(severity_name == \"EMERG\" or severity_name == \"ALERT\" or severity_name ==\"CRIT\") and (regex:find(\"System minor temperature alarm on module\", msg))] select 'syslogAlert' as name, 'WARNING' as severity, namespace, facility_name, facility_code, severity_code,severity_name ,entity, dims_appname, msgid,  msg, timestamp, ip, status, component, componentType, linkedPort, linkedSwitch, localPort, message, pod, bubble,dc,entityType,productionLevel, 'syslogAlert' as name, 'network' as namespace, 'Temp_Status' as cause, str:concat('Temp_Status', ':', dims_hostname, ':', component) as alertKey, '' as parentKey, UUID() as docId, 'CRITICAL' as severity,  'open' as state,0l as dedupCount, 0l as dedupFirstOccurrence, 'syslogAlertOutputStream' as streamName insert into syslogAlertOutputStream;",
-      "properties":{
-
-      },
-      "inputStreams":[
-
-      ],
-      "outputStreams":[
-
-      ]
-    },
-    "policyStatus":"DISABLED",
-    "partitionSpec":[
-      {
-        "streamId":"syslogEventStream",
-        "type":"GROUPBY",
-        "columns":[
-          "entity"
-        ]
-      }
-    ],
-    "parallelismHint":0
-  },
-  {
-    "name":"fatal_chassis",
-    "description":"fatal chassis alerts msgs",
-    "inputStreams":[
-      "syslogEventStream"
-    ],
-    "outputStreams":[
-      "syslogAlertOutputStream"
-    ],
-    "definition":{
-      "type":"siddhi",
-      "value":"from syslogEventStream[severity_name == \"ERR\" and (regex:find(\"Reporting self ping blackhole for\", msg))] select 'syslogAlert' as name, 'FATAL' as severity, namespace, facility_name, facility_code, severity_code,severity_name ,entity, dims_appname, msgid,  msg, timestamp, ip, status, component, componentType, linkedPort, linkedSwitch, localPort, message, pod, bubble,dc,entityType,productionLevel, 'syslogAlert' as name, 'network' as namespace, 'Chassis_Health' as cause, str:concat('Chassis_Health', ':', dims_hostname, ':', component) as alertKey, '' as parentKey, UUID() as docId, 'CRITICAL' as severity,  'open' as state,0l as dedupCount, 0l as dedupFirstOccurrence, 'syslogAlertOutputStream' as streamName insert into syslogAlertOutputStream;",
-      "properties":{
-
-      },
-      "inputStreams":[
-
-      ],
-      "outputStreams":[
-
-      ]
-    },
-    "policyStatus":"DISABLED",
-    "partitionSpec":[
-      {
-        "streamId":"syslogEventStream",
-        "type":"GROUPBY",
-        "columns":[
-          "entity"
-        ]
-      }
-    ],
-    "parallelismHint":0
-  },
-  {
-    "name":"fatal_FRUs",
-    "description":"fatal alert on keywords 'FRU Offline', 'FRU power off', and 'FRU power on'",
-    "inputStreams":[
-      "syslogEventStream"
-    ],
-    "outputStreams":[
-      "syslogAlertOutputStream"
-    ],
-    "definition":{
-      "type":"siddhi",
-      "value":"from syslogEventStream[(regex:find(\"Fru Offline\", msg)) or (regex:find(\"FRU power off\", msg)) or (regex:find(\"FRU power on\", msg))] select 'syslogAlert' as name, 'FATAL' as severity, namespace, facility_name, facility_code, severity_code, severity_name , entity, dims_appname, msgid,  msg, timestamp, ip, status, component, componentType, linkedPort, linkedSwitch, localPort, message, pod, bubble,dc,entityType,productionLevel, 'syslogAlert' as name, 'network' as namespace, 'Module_Health' as cause, str:concat('Module_Health', ':', dims_hostname, ':', component) as alertKey, '' as parentKey, UUID() as docId, 'CRITICAL' as severity,  'open' as state,0l as dedupCount, 0l as dedupFirstOccurrence, 'syslogAlertOutputStream' as streamName insert into syslogAlertOutputStream;",
-      "properties":{
-
-      },
-      "inputStreams":[
-
-      ],
-      "outputStreams":[
-
-      ]
-    },
-    "policyStatus":"DISABLED",
-    "partitionSpec":[
-      {
-        "streamId":"syslogEventStream",
-        "type":"GROUPBY",
-        "columns":[
-          "entity"
-        ]
-      }
-    ],
-    "parallelismHint":0
-  }
-]
\ No newline at end of file

http://git-wip-us.apache.org/repos/asf/eagle/blob/6fd95d5c/eagle-core/eagle-alert-parent/eagle-alert/alert-coordinator/src/test/resources/validation/publishments.json
----------------------------------------------------------------------
diff --git a/eagle-core/eagle-alert-parent/eagle-alert/alert-coordinator/src/test/resources/validation/publishments.json b/eagle-core/eagle-alert-parent/eagle-alert/alert-coordinator/src/test/resources/validation/publishments.json
deleted file mode 100644
index 4e2d48a..0000000
--- a/eagle-core/eagle-alert-parent/eagle-alert/alert-coordinator/src/test/resources/validation/publishments.json
+++ /dev/null
@@ -1,113 +0,0 @@
-[
-  {
-    "name":"network-syslog-publish",
-    "type":"org.apache.eagle.alert.engine.publisher.impl.AlertKafkaPublisher",
-    "policyIds":[
-      "syslog_mem_inconsistent",
-      "critical_temperature",
-      "critical_power_supply",
-      "critical_memory",
-      "critical_chassis",
-      "warning_disk",
-      "warning_stmlearning",
-      "warning_snmpd",
-      "warning_temperature",
-      "fatal_chassis",
-      "fatal_FRUs",
-      "test_severity_notice_check"
-    ],
-    "dedupIntervalMin":"PT0M",
-    "overrideDeduplicator":{
-      "className":"org.apache.eagle.alert.engine.extension.dedup.EsDocIdDeduplicator",
-      "properties":{
-        "esDocIdField":"values.docId",
-        "esAlertKeyField":"values.alertKey",
-        "esTimestampField":"timestamp",
-        "esStateField":"values.state",
-        "esStateCloseValue":"CLOSED",
-        "esIndice":"sherlock-alerts-network-*",
-        "esType":"syslogAlert",
-        "eventDocIdField":"docId",
-        "eventAlertKeyField":"alertKey",
-        "eventStateField":"state"
-      }
-    },
-    "properties":{
-      "kafka_broker":"broker:9092",
-      "topic":"process.network.alerts",
-      "value_deserializer":"SignalSetDeserializer",
-      "value_serializer":"SignalSetSerializer",
-      "rawAlertNamespaceLabel":"namespace",
-      "rawAlertNamespaceValue":"syslog"
-    },
-    "serializer":"AlertSignalSerializer"
-  },
-  {
-    "name":"network-nc-sherlock-publish",
-    "type":"org.apache.eagle.alert.engine.publisher.impl.AlertKafkaPublisher",
-    "policyIds":[
-      "sherlock_metric_updown"
-    ],
-    "dedupIntervalMin":"PT0M",
-    "dedupFields":[
-      "alertKey"
-    ],
-    "dedupStateField":"severity",
-    "properties":{
-      "kafka_broker":"broker:9092",
-      "topic":"process.network.alerts",
-      "value_deserializer":"SignalSetDeserializer",
-      "value_serializer":"SignalSetSerializer"
-    },
-    "serializer":"AlertSignalSerializer"
-  },
-  {
-    "name":"network-aggregation-publish",
-    "type":"org.apache.eagle.alert.engine.publisher.impl.AlertKafkaPublisher",
-    "policyIds":[
-      "network_aggregate"
-    ],
-    "dedupIntervalMin":"PT0M",
-    "properties":{
-      "kafka_broker":"broker:9092",
-      "topic":"process.network.alerts",
-      "value_deserializer":"SignalSetDeserializer",
-      "value_serializer":"SignalSetSerializer"
-    },
-    "serializer":"AlertSignalSerializer"
-  },
-  {
-    "name":"network-correlation-publish",
-    "type":"org.apache.eagle.alert.engine.publisher.impl.AlertKafkaPublisher",
-    "policyIds":[
-      "network_correlate"
-    ],
-    "dedupIntervalMin":"PT0M",
-    "properties":{
-      "kafka_broker":"broker:9092",
-      "topic":"process.network.alerts",
-      "value_deserializer":"SignalSetDeserializer",
-      "value_serializer":"SignalSetSerializer"
-    },
-    "serializer":"AlertSignalSerializer"
-  },
-  {
-    "name":"network-nc-nervecenter-publish",
-    "type":"org.apache.eagle.alert.engine.publisher.impl.AlertKafkaPublisher",
-    "policyIds":[
-      "nerveCenter_port_down"
-    ],
-    "dedupIntervalMin":"PT0M",
-    "dedupFields":[
-      "alertKey"
-    ],
-    "dedupStateField":"severity",
-    "properties":{
-      "kafka_broker":"broker:9092",
-      "topic":"process.network.alerts",
-      "value_deserializer":"SignalSetDeserializer",
-      "value_serializer":"SignalSetSerializer"
-    },
-    "serializer":"AlertSignalSerializer"
-  }
-]
\ No newline at end of file


Mime
View raw message