You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by mj...@apache.org on 2015/10/09 12:49:58 UTC
flink git commit: [FLINK-2831] [Storm Compatibility] Failing Test:
WrapperSetupHelperTest
Repository: flink
Updated Branches:
refs/heads/master c9088a491 -> 998be1bbb
[FLINK-2831] [Storm Compatibility] Failing Test: WrapperSetupHelperTest
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/998be1bb
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/998be1bb
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/998be1bb
Branch: refs/heads/master
Commit: 998be1bbbc823e1299dcb6bfe56774ec2f7286ab
Parents: c9088a4
Author: mjsax <mj...@apache.org>
Authored: Fri Oct 9 11:11:57 2015 +0200
Committer: mjsax <mj...@apache.org>
Committed: Fri Oct 9 12:49:15 2015 +0200
----------------------------------------------------------------------
.../storm/wrappers/WrapperSetupHelperTest.java | 18 +++++++++---------
1 file changed, 9 insertions(+), 9 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/998be1bb/flink-contrib/flink-storm/src/test/java/org/apache/flink/storm/wrappers/WrapperSetupHelperTest.java
----------------------------------------------------------------------
diff --git a/flink-contrib/flink-storm/src/test/java/org/apache/flink/storm/wrappers/WrapperSetupHelperTest.java b/flink-contrib/flink-storm/src/test/java/org/apache/flink/storm/wrappers/WrapperSetupHelperTest.java
index a5399b0..c3b0300 100644
--- a/flink-contrib/flink-storm/src/test/java/org/apache/flink/storm/wrappers/WrapperSetupHelperTest.java
+++ b/flink-contrib/flink-storm/src/test/java/org/apache/flink/storm/wrappers/WrapperSetupHelperTest.java
@@ -181,10 +181,10 @@ public class WrapperSetupHelperTest extends AbstractTest {
builder.setBolt("bolt1", (IRichBolt) operators.get("bolt1"), dops.get("bolt1")).shuffleGrouping("spout1");
builder.setBolt("bolt2", (IRichBolt) operators.get("bolt2"), dops.get("bolt2")).allGrouping("spout2");
builder.setBolt("sink", (IRichBolt) operators.get("sink"), dops.get("sink"))
- .fieldsGrouping("bolt1", TestDummyBolt.groupingStreamId, new Fields("id"))
- .shuffleGrouping("bolt1", TestDummyBolt.shuffleStreamId)
- .fieldsGrouping("bolt2", TestDummyBolt.groupingStreamId, new Fields("id"))
- .shuffleGrouping("bolt2", TestDummyBolt.shuffleStreamId);
+ .fieldsGrouping("bolt1", TestDummyBolt.groupingStreamId, new Fields("id"))
+ .shuffleGrouping("bolt1", TestDummyBolt.shuffleStreamId)
+ .fieldsGrouping("bolt2", TestDummyBolt.groupingStreamId, new Fields("id"))
+ .shuffleGrouping("bolt2", TestDummyBolt.shuffleStreamId);
int counter = 0;
while (true) {
@@ -192,7 +192,7 @@ public class WrapperSetupHelperTest extends AbstractTest {
Config c = new Config();
c.setNumAckers(0);
cluster.submitTopology("test", c, builder.createTopology());
- Utils.sleep((counter + 1) * 5000);
+ Utils.sleep(++counter * 10000);
cluster.shutdown();
if (TestSink.result.size() == 8) {
@@ -207,10 +207,10 @@ public class WrapperSetupHelperTest extends AbstractTest {
flinkBuilder.setBolt("bolt1", (IRichBolt) operators.get("bolt1"), dops.get("bolt1")).shuffleGrouping("spout1");
flinkBuilder.setBolt("bolt2", (IRichBolt) operators.get("bolt2"), dops.get("bolt2")).allGrouping("spout2");
flinkBuilder.setBolt("sink", (IRichBolt) operators.get("sink"), dops.get("sink"))
- .fieldsGrouping("bolt1", TestDummyBolt.groupingStreamId, new Fields("id"))
- .shuffleGrouping("bolt1", TestDummyBolt.shuffleStreamId)
- .fieldsGrouping("bolt2", TestDummyBolt.groupingStreamId, new Fields("id"))
- .shuffleGrouping("bolt2", TestDummyBolt.shuffleStreamId);
+ .fieldsGrouping("bolt1", TestDummyBolt.groupingStreamId, new Fields("id"))
+ .shuffleGrouping("bolt1", TestDummyBolt.shuffleStreamId)
+ .fieldsGrouping("bolt2", TestDummyBolt.groupingStreamId, new Fields("id"))
+ .shuffleGrouping("bolt2", TestDummyBolt.shuffleStreamId);
flinkBuilder.createTopology();
StormTopology stormTopology = flinkBuilder.getStormTopology();