You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by se...@apache.org on 2015/10/16 18:08:51 UTC
[24/24] flink git commit: [hotfix] [storm compatibility] Deactivate
tests for split stream field grouping,
which do not work in teh runtime and are now caught earlier
[hotfix] [storm compatibility] Deactivate tests for split stream field grouping, which do not work in teh runtime and are now caught earlier
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/34c232e9
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/34c232e9
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/34c232e9
Branch: refs/heads/master
Commit: 34c232e9bd8400b8409434116d0257cf643a0eaa
Parents: d68c8b1
Author: Stephan Ewen <se...@apache.org>
Authored: Fri Oct 16 16:31:11 2015 +0200
Committer: Stephan Ewen <se...@apache.org>
Committed: Fri Oct 16 16:31:11 2015 +0200
----------------------------------------------------------------------
.../java/org/apache/flink/storm/api/FlinkTopologyBuilderTest.java | 3 +++
1 file changed, 3 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/34c232e9/flink-contrib/flink-storm/src/test/java/org/apache/flink/storm/api/FlinkTopologyBuilderTest.java
----------------------------------------------------------------------
diff --git a/flink-contrib/flink-storm/src/test/java/org/apache/flink/storm/api/FlinkTopologyBuilderTest.java b/flink-contrib/flink-storm/src/test/java/org/apache/flink/storm/api/FlinkTopologyBuilderTest.java
index fa5c8d8..906d081 100644
--- a/flink-contrib/flink-storm/src/test/java/org/apache/flink/storm/api/FlinkTopologyBuilderTest.java
+++ b/flink-contrib/flink-storm/src/test/java/org/apache/flink/storm/api/FlinkTopologyBuilderTest.java
@@ -21,6 +21,7 @@ import org.apache.flink.storm.util.TestDummyBolt;
import org.apache.flink.storm.util.TestDummySpout;
import org.apache.flink.storm.util.TestSink;
+import org.junit.Ignore;
import org.junit.Test;
import backtype.storm.tuple.Fields;
@@ -53,6 +54,7 @@ public class FlinkTopologyBuilderTest {
}
@Test
+ @Ignore
public void testFieldsGroupingOnMultipleSpoutOutputStreams() {
FlinkTopologyBuilder flinkBuilder = new FlinkTopologyBuilder();
@@ -64,6 +66,7 @@ public class FlinkTopologyBuilderTest {
}
@Test
+ @Ignore
public void testFieldsGroupingOnMultipleBoltOutputStreams() {
FlinkTopologyBuilder flinkBuilder = new FlinkTopologyBuilder();