You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ga...@apache.org on 2019/08/04 18:52:13 UTC
[flink] 03/04: [hotfix][tests] Fix typo in method
CommonTestUtils#isSteamContentEqual()
This is an automated email from the ASF dual-hosted git repository.
gary pushed a commit to branch release-1.9
in repository https://gitbox.apache.org/repos/asf/flink.git
commit f6b22fcd3d7841a5dbbc1f108ebff041fa33239b
Author: Gary Yao <ga...@apache.org>
AuthorDate: Wed Jul 31 12:08:08 2019 +0200
[hotfix][tests] Fix typo in method CommonTestUtils#isSteamContentEqual()
Rename method isSteamContentEqual() to isStreamContentEqual().
---
.../flink/runtime/checkpoint/CheckpointCoordinatorTest.java | 10 +++++-----
.../runtime/state/DuplicatingCheckpointOutputStreamTest.java | 4 ++--
.../org/apache/flink/runtime/testutils/CommonTestUtils.java | 2 +-
3 files changed, 8 insertions(+), 8 deletions(-)
diff --git a/flink-runtime/src/test/java/org/apache/flink/runtime/checkpoint/CheckpointCoordinatorTest.java b/flink-runtime/src/test/java/org/apache/flink/runtime/checkpoint/CheckpointCoordinatorTest.java
index b11bf62..18052bb 100644
--- a/flink-runtime/src/test/java/org/apache/flink/runtime/checkpoint/CheckpointCoordinatorTest.java
+++ b/flink-runtime/src/test/java/org/apache/flink/runtime/checkpoint/CheckpointCoordinatorTest.java
@@ -2867,12 +2867,12 @@ public class CheckpointCoordinatorTest extends TestLogger {
Collection<OperatorStateHandle> managedOperatorState = opState.getManagedOperatorState();
assertEquals(1, managedOperatorState.size());
- assertTrue(CommonTestUtils.isSteamContentEqual(expectedManagedOpState.openInputStream(),
+ assertTrue(CommonTestUtils.isStreamContentEqual(expectedManagedOpState.openInputStream(),
managedOperatorState.iterator().next().openInputStream()));
Collection<OperatorStateHandle> rawOperatorState = opState.getRawOperatorState();
assertEquals(1, rawOperatorState.size());
- assertTrue(CommonTestUtils.isSteamContentEqual(expectedRawOpState.openInputStream(),
+ assertTrue(CommonTestUtils.isStreamContentEqual(expectedRawOpState.openInputStream(),
rawOperatorState.iterator().next().openInputStream()));
}
// operator2
@@ -2888,12 +2888,12 @@ public class CheckpointCoordinatorTest extends TestLogger {
Collection<OperatorStateHandle> managedOperatorState = opState.getManagedOperatorState();
assertEquals(1, managedOperatorState.size());
- assertTrue(CommonTestUtils.isSteamContentEqual(expectedManagedOpState.openInputStream(),
+ assertTrue(CommonTestUtils.isStreamContentEqual(expectedManagedOpState.openInputStream(),
managedOperatorState.iterator().next().openInputStream()));
Collection<OperatorStateHandle> rawOperatorState = opState.getRawOperatorState();
assertEquals(1, rawOperatorState.size());
- assertTrue(CommonTestUtils.isSteamContentEqual(expectedRawOpState.openInputStream(),
+ assertTrue(CommonTestUtils.isStreamContentEqual(expectedRawOpState.openInputStream(),
rawOperatorState.iterator().next().openInputStream()));
}
}
@@ -3290,7 +3290,7 @@ public class CheckpointCoordinatorTest extends TestLogger {
ChainedStateHandle<OperatorStateHandle> expectedOpStateBackend =
generateChainedPartitionableStateHandle(jobVertexID, i, 2, 8, false);
- assertTrue(CommonTestUtils.isSteamContentEqual(
+ assertTrue(CommonTestUtils.isStreamContentEqual(
expectedOpStateBackend.get(0).openInputStream(),
operatorState.getManagedOperatorState().iterator().next().openInputStream()));
diff --git a/flink-runtime/src/test/java/org/apache/flink/runtime/state/DuplicatingCheckpointOutputStreamTest.java b/flink-runtime/src/test/java/org/apache/flink/runtime/state/DuplicatingCheckpointOutputStreamTest.java
index 886dbdd..330bb85 100644
--- a/flink-runtime/src/test/java/org/apache/flink/runtime/state/DuplicatingCheckpointOutputStreamTest.java
+++ b/flink-runtime/src/test/java/org/apache/flink/runtime/state/DuplicatingCheckpointOutputStreamTest.java
@@ -71,11 +71,11 @@ public class DuplicatingCheckpointOutputStreamTest extends TestLogger {
StreamStateHandle primaryStateHandle = duplicatingStream.closeAndGetPrimaryHandle();
StreamStateHandle secondaryStateHandle = duplicatingStream.closeAndGetSecondaryHandle();
- Assert.assertTrue(CommonTestUtils.isSteamContentEqual(
+ Assert.assertTrue(CommonTestUtils.isStreamContentEqual(
refStateHandle.openInputStream(),
primaryStateHandle.openInputStream()));
- Assert.assertTrue(CommonTestUtils.isSteamContentEqual(
+ Assert.assertTrue(CommonTestUtils.isStreamContentEqual(
refStateHandle.openInputStream(),
secondaryStateHandle.openInputStream()));
diff --git a/flink-runtime/src/test/java/org/apache/flink/runtime/testutils/CommonTestUtils.java b/flink-runtime/src/test/java/org/apache/flink/runtime/testutils/CommonTestUtils.java
index 5ce5f56..b45ebd7 100644
--- a/flink-runtime/src/test/java/org/apache/flink/runtime/testutils/CommonTestUtils.java
+++ b/flink-runtime/src/test/java/org/apache/flink/runtime/testutils/CommonTestUtils.java
@@ -157,7 +157,7 @@ public class CommonTestUtils {
}
}
- public static boolean isSteamContentEqual(InputStream input1, InputStream input2) throws IOException {
+ public static boolean isStreamContentEqual(InputStream input1, InputStream input2) throws IOException {
if (!(input1 instanceof BufferedInputStream)) {
input1 = new BufferedInputStream(input1);