flink-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From mbala...@apache.org
Subject flink git commit: [FLINK-2232] [storm-compat] Increased sleeping time for IT-Cases
Date Thu, 18 Jun 2015 10:00:12 GMT
Repository: flink
Updated Branches:
  refs/heads/master 20a464f5b -> e9cad4da3


[FLINK-2232] [storm-compat] Increased sleeping time for IT-Cases

To make tests more stable as a temporal fix
additional bug fix: isRunning was not volatile in AbstractStormSpoutWrapper

Closes #845


Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/e9cad4da
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/e9cad4da
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/e9cad4da

Branch: refs/heads/master
Commit: e9cad4da3a814bcde46c10c0e4da2fc84f99d815
Parents: 20a464f
Author: mjsax <mjsax@informatik.hu-berlin.de>
Authored: Tue Jun 16 16:51:24 2015 +0200
Committer: mbalassi <mbalassi@apache.org>
Committed: Thu Jun 18 11:58:25 2015 +0200

----------------------------------------------------------------------
 .../stormcompatibility/wrappers/AbstractStormSpoutWrapper.java     | 2 +-
 .../flink/stormcompatibility/excamation/StormExclamationLocal.java | 2 +-
 .../flink/stormcompatibility/wordcount/StormWordCountLocal.java    | 2 +-
 3 files changed, 3 insertions(+), 3 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/flink/blob/e9cad4da/flink-contrib/flink-storm-compatibility/flink-storm-compatibility-core/src/main/java/org/apache/flink/stormcompatibility/wrappers/AbstractStormSpoutWrapper.java
----------------------------------------------------------------------
diff --git a/flink-contrib/flink-storm-compatibility/flink-storm-compatibility-core/src/main/java/org/apache/flink/stormcompatibility/wrappers/AbstractStormSpoutWrapper.java
b/flink-contrib/flink-storm-compatibility/flink-storm-compatibility-core/src/main/java/org/apache/flink/stormcompatibility/wrappers/AbstractStormSpoutWrapper.java
index 65cde55..3021bcb 100644
--- a/flink-contrib/flink-storm-compatibility/flink-storm-compatibility-core/src/main/java/org/apache/flink/stormcompatibility/wrappers/AbstractStormSpoutWrapper.java
+++ b/flink-contrib/flink-storm-compatibility/flink-storm-compatibility-core/src/main/java/org/apache/flink/stormcompatibility/wrappers/AbstractStormSpoutWrapper.java
@@ -52,7 +52,7 @@ public abstract class AbstractStormSpoutWrapper<OUT> extends RichParallelSourceF
 	/**
 	 * Indicates, if the source is still running or was canceled.
 	 */
-	protected boolean isRunning = true;
+	protected volatile boolean isRunning = true;
 
 	/**
 	 * Instantiates a new {@link AbstractStormSpoutWrapper} that wraps the given Storm {@link
IRichSpout spout} such

http://git-wip-us.apache.org/repos/asf/flink/blob/e9cad4da/flink-contrib/flink-storm-compatibility/flink-storm-compatibility-examples/src/main/java/org/apache/flink/stormcompatibility/excamation/StormExclamationLocal.java
----------------------------------------------------------------------
diff --git a/flink-contrib/flink-storm-compatibility/flink-storm-compatibility-examples/src/main/java/org/apache/flink/stormcompatibility/excamation/StormExclamationLocal.java
b/flink-contrib/flink-storm-compatibility/flink-storm-compatibility-examples/src/main/java/org/apache/flink/stormcompatibility/excamation/StormExclamationLocal.java
index c87fe8f..a25e5e0 100644
--- a/flink-contrib/flink-storm-compatibility/flink-storm-compatibility-examples/src/main/java/org/apache/flink/stormcompatibility/excamation/StormExclamationLocal.java
+++ b/flink-contrib/flink-storm-compatibility/flink-storm-compatibility-examples/src/main/java/org/apache/flink/stormcompatibility/excamation/StormExclamationLocal.java
@@ -42,7 +42,7 @@ public class StormExclamationLocal {
 		final FlinkLocalCluster cluster = FlinkLocalCluster.getLocalCluster();
 		cluster.submitTopology(topologyId, null, builder.createTopology());
 
-		Utils.sleep(5 * 1000);
+		Utils.sleep(10 * 1000);
 
 		// TODO kill does no do anything so far
 		cluster.killTopology(topologyId);

http://git-wip-us.apache.org/repos/asf/flink/blob/e9cad4da/flink-contrib/flink-storm-compatibility/flink-storm-compatibility-examples/src/main/java/org/apache/flink/stormcompatibility/wordcount/StormWordCountLocal.java
----------------------------------------------------------------------
diff --git a/flink-contrib/flink-storm-compatibility/flink-storm-compatibility-examples/src/main/java/org/apache/flink/stormcompatibility/wordcount/StormWordCountLocal.java
b/flink-contrib/flink-storm-compatibility/flink-storm-compatibility-examples/src/main/java/org/apache/flink/stormcompatibility/wordcount/StormWordCountLocal.java
index 7b4f471..3fbd5b7 100644
--- a/flink-contrib/flink-storm-compatibility/flink-storm-compatibility-examples/src/main/java/org/apache/flink/stormcompatibility/wordcount/StormWordCountLocal.java
+++ b/flink-contrib/flink-storm-compatibility/flink-storm-compatibility-examples/src/main/java/org/apache/flink/stormcompatibility/wordcount/StormWordCountLocal.java
@@ -65,7 +65,7 @@ public class StormWordCountLocal {
 		final FlinkLocalCluster cluster = FlinkLocalCluster.getLocalCluster();
 		cluster.submitTopology(topologyId, null, builder.createTopology());
 
-		Utils.sleep(5 * 1000);
+		Utils.sleep(10 * 1000);
 
 		// TODO kill does no do anything so far
 		cluster.killTopology(topologyId);


Mime
View raw message