eagle-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From h..@apache.org
Subject [08/46] incubator-eagle git commit: [EAGLE-325] Initialize next-gen alert engine code on branch-0.5
Date Thu, 02 Jun 2016 07:07:47 GMT
http://git-wip-us.apache.org/repos/asf/incubator-eagle/blob/737e5a2d/eagle-core/eagle-alert/alert/alert-engine/alert-engine-base/src/test/java/org/apache/eagle/alert/engine/topology/TestMetadataSpecSerDeser.java
----------------------------------------------------------------------
diff --git a/eagle-core/eagle-alert/alert/alert-engine/alert-engine-base/src/test/java/org/apache/eagle/alert/engine/topology/TestMetadataSpecSerDeser.java b/eagle-core/eagle-alert/alert/alert-engine/alert-engine-base/src/test/java/org/apache/eagle/alert/engine/topology/TestMetadataSpecSerDeser.java
deleted file mode 100644
index 65b16d9..0000000
--- a/eagle-core/eagle-alert/alert/alert-engine/alert-engine-base/src/test/java/org/apache/eagle/alert/engine/topology/TestMetadataSpecSerDeser.java
+++ /dev/null
@@ -1,266 +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.eagle.alert.engine.topology;
-
-import java.util.Arrays;
-import java.util.Collections;
-import java.util.HashMap;
-import java.util.HashSet;
-import java.util.List;
-import java.util.Map;
-import java.util.Properties;
-import java.util.Set;
-
-import org.apache.eagle.alert.coordination.model.AlertBoltSpec;
-import org.apache.eagle.alert.coordination.model.Kafka2TupleMetadata;
-import org.apache.eagle.alert.coordination.model.PolicyWorkerQueue;
-import org.apache.eagle.alert.coordination.model.RouterSpec;
-import org.apache.eagle.alert.coordination.model.SpoutSpec;
-import org.apache.eagle.alert.coordination.model.StreamRepartitionMetadata;
-import org.apache.eagle.alert.coordination.model.StreamRepartitionStrategy;
-import org.apache.eagle.alert.coordination.model.StreamRouterSpec;
-import org.apache.eagle.alert.coordination.model.Tuple2StreamMetadata;
-import org.apache.eagle.alert.coordination.model.WorkSlot;
-import org.apache.eagle.alert.engine.coordinator.PolicyDefinition;
-import org.apache.eagle.alert.engine.coordinator.StreamColumn;
-import org.apache.eagle.alert.engine.coordinator.StreamDefinition;
-import org.apache.eagle.alert.engine.coordinator.StreamPartition;
-import org.apache.eagle.alert.engine.coordinator.StreamSortSpec;
-import org.apache.eagle.alert.engine.evaluator.PolicyStreamHandlers;
-import org.apache.eagle.alert.engine.utils.MetadataSerDeser;
-import org.codehaus.jackson.type.TypeReference;
-import org.joda.time.Period;
-import org.junit.Assert;
-import org.junit.Test;
-
-/**
- * Since 5/6/16.
- */
-public class TestMetadataSpecSerDeser {
-    private String getStreamNameByTopic(String topic){
-        return topic + "Stream";
-    }
-
-    @Test
-    public void testStreamDefinitions(){
-        Map<String, StreamDefinition> sds = new HashMap<>();
-        List<String> topics = Arrays.asList("testTopic3", "testTopic4", "testTopic5");
-        for(String topic : topics) {
-            String streamId = getStreamNameByTopic(topic);
-            if (topic.equals("testTopic3") || topic.equals("testTopic4")) {
-                StreamDefinition schema = new StreamDefinition();
-                schema.setStreamId(streamId);
-                StreamColumn column = new StreamColumn();
-                column.setName("value");
-                column.setType(StreamColumn.Type.STRING);
-                schema.setColumns(Collections.singletonList(column));
-                sds.put(schema.getStreamId(), schema);
-            }else if(topic.equals("testTopic5")){
-                StreamDefinition schema = new StreamDefinition();
-                schema.setStreamId(streamId);
-                StreamColumn column = new StreamColumn();
-                column.setName("value");
-                column.setType(StreamColumn.Type.STRING);
-                schema.setColumns(Collections.singletonList(column));
-                sds.put(schema.getStreamId(), schema);
-            }
-        }
-
-        String json = MetadataSerDeser.serialize(sds);
-        System.out.println(json);
-
-        Map<String, StreamDefinition> deserializedSpec = MetadataSerDeser.deserialize(json, new TypeReference<Map<String, StreamDefinition>>(){});
-        Assert.assertEquals(3, deserializedSpec.size());
-    }
-
-    @SuppressWarnings("unused")
-    @Test
-    public void testSpoutSpec(){
-        String topologyName = "testTopology";
-        String spoutId = "alertEngineSpout";
-        List<String> plainStringTopics = Arrays.asList("testTopic3", "testTopic4");
-        List<String> jsonStringTopics = Arrays.asList("testTopic5");
-        Map<String, Kafka2TupleMetadata> kafka2TupleMetadataMap = new HashMap<>();
-        for(String topic : plainStringTopics) {
-            Kafka2TupleMetadata kafka2TupleMetadata = new Kafka2TupleMetadata();
-            kafka2TupleMetadata.setName(topic);
-            kafka2TupleMetadata.setTopic(topic);
-            kafka2TupleMetadata.setSchemeCls("org.apache.eagle.alert.engine.scheme.PlainStringScheme");
-            kafka2TupleMetadataMap.put(topic, kafka2TupleMetadata);
-        }
-        for(String topic : jsonStringTopics){
-            Kafka2TupleMetadata kafka2TupleMetadata = new Kafka2TupleMetadata();
-            kafka2TupleMetadata.setName(topic);
-            kafka2TupleMetadata.setTopic(topic);
-            kafka2TupleMetadata.setSchemeCls("org.apache.eagle.alert.engine.scheme.JsonScheme");
-            kafka2TupleMetadataMap.put(topic, kafka2TupleMetadata);
-        }
-
-        // construct Tuple2StreamMetadata
-        Map<String, Tuple2StreamMetadata> tuple2StreamMetadataMap = new HashMap<>();
-        for(String topic : plainStringTopics) {
-            String streamId = getStreamNameByTopic(topic);
-            Tuple2StreamMetadata tuple2StreamMetadata = new Tuple2StreamMetadata();
-            Set<String> activeStreamNames = new HashSet<>();
-            activeStreamNames.add(streamId);
-            tuple2StreamMetadata.setStreamNameSelectorCls("org.apache.eagle.alert.engine.scheme.PlainStringStreamNameSelector");
-            tuple2StreamMetadata.setStreamNameSelectorProp(new Properties());
-            tuple2StreamMetadata.getStreamNameSelectorProp().put("userProvidedStreamName", streamId);
-            tuple2StreamMetadata.setActiveStreamNames(activeStreamNames);
-            tuple2StreamMetadata.setTimestampColumn("timestamp");
-            tuple2StreamMetadataMap.put(topic, tuple2StreamMetadata);
-        }
-
-        for(String topic : jsonStringTopics) {
-            String streamId = getStreamNameByTopic(topic);
-            Tuple2StreamMetadata tuple2StreamMetadata = new Tuple2StreamMetadata();
-            Set<String> activeStreamNames = new HashSet<>();
-            activeStreamNames.add(streamId);
-            tuple2StreamMetadata.setStreamNameSelectorCls("org.apache.eagle.alert.engine.scheme.JsonStringStreamNameSelector");
-            tuple2StreamMetadata.setStreamNameSelectorProp(new Properties());
-            tuple2StreamMetadata.getStreamNameSelectorProp().put("userProvidedStreamName", streamId);
-            tuple2StreamMetadata.setActiveStreamNames(activeStreamNames);
-            tuple2StreamMetadata.setTimestampColumn("timestamp");
-            tuple2StreamMetadataMap.put(topic, tuple2StreamMetadata);
-        }
-
-        // construct StreamRepartitionMetadata
-        Map<String, List<StreamRepartitionMetadata>> streamRepartitionMetadataMap = new HashMap<>();
-        for(String topic : plainStringTopics) {
-            String streamId = getStreamNameByTopic(topic);
-            StreamRepartitionMetadata streamRepartitionMetadata = new StreamRepartitionMetadata(topic, "defaultStringStream");
-            StreamRepartitionStrategy gs = new StreamRepartitionStrategy();
-            // StreamPartition, groupby col1 for stream cpuUsageStream
-            StreamPartition sp = new StreamPartition();
-            sp.setStreamId(streamId);
-            sp.setColumns(Arrays.asList("value"));
-            sp.setType(StreamPartition.Type.GROUPBY);
-            StreamSortSpec sortSpec = new StreamSortSpec();
-            sortSpec.setWindowMargin(1000);
-            sortSpec.setWindowPeriod2(Period.seconds(10));
-            sp.setSortSpec(sortSpec);
-
-            gs.partition = sp;
-            gs.numTotalParticipatingRouterBolts = 1;
-            gs.startSequence = 0;
-            streamRepartitionMetadata.addGroupStrategy(gs);
-            streamRepartitionMetadataMap.put(topic, Arrays.asList(streamRepartitionMetadata));
-        }
-
-        for(String topic : jsonStringTopics) {
-            String streamId = getStreamNameByTopic(topic);
-            StreamRepartitionMetadata streamRepartitionMetadata = new StreamRepartitionMetadata(topic, "defaultStringStream");
-            StreamRepartitionStrategy gs = new StreamRepartitionStrategy();
-            // StreamPartition, groupby col1 for stream cpuUsageStream
-            StreamPartition sp = new StreamPartition();
-            sp.setStreamId(streamId);
-            sp.setColumns(Arrays.asList("value"));
-            sp.setType(StreamPartition.Type.GROUPBY);
-            StreamSortSpec sortSpec = new StreamSortSpec();
-            sortSpec.setWindowMargin(1000);
-            sortSpec.setWindowPeriod2(Period.seconds(10));
-            sp.setSortSpec(sortSpec);
-
-            gs.partition = sp;
-            gs.numTotalParticipatingRouterBolts = 1;
-            gs.startSequence = 0;
-            streamRepartitionMetadata.addGroupStrategy(gs);
-            streamRepartitionMetadataMap.put(topic, Arrays.asList(streamRepartitionMetadata));
-        }
-
-        SpoutSpec newSpec = new SpoutSpec(topologyName, streamRepartitionMetadataMap, tuple2StreamMetadataMap, kafka2TupleMetadataMap);
-        String json = MetadataSerDeser.serialize(newSpec);
-        System.out.println(json);
-
-        SpoutSpec deserializedSpec = MetadataSerDeser.deserialize(json, SpoutSpec.class);
-        Assert.assertNotNull(deserializedSpec);
-//        Assert.assertEquals(spoutId, deserializedSpec.getSpoutId());
-    }
-
-    @Test
-    public void testRouterBoltSpec(){
-        List<String> topics = Arrays.asList("testTopic3", "testTopic4", "testTopic5");
-        RouterSpec boltSpec = new RouterSpec();
-        for(String topic : topics) {
-            String streamId = getStreamNameByTopic(topic);
-            // StreamPartition, groupby col1 for stream cpuUsageStream
-            StreamPartition sp = new StreamPartition();
-            sp.setStreamId(streamId);
-            sp.setColumns(Arrays.asList("value"));
-            sp.setType(StreamPartition.Type.GROUPBY);
-
-            StreamSortSpec sortSpec = new StreamSortSpec();
-            sortSpec.setWindowMargin(1000);
-            sortSpec.setWindowPeriod2(Period.seconds(10));
-            sp.setSortSpec(sortSpec);
-
-            // set StreamRouterSpec to have 2 WorkSlot
-            StreamRouterSpec routerSpec = new StreamRouterSpec();
-            routerSpec.setPartition(sp);
-            routerSpec.setStreamId(streamId);
-            PolicyWorkerQueue queue = new PolicyWorkerQueue();
-            queue.setPartition(sp);
-            queue.setWorkers(Arrays.asList(new WorkSlot("testTopology", "alertBolt0"), new WorkSlot("testTopology", "alertBolt1")));
-            routerSpec.setTargetQueue(Arrays.asList(queue));
-            boltSpec.addRouterSpec(routerSpec);
-        }
-
-        String json = MetadataSerDeser.serialize(boltSpec);
-        System.out.println(json);
-        RouterSpec deserializedSpec = MetadataSerDeser.deserialize(json, RouterSpec.class);
-        Assert.assertEquals(3, deserializedSpec.getRouterSpecs().size());
-    }
-
-    @Test
-    public void testAlertBoltSpec(){
-        String topologyName = "testTopology";
-        AlertBoltSpec spec = new AlertBoltSpec();
-        List<String> topics = Arrays.asList("testTopic3", "testTopic4", "testTopic5");
-        for(String topic : topics) {
-            String streamId = getStreamNameByTopic(topic);
-
-            // construct StreamPartition
-            StreamPartition sp = new StreamPartition();
-            sp.setColumns(Collections.singletonList("value"));
-            sp.setStreamId(streamId);
-            sp.setType(StreamPartition.Type.GROUPBY);
-            StreamSortSpec sortSpec = new StreamSortSpec();
-            sortSpec.setWindowMargin(1000);
-            sortSpec.setWindowPeriod2(Period.seconds(10));
-            sp.setSortSpec(sortSpec);
-
-            spec.setVersion("version1");
-            spec.setTopologyName(topologyName);
-            PolicyDefinition pd = new PolicyDefinition();
-            pd.setName("policy1");
-            pd.setPartitionSpec(Collections.singletonList(sp));
-            pd.setOutputStreams(Collections.singletonList("testAlertStream"));
-            pd.setInputStreams(Collections.singletonList(streamId));
-            pd.setDefinition(new PolicyDefinition.Definition());
-            pd.getDefinition().type = PolicyStreamHandlers.SIDDHI_ENGINE;
-            pd.getDefinition().value = String.format("from %s[value=='xyz'] select value insert into testAlertStream;", streamId);
-            spec.addBoltPolicy("alertBolt0", pd.getName());
-        }
-        String json = MetadataSerDeser.serialize(spec);
-        System.out.println(json);
-        AlertBoltSpec deserializedSpec = MetadataSerDeser.deserialize(json, AlertBoltSpec.class);
-        Assert.assertEquals(topologyName, deserializedSpec.getTopologyName());
-    }
-}

