[jira] [Updated] (STORM-101) Merging two streams with the same fields in a different order results in the wrong values being returned when getting tuple values by index

["Rick Kellogg (JIRA)" <ji...@apache.org>]

     [ https://issues.apache.org/jira/browse/STORM-101?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Rick Kellogg updated STORM-101:
-------------------------------
    Component/s: storm-core

> Merging two streams with the same fields in a different order results in the wrong values being returned when getting tuple values by index
> -------------------------------------------------------------------------------------------------------------------------------------------
>
>                 Key: STORM-101
>                 URL: https://issues.apache.org/jira/browse/STORM-101
>             Project: Apache Storm
>          Issue Type: Bug
>          Components: storm-core
>            Reporter: James Xu
>            Priority: Minor
>
> https://github.com/nathanmarz/storm/issues/688
> Given the following topology (Constant is a function that simply injects a constant into the tuple):
>     TridentTopology topology = new TridentTopology();
>     List<Object> tuple = Arrays.<Object>asList(10);
>     Stream stream = topology.newStream("spout", new FixedBatchSpout(new Fields("trigger"), 1, tuple));
>     Stream s1 = stream
>             .each(new Constant("StringVal"), new Fields("string"))
>             .each(new Constant(20), new Fields("number"));
>     Stream s2 = stream
>             .each(new Constant(20), new Fields("number"))
>             .each(new Constant("StringVal"), new Fields("string"));
>     topology.merge(s1, s2).each(new Fields("string"), new Debug());
> What I expect to be output:
> DEBUG: [StringVal]
> DEBUG: [StringVal]
> What is actually output:
> DEBUG: [StringVal]
> DEBUG: [20]
> I expect the field selector for the input to Debug to pick the first field for the tuple from s1, and the second field for the tuple from s2.



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