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 2018/04/30 21:23:15 UTC
[14/15] flink git commit: [hotfix] [tests] Remove redundant rebalance
in SuccessAfterNetworkBuffersFailureITCase
[hotfix] [tests] Remove redundant rebalance in SuccessAfterNetworkBuffersFailureITCase
This closes #5916
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/b957bf26
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/b957bf26
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/b957bf26
Branch: refs/heads/master
Commit: b957bf26fb588cab072e51240e9026456b862ce7
Parents: fa63c33
Author: Nico Kruber <ni...@data-artisans.com>
Authored: Thu Apr 26 10:35:55 2018 +0200
Committer: Stephan Ewen <se...@apache.org>
Committed: Mon Apr 30 21:30:54 2018 +0200
----------------------------------------------------------------------
.../flink/test/misc/SuccessAfterNetworkBuffersFailureITCase.java | 1 -
1 file changed, 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/b957bf26/flink-tests/src/test/java/org/apache/flink/test/misc/SuccessAfterNetworkBuffersFailureITCase.java
----------------------------------------------------------------------
diff --git a/flink-tests/src/test/java/org/apache/flink/test/misc/SuccessAfterNetworkBuffersFailureITCase.java b/flink-tests/src/test/java/org/apache/flink/test/misc/SuccessAfterNetworkBuffersFailureITCase.java
index c5c1882..e149f43 100644
--- a/flink-tests/src/test/java/org/apache/flink/test/misc/SuccessAfterNetworkBuffersFailureITCase.java
+++ b/flink-tests/src/test/java/org/apache/flink/test/misc/SuccessAfterNetworkBuffersFailureITCase.java
@@ -136,7 +136,6 @@ public class SuccessAfterNetworkBuffersFailureITCase extends TestLogger {
// add some re-partitions to increase network buffer use
DataSet<KMeans.Centroid> newCentroids = points
- .rebalance()
// compute closest centroid for each point
.map(new KMeans.SelectNearestCenter()).withBroadcastSet(loop, "centroids")
.rebalance()