http://git-wip-us.apache.org/repos/asf/incubator-eagle/blob/737e5a2d/eagle-core/eagle-alert/alert/alert-engine/alert-engine-base/src/test/java/org/apache/eagle/alert/engine/topology/TestStormCustomGroupingRouting.java
----------------------------------------------------------------------
diff --git a/eagle-core/eagle-alert/alert/alert-engine/alert-engine-base/src/test/java/org/apache/eagle/alert/engine/topology/TestStormCustomGroupingRouting.java b/eagle-core/eagle-alert/alert/alert-engine/alert-engine-base/src/test/java/org/apache/eagle/alert/engine/topology/TestStormCustomGroupingRouting.java
deleted file mode 100644
index 0466ed3..0000000
--- a/eagle-core/eagle-alert/alert/alert-engine/alert-engine-base/src/test/java/org/apache/eagle/alert/engine/topology/TestStormCustomGroupingRouting.java
+++ /dev/null
@@ -1,144 +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.eagle.alert.engine.topology;
-
-import java.io.Serializable;
-import java.util.Arrays;
-import java.util.HashMap;
-import java.util.List;
-import java.util.Map;
-
-import org.junit.Ignore;
-import org.junit.Test;
-
-import backtype.storm.Config;
-import backtype.storm.LocalCluster;
-import backtype.storm.generated.GlobalStreamId;
-import backtype.storm.grouping.CustomStreamGrouping;
-import backtype.storm.spout.SpoutOutputCollector;
-import backtype.storm.task.OutputCollector;
-import backtype.storm.task.TopologyContext;
-import backtype.storm.task.WorkerTopologyContext;
-import backtype.storm.topology.OutputFieldsDeclarer;
-import backtype.storm.topology.TopologyBuilder;
-import backtype.storm.topology.base.BaseRichBolt;
-import backtype.storm.topology.base.BaseRichSpout;
-import backtype.storm.tuple.Fields;
-import backtype.storm.tuple.Tuple;
-
-/**
- * Since 4/29/16.
- */
-@SuppressWarnings({ "rawtypes", "serial" })
-public class TestStormCustomGroupingRouting implements Serializable {
-    @Ignore
-    @Test
-    public void testRoutingByCustomGrouping() throws Exception{
-        Config conf = new Config();
-        conf.setNumWorkers(2); // use two worker processes
-        TopologyBuilder topologyBuilder = new TopologyBuilder();
-        topologyBuilder.setSpout("blue-spout", new BlueSpout()); // parallelism hint
-
-        topologyBuilder.setBolt("green-bolt-1", new GreenBolt(0)).setNumTasks(2)
-                .customGrouping("blue-spout", new CustomStreamGrouping(){
-                    int count = 0;
-                    List<Integer> targetTask;
-                    @Override
-                    public void prepare(WorkerTopologyContext context, GlobalStreamId stream, List<Integer> targetTasks) {
-                        this.targetTask = targetTasks;
-                    }
-
-                    @Override
-                    public List<Integer> chooseTasks(int taskId, List<Object> values) {
-                        if(count % 2 == 0) {
-                            count++;
-                            return Arrays.asList(targetTask.get(0));
-                        }else{
-                            count++;
-                            return Arrays.asList(targetTask.get(1));
-                        }
-                    }
-                });
-
-        LocalCluster cluster = new LocalCluster();
-        cluster.submitTopology("mytopology", new HashMap(), topologyBuilder.createTopology());
-
-        while(true) {
-            try {
-                Thread.sleep(1000);
-            } catch (Exception e) {
-                e.printStackTrace();
-            }
-        }
-    }
-
-    private static class BlueSpout extends BaseRichSpout {
-        int count = 0;
-        private SpoutOutputCollector collector;
-        public BlueSpout(){
-        }
-        @Override
-        public void declareOutputFields(OutputFieldsDeclarer declarer) {
-            declarer.declare(new Fields("a"));
-        }
-
-        @Override
-        public void open(Map conf, TopologyContext context, SpoutOutputCollector collector) {
-            this.collector = collector;
-        }
-
-        @Override
-        public void nextTuple() {
-            if(count % 2 == 0) {
-                this.collector.emit(Arrays.asList("testdata" + count));
-                count++;
-            }else{
-                this.collector.emit(Arrays.asList("testdata" + count));
-                count++;
-            }
-            try{
-                Thread.sleep(10000);
-            }catch(Exception ex){
-
-            }
-        }
-    }
-
-    private static class GreenBolt extends BaseRichBolt {
-        private int id;
-        public GreenBolt(int id){
-            this.id = id;
-        }
-        @Override
-        public void prepare(Map stormConf, TopologyContext context, OutputCollector collector) {
-        }
-
-        @Override
-        public void execute(Tuple input) {
-            System.out.println("bolt " + id + " received data " + input.getString(0));
-            System.out.flush();
-        }
-
-        @Override
-        public void declareOutputFields(OutputFieldsDeclarer declarer) {
-            declarer.declare(new Fields("a"));
-        }
-    }
-}

