[jira] [Created] (EAGLE-620) AlertEngine: SpoutWrapper are sending duplicated message.

["Su Ralph (JIRA)" <ji...@apache.org>]

Su Ralph created EAGLE-620:
------------------------------

             Summary: AlertEngine: SpoutWrapper are sending duplicated message.
                 Key: EAGLE-620
                 URL: https://issues.apache.org/jira/browse/EAGLE-620
             Project: Eagle
          Issue Type: Bug
    Affects Versions: v0.5.0
            Reporter: Su Ralph
            Assignee: Su Ralph
            Priority: Blocker
             Fix For: v0.5.0


An event of stream id "ncAlertOutputStream" will be send three times given below spec:

process.network.alerts: [
{
topicName: "network_aggregate_alert_output_datasource",
streamId: "ncAlertOutputStream",
groupingStrategies: [
{
partition: {
streamId: "ncAlertOutputStream",
type: "GROUPBY",
columns: [
"entity"
]
},
numTotalParticipatingRouterBolts: 4,
startSequence: 0,
totalTargetBoltIds: [
"streamRouterBolt0",
"streamRouterBolt1",
"streamRouterBolt2",
"streamRouterBolt3"
]
}
]
},
{
topicName: "network_aggregate_alert_output_datasource",
streamId: "sherlockAlertOutputStream",
groupingStrategies: [
{
partition: {
streamId: "sherlockAlertOutputStream",
type: "GROUPBY",
columns: [
"entity"
]
},
numTotalParticipatingRouterBolts: 4,
startSequence: 0,
totalTargetBoltIds: [
"streamRouterBolt0",
"streamRouterBolt1",
"streamRouterBolt2",
"streamRouterBolt3"
]
}
]
},
{
topicName: "network_aggregate_alert_output_datasource",
streamId: "correlatedAlertStream",
groupingStrategies: [
{
partition: {
streamId: "correlatedAlertStream",
type: "GROUPBY",
columns: [
"linkedSwitch"
]
},
numTotalParticipatingRouterBolts: 4,
startSequence: 0,
totalTargetBoltIds: [
"streamRouterBolt0",
"streamRouterBolt1",
"streamRouterBolt2",
"streamRouterBolt3"
]
}
]
}
],

The root cause is in SpoutOutputCollectorWrapper.emit() the streamId of group strategy is not compared with the given stream event.



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)