[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/f1fa5174 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/f1fa5174 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/f1fa5174 Branch: refs/heads/release-1.5 Commit: f1fa517474920da89f8b67bb1a58844c5234af76 Parents: 514cf81 Author: Nico Kruber <[email protected]> Authored: Thu Apr 26 10:35:55 2018 +0200 Committer: Stephan Ewen <[email protected]> Committed: Mon Apr 30 23:25:32 2018 +0200 ---------------------------------------------------------------------- .../flink/test/misc/SuccessAfterNetworkBuffersFailureITCase.java | 1 - 1 file changed, 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/f1fa5174/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()