http://git-wip-us.apache.org/repos/asf/incubator-eagle/blob/737e5a2d/eagle-core/eagle-alert/alert/alert-engine/alert-engine-base/src/test/java/org/apache/eagle/alert/engine/topology/TestStormParallelism.java
----------------------------------------------------------------------
diff --git a/eagle-core/eagle-alert/alert/alert-engine/alert-engine-base/src/test/java/org/apache/eagle/alert/engine/topology/TestStormParallelism.java b/eagle-core/eagle-alert/alert/alert-engine/alert-engine-base/src/test/java/org/apache/eagle/alert/engine/topology/TestStormParallelism.java
deleted file mode 100644
index 279a041..0000000
--- a/eagle-core/eagle-alert/alert/alert-engine/alert-engine-base/src/test/java/org/apache/eagle/alert/engine/topology/TestStormParallelism.java
+++ /dev/null
@@ -1,161 +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.eagle.alert.engine.topology;
-
-import java.util.HashMap;
-import java.util.Map;
-
-import org.junit.Ignore;
-import org.junit.Test;
-
-import backtype.storm.Config;
-import backtype.storm.LocalCluster;
-import backtype.storm.spout.SpoutOutputCollector;
-import backtype.storm.task.OutputCollector;
-import backtype.storm.task.TopologyContext;
-import backtype.storm.topology.OutputFieldsDeclarer;
-import backtype.storm.topology.TopologyBuilder;
-import backtype.storm.topology.base.BaseRichBolt;
-import backtype.storm.topology.base.BaseRichSpout;
-import backtype.storm.tuple.Fields;
-import backtype.storm.tuple.Tuple;
-
-/**
- * Since 4/29/16.
- */
-@SuppressWarnings({"serial", "rawtypes"})
-public class TestStormParallelism {
-    /**
-     * When run this test, please check the following through jstack and log
-     * 1) for blue-spout, num of executors is 2, # of tasks is 2
-     *
-     * Expected:
-     *
-     * a. 2 threads uniquely named Thread-*-blue-spout-executor[*,*]
-     * b. each thread will have single task
-     *
-     * 2) for green-bolt, num of executors is 2, # of tasks is 4
-     *
-     * Expected:
-     *
-     * a. 2 threads uniquely named Thread-*-green-bolt-executor[*,*]
-     * b. each thread will have 2 tasks
-     *
-     * 3) for yellow-bolt, num of executors is 6, # of tasks is 6
-     *
-     * Expected:
-     *
-     * a. 6 threads uniquely named Thread-*-yellow-bolt-executor[*,*]
-     * b. each thread will have 1 tasks
-     *
-     *
-     * Continue to think:
-     *
-     * For alter engine, if we use multiple tasks per component instead of one task per component,
-     * what will the parallelism mechanism affect?
-     *
-     * @throws Exception
-     */
-    @Ignore
-    @Test
-    public void testParallelism() throws Exception{
-        Config conf = new Config();
-        conf.setNumWorkers(2); // use two worker processes
-        TopologyBuilder topologyBuilder = new TopologyBuilder();
-        topologyBuilder.setSpout("blue-spout", new BlueSpout(), 2); // parallelism hint
-
-        topologyBuilder.setBolt("green-bolt", new GreenBolt(), 2)
-                .setNumTasks(4)
-                .shuffleGrouping("blue-spout");
-
-        topologyBuilder.setBolt("yellow-bolt", new YellowBolt(), 6)
-                .shuffleGrouping("green-bolt");
-
-        LocalCluster cluster = new LocalCluster();
-        cluster.submitTopology("mytopology", new HashMap(), topologyBuilder.createTopology());
-
-        while(true) {
-            try {
-                Thread.sleep(1000);
-            } catch (Exception e) {
-                e.printStackTrace();
-            }
-        }
-    }
-
-    private static class BlueSpout extends BaseRichSpout{
-        static int count = 0;
-        public BlueSpout(){
-        }
-        @Override
-        public void declareOutputFields(OutputFieldsDeclarer declarer) {
-            declarer.declare(new Fields("a"));
-        }
-
-        @Override
-        public void open(Map conf, TopologyContext context, SpoutOutputCollector collector) {
-            count++;
-            System.out.println("# of spout objects " + count + ", current spout " + this);
-        }
-
-        @Override
-        public void nextTuple() {
-
-        }
-    }
-
-    private static class GreenBolt extends BaseRichBolt{
-        static int count;
-        @Override
-        public void prepare(Map stormConf, TopologyContext context, OutputCollector collector) {
-            count++;
-            System.out.println("# of green bolt objects " + count + ", current green bolt " + this);
-        }
-
-        @Override
-        public void execute(Tuple input) {
-
-        }
-
-        @Override
-        public void declareOutputFields(OutputFieldsDeclarer declarer) {
-            declarer.declare(new Fields("a"));
-        }
-    }
-
-    private static class YellowBolt extends BaseRichBolt{
-        static int count;
-        @Override
-        public void prepare(Map stormConf, TopologyContext context, OutputCollector collector) {
-            count++;
-            System.out.println("# of yellow bolt objects " + count + ", current yellow bolt " + this);
-        }
-
-        @Override
-        public void execute(Tuple input) {
-
-        }
-
-        @Override
-        public void declareOutputFields(OutputFieldsDeclarer declarer) {
-            declarer.declare(new Fields("a"));
-        }
-    }
-}

http://git-wip-us.apache.org/repos/asf/incubator-eagle/blob/737e5a2d/eagle-core/eagle-alert/alert/alert-engine/alert-engine-base/src/test/java/org/apache/eagle/alert/engine/topology/TestStormStreamIdRouting.java
----------------------------------------------------------------------
diff --git a/eagle-core/eagle-alert/alert/alert-engine/alert-engine-base/src/test/java/org/apache/eagle/alert/engine/topology/TestStormStreamIdRouting.java b/eagle-core/eagle-alert/alert/alert-engine/alert-engine-base/src/test/java/org/apache/eagle/alert/engine/topology/TestStormStreamIdRouting.java
deleted file mode 100644
index 9d3892a..0000000
--- a/eagle-core/eagle-alert/alert/alert-engine/alert-engine-base/src/test/java/org/apache/eagle/alert/engine/topology/TestStormStreamIdRouting.java
+++ /dev/null
@@ -1,140 +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.eagle.alert.engine.topology;
-
-import java.util.Arrays;
-import java.util.HashMap;
-import java.util.Map;
-
-import org.junit.Ignore;
-import org.junit.Test;
-
-import backtype.storm.Config;
-import backtype.storm.LocalCluster;
-import backtype.storm.spout.SpoutOutputCollector;
-import backtype.storm.task.OutputCollector;
-import backtype.storm.task.TopologyContext;
-import backtype.storm.topology.OutputFieldsDeclarer;
-import backtype.storm.topology.TopologyBuilder;
-import backtype.storm.topology.base.BaseRichBolt;
-import backtype.storm.topology.base.BaseRichSpout;
-import backtype.storm.tuple.Fields;
-import backtype.storm.tuple.Tuple;
-
-
-/**
- * Since 4/29/16.
- */
-@SuppressWarnings({"serial", "rawtypes", "unused"})
-public class TestStormStreamIdRouting {
-    @Ignore
-    @Test
-    public void testRoutingByStreamId() throws Exception{
-        Config conf = new Config();
-        conf.setNumWorkers(2); // use two worker processes
-        TopologyBuilder topologyBuilder = new TopologyBuilder();
-        topologyBuilder.setSpout("blue-spout", new BlueSpout()); // parallelism hint
-
-        topologyBuilder.setBolt("green-bolt-1", new GreenBolt(1))
-                .shuffleGrouping("blue-spout", "green-bolt-stream-1");
-        topologyBuilder.setBolt("green-bolt-2", new GreenBolt(2))
-                .shuffleGrouping("blue-spout", "green-bolt-stream-2");
-
-        LocalCluster cluster = new LocalCluster();
-        cluster.submitTopology("mytopology", new HashMap(), topologyBuilder.createTopology());
-
-        while(true) {
-            try {
-                Thread.sleep(1000);
-            } catch (Exception e) {
-                e.printStackTrace();
-            }
-        }
-    }
-
-    private static class BlueSpout extends BaseRichSpout {
-        int count = 0;
-        private SpoutOutputCollector collector;
-        public BlueSpout(){
-        }
-        @Override
-        public void declareOutputFields(OutputFieldsDeclarer declarer) {
-            declarer.declareStream("green-bolt-stream-1", new Fields("a"));
-            declarer.declareStream("green-bolt-stream-2", new Fields("a"));
-        }
-
-        @Override
-        public void open(Map conf, TopologyContext context, SpoutOutputCollector collector) {
-            this.collector = collector;
-        }
-
-        @Override
-        public void nextTuple() {
-            if(count % 2 == 0) {
-                this.collector.emit("green-bolt-stream-1", Arrays.asList("testdata" + count));
-                count++;
-            }else{
-                this.collector.emit("green-bolt-stream-2", Arrays.asList("testdata" + count));
-                count++;
-            }
-            try{
-                Thread.sleep(10000);
-            }catch(Exception ex){
-
-            }
-        }
-    }
-
-    private static class GreenBolt extends BaseRichBolt {
-        private int id;
-        public GreenBolt(int id){
-            this.id = id;
-        }
-        @Override
-        public void prepare(Map stormConf, TopologyContext context, OutputCollector collector) {
-        }
-
-        @Override
-        public void execute(Tuple input) {
-            System.out.println("bolt " + id + " received data " + input.getString(0));
-        }
-
-        @Override
-        public void declareOutputFields(OutputFieldsDeclarer declarer) {
-            declarer.declare(new Fields("a"));
-        }
-    }
-
-    private static class YellowBolt extends BaseRichBolt{
-        @Override
-        public void prepare(Map stormConf, TopologyContext context, OutputCollector collector) {
-        }
-
-        @Override
-        public void execute(Tuple input) {
-
-        }
-
-        @Override
-        public void declareOutputFields(OutputFieldsDeclarer declarer) {
-            declarer.declare(new Fields("a"));
-        }
-    }
-}

http://git-wip-us.apache.org/repos/asf/incubator-eagle/blob/737e5a2d/eagle-core/eagle-alert/alert/alert-engine/alert-engine-base/src/test/java/org/apache/eagle/alert/engine/topology/TestTuple2StreamConverter.java
----------------------------------------------------------------------
diff --git a/eagle-core/eagle-alert/alert/alert-engine/alert-engine-base/src/test/java/org/apache/eagle/alert/engine/topology/TestTuple2StreamConverter.java b/eagle-core/eagle-alert/alert/alert-engine/alert-engine-base/src/test/java/org/apache/eagle/alert/engine/topology/TestTuple2StreamConverter.java
deleted file mode 100644
index b0e5c4a..0000000
--- a/eagle-core/eagle-alert/alert/alert-engine/alert-engine-base/src/test/java/org/apache/eagle/alert/engine/topology/TestTuple2StreamConverter.java
+++ /dev/null
@@ -1,62 +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.eagle.alert.engine.topology;
-
-import java.util.Arrays;
-import java.util.HashMap;
-import java.util.HashSet;
-import java.util.List;
-import java.util.Map;
-import java.util.Properties;
-import java.util.Set;
-
-import org.apache.eagle.alert.coordination.model.Tuple2StreamConverter;
-import org.apache.eagle.alert.coordination.model.Tuple2StreamMetadata;
-import org.junit.Assert;
-import org.junit.Test;
-
-/**
- * Since 5/3/16.
- */
-public class TestTuple2StreamConverter {
-    @SuppressWarnings({ "unchecked", "rawtypes" })
-    @Test
-    public void test(){
-        Tuple2StreamMetadata metadata = new Tuple2StreamMetadata();
-        Set activeStreamNames = new HashSet<>();
-        activeStreamNames.add("defaultStringStream");
-        metadata.setStreamNameSelectorCls("org.apache.eagle.alert.engine.scheme.PlainStringStreamNameSelector");
-        metadata.setStreamNameSelectorProp(new Properties());
-        metadata.getStreamNameSelectorProp().put("userProvidedStreamName", "defaultStringStream");
-        metadata.setActiveStreamNames(activeStreamNames);
-        metadata.setTimestampColumn("timestamp");
-        Tuple2StreamConverter convert = new Tuple2StreamConverter(metadata);
-        String topic = "testTopic";
-        Map m = new HashMap<>();
-        m.put("value", "IAmPlainString");
-        long t = System.currentTimeMillis();
-        m.put("timestamp", t);
-        List<Object> ret = convert.convert(Arrays.asList(topic, m));
-        Assert.assertEquals(topic, ret.get(0));
-        Assert.assertEquals("defaultStringStream", ret.get(1));
-        Assert.assertEquals(t, ret.get(2));
-        Assert.assertEquals(m, ret.get(3));
-    }
-}

