You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@eagle.apache.org by ha...@apache.org on 2016/07/25 10:23:43 UTC
incubator-eagle git commit: [EAGLE-393] Fix UnitTest Error caused by
streamDef.json and TestApplicationImpl
Repository: incubator-eagle
Updated Branches:
refs/heads/develop ef84ca1e3 -> fabfc25b9
[EAGLE-393] Fix UnitTest Error caused by streamDef.json and TestApplicationImpl
https://issues.apache.org/jira/browse/EAGLE-393
Author: Hao Chen <ha...@apache.org>
Closes #275 from haoch/EAGLE-393.
Project: http://git-wip-us.apache.org/repos/asf/incubator-eagle/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-eagle/commit/fabfc25b
Tree: http://git-wip-us.apache.org/repos/asf/incubator-eagle/tree/fabfc25b
Diff: http://git-wip-us.apache.org/repos/asf/incubator-eagle/diff/fabfc25b
Branch: refs/heads/develop
Commit: fabfc25b9d30faff7b72f45c2ca39e392726eda8
Parents: ef84ca1
Author: Hao Chen <ha...@apache.org>
Authored: Mon Jul 25 18:23:26 2016 +0800
Committer: Hao Chen <ha...@apache.org>
Committed: Mon Jul 25 18:23:26 2016 +0800
----------------------------------------------------------------------
.../eagle-alert/alert-common/src/test/resources/streamDef.json | 6 +++---
.../test/java/org/apache/eagle/app/TestApplicationImpl.java | 4 ++--
2 files changed, 5 insertions(+), 5 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-eagle/blob/fabfc25b/eagle-core/eagle-alert-parent/eagle-alert/alert-common/src/test/resources/streamDef.json
----------------------------------------------------------------------
diff --git a/eagle-core/eagle-alert-parent/eagle-alert/alert-common/src/test/resources/streamDef.json b/eagle-core/eagle-alert-parent/eagle-alert/alert-common/src/test/resources/streamDef.json
index 078cd73..8c7c33a 100644
--- a/eagle-core/eagle-alert-parent/eagle-alert/alert-common/src/test/resources/streamDef.json
+++ b/eagle-core/eagle-alert-parent/eagle-alert/alert-common/src/test/resources/streamDef.json
@@ -18,12 +18,12 @@
"required":true
},{
"name": "metric",
- "type" : "float",
+ "type" : "string",
"defaultValue": "perfmon_cpu",
"required": true
},{
"name": "pool",
- "type" : "int",
+ "type" : "string",
"defaultValue": "raptor_general",
"required":true
},{
@@ -35,7 +35,7 @@
{
"name": "colo",
"type" : "bool",
- "defaultValue": "",
+ "defaultValue": true,
"required":true
}
]
http://git-wip-us.apache.org/repos/asf/incubator-eagle/blob/fabfc25b/eagle-core/eagle-app/eagle-app-base/src/test/java/org/apache/eagle/app/TestApplicationImpl.java
----------------------------------------------------------------------
diff --git a/eagle-core/eagle-app/eagle-app-base/src/test/java/org/apache/eagle/app/TestApplicationImpl.java b/eagle-core/eagle-app/eagle-app-base/src/test/java/org/apache/eagle/app/TestApplicationImpl.java
index d379185..aeefd77 100644
--- a/eagle-core/eagle-app/eagle-app-base/src/test/java/org/apache/eagle/app/TestApplicationImpl.java
+++ b/eagle-core/eagle-app/eagle-app-base/src/test/java/org/apache/eagle/app/TestApplicationImpl.java
@@ -36,8 +36,8 @@ public class TestApplicationImpl extends AbstractApplication {
private final static Logger LOG = LoggerFactory.getLogger(TestApplicationImpl.class);
protected void buildApp(TopologyBuilder builder, ApplicationContext context) {
builder.setSpout("metric_spout", new RandomEventSpout(), 4);
- builder.setBolt("sink_1",context.getFlattenStreamSink("SAMPLE_STREAM_1")).fieldsGrouping("metric_spout",new Fields("metric"));
- builder.setBolt("sink_2",context.getFlattenStreamSink("SAMPLE_STREAM_2")).fieldsGrouping("metric_spout",new Fields("metric"));
+ builder.setBolt("sink_1",context.getFlattenStreamSink("TEST_STREAM_1")).fieldsGrouping("metric_spout",new Fields("metric"));
+ builder.setBolt("sink_2",context.getFlattenStreamSink("TEST_STREAM_2")).fieldsGrouping("metric_spout",new Fields("metric"));
}
private class RandomEventSpout extends BaseRichSpout {