http://git-wip-us.apache.org/repos/asf/eagle/blob/6fd95d5c/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/test/resources/interpreter/policy.json ---------------------------------------------------------------------- diff --git a/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/test/resources/interpreter/policy.json b/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/test/resources/interpreter/policy.json deleted file mode 100644 index 72eabad..0000000 --- a/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/test/resources/interpreter/policy.json +++ /dev/null @@ -1,36 +0,0 @@ -{ - "name": "network_symptomatic_join", - "description": "Set parentKey of child alerts as docId of device down alert", - "inputStreams": [ - "networkCorrelateIntermediumStream", - "deviceDownAlertStream" - ], - "outputStreams": [ - "symptomaticAlertOutputStream" - ], - "definition": { - "type": "siddhi", - "value": "from networkCorrelateIntermediumStream#window.time(10 min) as left join deviceDownAlertStream[state=='open']#window.time(10 min) as right on left.linkedSwitch == right.entity select left.name, left.pod, left.docId, left.cause, left.firstOccurrenceTime, left.bubble, left.timestamp, left.severity, left.componentType, left.linkedSwitch, left.alertSource, left.entityType, left.ip, left.alertKey, left.message, 'symptomaticAlertOutputStream' as streamName, left.component, left.linkedPort, left.namespace, left.entity, left.dc, left.status, left.endTime, left.lastModifiedTime, right.docId as parentKey insert into symptomaticAlertOutputStream;", - "properties": {}, - "inputStreams": [], - "outputStreams": [] - }, - "policyStatus": "ENABLED", - "partitionSpec": [ - { - "streamId": "networkCorrelateIntermediumStream", - "type": "GROUPBY", - "columns": [ - "linkedSwitch" - ] - }, - { - "streamId": "deviceDownAlertStream", - "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-engine/src/test/resources/interpreter/streams.json ---------------------------------------------------------------------- diff --git a/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/test/resources/interpreter/streams.json b/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/test/resources/interpreter/streams.json deleted file mode 100644 index ed7c78f..0000000 --- a/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/test/resources/interpreter/streams.json +++ /dev/null @@ -1,524 +0,0 @@ -[ - { - "streamId": "deviceDownAlertStream", - "description": "Stream definition for symptomatic parent alerts", - "validate": false, - "timeseries": false, - "dataSource": "network_aggregate_alert_output_datasource", - "columns": [ - { - "name": "docId", - "type": "STRING", - "defaultValue": "", - "required": true, - "description": "the docId for correlated alerts" - }, - { - "name": "parentKey", - "type": "STRING", - "defaultValue": "", - "required": true, - "description": "the parent key for correlated alert" - }, - { - "name": "state", - "type": "STRING", - "defaultValue": "closed", - "required": true, - "description": "the alert state" - }, - { - "name": "name", - "type": "STRING", - "defaultValue": "", - "required": true, - "description": "" - }, - { - "name": "namespace", - "type": "STRING", - "defaultValue": "", - "required": true, - "description": "" - }, - { - "name": "timestamp", - "type": "LONG", - "defaultValue": 0, - "required": true, - "description": "" - }, - { - "name": "lastModifiedTime", - "type": "LONG", - "defaultValue": 0, - "required": true, - "description": "" - }, - { - "name": "severity", - "type": "STRING", - "defaultValue": "", - "required": true, - "description": "severity for symptomatic alert" - }, - { - "name": "severityCode", - "type": "STRING", - "defaultValue": "", - "required": true, - "description": "severity code for symptomatic alert" - }, - { - "name": "streamName", - "type": "STRING", - "defaultValue": "", - "required": false - }, - { - "name": "entity", - "type": "STRING", - "defaultValue": "", - "required": false - }, - { - "name": "pod", - "type": "STRING", - "defaultValue": "", - "required": false - }, - { - "name": "bubble", - "type": "STRING", - "defaultValue": "", - "required": false - }, - { - "name": "dc", - "type": "STRING", - "defaultValue": "", - "required": false - }, - { - "name": "cause", - "type": "STRING", - "defaultValue": "", - "required": true, - "description": "" - }, - { - "name": "message", - "type": "STRING", - "defaultValue": "", - "required": true, - "description": "" - }, - { - "name": "count", - "type": "LONG", - "defaultValue": 0, - "required": false - }, - { - "name": "firstOccurrenceTime", - "type": "LONG", - "defaultValue": 0, - "required": false - }, - { - "name": "alertKey", - "type": "STRING", - "defaultValue": "", - "required": true - } - ] - }, - { - "streamId": "networkCorrelateIntermediumStream", - "description": "The template aggregated *OUTPUT* data stream schema for network correlation intermedium step", - "validate": false, - "timeseries": false, - "dataSource": "network_aggregate_alert_output_datasource", - "columns": [ - { - "name": "docId", - "type": "STRING", - "defaultValue": "", - "required": true, - "description": "the docId for aggregated alerts" - }, - { - "name": "firstOccurrenceTime", - "type": "LONG", - "defaultValue": 0, - "required": true, - "description": "firstOccurTime for aggregated alert" - }, - { - "name": "endTime", - "type": "LONG", - "defaultValue": 0, - "required": true, - "description": "the end time of aggregated alert, 0 as default" - }, - { - "name": "alertKey", - "type": "STRING", - "defaultValue": "", - "required": true, - "description": "the alert key for aggregated alert" - }, - { - "name": "parentKey", - "type": "STRING", - "defaultValue": "", - "required": true, - "description": "the parent key for aggregated alert" - }, - { - "name": "state", - "type": "STRING", - "defaultValue": "closed", - "required": true, - "description": "the alert state" - }, - { - "name": "name", - "type": "STRING", - "defaultValue": "", - "required": true, - "description": "" - }, - { - "name": "namespace", - "type": "STRING", - "defaultValue": "", - "required": true, - "description": "" - }, - { - "name": "timestamp", - "type": "LONG", - "defaultValue": 0, - "required": true, - "description": "" - }, - { - "name": "lastModifiedTime", - "type": "LONG", - "defaultValue": 0, - "required": true, - "description": "" - }, - { - "name": "severity", - "type": "STRING", - "defaultValue": "", - "required": true, - "description": "severity for aggregated alert" - }, - { - "name": "alertSource", - "type": "STRING", - "defaultValue": "", - "required": false - }, - { - "name": "streamName", - "type": "STRING", - "defaultValue": "", - "required": false - }, - { - "name": "entity", - "type": "STRING", - "defaultValue": "", - "required": false - }, - { - "name": "entityType", - "type": "STRING", - "defaultValue": "", - "required": false - }, - { - "name": "ip", - "type": "STRING", - "defaultValue": "", - "required": false - }, - { - "name": "pod", - "type": "STRING", - "defaultValue": "", - "required": false - }, - { - "name": "bubble", - "type": "STRING", - "defaultValue": "", - "required": false - }, - { - "name": "dc", - "type": "STRING", - "defaultValue": "", - "required": false - }, - { - "name": "component", - "type": "STRING", - "defaultValue": "", - "required": false - }, - { - "name": "componentType", - "type": "STRING", - "defaultValue": "", - "required": false - }, - { - "name": "status", - "type": "STRING", - "defaultValue": "", - "required": false - }, - { - "name": "cause", - "type": "STRING", - "defaultValue": "", - "required": true, - "description": "" - }, - { - "name": "message", - "type": "STRING", - "defaultValue": "", - "required": true, - "description": "" - }, - { - "name": "linkedPort", - "type": "STRING", - "defaultValue": "", - "required": true, - "description": "" - }, - { - "name": "linkedSwitch", - "type": "STRING", - "defaultValue": "", - "required": true, - "description": "" - }, - { - "name": "severityCode", - "type": "STRING", - "defaultValue": "", - "required": false, - "description": "" - }, - { - "name": "count", - "type": "LONG", - "defaultValue": 0, - "required": false, - "description": "" - } - ] - }, - { - "streamId": "symptomaticAlertOutputStream", - "description": "Stream definition for symptomatic child alerts", - "validate": false, - "timeseries": false, - "dataSource": "network_aggregate_alert_output_datasource", - "columns": [ - { - "name": "docId", - "type": "STRING", - "defaultValue": "", - "required": true, - "description": "the docId for symptomatic alerts" - }, - { - "name": "firstOccurrenceTime", - "type": "LONG", - "defaultValue": 0, - "required": true, - "description": "firstOccurTime for symptomatic alert" - }, - { - "name": "endTime", - "type": "LONG", - "defaultValue": 0, - "required": true, - "description": "the end time of symptomatic alert, 0 as default" - }, - { - "name": "alertKey", - "type": "STRING", - "defaultValue": "", - "required": true, - "description": "the alert key for symptomatic alert" - }, - { - "name": "parentKey", - "type": "STRING", - "defaultValue": "", - "required": true, - "description": "the parent key for symptomatic alert" - }, - { - "name": "state", - "type": "STRING", - "defaultValue": "closed", - "required": true, - "description": "the alert state" - }, - { - "name": "name", - "type": "STRING", - "defaultValue": "", - "required": true, - "description": "" - }, - { - "name": "namespace", - "type": "STRING", - "defaultValue": "", - "required": true, - "description": "" - }, - { - "name": "timestamp", - "type": "LONG", - "defaultValue": 0, - "required": true, - "description": "" - }, - { - "name": "lastModifiedTime", - "type": "LONG", - "defaultValue": 0, - "required": true, - "description": "" - }, - { - "name": "severity", - "type": "STRING", - "defaultValue": "", - "required": true, - "description": "severity for symptomatic alert" - }, - { - "name": "severityCode", - "type": "STRING", - "defaultValue": "", - "required": true, - "description": "severity code for symptomatic alert" - }, - { - "name": "streamName", - "type": "STRING", - "defaultValue": "", - "required": false - }, - { - "name": "entity", - "type": "STRING", - "defaultValue": "", - "required": false - }, - { - "name": "entityType", - "type": "STRING", - "defaultValue": "", - "required": false - }, - { - "name": "ip", - "type": "STRING", - "defaultValue": "", - "required": false - }, - { - "name": "pod", - "type": "STRING", - "defaultValue": "", - "required": false - }, - { - "name": "bubble", - "type": "STRING", - "defaultValue": "", - "required": false - }, - { - "name": "dc", - "type": "STRING", - "defaultValue": "", - "required": false - }, - { - "name": "component", - "type": "STRING", - "defaultValue": "", - "required": false - }, - { - "name": "componentType", - "type": "STRING", - "defaultValue": "", - "required": false - }, - { - "name": "status", - "type": "STRING", - "defaultValue": "", - "required": false - }, - { - "name": "alertSource", - "type": "STRING", - "defaultValue": "", - "required": false - }, - { - "name": "cause", - "type": "STRING", - "defaultValue": "", - "required": true, - "description": "" - }, - { - "name": "message", - "type": "STRING", - "defaultValue": "", - "required": true, - "description": "" - }, - { - "name": "linkedPort", - "type": "STRING", - "defaultValue": "", - "required": true, - "description": "" - }, - { - "name": "linkedSwitch", - "type": "STRING", - "defaultValue": "", - "required": true, - "description": "" - }, - { - "name": "count", - "type": "LONG", - "defaultValue": 0, - "required": true, - "description": "" - } - ] - } -] \ 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-engine/src/test/resources/log4j.properties ---------------------------------------------------------------------- diff --git a/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/test/resources/log4j.properties b/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/test/resources/log4j.properties deleted file mode 100644 index be79336..0000000 --- a/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/test/resources/log4j.properties +++ /dev/null @@ -1,20 +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=DEBUG, 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.engine.evaluator.nodata=DEBUG \ 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-engine/src/test/resources/loopback/datasources.json ---------------------------------------------------------------------- diff --git a/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/test/resources/loopback/datasources.json b/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/test/resources/loopback/datasources.json deleted file mode 100644 index 4162ed6..0000000 --- a/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/test/resources/loopback/datasources.json +++ /dev/null @@ -1,36 +0,0 @@ -[ - { - "name": "network_syslog_datasource", - "type": "KAFKA", - "properties": { - }, - "topic": "syslog_events", - "schemeCls": "org.apache.eagle.alert.engine.scheme.JsonScheme", - "codec": { - "streamNameSelectorProp": { - "userProvidedStreamName": "syslog_stream", - "streamNameFormat": "%s" - }, - "streamNameSelectorCls": "org.apache.eagle.alert.engine.scheme.JsonStringStreamNameSelector", - "timestampColumn": "timestamp", - "timestampFormat": "" - } - }, - { - "name": "network_syslog_alert_datasource", - "type": "KAFKA", - "properties": { - }, - "topic": "syslog_alerts", - "schemeCls": "org.apache.eagle.alert.engine.scheme.JsonScheme", - "codec": { - "streamNameSelectorProp": { - "userProvidedStreamName": "syslog_stream_subalert", - "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-engine/src/test/resources/loopback/policies.json ---------------------------------------------------------------------- diff --git a/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/test/resources/loopback/policies.json b/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/test/resources/loopback/policies.json deleted file mode 100644 index 05743f5..0000000 --- a/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/test/resources/loopback/policies.json +++ /dev/null @@ -1,50 +0,0 @@ -[ - { - "name": "syslog_severity_critical_check", - "description": "syslog.severity > 3 then error", - "inputStreams": [ - "syslog_stream" - ], - "outputStreams": [ - "syslog_severity_critical_output" - ], - "definition": { - "type": "siddhi", - "value": "from syslog_stream[(severity_name == \"EMERG\" or severity_name == \"ALERT\" or severity_name ==\"CRIT\") and (regex:find(\"The system is overheating\", msg) or regex:find(\"Power Supply is not responding\",msg) or regex:find(\"Memory inconsistency detected\", msg))] select 'alert' as name, 'CRITICAL' as alertSeverity, namespace, facility_name, facility_code, severity_code,severity_name ,dims_hostname, dims_appname, msgid, msg, epochMillis, str:concat('ab', 'c') as alertKey insert into syslog_severity_critical_output;" - }, - "partitionSpec": [ - { - "streamId": "syslog_stream", - "type": "GROUPBY", - "columns": [ - "dims_hostname" - ] - } - ], - "parallelismHint": 10 - }, - { - "name": "syslog_parent_alert", - "description": "aggregate alerts into parent alerts", - "inputStreams": [ - "syslog_severity_critical_output" - ], - "outputStreams": [ - "syslog_parent_alert_aggregate_out" - ], - "definition": { - "type": "siddhi", - "value": "from syslog_severity_critical_output#window.externalTimeBatch(timestamp, 3min) select 'AggregateAlert' as name, 'CRITICAL' as alertSeverity, namespace, facility_name, facility_code, severity_code,severity_name ,dims_hostname, dims_appname, msgid, msg, epochMillis, str:subStr(alertKey, 0, 20) as alertKey insert into syslog_parent_alert_aggregate_out;" - }, - "partitionSpec": [ - { - "streamId": "syslog_severity_critical_output", - "type": "GROUPBY", - "columns": [ - "dims_hostname" - ] - } - ], - "parallelismHint": 10 - } -] \ 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-engine/src/test/resources/loopback/publishments.json ---------------------------------------------------------------------- diff --git a/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/test/resources/loopback/publishments.json b/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/test/resources/loopback/publishments.json deleted file mode 100644 index cb6198e..0000000 --- a/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/test/resources/loopback/publishments.json +++ /dev/null @@ -1,16 +0,0 @@ -[ - { - "type": "org.apache.eagle.alert.engine.publisher.impl.AlertKafkaPublisher", - "name": "network-syslog-publish", - "policyIds": [ - "syslog_severity_critical_check", - "syslog_aggregation_alert" - ], - "dedupIntervalMin": "PT0M", - "properties": { - "kafka_broker": "localhost:9092", - "topic": "syslog_alerts" - }, - "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-engine/src/test/resources/loopback/streamdefinitions.json ---------------------------------------------------------------------- diff --git a/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/test/resources/loopback/streamdefinitions.json b/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/test/resources/loopback/streamdefinitions.json deleted file mode 100644 index 68eb748..0000000 --- a/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/test/resources/loopback/streamdefinitions.json +++ /dev/null @@ -1,195 +0,0 @@ -[ - { - "streamId": "syslog_stream", - "dataSource": "network_syslog_datasource", - "description": "the data stream for syslog events", - "validate": false, - "timeseries": false, - "columns": [ - { - "name": "dims_hostname", - "type": "STRING", - "defaultValue": "", - "required": true, - "description": null - }, - { - "name": "facility_code", - "type": "INT", - "defaultValue": "", - "required": true, - "description": null - }, - { - "name": "facility_name", - "type": "STRING", - "defaultValue": "", - "required": true, - "description": null - }, - { - "name": "severity_code", - "type": "INT", - "defaultValue": "", - "required": true, - "description": null - }, - { - "name": "severity_name", - "type": "STRING", - "defaultValue": "", - "required": true, - "description": null - }, - { - "name": "msg", - "type": "STRING", - "defaultValue": "", - "required": true, - "description": null - }, - { - "name": "msgid", - "type": "STRING", - "defaultValue": "", - "required": true, - "description": null - }, - { - "name": "procid", - "type": "STRING", - "defaultValue": "", - "required": true, - "description": null - }, - { - "name": "dims_appname", - "type": "STRING", - "defaultValue": "", - "required": true, - "description": null - }, - { - "name": "name", - "type": "STRING", - "defaultValue": "", - "required": true, - "description": null - }, - { - "name": "namespace", - "type": "STRING", - "defaultValue": "", - "required": true, - "description": null - }, - { - "name": "epochMillis", - "type": "LONG", - "defaultValue": 0, - "required": true, - "description": null - } - ] - }, - { - "streamId": "syslog_severity_critical_check", - "dataSource": "network_syslog_alert_datasource", - "description": "the data stream for syslog events", - "validate": false, - "timeseries": false, - "columns": [ - { - "name": "dims_hostname", - "type": "STRING", - "defaultValue": "", - "required": true, - "description": null - }, - { - "name": "facility_code", - "type": "INT", - "defaultValue": "", - "required": true, - "description": null - }, - { - "name": "facility_name", - "type": "STRING", - "defaultValue": "", - "required": true, - "description": null - }, - { - "name": "severity_code", - "type": "INT", - "defaultValue": "", - "required": true, - "description": null - }, - { - "name": "severity_name", - "type": "STRING", - "defaultValue": "", - "required": true, - "description": null - }, - { - "name": "msg", - "type": "STRING", - "defaultValue": "", - "required": true, - "description": null - }, - { - "name": "msgid", - "type": "STRING", - "defaultValue": "", - "required": true, - "description": null - }, - { - "name": "procid", - "type": "STRING", - "defaultValue": "", - "required": true, - "description": null - }, - { - "name": "dims_appname", - "type": "STRING", - "defaultValue": "", - "required": true, - "description": null - }, - { - "name": "name", - "type": "STRING", - "defaultValue": "", - "required": true, - "description": null - }, - { - "name": "namespace", - "type": "STRING", - "defaultValue": "", - "required": true, - "description": null - }, - { - "name": "epochMillis", - "type": "LONG", - "defaultValue": 0, - "required": true, - "description": null - }, - { - "name": "alertKey", - "type": "STRING", - "defaultValue": "", - "required": true, - "description": null - } - ] - } -] \ 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-engine/src/test/resources/nodata/application-nodata.conf ---------------------------------------------------------------------- diff --git a/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/test/resources/nodata/application-nodata.conf b/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/test/resources/nodata/application-nodata.conf deleted file mode 100644 index 11df895..0000000 --- a/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/test/resources/nodata/application-nodata.conf +++ /dev/null @@ -1,60 +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": "sandbox.hortonworks.com:2181", - "kafkaBrokerZkBasePath": "/brokers", - "stormKafkaUseSameZkQuorumWithKafkaBroker": true, - "stormKafkaTransactionZkQuorum": "", - "stormKafkaTransactionZkPath": "/consumers", - "stormKafkaEagleConsumer": "eagle_consumer", - "stormKafkaStateUpdateIntervalMs": 2000, - "stormKafkaFetchSizeBytes": 1048586, - }, - "zkConfig": { - "zkQuorum": "sandbox.hortonworks.com:2181", - "zkRoot": "/alert", - "zkSessionTimeoutMs": 10000, - "connectionTimeoutMs": 10000, - "zkRetryTimes": 3, - "zkRetryInterval": 3000 - }, - "dynamicConfigSource": { - "initDelayMillis": 3000, - "delayMillis": 10000 - }, - "metadataService": { - "context": "/rest", - "host": "localhost", - "port": 8080 - }, - "coordinatorService": { - "host": "localhost", - "port": "8080", - "context": "/rest" - }, - "kafkaProducer": { - "bootstrapServers": "sandbox.hortonworks.com:6667" - } -} \ 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-engine/src/test/resources/nodata/datasources.json ---------------------------------------------------------------------- diff --git a/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/test/resources/nodata/datasources.json b/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/test/resources/nodata/datasources.json deleted file mode 100644 index 814f4c0..0000000 --- a/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/test/resources/nodata/datasources.json +++ /dev/null @@ -1,17 +0,0 @@ -[ - { - "name": "noDataAlertDataSource", - "type": "KAFKA", - "properties": {}, - "topic": "noDataAlertTopic", - "schemeCls": "org.apache.eagle.alert.engine.scheme.JsonScheme", - "codec": { - "streamNameSelectorProp": { - "userProvidedStreamName": "noDataAlertStream" - }, - "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-engine/src/test/resources/nodata/policies-provided-wisb.json ---------------------------------------------------------------------- diff --git a/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/test/resources/nodata/policies-provided-wisb.json b/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/test/resources/nodata/policies-provided-wisb.json deleted file mode 100644 index 64d6885..0000000 --- a/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/test/resources/nodata/policies-provided-wisb.json +++ /dev/null @@ -1,23 +0,0 @@ -[ - { - "name": "noDataAlertPolicy", - "description": "noDataAlertPolicy", - "inputStreams": [ - "noDataAlertStream" - ], - "outputStreams": [ - "noDataAlertStream_out" - ], - "definition": { - "type": "nodataalert", - "value": "PT1M,plain,1,host,host1,host2,host3" - }, - "partitionSpec": [ - { - "streamId": "noDataAlertStream", - "type": "GROUPBY" - } - ], - "parallelismHint": 2 - } -] \ 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-engine/src/test/resources/nodata/policies.json ---------------------------------------------------------------------- diff --git a/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/test/resources/nodata/policies.json b/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/test/resources/nodata/policies.json deleted file mode 100644 index 18d08b9..0000000 --- a/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/test/resources/nodata/policies.json +++ /dev/null @@ -1,26 +0,0 @@ -[ - { - "name": "noDataAlertPolicy", - "description": "noDataAlertPolicy", - "inputStreams": [ - "noDataAlertStream" - ], - "outputStreams": [ - "noDataAlertStream_out" - ], - "definition": { - "type": "nodataalert", - "value": "PT1M,dynamic,1,host" - }, - "partitionSpec": [ - { - "streamId": "noDataAlertStream", - "type": "GROUPBY", - "columns": [ - "host" - ] - } - ], - "parallelismHint": 2 - } -] \ 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-engine/src/test/resources/nodata/publishments.json ---------------------------------------------------------------------- diff --git a/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/test/resources/nodata/publishments.json b/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/test/resources/nodata/publishments.json deleted file mode 100644 index d8d4476..0000000 --- a/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/test/resources/nodata/publishments.json +++ /dev/null @@ -1,20 +0,0 @@ -[ - { - "name": "test-stream-output", - "type": "org.apache.eagle.alert.engine.publisher.impl.AlertEmailPublisher", - "policyIds": [ - "noDataAlertPolicy" - ], - "properties": { - "subject": "Eagle Test Alert", - "template": "", - "sender": "[email protected]", - "recipients": "[email protected]", - "smtp.server": "smtp.mailhost.com", - "connection": "plaintext", - "smtp.port": "25" - }, - "dedupIntervalMin": "PT5M", - "serializer": "org.apache.eagle.alert.engine.publisher.impl.StringEventSerializer" - } -] http://git-wip-us.apache.org/repos/asf/eagle/blob/6fd95d5c/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/test/resources/nodata/streamdefinitions.json ---------------------------------------------------------------------- diff --git a/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/test/resources/nodata/streamdefinitions.json b/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/test/resources/nodata/streamdefinitions.json deleted file mode 100644 index 4fb40d2..0000000 --- a/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/test/resources/nodata/streamdefinitions.json +++ /dev/null @@ -1,29 +0,0 @@ -[ - { - "streamId": "noDataAlertStream", - "dataSource": "noDataAlertDataSource", - "description": "the data stream for testing no data alert", - "validate": false, - "timeseries": false, - "columns": [ - { - "name": "host", - "type": "STRING", - "defaultValue": "", - "required": true - }, - { - "name": "timestamp", - "type": "LONG", - "defaultValue": 0, - "required": true - }, - { - "name": "value", - "type": "DOUBLE", - "defaultValue": "0.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-engine/src/test/resources/nodata/topologies.json ---------------------------------------------------------------------- diff --git a/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/test/resources/nodata/topologies.json b/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/test/resources/nodata/topologies.json deleted file mode 100644 index c13eeb2..0000000 --- a/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/test/resources/nodata/topologies.json +++ /dev/null @@ -1,31 +0,0 @@ -[ - { - "name": "alertUnitTopology_1", - "numOfSpout": 1, - "numOfAlertBolt": 10, - "numOfGroupBolt": 4, - "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/eagle/blob/6fd95d5c/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/test/resources/publishments1.json ---------------------------------------------------------------------- diff --git a/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/test/resources/publishments1.json b/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/test/resources/publishments1.json deleted file mode 100644 index 0b2d727..0000000 --- a/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/test/resources/publishments1.json +++ /dev/null @@ -1,25 +0,0 @@ -[ - { - "name": "test-stream-output", - "type": "org.apache.eagle.alert.engine.publisher.impl.AlertEmailPublisher", - "policyIds": [ - "perfmon_cpu_host_check", - "perfmon_cpu_pool_check" - ], - "properties": { - "subject": "Test Alert", - "template": "", - "sender": "[email protected]", - "recipients": "[email protected]", - "mail.smtp.host": "smtp.mailhost.com", - "mail.smtp.auth": "true", - "mail.username": "username", - "mail.password": "password", - "mail.debug": "false", - "mail.connection": "tls", - "mail.smtp.port": "587" - }, - "dedupIntervalMin": "PT1M", - "serializer": "org.apache.eagle.alert.engine.publisher.impl.StringEventSerializer" - } -] \ 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-engine/src/test/resources/publishments2.json ---------------------------------------------------------------------- diff --git a/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/test/resources/publishments2.json b/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/test/resources/publishments2.json deleted file mode 100644 index 96cc015..0000000 --- a/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/test/resources/publishments2.json +++ /dev/null @@ -1,25 +0,0 @@ -[ - { - "name": "test-stream-output", - "type": "org.apache.eagle.alert.engine.publisher.impl.AlertEmailPublisher", - "policyIds": [ - "policy1", - "policy2" - ], - "properties": { - "subject": "Test Alert", - "template": "", - "sender": "[email protected]", - "recipients": "[email protected]", - "mail.smtp.host": "smtp.mailhost.com", - "mail.smtp.auth": "true", - "mail.username": "username", - "mail.password": "password", - "mail.debug": "false", - "mail.connection": "tls", - "mail.smtp.port": "587" - }, - "dedupIntervalMin": "PT0M", - "serializer": "org.apache.eagle.alert.engine.publisher.impl.StringEventSerializer" - } -] \ 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-engine/src/test/resources/router/publishments-empty-dedup-field.json ---------------------------------------------------------------------- diff --git a/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/test/resources/router/publishments-empty-dedup-field.json b/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/test/resources/router/publishments-empty-dedup-field.json deleted file mode 100644 index 56c4686..0000000 --- a/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/test/resources/router/publishments-empty-dedup-field.json +++ /dev/null @@ -1,23 +0,0 @@ -[ - { - "name": "test-stream-output", - "type": "org.apache.eagle.alert.engine.publisher.impl.AlertEmailPublisher", - "policyIds": [ - "perfmon_cpu_host_check", - "perfmon_cpu_pool_check" - ], - "properties": { - "subject": "Eagle Test Alert", - "template": "", - "sender": "[email protected]", - "recipients": "[email protected]", - "smtp.server": "mailhost.com", - "connection": "plaintext", - "smtp.port": "25" - }, - "dedupIntervalMin": "PT1M", - "dedupStateField": "state", - "dedupStateCloseValue": "CLOSE", - "serializer": "org.apache.eagle.alert.engine.publisher.impl.StringEventSerializer" - } -] \ 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-engine/src/test/resources/router/publishments-extended-deduplicator.json ---------------------------------------------------------------------- diff --git a/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/test/resources/router/publishments-extended-deduplicator.json b/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/test/resources/router/publishments-extended-deduplicator.json deleted file mode 100644 index 5e14e78..0000000 --- a/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/test/resources/router/publishments-extended-deduplicator.json +++ /dev/null @@ -1,31 +0,0 @@ -[ - { - "name": "test-stream-output", - "type": "org.apache.eagle.alert.engine.publisher.impl.AlertEmailPublisher", - "policyIds": [ - "perfmon_cpu_host_check", - "perfmon_cpu_pool_check" - ], - "properties": { - "subject": "Eagle Test Alert", - "template": "", - "sender": "[email protected]", - "recipients": "[email protected]", - "smtp.server": "mailhost.com", - "connection": "plaintext", - "smtp.port": "25" - }, - "dedupIntervalMin": "PT1M", - "dedupFields": [ - "appname" - ], - "dedupStateField": "state", - "overrideDeduplicator": { - "className": "org.apache.eagle.alert.engine.publisher.dedup.TestDeduplicator", - "properties": { - "docIdField": "docId" - } - }, - "serializer": "org.apache.eagle.alert.engine.publisher.impl.StringEventSerializer" - } -] \ 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-engine/src/test/resources/router/publishments-slack.json ---------------------------------------------------------------------- diff --git a/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/test/resources/router/publishments-slack.json b/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/test/resources/router/publishments-slack.json deleted file mode 100644 index dee7106..0000000 --- a/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/test/resources/router/publishments-slack.json +++ /dev/null @@ -1,19 +0,0 @@ -[ - { - "name": "test-slack-output", - "type": "org.apache.eagle.alert.engine.publisher.impl.AlertSlackPublisher", - "policyIds": [ - "switch_check" - ], - "properties": { - "token": "your token", - "channels": "your channel1, your channel2", - "severitys": "CRITICAL" - }, - "dedupIntervalMin": "PT1M", - "dedupFields": [ - "appname" - ], - "serializer": "org.apache.eagle.alert.engine.publisher.impl.StringEventSerializer" - } -] \ 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-engine/src/test/resources/router/publishments.json ---------------------------------------------------------------------- diff --git a/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/test/resources/router/publishments.json b/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/test/resources/router/publishments.json deleted file mode 100644 index 1f4ddcc..0000000 --- a/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/test/resources/router/publishments.json +++ /dev/null @@ -1,25 +0,0 @@ -[ - { - "name": "test-stream-output", - "type": "org.apache.eagle.alert.engine.publisher.impl.AlertEmailPublisher", - "policyIds": [ - "perfmon_cpu_host_check", - "perfmon_cpu_pool_check" - ], - "properties": { - "subject": "Eagle Test Alert", - "template": "", - "sender": "[email protected]", - "recipients": "[email protected]", - "smtp.server": "mailhost.com", - "connection": "plaintext", - "smtp.port": "25" - }, - "dedupIntervalMin": "PT1M", - "dedupFields": [ - "appname" - ], - "dedupStateField": "state", - "serializer": "org.apache.eagle.alert.engine.publisher.impl.StringEventSerializer" - } -] \ 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-engine/src/test/resources/sample_perfmon_data.json ---------------------------------------------------------------------- diff --git a/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/test/resources/sample_perfmon_data.json b/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/test/resources/sample_perfmon_data.json deleted file mode 100644 index 8d1e5fa..0000000 --- a/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/test/resources/sample_perfmon_data.json +++ /dev/null @@ -1,10 +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/eagle/blob/6fd95d5c/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/test/resources/simple/application-integration.conf ---------------------------------------------------------------------- diff --git a/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/test/resources/simple/application-integration.conf b/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/test/resources/simple/application-integration.conf deleted file mode 100644 index 288d9f9..0000000 --- a/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/test/resources/simple/application-integration.conf +++ /dev/null @@ -1,66 +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": 20, - "numOfPublishTasks": 1, - "localMode": "true" - }, - "spout": { - "kafkaBrokerZkQuorum": "127.0.0.1:2181", - "kafkaBrokerZkBasePath": "/brokers", - "stormKafkaUseSameZkQuorumWithKafkaBroker": true, - "stormKafkaTransactionZkQuorum": "", - "stormKafkaTransactionZkPath": "/consumers", - "stormKafkaEagleConsumer": "eagle_consumer", - "stormKafkaStateUpdateIntervalMs": 2000, - "stormKafkaFetchSizeBytes": 1048586, - }, - "zkConfig": { - "zkQuorum": "127.0.0.1:2181", - "zkRoot": "/alert", - "zkSessionTimeoutMs": 10000, - "connectionTimeoutMs": 10000, - "zkRetryTimes": 3, - "zkRetryInterval": 3000 - }, - "dynamicConfigSource": { - "initDelayMillis": 3000, - "delayMillis": 10000 - }, - "metadataService": { - "context": "/rest", - "host": "localhost", - "port": 8080 - }, - "coordinatorService": { - "host": "localhost", - "port": "8080", - "context": "/rest" - }, - "kafkaProducer": { - "bootstrapServers": "127.0.0.1:9092" - }, - "email": { - "sender": "[email protected]", - "recipients": "[email protected]", - "mail.smtp.host": "test.eagle.com", - "mail.smtp.port": "25" - } -} http://git-wip-us.apache.org/repos/asf/eagle/blob/6fd95d5c/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/test/resources/simple/datasources.json ---------------------------------------------------------------------- diff --git a/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/test/resources/simple/datasources.json b/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/test/resources/simple/datasources.json deleted file mode 100644 index 19c70b4..0000000 --- a/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/test/resources/simple/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/eagle/blob/6fd95d5c/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/test/resources/simple/policies.json ---------------------------------------------------------------------- diff --git a/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/test/resources/simple/policies.json b/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/test/resources/simple/policies.json deleted file mode 100644 index 043d6a8..0000000 --- a/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/test/resources/simple/policies.json +++ /dev/null @@ -1,81 +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" - } - } - ] - }, - { - "name": "perfmon_cpu_pool_check_2", - "description": "policy to check pool perfmon_cpu", - "inputStreams": [ - "perfmon_cpu_stream" - ], - "outputStreams": [ - "perfmon_cpu_check_output_2" - ], - "definition": { - "type": "siddhi", - "value": "from perfmon_cpu_stream[value > 90.0] select * group by pool insert into perfmon_cpu_check_output_2;" - }, - "partitionSpec": [ - { - "streamId": "perfmon_cpu_stream", - "type": "GROUPBY", - "columns": [ - "pool" - ], - "sortSpec": { - "windowPeriod": "PT1M" - } - } - ], - "policyStatus": "DISABLED" - } -] \ 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-engine/src/test/resources/simple/publishments.json ---------------------------------------------------------------------- diff --git a/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/test/resources/simple/publishments.json b/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/test/resources/simple/publishments.json deleted file mode 100644 index 21edd0a..0000000 --- a/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/test/resources/simple/publishments.json +++ /dev/null @@ -1,34 +0,0 @@ -[ - { - "name": "test-stream-output", - "type": "org.apache.eagle.alert.engine.publisher.impl.AlertEmailPublisher", - "policyIds": [ - "perfmon_cpu_host_check", - "perfmon_cpu_pool_check" - ], - "properties": { - "subject": "Eagle Test Alert", - "template": "", - "sender": "[email protected]", - "recipients": "[email protected]", - "smtp.server": "smtp.mailhost.com", - "connection": "plaintext", - "smtp.port": "25" - }, - "dedupIntervalMin": "PT1M", - "serializer": "org.apache.eagle.alert.engine.publisher.impl.StringEventSerializer" - }, - { - "type": "org.apache.eagle.alert.engine.publisher.impl.AlertKafkaPublisher", - "name": "kafka-testAlertStream", - "policyIds": [ - "perfmon_cpu_host_check" - ], - "dedupIntervalMin": "PT1M", - "properties": { - "kafka_broker": "localhost:9092", - "topic": "test_kafka" - }, - "serializer": "org.apache.eagle.alert.engine.publisher.impl.StringEventSerializer" - } -] http://git-wip-us.apache.org/repos/asf/eagle/blob/6fd95d5c/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/test/resources/simple/streamdefinitions.json ---------------------------------------------------------------------- diff --git a/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/test/resources/simple/streamdefinitions.json b/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/test/resources/simple/streamdefinitions.json deleted file mode 100644 index abfbcf3..0000000 --- a/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/test/resources/simple/streamdefinitions.json +++ /dev/null @@ -1,47 +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/eagle/blob/6fd95d5c/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/test/resources/simple/topologies.json ---------------------------------------------------------------------- diff --git a/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/test/resources/simple/topologies.json b/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/test/resources/simple/topologies.json deleted file mode 100644 index 7417934..0000000 --- a/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/test/resources/simple/topologies.json +++ /dev/null @@ -1,41 +0,0 @@ -[ - { - "name": "alertUnitTopology_1", - "numOfSpout": 1, - "numOfAlertBolt": 20, - "numOfGroupBolt": 4, - "spoutId": "alertEngineSpout", - "groupNodeIds": [ - "streamRouterBolt0", - "streamRouterBolt1", - "streamRouterBolt2", - "streamRouterBolt3" - ], - "alertBoltIds": [ - "alertBolt0", - "alertBolt1", - "alertBolt2", - "alertBolt3", - "alertBolt4", - "alertBolt5", - "alertBolt6", - "alertBolt7", - "alertBolt8", - "alertBolt9", - "alertBolt10", - "alertBolt11", - "alertBolt12", - "alertBolt13", - "alertBolt14", - "alertBolt15", - "alertBolt16", - "alertBolt17", - "alertBolt18", - "alertBolt19" - ], - "pubBoltId": "alertPublishBolt", - "spoutParallelism": 1, - "groupParallelism": 1, - "alertParallelism": 1 - } -] http://git-wip-us.apache.org/repos/asf/eagle/blob/6fd95d5c/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/test/resources/statecheck/application-statecheck.conf ---------------------------------------------------------------------- diff --git a/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/test/resources/statecheck/application-statecheck.conf b/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/test/resources/statecheck/application-statecheck.conf deleted file mode 100644 index db14d3c..0000000 --- a/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/test/resources/statecheck/application-statecheck.conf +++ /dev/null @@ -1,60 +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": "/rest", - "host": "localhost", - "port": 8080 - }, - "coordinatorService": { - "host": "localhost", - "port": "8080", - "context": "/rest" - }, - "kafkaProducer": { - "bootstrapServers": "localhost:9092" - } -} http://git-wip-us.apache.org/repos/asf/eagle/blob/6fd95d5c/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/test/resources/statecheck/datasources.json ---------------------------------------------------------------------- diff --git a/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/test/resources/statecheck/datasources.json b/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/test/resources/statecheck/datasources.json deleted file mode 100644 index 19c70b4..0000000 --- a/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/test/resources/statecheck/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/eagle/blob/6fd95d5c/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/test/resources/statecheck/policies.json ---------------------------------------------------------------------- diff --git a/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/test/resources/statecheck/policies.json b/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/test/resources/statecheck/policies.json deleted file mode 100644 index 7680b9e..0000000 --- a/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/test/resources/statecheck/policies.json +++ /dev/null @@ -1,38 +0,0 @@ -[ - { - "name": "state_check_latency", - "definition": { - "type": "siddhi", - "value": "from perfmon_latency_stream#window.time(5 min) select host, timestamp, metric, pool, value, colo, convert(avg(value)/1000, 'int') as latencyState group by host insert into perfmon_latency_check_output;", - "inputStreams": [ - "perfmon_latency_stream" - ], - "outputStreams": [ - "perfmon_latency_check_output" - ] - }, - "stateDefinition": { - "type": "siddhi", - "value": "from every a = perfmon_latency_check_output -> b = perfmon_latency_check_output[host == a.host and timestamp > a.timestamp] within 5 min select a.latencyState as fromState, b.latencyState as toState, b.timestamp as happenTime insert into perfmon_latency_check_output2", - "value1": "from every a = perfmon_latency_check_output[latencyState >= 1] -> b = perfmon_latency_check_output[host == a.host and latencyState != a.latencyState and timestamp > a.timestamp] within 5 min select a.latencyState as fromState, b.latencyState as toState, b.timestamp as happenTime insert into perfmon_latency_check_output2", - "inputStreams": [ - "perfmon_latency_check_output" - ], - "outputStreams": [ - "perfmon_latency_check_output2" - ] - }, - "partitionSpec": [ - { - "streamId": "perfmon_latency_stream", - "type": "GROUPBY", - "columns": [ - "host" - ], - "sortSpec": { - "windowPeriod": "PT0M" - } - } - ] - } -] \ 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-engine/src/test/resources/statecheck/publishments.json ---------------------------------------------------------------------- diff --git a/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/test/resources/statecheck/publishments.json b/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/test/resources/statecheck/publishments.json deleted file mode 100644 index 3e1910f..0000000 --- a/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/test/resources/statecheck/publishments.json +++ /dev/null @@ -1,28 +0,0 @@ -[ - { - "type": "org.apache.eagle.alert.engine.publisher.impl.AlertKafkaPublisher", - "name": "kafka-testAlertStream", - "policyIds": [ - "state_check_latency" - ], - "dedupIntervalMin": "PT1M", - "properties": { - "kafka_broker": "localhost:9092", - "topic": "latency_state_kafka1" - }, - "serializer": "org.apache.eagle.alert.engine.publisher.impl.StringEventSerializer" - }, - { - "type": "org.apache.eagle.alert.engine.publisher.impl.AlertKafkaPublisher", - "name": "kafka-testAlertStream_state", - "policyIds": [ - "state_check_latency" - ], - "dedupIntervalMin": "PT1M", - "properties": { - "kafka_broker": "localhost:9092", - "topic": "latency_state_kafka2" - }, - "serializer": "org.apache.eagle.alert.engine.publisher.impl.StringEventSerializer" - } -] http://git-wip-us.apache.org/repos/asf/eagle/blob/6fd95d5c/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/test/resources/statecheck/streamdefinitions.json ---------------------------------------------------------------------- diff --git a/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/test/resources/statecheck/streamdefinitions.json b/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/test/resources/statecheck/streamdefinitions.json deleted file mode 100644 index 8f9f80e..0000000 --- a/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/test/resources/statecheck/streamdefinitions.json +++ /dev/null @@ -1,98 +0,0 @@ -[ - { - "streamId": "perfmon_latency_stream", - "dataSource": "perfmon_datasource", - "description": "the data stream for perfmon latency 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_latency", - "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 - } - ] - }, - { - "streamId": "perfmon_latency_check_output", - "dataSource": "", - "description": "the data stream for perfmon latency state output", - "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_latency", - "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 - }, - { - "name": "latencyState", - "type": "INT", - "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-engine/src/test/resources/statecheck/topologies.json ---------------------------------------------------------------------- diff --git a/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/test/resources/statecheck/topologies.json b/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/test/resources/statecheck/topologies.json deleted file mode 100644 index c13eeb2..0000000 --- a/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/test/resources/statecheck/topologies.json +++ /dev/null @@ -1,31 +0,0 @@ -[ - { - "name": "alertUnitTopology_1", - "numOfSpout": 1, - "numOfAlertBolt": 10, - "numOfGroupBolt": 4, - "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/eagle/blob/6fd95d5c/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/test/resources/testAlertBoltSpec.json ---------------------------------------------------------------------- diff --git a/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/test/resources/testAlertBoltSpec.json b/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/test/resources/testAlertBoltSpec.json deleted file mode 100644 index fd255cd..0000000 --- a/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/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/eagle/blob/6fd95d5c/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/test/resources/testPublishForAdd0.json ---------------------------------------------------------------------- diff --git a/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/test/resources/testPublishForAdd0.json b/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/test/resources/testPublishForAdd0.json deleted file mode 100644 index 3d0d5a2..0000000 --- a/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/test/resources/testPublishForAdd0.json +++ /dev/null @@ -1,26 +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": "[email protected]", - "recipients": "[email protected]", - "smtp.server": "mailhost.com", - "connection": "plaintext", - "smtp.port": "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-engine/src/test/resources/testPublishForAdd1.json ---------------------------------------------------------------------- diff --git a/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/test/resources/testPublishForAdd1.json b/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/test/resources/testPublishForAdd1.json deleted file mode 100644 index 0187e8b..0000000 --- a/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/test/resources/testPublishForAdd1.json +++ /dev/null @@ -1,38 +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": "[email protected]", - "recipients": "[email protected]", - "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/eagle/blob/6fd95d5c/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/test/resources/testPublishForMdyValue.json ---------------------------------------------------------------------- diff --git a/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/test/resources/testPublishForMdyValue.json b/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/test/resources/testPublishForMdyValue.json deleted file mode 100644 index 6fa99d6..0000000 --- a/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/test/resources/testPublishForMdyValue.json +++ /dev/null @@ -1,27 +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", - "policy_MdyValue" - ], - "dedupIntervalMin": "PT1M", - "properties": { - "subject": "UMP Test Alert", - "template": "", - "sender": "[email protected]", - "recipients": "[email protected]", - "smtp.server": "mailhost.com", - "connection": "plaintext", - "smtp.port": "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-engine/src/test/resources/testPublishSpec.json ---------------------------------------------------------------------- diff --git a/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/test/resources/testPublishSpec.json b/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/test/resources/testPublishSpec.json deleted file mode 100644 index a8f4105..0000000 --- a/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/test/resources/testPublishSpec.json +++ /dev/null @@ -1,44 +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" - ], - "streamIds": [ - "stream1" - ], - "dedupIntervalMin": "PT1M", - "properties": { - "subject": "Test Alert", - "template": "", - "sender": "[email protected]", - "recipients": "[email protected]", - "mail.smtp.host": "smtp.mailhost.com", - "mail.smtp.auth": "true", - "mail.username": "username", - "mail.password": "password", - "mail.debug": "false", - "mail.connection": "tls", - "mail.smtp.port": "587" - }, - "serializer": "org.apache.eagle.alert.engine.publisher.impl.JsonEventSerializer" - } - /* { - "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/eagle/blob/6fd95d5c/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/test/resources/testPublishSpec2.json ---------------------------------------------------------------------- diff --git a/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/test/resources/testPublishSpec2.json b/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/test/resources/testPublishSpec2.json deleted file mode 100644 index e31e1f4..0000000 --- a/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/test/resources/testPublishSpec2.json +++ /dev/null @@ -1,42 +0,0 @@ -{ - "version": "version1", - "topologyName": "testTopology", - "boltId": "alertPublishBolt", - "publishments": [ - { - "type": "org.apache.eagle.alert.engine.publisher.impl.AlertEmailPublisher", - "name": "email-testAlertStream", - "policyIds": [ - "policy1" - ], - "streamIds": [ - "stream1" - ], - "dedupIntervalMin": "PT2M", - "properties": { - "subject": "Test Alert", - "template": "", - "sender": "[email protected]", - "recipients": "[email protected]", - "mail.smtp.host": "smtp.mailhost.com", - "mail.smtp.auth": "true", - "mail.username": "username", - "mail.password": "password", - "mail.debug": "false", - "mail.connection": "tls", - "mail.smtp.port": "587" - }, - "serializer": "org.apache.eagle.alert.engine.publisher.impl.JsonEventSerializer" - } - // { - // "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/eagle/blob/6fd95d5c/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/test/resources/testPublishSpec3.json ---------------------------------------------------------------------- diff --git a/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/test/resources/testPublishSpec3.json b/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/test/resources/testPublishSpec3.json deleted file mode 100644 index 0de8218..0000000 --- a/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/test/resources/testPublishSpec3.json +++ /dev/null @@ -1,39 +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": "Test Alert", - "template": "", - "sender": "[email protected]", - "recipients": "[email protected]", - "mail.smtp.host": "smtp.mailhost.com", - "mail.smtp.auth": "true", - "mail.username": "username", - "mail.password": "password", - "mail.debug": "false", - "mail.connection": "tls", - "mail.smtp.port": "587" - }, - "serializer": "org.apache.eagle.alert.engine.publisher.impl.JsonEventSerializer" - } - // { - // "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/eagle/blob/6fd95d5c/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/test/resources/testSpoutSpec.json ---------------------------------------------------------------------- diff --git a/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/test/resources/testSpoutSpec.json b/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/test/resources/testSpoutSpec.json deleted file mode 100644 index c97ec43..0000000 --- a/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/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/eagle/blob/6fd95d5c/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/test/resources/testStreamDefinitionsSpec.json ---------------------------------------------------------------------- diff --git a/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/test/resources/testStreamDefinitionsSpec.json b/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/test/resources/testStreamDefinitionsSpec.json deleted file mode 100644 index 6b3ccff..0000000 --- a/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/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