http://git-wip-us.apache.org/repos/asf/incubator-eagle/blob/737e5a2d/eagle-core/eagle-alert/alert/alert-engine/alert-engine-base/src/test/java/org/apache/eagle/alert/engine/topology/TestUnitTopologyMain.java
----------------------------------------------------------------------
diff --git a/eagle-core/eagle-alert/alert/alert-engine/alert-engine-base/src/test/java/org/apache/eagle/alert/engine/topology/TestUnitTopologyMain.java b/eagle-core/eagle-alert/alert/alert-engine/alert-engine-base/src/test/java/org/apache/eagle/alert/engine/topology/TestUnitTopologyMain.java
deleted file mode 100644
index 7132f5a..0000000
--- a/eagle-core/eagle-alert/alert/alert-engine/alert-engine-base/src/test/java/org/apache/eagle/alert/engine/topology/TestUnitTopologyMain.java
+++ /dev/null
@@ -1,57 +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.eagle.alert.engine.topology;
-
-import org.apache.eagle.alert.engine.runner.UnitTopologyRunner;
-import org.junit.Ignore;
-import org.junit.Test;
-
-import com.typesafe.config.Config;
-import com.typesafe.config.ConfigFactory;
-
-/**
- * Since 5/4/16.
- */
-public class TestUnitTopologyMain {
-    @Ignore
-    @Test
-    public void testTopologyRun(){
-        testTopologyRun("/application-test.conf");
-    }
-
-    public void testTopologyRun(String configResourceName){
-        ConfigFactory.invalidateCaches();
-        System.setProperty("config.resource", configResourceName);
-        System.out.print("Set config.resource = "+configResourceName);
-        Config config = ConfigFactory.load();
-        String topologyId = config.getString("topology.name");
-        MockMetadataChangeNotifyService changeNotifyService =
-                new MockMetadataChangeNotifyService(topologyId,"alertEngineSpout");
-        new UnitTopologyRunner(changeNotifyService).run(topologyId,config);
-    }
-
-    public static void main(String[] args){
-        if(args.length>0) {
-            new TestUnitTopologyMain().testTopologyRun(args[0]);
-        } else {
-            new TestUnitTopologyMain().testTopologyRun();
-        }
-    }
-}
\ No newline at end of file

http://git-wip-us.apache.org/repos/asf/incubator-eagle/blob/737e5a2d/eagle-core/eagle-alert/alert/alert-engine/alert-engine-base/src/test/java/org/apache/eagle/alert/engine/utils/CompressionUtilsTest.java
----------------------------------------------------------------------
diff --git a/eagle-core/eagle-alert/alert/alert-engine/alert-engine-base/src/test/java/org/apache/eagle/alert/engine/utils/CompressionUtilsTest.java b/eagle-core/eagle-alert/alert/alert-engine/alert-engine-base/src/test/java/org/apache/eagle/alert/engine/utils/CompressionUtilsTest.java
deleted file mode 100644
index 0861597..0000000
--- a/eagle-core/eagle-alert/alert/alert-engine/alert-engine-base/src/test/java/org/apache/eagle/alert/engine/utils/CompressionUtilsTest.java
+++ /dev/null
@@ -1,43 +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
- * <p/>
- * http://www.apache.org/licenses/LICENSE-2.0
- * <p/>
- * 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.eagle.alert.engine.utils;
-
-import org.junit.Assert;
-import org.junit.Test;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-
-import java.io.IOException;
-
-public class CompressionUtilsTest {
-    private final static Logger LOG = LoggerFactory.getLogger(CompressionUtilsTest.class);
-
-    @Test
-    public void testCompressAndDecompress() throws IOException {
-        String value = "http://www.apache.org/licenses/LICENSE-2.0";
-        byte[] original = value.getBytes();
-        byte[] compressed = CompressionUtils.compress(original);
-        byte[] decompressed = CompressionUtils.decompress(compressed);
-
-        LOG.info("original size: {}",original.length);
-        LOG.info("compressed size: {}",compressed.length);
-        LOG.info("decompressed size: {}",decompressed.length);
-
-        String decompressedValue = new String(decompressed);
-        Assert.assertEquals(value,decompressedValue);
-    }
-}

http://git-wip-us.apache.org/repos/asf/incubator-eagle/blob/737e5a2d/eagle-core/eagle-alert/alert/alert-engine/alert-engine-base/src/test/java/org/apache/eagle/alert/engine/utils/TimePeriodUtilsTest.java
----------------------------------------------------------------------
diff --git a/eagle-core/eagle-alert/alert/alert-engine/alert-engine-base/src/test/java/org/apache/eagle/alert/engine/utils/TimePeriodUtilsTest.java b/eagle-core/eagle-alert/alert/alert-engine/alert-engine-base/src/test/java/org/apache/eagle/alert/engine/utils/TimePeriodUtilsTest.java
deleted file mode 100644
index cad53d4..0000000
--- a/eagle-core/eagle-alert/alert/alert-engine/alert-engine-base/src/test/java/org/apache/eagle/alert/engine/utils/TimePeriodUtilsTest.java
+++ /dev/null
@@ -1,91 +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.eagle.alert.engine.utils;
-
-import java.text.ParseException;
-
-import org.apache.eagle.alert.utils.DateTimeUtil;
-import org.apache.eagle.alert.utils.TimePeriodUtils;
-import org.joda.time.Period;
-import org.joda.time.Seconds;
-import org.junit.Assert;
-import org.junit.Test;
-
-public class TimePeriodUtilsTest {
-    @Test
-    public void testJodaTimePeriod() throws ParseException {
-        String periodText = "PT10m";
-        Period period = new Period(periodText);
-        int seconds = period.toStandardSeconds().getSeconds();
-        Assert.assertEquals(600, seconds);
-        Assert.assertEquals(60, period.toStandardSeconds().dividedBy(10).getSeconds());
-    }
-
-    @Test
-    public void testJodaTimePeriodBySeconds() throws ParseException {
-        String periodText = "PT10s";
-        Period period = new Period(periodText);
-        int seconds = period.toStandardSeconds().getSeconds();
-        Assert.assertEquals(10, seconds);
-    }
-
-    @Test
-    public void testFormatSecondsByPeriod15M() throws ParseException {
-
-        Period period = new Period("PT15m");
-        Seconds seconds = period.toStandardSeconds();
-        Assert.assertEquals(15*60,seconds.getSeconds());
-
-        long time = DateTimeUtil.humanDateToSeconds("2015-07-01 13:56:12");
-        long expect = DateTimeUtil.humanDateToSeconds("2015-07-01 13:45:00");
-        long result = TimePeriodUtils.formatSecondsByPeriod(time,seconds);
-        Assert.assertEquals(expect,result);
-
-        time = DateTimeUtil.humanDateToSeconds("2015-07-01 03:14:59");
-        expect = DateTimeUtil.humanDateToSeconds("2015-07-01 03:00:00");
-        result = TimePeriodUtils.formatSecondsByPeriod(time, seconds);
-        Assert.assertEquals(expect,result);
-
-        time = DateTimeUtil.humanDateToSeconds("2015-07-01 03:14:59");
-        expect = DateTimeUtil.humanDateToSeconds("2015-07-01 03:00:00");
-        result = TimePeriodUtils.formatSecondsByPeriod(time, seconds);
-        Assert.assertEquals(expect,result);
-    }
-
-    @Test
-     public void testFormatSecondsByPeriod1H() throws ParseException {
-
-        Period period = new Period("PT1h");
-        Seconds seconds = period.toStandardSeconds();
-        Assert.assertEquals(60*60,seconds.getSeconds());
-
-        long time = DateTimeUtil.humanDateToSeconds("2015-07-01 13:56:12");
-        long expect = DateTimeUtil.humanDateToSeconds("2015-07-01 13:00:00");
-        long result = TimePeriodUtils.formatSecondsByPeriod(time,seconds);
-        Assert.assertEquals(expect,result);
-
-        time = DateTimeUtil.humanDateToSeconds("2015-07-01 03:14:59");
-        expect = DateTimeUtil.humanDateToSeconds("2015-07-01 03:00:00");
-        result = TimePeriodUtils.formatSecondsByPeriod(time, seconds);
-        Assert.assertEquals(expect,result);
-
-        time = DateTimeUtil.humanDateToSeconds("2015-07-01 03:30:59");
-        expect = DateTimeUtil.humanDateToSeconds("2015-07-01 03:00:00");
-        result = TimePeriodUtils.formatSecondsByPeriod(time, seconds);
-        Assert.assertEquals(expect,result);
-    }
-}
\ No newline at end of file

