Github user kevpeek commented on a diff in the pull request:
https://github.com/apache/storm/pull/2379#discussion_r145984652
--- Diff:
storm-client/test/jvm/org/apache/storm/grouping/partialKeyGrouping/PartialKeyGroupingTest.java
---
@@ -53,7 +62,7 @@ public void testChooseTasksFields() {
PartialKeyGrouping pkg = new PartialKeyGrouping(new
Fields("test"));
WorkerTopologyContext context = mock(WorkerTopologyContext.class);
when(context.getComponentOutputFields(any(GlobalStreamId.class))).thenReturn(new
Fields("test"));
- pkg.prepare(context, mock(GlobalStreamId.class),
Lists.newArrayList(0, 1, 2, 3, 4, 5));
+ pkg.prepare(context, mock(GlobalStreamId.class),
Lists.newArrayList(9, 8, 7, 1, 2, 3));
--- End diff --
I can add another test that does use consecutive numbers. I simply wanted
to ensure the code did not require consecutive numbers.
---
