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/01/21 12:18:14 UTC
incubator-eagle git commit: EAGLE-130 Fix bad expansion logic for
FlatMapProducer in AlertExpansion
Repository: incubator-eagle
Updated Branches:
refs/heads/master 8f8a58f98 -> d00513ce5
EAGLE-130 Fix bad expansion logic for FlatMapProducer in AlertExpansion
https://issues.apache.org/jira/browse/EAGLE-130
Author: @haoch <ha...@apache.org>
Reviewer: @haoch <ha...@apache.org>
Closes #70
Project: http://git-wip-us.apache.org/repos/asf/incubator-eagle/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-eagle/commit/d00513ce
Tree: http://git-wip-us.apache.org/repos/asf/incubator-eagle/tree/d00513ce
Diff: http://git-wip-us.apache.org/repos/asf/incubator-eagle/diff/d00513ce
Branch: refs/heads/master
Commit: d00513ce52063f41a7577ac40d7081e446228a6c
Parents: 8f8a58f
Author: Hao Chen <ha...@apache.org>
Authored: Thu Jan 21 19:17:07 2016 +0800
Committer: Hao Chen <ha...@apache.org>
Committed: Thu Jan 21 19:17:07 2016 +0800
----------------------------------------------------------------------
.../org/apache/eagle/datastream/core/StreamAlertExpansion.scala | 3 +--
1 file changed, 1 insertion(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-eagle/blob/d00513ce/eagle-core/eagle-data-process/eagle-stream-process-api/src/main/scala/org/apache/eagle/datastream/core/StreamAlertExpansion.scala
----------------------------------------------------------------------
diff --git a/eagle-core/eagle-data-process/eagle-stream-process-api/src/main/scala/org/apache/eagle/datastream/core/StreamAlertExpansion.scala b/eagle-core/eagle-data-process/eagle-stream-process-api/src/main/scala/org/apache/eagle/datastream/core/StreamAlertExpansion.scala
index 700e21d..97ea669 100644
--- a/eagle-core/eagle-data-process/eagle-stream-process-api/src/main/scala/org/apache/eagle/datastream/core/StreamAlertExpansion.scala
+++ b/eagle-core/eagle-data-process/eagle-stream-process-api/src/main/scala/org/apache/eagle/datastream/core/StreamAlertExpansion.scala
@@ -133,8 +133,7 @@ case class StreamAlertExpansion(config: Config) extends StreamDAGExpansion(confi
i += 1
})
}
- case p: FlatMapProducer[AnyRef, AnyRef] =>
- if(upStreamNames.size()>1) throw new IllegalStateException("More than 1 upStreamNames "+upStreamNames+" found for "+p){
+ case p: FlatMapProducer[AnyRef, AnyRef] => {
newStreamProducers += replace(toBeAddedEdges, toBeRemovedVertex, dag, current, recognizeSingleStreamName(p,upStreamNames))
}
case p: MapperProducer[AnyRef,AnyRef] => {