http://git-wip-us.apache.org/repos/asf/incubator-eagle/blob/737e5a2d/eagle-core/eagle-alert/alert/alert-engine/alert-engine-base/src/test/resources/application-integration.conf
----------------------------------------------------------------------
diff --git a/eagle-core/eagle-alert/alert/alert-engine/alert-engine-base/src/test/resources/application-integration.conf b/eagle-core/eagle-alert/alert/alert-engine/alert-engine-base/src/test/resources/application-integration.conf
deleted file mode 100644
index 13d4ee1..0000000
--- a/eagle-core/eagle-alert/alert/alert-engine/alert-engine-base/src/test/resources/application-integration.conf
+++ /dev/null
@@ -1,57 +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.
-{
-  "topology" : {
-    "name" : "alertUnitTopology_1",
-    "numOfTotalWorkers": 20,
-    "numOfSpoutTasks" : 1,
-    "numOfRouterBolts" : 4,
-    "numOfAlertBolts" : 10,
-    "numOfPublishTasks" : 1,
-    "localMode" : "true"
-  },
-  "spout" : {
-    "kafkaBrokerZkQuorum": "localhost:2181",
-    "kafkaBrokerZkBasePath": "/brokers",
-    "stormKafkaUseSameZkQuorumWithKafkaBroker": true,
-    "stormKafkaTransactionZkQuorum": "",
-    "stormKafkaTransactionZkPath": "/consumers",
-    "stormKafkaEagleConsumer": "eagle_consumer",
-    "stormKafkaStateUpdateIntervalMs": 2000,
-    "stormKafkaFetchSizeBytes": 1048586,
-  },
-  "zkConfig" : {
-    "zkQuorum" : "localhost:2181",
-    "zkRoot" : "/alert",
-    "zkSessionTimeoutMs" : 10000,
-    "connectionTimeoutMs" : 10000,
-    "zkRetryTimes" : 3,
-    "zkRetryInterval" : 3000
-  },
-  "dynamicConfigSource" : {
-    "initDelayMillis": 3000,
-    "delayMillis" : 10000
-  },
-  "metadataService": {
-	"context" : "/api",
-	"host" : "localhost",
-	"port" : 8080
-  },
-  "coordinatorService": {
-  	"host": "localhost",
-  	"port": "9090",
-  	"context" : "/api"
-  }
-}
\ No newline at end of file

http://git-wip-us.apache.org/repos/asf/incubator-eagle/blob/737e5a2d/eagle-core/eagle-alert/alert/alert-engine/alert-engine-base/src/test/resources/application-test-backup.conf
----------------------------------------------------------------------
diff --git a/eagle-core/eagle-alert/alert/alert-engine/alert-engine-base/src/test/resources/application-test-backup.conf b/eagle-core/eagle-alert/alert/alert-engine/alert-engine-base/src/test/resources/application-test-backup.conf
deleted file mode 100755
index 2c99a68..0000000
--- a/eagle-core/eagle-alert/alert/alert-engine/alert-engine-base/src/test/resources/application-test-backup.conf
+++ /dev/null
@@ -1,71 +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.
-{
-  "topology" : {
-    "name" : "alertUnitTopology_bug",
-    "numOfSpoutTasks" : 3,
-    "numOfRouterBolts" : 6,
-    "numOfAlertBolts" : 6,
-    "numOfPublishTasks" : 1,
-    "numOfTotalWorkers":1,
-    "messageTimeoutSecs": 30,     // topology.message.timeout.secs: 30 by default
-    "localMode" : true
-  },
-  "spout" : {
-    "kafkaBrokerZkQuorum": "10.64.243.71:2181",
-    "kafkaBrokerZkBasePath": "/brokers",
-    "stormKafkaUseSameZkQuorumWithKafkaBroker": true,
-    "stormKafkaTransactionZkQuorum": "",
-    "stormKafkaTransactionZkPath": "/consumers",
-    "stormKafkaEagleConsumer": "eagle_consumer",
-    "stormKafkaStateUpdateIntervalMs": 2000,
-    "stormKafkaFetchSizeBytes": 1048586,
-  },
-  "zkConfig" : {
-    "zkQuorum" : "10.64.243.71:2181",
-    "zkRoot" : "/alert",
-    "zkSessionTimeoutMs" : 10000,
-    "connectionTimeoutMs" : 10000,
-    "zkRetryTimes" : 3,
-    "zkRetryInterval" : 3000
-  },
-  "dynamicConfigSource" : {
-    "initDelayMillis": 3000,
-    "delayMillis" : 10000
-  },
-  "metadataService": {
-    "context" : "/api",
-    "host" : "localhost",
-    "port" : 8080
-  },
-  "metric":{
-    "tags":{
-      "topologyName":"alertUnitTopology_1"
-    }
-    "sink": {
-//      "kafka": {
-//        "topic": "alert_metric_test"
-//        "bootstrap.servers": "localhost:9092"
-//      }
-      "logger": {
-        "level":"DEBUG"
-      }
-      "elasticsearch": {
-        "hosts": ["10.64.223.222:9200"]
-        "index": "alert_metric_test"
-      }
-    }
-  }
-}
\ No newline at end of file

http://git-wip-us.apache.org/repos/asf/incubator-eagle/blob/737e5a2d/eagle-core/eagle-alert/alert/alert-engine/alert-engine-base/src/test/resources/application-test.conf
----------------------------------------------------------------------
diff --git a/eagle-core/eagle-alert/alert/alert-engine/alert-engine-base/src/test/resources/application-test.conf b/eagle-core/eagle-alert/alert/alert-engine/alert-engine-base/src/test/resources/application-test.conf
deleted file mode 100755
index f4a797e..0000000
--- a/eagle-core/eagle-alert/alert/alert-engine/alert-engine-base/src/test/resources/application-test.conf
+++ /dev/null
@@ -1,68 +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.
-{
-  "topology" : {
-    "name" : "alertUnitTopology_1_test",
-    "numOfSpoutTasks" : 3,
-    "numOfRouterBolts" : 6,
-    "numOfAlertBolts" : 6,
-    "numOfPublishTasks" : 1,
-    "numOfTotalWorkers":1,
-    "messageTimeoutSecs": 30,     // topology.message.timeout.secs: 30 by default
-    "localMode" : true
-  },
-  "spout" : {
-    "kafkaBrokerZkQuorum": "localhost:2181",
-    "kafkaBrokerZkBasePath": "/brokers",
-    "stormKafkaUseSameZkQuorumWithKafkaBroker": true,
-    "stormKafkaTransactionZkQuorum": "",
-    "stormKafkaTransactionZkPath": "/consumers",
-    "stormKafkaEagleConsumer": "eagle_consumer",
-    "stormKafkaStateUpdateIntervalMs": 2000,
-    "stormKafkaFetchSizeBytes": 1048586,
-  },
-  "zkConfig" : {
-    "zkQuorum" : "localhost:2181",
-    "zkRoot" : "/alert",
-    "zkSessionTimeoutMs" : 10000,
-    "connectionTimeoutMs" : 10000,
-    "zkRetryTimes" : 3,
-    "zkRetryInterval" : 3000
-  },
-  "dynamicConfigSource" : {
-    "initDelayMillis": 3000,
-    "delayMillis" : 10000
-  },
-  "metadataService": {
-    "context" : "/api",
-    "host" : "localhost",
-    "port" : 8080
-  },
-  "metric":{
-    "sink": {
-//      "kafka": {
-//        "topic": "alert_metric_test"
-//        "bootstrap.servers": "localhost:9092"
-//      }
-      "logger": {
-        "level":"INFO"
-      }
-      "elasticsearch": {
-        "hosts": ["10.64.223.222:9200"]
-        "index": "alert_metric_test"
-      }
-    }
-  }
-}
\ No newline at end of file

http://git-wip-us.apache.org/repos/asf/incubator-eagle/blob/737e5a2d/eagle-core/eagle-alert/alert/alert-engine/alert-engine-base/src/test/resources/correlation/application-integration-2.conf
----------------------------------------------------------------------
diff --git a/eagle-core/eagle-alert/alert/alert-engine/alert-engine-base/src/test/resources/correlation/application-integration-2.conf b/eagle-core/eagle-alert/alert/alert-engine/alert-engine-base/src/test/resources/correlation/application-integration-2.conf
deleted file mode 100644
index bb998cd..0000000
--- a/eagle-core/eagle-alert/alert/alert-engine/alert-engine-base/src/test/resources/correlation/application-integration-2.conf
+++ /dev/null
@@ -1,57 +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.
-{
-  "topology" : {
-    "name" : "alertUnitTopology_2",
-    "numOfSpoutTasks" : 1,
-    "numOfRouterBolts" : 4,
-    "numOfAlertBolts" : 10,
-    "numOfPublishTasks" : 1,
-    "numOfTotalWorkers": 20,
-    "localMode" : "true"
-  },
-  "spout" : {
-    "kafkaBrokerZkQuorum": "localhost:2181",
-    "kafkaBrokerZkBasePath": "/brokers",
-    "stormKafkaUseSameZkQuorumWithKafkaBroker": true,
-    "stormKafkaTransactionZkQuorum": "",
-    "stormKafkaTransactionZkPath": "/consumers",
-    "stormKafkaEagleConsumer": "eagle_consumer",
-    "stormKafkaStateUpdateIntervalMs": 2000,
-    "stormKafkaFetchSizeBytes": 1048586,
-  },
-  "zkConfig" : {
-    "zkQuorum" : "localhost:2181",
-    "zkRoot" : "/alert",
-    "zkSessionTimeoutMs" : 10000,
-    "connectionTimeoutMs" : 10000,
-    "zkRetryTimes" : 3,
-    "zkRetryInterval" : 3000
-  },
-  "dynamicConfigSource" : {
-    "initDelayMillis": 3000,
-    "delayMillis" : 10000
-  },
-  "metadataService": {
-	"context" : "/api",
-	"host" : "localhost",
-	"port" : 8080
-  },
-  "coordinatorService": {
-  	"host": "localhost",
-  	"port": "9090",
-  	"context" : "/api"
-  }
-}
\ No newline at end of file

