You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by fh...@apache.org on 2016/11/10 14:34:56 UTC
[2/4] flink git commit: [hotfix] [tests] Fix boxed Integer comparison
with != in PartitionerITCase.
[hotfix] [tests] Fix boxed Integer comparison with != in PartitionerITCase.
This closes #2774.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/01459505
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/01459505
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/01459505
Branch: refs/heads/master
Commit: 014595055aad3e044d17e1290b94e8f6846276ce
Parents: 22958fb
Author: Boris Osipov <bo...@epam.com>
Authored: Tue Nov 8 12:30:29 2016 +0300
Committer: Fabian Hueske <fh...@apache.org>
Committed: Thu Nov 10 15:34:17 2016 +0100
----------------------------------------------------------------------
.../apache/flink/test/streaming/runtime/PartitionerITCase.java | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/01459505/flink-tests/src/test/java/org/apache/flink/test/streaming/runtime/PartitionerITCase.java
----------------------------------------------------------------------
diff --git a/flink-tests/src/test/java/org/apache/flink/test/streaming/runtime/PartitionerITCase.java b/flink-tests/src/test/java/org/apache/flink/test/streaming/runtime/PartitionerITCase.java
index bff8df1..3a125ba 100644
--- a/flink-tests/src/test/java/org/apache/flink/test/streaming/runtime/PartitionerITCase.java
+++ b/flink-tests/src/test/java/org/apache/flink/test/streaming/runtime/PartitionerITCase.java
@@ -36,6 +36,7 @@ import java.util.Arrays;
import java.util.HashMap;
import java.util.HashSet;
import java.util.List;
+import java.util.Objects;
import static org.junit.Assert.assertEquals;
import static org.junit.Assert.fail;
@@ -174,7 +175,7 @@ public class PartitionerITCase extends StreamingMultipleProgramsTestBase {
Integer subtaskIndex = verifier.get(elem.f1);
if (subtaskIndex == null) {
verifier.put(elem.f1, elem.f0);
- } else if (subtaskIndex != elem.f0) {
+ } else if (!Objects.equals(subtaskIndex, elem.f0)) {
fail();
}
}