http://git-wip-us.apache.org/repos/asf/incubator-eagle/blob/737e5a2d/eagle-core/eagle-alert/alert/alert-engine/alert-engine-base/src/test/resources/correlation/datasources.json
----------------------------------------------------------------------
diff --git a/eagle-core/eagle-alert/alert/alert-engine/alert-engine-base/src/test/resources/correlation/datasources.json b/eagle-core/eagle-alert/alert/alert-engine/alert-engine-base/src/test/resources/correlation/datasources.json
deleted file mode 100644
index 946acd6..0000000
--- a/eagle-core/eagle-alert/alert/alert-engine/alert-engine-base/src/test/resources/correlation/datasources.json
+++ /dev/null
@@ -1,37 +0,0 @@
-[
-{
-	"name": "eslog_datasource",
-	"type": "KAFKA",
-	"properties": {
-	},
-	"topic": "eslogs",
-	"schemeCls": "org.apache.eagle.alert.engine.scheme.JsonScheme",
-	"codec": {
-		"streamNameSelectorProp": {
-			"userProvidedStreamName" : "esStream",
-			"streamNameFormat":"%s"
-		},
-		"streamNameSelectorCls":"org.apache.eagle.alert.engine.scheme.JsonStringStreamNameSelector",
-		"timestampColumn": "timestamp",
-		"timestampFormat":""
-	}
-},
-{
-	"name": "bootfailure_datasource",
-	"type": "KAFKA",
-	"properties": {
-	},
-	"topic": "bootfailures",
-	"schemeCls": "org.apache.eagle.alert.engine.scheme.JsonScheme",
-	"codec": {
-		"streamNameSelectorProp": {
-			"userProvidedStreamName" : "ifStream",
-			"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/incubator-eagle/blob/737e5a2d/eagle-core/eagle-alert/alert/alert-engine/alert-engine-base/src/test/resources/correlation/policies.json
----------------------------------------------------------------------
diff --git a/eagle-core/eagle-alert/alert/alert-engine/alert-engine-base/src/test/resources/correlation/policies.json b/eagle-core/eagle-alert/alert/alert-engine/alert-engine-base/src/test/resources/correlation/policies.json
deleted file mode 100644
index 4702575..0000000
--- a/eagle-core/eagle-alert/alert/alert-engine/alert-engine-base/src/test/resources/correlation/policies.json
+++ /dev/null
@@ -1,39 +0,0 @@
-[
-{
-	"name": "logStreamJoinBootFailure",
-	"description" : "policy to check host perfmon_cpu",
-	"inputStreams": [
-		"esStream",
-		"ifStream"
-	],
-	"outputStreams": [
-		"log_stream_join_output"
-	],
-	"definition": {
-		"type": "siddhi",
-		"value": " from esStream#window.externalTime(timestamp, 20 min) as a join ifStream#window.externalTime(timestamp, 5 min) as b on a.instanceUuid == b.instanceUuid select logLevel, a.host as aHost, a.component, a.message as logMessage, b.message as failMessage, a.timestamp as t1, b.timestamp as t2, b.host as bHost, count(1) as errorCount insert into log_stream_join_output;  "
-	},
-	"partitionSpec": [
-		{
-			"streamId" : "esStream",
-			"type" : "GROUPBY",
-			"columns" : [
-				"instanceUuid"
-			],
-			"sortSpec": {
-				"windowPeriod" : "PT1M"
-			}
-		},
-		{
-			"streamId" : "ifStream",
-			"type" : "GROUPBY",
-			"columns" : [
-				"instanceUuid"
-			],
-			"sortSpec": {
-				"windowPeriod" : "PT1M"
-			}
-		}
-	]
-}
-]
\ No newline at end of file

http://git-wip-us.apache.org/repos/asf/incubator-eagle/blob/737e5a2d/eagle-core/eagle-alert/alert/alert-engine/alert-engine-base/src/test/resources/correlation/publishments.json
----------------------------------------------------------------------
diff --git a/eagle-core/eagle-alert/alert/alert-engine/alert-engine-base/src/test/resources/correlation/publishments.json b/eagle-core/eagle-alert/alert/alert-engine/alert-engine-base/src/test/resources/correlation/publishments.json
deleted file mode 100644
index 7b531fc..0000000
--- a/eagle-core/eagle-alert/alert/alert-engine/alert-engine-base/src/test/resources/correlation/publishments.json
+++ /dev/null
@@ -1,17 +0,0 @@
-[
-{
-	"name":"log-stream-join-output",
-	"type":"org.apache.eagle.alert.engine.publisher.impl.AlertEmailPublisher",
-	"inputStreams": [
-		"log_stream_join_output"
-	],
-	"properties": {
-		"subject":"UMP Test Alert",
-        "template":"",
-	  "sender": "sender@corp.com",
-	  "recipients": "receiver@corp.com",
-	  "smtp.server":"mailhost.com"
-	},
-	"dedupIntervalMin" : "1"
-}
-]
\ No newline at end of file

http://git-wip-us.apache.org/repos/asf/incubator-eagle/blob/737e5a2d/eagle-core/eagle-alert/alert/alert-engine/alert-engine-base/src/test/resources/correlation/streamdefinitions.json
----------------------------------------------------------------------
diff --git a/eagle-core/eagle-alert/alert/alert-engine/alert-engine-base/src/test/resources/correlation/streamdefinitions.json b/eagle-core/eagle-alert/alert/alert-engine/alert-engine-base/src/test/resources/correlation/streamdefinitions.json
deleted file mode 100644
index 0a26a28..0000000
--- a/eagle-core/eagle-alert/alert/alert-engine/alert-engine-base/src/test/resources/correlation/streamdefinitions.json
+++ /dev/null
@@ -1,93 +0,0 @@
-[
-{
-	"streamId": "esStream",
-	"dataSource" : "eslog_datasource",
-	"description":"the data stream for es log of different modules",
-	"validate": false,
-	"timeseries":false,
-	"columns": [
-		{
-			"name": "instanceUuid",
-			"type" : "string",
-			"defaultValue": "",
-			"required":true
-		},
-		{
-			"name": "timestamp",
-			"type" : "long",
-			"defaultValue": 0,
-			"required":true
-		},
-		{
-			"name": "logLevel",
-			"type" : "string",
-			"defaultValue": "ERROR",
-			"required": true
-		},
-		{
-			"name": "message",
-			"type" : "string",
-			"defaultValue": "",
-			"required":true
-		},
-		{
-			"name": "reqId",
-			"type" : "string",
-			"defaultValue": "",
-			"required":true
-		},
-		{
-			"name": "host",
-			"type" : "string",
-			"defaultValue": "",
-			"required":true
-		},
-		{
-			"name": "component",
-			"type" : "string",
-			"defaultValue": "nova",
-			"required":true
-		}
-	]
-}
-,
-{
-	"streamId": "ifStream",
-	"dataSource" : "bootfailure_datasource",
-	"description":"the data stream for boot failure(instance fault)",
-	"validate": false,
-	"timeseries":false,
-	"columns": [
-		{
-			"name": "instanceUuid",
-			"type" : "string",
-			"defaultValue": "",
-			"required":true
-		},
-		{
-			"name": "timestamp",
-			"type" : "long",
-			"defaultValue": 0,
-			"required":true
-		},
-		{
-			"name": "reqId",
-			"type" : "string",
-			"defaultValue": "",
-			"required": true
-		},
-		{
-			"name": "message",
-			"type" : "string",
-			"defaultValue": "",
-			"required":true
-		},
-		{
-			"name": "host",
-			"type" : "string",
-			"defaultValue": "",
-			"required":true
-		}
-	]
-}
-]
\ No newline at end of file

http://git-wip-us.apache.org/repos/asf/incubator-eagle/blob/737e5a2d/eagle-core/eagle-alert/alert/alert-engine/alert-engine-base/src/test/resources/correlation/topologies.json
----------------------------------------------------------------------
diff --git a/eagle-core/eagle-alert/alert/alert-engine/alert-engine-base/src/test/resources/correlation/topologies.json b/eagle-core/eagle-alert/alert/alert-engine/alert-engine-base/src/test/resources/correlation/topologies.json
deleted file mode 100644
index 9aa8716..0000000
--- a/eagle-core/eagle-alert/alert/alert-engine/alert-engine-base/src/test/resources/correlation/topologies.json
+++ /dev/null
@@ -1,31 +0,0 @@
-[
-{
-	"name": "alertUnitTopology_2",
-	"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
-}
-]

http://git-wip-us.apache.org/repos/asf/incubator-eagle/blob/737e5a2d/eagle-core/eagle-alert/alert/alert-engine/alert-engine-base/src/test/resources/datasources.json
----------------------------------------------------------------------
diff --git a/eagle-core/eagle-alert/alert/alert-engine/alert-engine-base/src/test/resources/datasources.json b/eagle-core/eagle-alert/alert/alert-engine/alert-engine-base/src/test/resources/datasources.json
deleted file mode 100644
index 77a280c..0000000
--- a/eagle-core/eagle-alert/alert/alert-engine/alert-engine-base/src/test/resources/datasources.json
+++ /dev/null
@@ -1,19 +0,0 @@
-[
-{
-	"name": "perfmon_datasource",
-	"type": "KAFKA",
-	"properties": {
-	},
-	"topic": "perfmon_metrics",
-	"schemeCls": "org.apache.eagle.alert.engine.scheme.JsonScheme",
-	"codec": {
-		"streamNameSelectorProp": {
-			"fieldNamesToInferStreamName" : "metric",
-			"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/incubator-eagle/blob/737e5a2d/eagle-core/eagle-alert/alert/alert-engine/alert-engine-base/src/test/resources/log4j.properties
----------------------------------------------------------------------
diff --git a/eagle-core/eagle-alert/alert/alert-engine/alert-engine-base/src/test/resources/log4j.properties b/eagle-core/eagle-alert/alert/alert-engine/alert-engine-base/src/test/resources/log4j.properties
deleted file mode 100644
index 3ba587d..0000000
--- a/eagle-core/eagle-alert/alert/alert-engine/alert-engine-base/src/test/resources/log4j.properties
+++ /dev/null
@@ -1,23 +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
-
-#log4j.logger.org.apache.eagle.alert.metric=DEBUG
\ No newline at end of file

http://git-wip-us.apache.org/repos/asf/incubator-eagle/blob/737e5a2d/eagle-core/eagle-alert/alert/alert-engine/alert-engine-base/src/test/resources/policies.json
----------------------------------------------------------------------
diff --git a/eagle-core/eagle-alert/alert/alert-engine/alert-engine-base/src/test/resources/policies.json b/eagle-core/eagle-alert/alert/alert-engine/alert-engine-base/src/test/resources/policies.json
deleted file mode 100644
index 5edece9..0000000
--- a/eagle-core/eagle-alert/alert/alert-engine/alert-engine-base/src/test/resources/policies.json
+++ /dev/null
@@ -1,54 +0,0 @@
-[
-{
-	"name": "perfmon_cpu_host_check",
-	"description" : "policy to check host perfmon_cpu",
-	"inputStreams": [
-		"perfmon_cpu_stream"
-	],
-	"outputStreams": [
-		"perfmon_cpu_check_output"
-	],
-	"definition": {
-		"type": "siddhi",
-		"value": "from perfmon_cpu_stream[value > 90.0] select * group by host insert into perfmon_cpu_check_output;"
-	},
-	"partitionSpec": [
-		{
-			"streamId" : "perfmon_cpu_stream",
-			"type" : "GROUPBY",
-			"columns" : [
-				"host"
-			],
-			"sortSpec": {
-				"windowPeriod" : "PT1M"
-			}
-		}
-	]
-},
-{
-	"name": "perfmon_cpu_pool_check",
-	"description" : "policy to check pool perfmon_cpu",
-	"inputStreams": [
-		"perfmon_cpu_stream"
-	],
-	"outputStreams": [
-		"perfmon_cpu_check_output"
-	],
-	"definition": {
-		"type": "siddhi",
-		"value": "from perfmon_cpu_stream[value > 75.0] select * group by pool insert into perfmon_cpu_check_output;"
-	},
-	"partitionSpec": [
-		{
-			"streamId" : "perfmon_cpu_stream",
-			"type" : "GROUPBY",
-			"columns" : [
-				"pool"
-			],
-			"sortSpec": {
-				"windowPeriod" : "PT1M"
-			}
-		}
-	]
-}
-]
\ No newline at end of file

http://git-wip-us.apache.org/repos/asf/incubator-eagle/blob/737e5a2d/eagle-core/eagle-alert/alert/alert-engine/alert-engine-base/src/test/resources/publishments.json
----------------------------------------------------------------------
diff --git a/eagle-core/eagle-alert/alert/alert-engine/alert-engine-base/src/test/resources/publishments.json b/eagle-core/eagle-alert/alert/alert-engine/alert-engine-base/src/test/resources/publishments.json
deleted file mode 100644
index b3840a5..0000000
--- a/eagle-core/eagle-alert/alert/alert-engine/alert-engine-base/src/test/resources/publishments.json
+++ /dev/null
@@ -1,29 +0,0 @@
-[
-{
-	"name":"test-stream-output",
-	"type":"org.apache.eagle.alert.engine.publisher.impl.AlertKafkaPublisher",
-	"policyIds": [
-		"perfmon_cpu_host_check", "perfmon_cpu_pool_check"
-	],
-	"properties": {
-	  "subject":"UMP Test Alert",
-	  "template":"",
-	  "sender": "sender@corp.com",
-	  "recipients": "receiver@corp.com",
-	  "smtp.server":"mailhost.com",
-	  "connection": "plaintext",
-	  "smtp.port": "25"
-	},
-	"dedupIntervalMin" : "PT0M"
-},
-{
-  "type": "org.apache.eagle.alert.engine.publisher.impl.AlertKafkaPublisher",
-  "name":"kafka-testAlertStream",
-  "policyIds": ["perfmon_cpu_host_check"],
-  "dedupIntervalMin": "PT1M",
-  "properties":{
-    "kafka_broker":"sandbox.hortonworks.com:6667",
-    "topic":"test_kafka"
-  }
-}
-]
\ No newline at end of file

http://git-wip-us.apache.org/repos/asf/incubator-eagle/blob/737e5a2d/eagle-core/eagle-alert/alert/alert-engine/alert-engine-base/src/test/resources/publishments2.json
----------------------------------------------------------------------
diff --git a/eagle-core/eagle-alert/alert/alert-engine/alert-engine-base/src/test/resources/publishments2.json b/eagle-core/eagle-alert/alert/alert-engine/alert-engine-base/src/test/resources/publishments2.json
deleted file mode 100644
index 277ba75..0000000
--- a/eagle-core/eagle-alert/alert/alert-engine/alert-engine-base/src/test/resources/publishments2.json
+++ /dev/null
@@ -1,19 +0,0 @@
-[
-{
-	"name":"test-stream-output",
-	"type":"org.apache.eagle.alert.engine.publisher.impl.AlertEmailPublisher",
-	"policyIds": [
-		"policy1", "policy2"
-	],
-	"properties": {
-	  "subject":"UMP Test Alert",
-	  "template":"",
-	  "sender": "sender@corp.com",
-	  "recipients": "receiver@corp.com",
-	  "smtp.server":"mailhost.com",
-	  "connection": "plaintext",
-	  "smtp.port": "25"
-	},
-	"dedupIntervalMin" : "PT0M"
-}
-]
\ No newline at end of file

http://git-wip-us.apache.org/repos/asf/incubator-eagle/blob/737e5a2d/eagle-core/eagle-alert/alert/alert-engine/alert-engine-base/src/test/resources/sample_perfmon_data.json
----------------------------------------------------------------------
diff --git a/eagle-core/eagle-alert/alert/alert-engine/alert-engine-base/src/test/resources/sample_perfmon_data.json b/eagle-core/eagle-alert/alert/alert-engine/alert-engine-base/src/test/resources/sample_perfmon_data.json
deleted file mode 100644
index c63b9ff..0000000
--- a/eagle-core/eagle-alert/alert/alert-engine/alert-engine-base/src/test/resources/sample_perfmon_data.json
+++ /dev/null
@@ -1,3 +0,0 @@
-[
-{"host": "", "timestamp" : "", "metric" : "", "pool": "", "value": 1.0, "colo": "phx"},
-]
\ No newline at end of file

http://git-wip-us.apache.org/repos/asf/incubator-eagle/blob/737e5a2d/eagle-core/eagle-alert/alert/alert-engine/alert-engine-base/src/test/resources/streamdefinitions.json
----------------------------------------------------------------------
diff --git a/eagle-core/eagle-alert/alert/alert-engine/alert-engine-base/src/test/resources/streamdefinitions.json b/eagle-core/eagle-alert/alert/alert-engine/alert-engine-base/src/test/resources/streamdefinitions.json
deleted file mode 100644
index cbeae19..0000000
--- a/eagle-core/eagle-alert/alert/alert-engine/alert-engine-base/src/test/resources/streamdefinitions.json
+++ /dev/null
@@ -1,44 +0,0 @@
-[
-{
-	"streamId": "perfmon_cpu_stream",
-	"dataSource" : "perfmon_datasource",
-	"description":"the data stream for perfmon cpu metrics",
-	"validate": false,
-	"timeseries":false,
-	"columns": [
-		{
-			"name": "host",
-			"type" : "string",
-			"defaultValue": "",
-			"required":true
-		},
-		{
-			"name": "timestamp",
-			"type" : "long",
-			"defaultValue": 0,
-			"required":true
-		},{
-			"name": "metric",
-			"type" : "string",
-			"defaultValue": "perfmon_cpu",
-			"required": true
-		},{
-			"name": "pool",
-			"type" : "string",
-			"defaultValue": "raptor_general",
-			"required":true
-		},{
-			"name": "value",
-			"type" : "double",
-			"defaultValue": 0.0,
-			"required":true
-		},
-		{
-			"name": "colo",
-			"type" : "string",
-			"defaultValue": "",
-			"required":true
-		}
-	]
-}
-]
\ No newline at end of file

http://git-wip-us.apache.org/repos/asf/incubator-eagle/blob/737e5a2d/eagle-core/eagle-alert/alert/alert-engine/alert-engine-base/src/test/resources/testAlertBoltSpec.json
----------------------------------------------------------------------
diff --git a/eagle-core/eagle-alert/alert/alert-engine/alert-engine-base/src/test/resources/testAlertBoltSpec.json b/eagle-core/eagle-alert/alert/alert-engine/alert-engine-base/src/test/resources/testAlertBoltSpec.json
deleted file mode 100644
index fd255cd..0000000
--- a/eagle-core/eagle-alert/alert/alert-engine/alert-engine-base/src/test/resources/testAlertBoltSpec.json
+++ /dev/null
@@ -1,92 +0,0 @@
-{
-  "version": "version1",
-  "topologyName": "testTopology",
-  "boltPoliciesMap": {
-    "alertBolt0": [
-      {
-        "name": "policy1",
-        "description": null,
-        "inputStreams": [
-          "testTopic3Stream"
-        ],
-        "outputStreams": [
-          "testAlertStream"
-        ],
-        "definition": {
-          "type": "siddhi",
-          "value": "from testTopic3Stream[value=='xyz'] select value insert into testAlertStream;"
-        },
-        "partitionSpec": [
-          {
-            "streamId": "testTopic3Stream",
-            "type": "GROUPBY",
-            "columns": [
-              "value"
-            ],
-            "sortSpec": {
-              "windowPeriod": "PT10S",
-              "windowMargin": 1000
-            }
-          }
-        ],
-        "parallelismHint": 0
-      },
-      {
-        "name": "policy2",
-        "description": null,
-        "inputStreams": [
-          "testTopic4Stream"
-        ],
-        "outputStreams": [
-          "testAlertStream"
-        ],
-        "definition": {
-          "type": "siddhi",
-          "value": "from testTopic4Stream[value=='xyz'] select value insert into testAlertStream;"
-        },
-        "partitionSpec": [
-          {
-            "streamId": "testTopic4Stream",
-            "type": "GROUPBY",
-            "columns": [
-              "value"
-            ],
-            "sortSpec": {
-              "windowPeriod": "PT10S",
-              "windowMargin": 1000
-            }
-          }
-        ],
-        "parallelismHint": 0
-      },
-      {
-        "name": "policy3",
-        "description": null,
-        "inputStreams": [
-          "testTopic5Stream"
-        ],
-        "outputStreams": [
-          "testAlertStream"
-        ],
-        "definition": {
-          "type": "siddhi",
-          "value": "from testTopic5Stream[value=='xyz'] select value insert into testAlertStream;"
-        },
-        "partitionSpec": [
-          {
-            "streamId": "testTopic5Stream",
-            "type": "GROUPBY",
-            "columns": [
-              "value"
-            ],
-            "sortSpec": {
-              "windowPeriod": "PT10S",
-              "windowMargin": 1000
-            }
-          }
-        ],
-        "parallelismHint": 0
-      }
-    ]
-  }
-}
\ No newline at end of file

http://git-wip-us.apache.org/repos/asf/incubator-eagle/blob/737e5a2d/eagle-core/eagle-alert/alert/alert-engine/alert-engine-base/src/test/resources/testPublishSpec.json
----------------------------------------------------------------------
diff --git a/eagle-core/eagle-alert/alert/alert-engine/alert-engine-base/src/test/resources/testPublishSpec.json b/eagle-core/eagle-alert/alert/alert-engine/alert-engine-base/src/test/resources/testPublishSpec.json
deleted file mode 100644
index 220c8fe..0000000
--- a/eagle-core/eagle-alert/alert/alert-engine/alert-engine-base/src/test/resources/testPublishSpec.json
+++ /dev/null
@@ -1,32 +0,0 @@
-{
-  "version": "version1",
-  "topologyName": "testTopology",
-  "boltId": "alertPublishBolt",
-  "publishments": [
-    {
-      "type": "org.apache.eagle.alert.engine.publisher.impl.AlertEmailPublisher",
-      "name":"email-testAlertStream",
-      "policyIds": ["policy1", "policy2", "policy3"],
-      "dedupIntervalMin": "PT1M",
-      "properties":{
-        "subject":"UMP Test Alert",
-        "template":"",
-	  "sender": "sender@corp.com",
-	  "recipients": "receiver@corp.com",
-	  "smtp.server":"mailhost.com",
-        "connection": "plaintext",
-        "smtp.port": "25"
-      }
-    }
-/*    {
-      "type": "org.apache.eagle.alert.engine.publisher.impl.AlertKafkaPublisher",
-      "name":"kafka-testAlertStream",
-      "policyIds": ["testPolicy"],
-      "dedupIntervalMin": "PT1M",
-      "properties":{
-        "kafka_broker":"sandbox.hortonworks.com:6667",
-        "topic":"test_kafka"
-      }
-    }*/
-  ]
-}
\ No newline at end of file

http://git-wip-us.apache.org/repos/asf/incubator-eagle/blob/737e5a2d/eagle-core/eagle-alert/alert/alert-engine/alert-engine-base/src/test/resources/testPublishSpec2.json
----------------------------------------------------------------------
diff --git a/eagle-core/eagle-alert/alert/alert-engine/alert-engine-base/src/test/resources/testPublishSpec2.json b/eagle-core/eagle-alert/alert/alert-engine/alert-engine-base/src/test/resources/testPublishSpec2.json
deleted file mode 100644
index 0a16540..0000000
--- a/eagle-core/eagle-alert/alert/alert-engine/alert-engine-base/src/test/resources/testPublishSpec2.json
+++ /dev/null
@@ -1,32 +0,0 @@
-{
-  "version": "version1",
-  "topologyName": "testTopology",
-  "boltId": "alertPublishBolt",
-  "publishments": [
-    {
-      "type": "org.apache.eagle.alert.engine.publisher.impl.AlertEmailPublisher",
-      "name":"email-testAlertStream",
-      "policyIds": ["policy1"],
-      "dedupIntervalMin": "PT2M",
-      "properties":{
-        "subject":"UMP Test Alert",
-        "template":"",
-	  "sender": "sender@corp.com",
-	  "recipients": "receiver@corp.com",
-	  "smtp.server":"mailhost.com",
-        "connection": "plaintext",
-        "smtp.port": "25"
-      }
-    }
-//    {
-//      "type": "org.apache.eagle.alert.engine.publisher.impl.AlertKafkaPublisher",
-//      "name":"kafka-testAlertStream",
-//      "policyIds": ["testPolicy"],
-//      "dedupIntervalMin": "PT1M",
-//      "properties":{
-//        "kafka_broker":"sandbox.hortonworks.com:6667",
-//        "topic":"test_kafka"
-//      }
-//    }
-  ]
-}
\ No newline at end of file

http://git-wip-us.apache.org/repos/asf/incubator-eagle/blob/737e5a2d/eagle-core/eagle-alert/alert/alert-engine/alert-engine-base/src/test/resources/testSpoutSpec.json
----------------------------------------------------------------------
diff --git a/eagle-core/eagle-alert/alert/alert-engine/alert-engine-base/src/test/resources/testSpoutSpec.json b/eagle-core/eagle-alert/alert/alert-engine/alert-engine-base/src/test/resources/testSpoutSpec.json
deleted file mode 100644
index c97ec43..0000000
--- a/eagle-core/eagle-alert/alert/alert-engine/alert-engine-base/src/test/resources/testSpoutSpec.json
+++ /dev/null
@@ -1,139 +0,0 @@
-{
-  "version": null,
-  "topologyId": "testTopology",
-  "kafka2TupleMetadataMap": {
-    "testTopic5": {
-      "type": null,
-      "name": "testTopic5",
-      "properties": null,
-      "topic": "testTopic5",
-      "schemeCls": "org.apache.eagle.alert.engine.scheme.JsonScheme",
-      "codec": null
-    },
-    "testTopic3": {
-      "type": null,
-      "name": "testTopic3",
-      "properties": null,
-      "topic": "testTopic3",
-      "schemeCls": "org.apache.eagle.alert.engine.scheme.PlainStringScheme",
-      "codec": null
-    },
-    "testTopic4": {
-      "type": null,
-      "name": "testTopic4",
-      "properties": null,
-      "topic": "testTopic4",
-      "schemeCls": "org.apache.eagle.alert.engine.scheme.PlainStringScheme",
-      "codec": null
-    }
-  },
-  "tuple2StreamMetadataMap": {
-    "testTopic5": {
-      "activeStreamNames": [
-        "testTopic5Stream"
-      ],
-      "streamNameSelectorProp": {
-        "userProvidedStreamName": "testTopic5Stream"
-      },
-      "streamNameSelectorCls": "org.apache.eagle.alert.engine.scheme.JsonStringStreamNameSelector",
-      "timestampColumn": "timestamp",
-      "timestampFormat": null
-    },
-    "testTopic3": {
-      "activeStreamNames": [
-        "testTopic3Stream"
-      ],
-      "streamNameSelectorProp": {
-        "userProvidedStreamName": "testTopic3Stream"
-      },
-      "streamNameSelectorCls": "org.apache.eagle.alert.engine.scheme.PlainStringStreamNameSelector",
-      "timestampColumn": "timestamp",
-      "timestampFormat": null
-    },
-    "testTopic4": {
-      "activeStreamNames": [
-        "testTopic4Stream"
-      ],
-      "streamNameSelectorProp": {
-        "userProvidedStreamName": "testTopic4Stream"
-      },
-      "streamNameSelectorCls": "org.apache.eagle.alert.engine.scheme.PlainStringStreamNameSelector",
-      "timestampColumn": "timestamp",
-      "timestampFormat": null
-    }
-  },
-  "streamRepartitionMetadataMap": {
-    "testTopic5": [
-      {
-        "topicName": "testTopic5",
-        "streamId": "defaultStringStream",
-        "groupingStrategies": [
-          {
-            "partition": {
-              "streamId": "testTopic5Stream",
-              "type": "GROUPBY",
-              "columns": [
-                "value"
-              ],
-              "sortSpec": {
-                "windowPeriod": "PT10S",
-                "windowMargin": 1000
-              }
-            },
-            "numTotalParticipatingRouterBolts": 1,
-            "startSequence": 0,
-            "totalTargetBoltIds": []
-          }
-        ]
-      }
-    ],
-    "testTopic3": [
-      {
-        "topicName": "testTopic3",
-        "streamId": "defaultStringStream",
-        "groupingStrategies": [
-          {
-            "partition": {
-              "streamId": "testTopic3Stream",
-              "type": "GROUPBY",
-              "columns": [
-                "value"
-              ],
-              "sortSpec": {
-                "windowPeriod": "PT10S",
-                "windowMargin": 1000
-              }
-            },
-            "numTotalParticipatingRouterBolts": 1,
-            "startSequence": 0,
-            "totalTargetBoltIds": []
-          }
-        ]
-      }
-    ],
-    "testTopic4": [
-      {
-        "topicName": "testTopic4",
-        "streamId": "defaultStringStream",
-        "groupingStrategies": [
-          {
-            "partition": {
-              "streamId": "testTopic4Stream",
-              "type": "GROUPBY",
-              "columns": [
-                "value"
-              ],
-              "sortSpec": {
-                "windowPeriod": "PT10S",
-                "windowMargin": 1000
-              }
-            },
-            "numTotalParticipatingRouterBolts": 1,
-            "startSequence": 0,
-            "totalTargetBoltIds": []
-          }
-        ]
-      }
-    ]
-  }
-}
\ No newline at end of file

http://git-wip-us.apache.org/repos/asf/incubator-eagle/blob/737e5a2d/eagle-core/eagle-alert/alert/alert-engine/alert-engine-base/src/test/resources/testStreamDefinitionsSpec.json
----------------------------------------------------------------------
diff --git a/eagle-core/eagle-alert/alert/alert-engine/alert-engine-base/src/test/resources/testStreamDefinitionsSpec.json b/eagle-core/eagle-alert/alert/alert-engine/alert-engine-base/src/test/resources/testStreamDefinitionsSpec.json
deleted file mode 100644
index 6b3ccff..0000000
--- a/eagle-core/eagle-alert/alert/alert-engine/alert-engine-base/src/test/resources/testStreamDefinitionsSpec.json
+++ /dev/null
@@ -1,47 +0,0 @@
-{
-  "testTopic5Stream": {
-    "streamId": "testTopic5Stream",
-    "dataSource": null,
-    "description": null,
-    "validate": false,
-    "timeseries": false,
-    "columns": [
-      {
-        "name": "value",
-        "type": "STRING",
-        "defaultValue": null,
-        "required": false
-      }
-    ]
-  },
-  "testTopic4Stream": {
-    "streamId": "testTopic4Stream",
-    "dataSource": null,
-    "description": null,
-    "validate": false,
-    "timeseries": false,
-    "columns": [
-      {
-        "name": "value",
-        "type": "STRING",
-        "defaultValue": null,
-        "required": false
-      }
-    ]
-  },
-  "testTopic3Stream": {
-    "streamId": "testTopic3Stream",
-    "dataSource": null,
-    "description": null,
-    "validate": false,
-    "timeseries": false,
-    "columns": [
-      {
-        "name": "value",
-        "type": "STRING",
-        "defaultValue": null,
-        "required": false
-      }
-    ]
-  }
-}
\ No newline at end of file


Mime
View raw message