You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by yi...@apache.org on 2022/01/16 08:57:56 UTC
[flink] 02/02: [hotfix] Fix typing errors for SortMergeResultPartitionReadScheduler#createSubpartitionReader
This is an automated email from the ASF dual-hosted git repository.
yingjie pushed a commit to branch release-1.14
in repository https://gitbox.apache.org/repos/asf/flink.git
commit b1efd3b0fbcf96cb9368ce925efe5fe67be04902
Author: Yuxin Tan <ta...@gmail.com>
AuthorDate: Tue Dec 14 16:54:52 2021 +0800
[hotfix] Fix typing errors for SortMergeResultPartitionReadScheduler#createSubpartitionReader
This closes #17936.
---
.../io/network/partition/SortMergeResultPartition.java | 2 +-
.../partition/SortMergeResultPartitionReadScheduler.java | 2 +-
.../SortMergeResultPartitionReadSchedulerTest.java | 14 +++++++-------
3 files changed, 9 insertions(+), 9 deletions(-)
diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/SortMergeResultPartition.java b/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/SortMergeResultPartition.java
index 650d1de..af27a0d 100644
--- a/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/SortMergeResultPartition.java
+++ b/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/SortMergeResultPartition.java
@@ -456,7 +456,7 @@ public class SortMergeResultPartition extends ResultPartition {
checkState(!isReleased(), "Partition released.");
checkState(isFinished(), "Trying to read unfinished blocking partition.");
- return readScheduler.crateSubpartitionReader(
+ return readScheduler.createSubpartitionReader(
availabilityListener, subpartitionIndex, resultFile);
}
}
diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/SortMergeResultPartitionReadScheduler.java b/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/SortMergeResultPartitionReadScheduler.java
index 7551dc8..539a43b 100644
--- a/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/SortMergeResultPartitionReadScheduler.java
+++ b/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/SortMergeResultPartitionReadScheduler.java
@@ -289,7 +289,7 @@ class SortMergeResultPartitionReadScheduler implements Runnable, BufferRecycler
}
}
- SortMergeSubpartitionReader crateSubpartitionReader(
+ SortMergeSubpartitionReader createSubpartitionReader(
BufferAvailabilityListener availabilityListener,
int targetSubpartition,
PartitionedFile resultFile)
diff --git a/flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/SortMergeResultPartitionReadSchedulerTest.java b/flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/SortMergeResultPartitionReadSchedulerTest.java
index 78ef5fa..4650630 100644
--- a/flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/SortMergeResultPartitionReadSchedulerTest.java
+++ b/flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/SortMergeResultPartitionReadSchedulerTest.java
@@ -105,7 +105,7 @@ public class SortMergeResultPartitionReadSchedulerTest extends TestLogger {
@Test
public void testCreateSubpartitionReader() throws Exception {
SortMergeSubpartitionReader subpartitionReader =
- readScheduler.crateSubpartitionReader(
+ readScheduler.createSubpartitionReader(
new NoOpBufferAvailablityListener(), 0, partitionedFile);
assertTrue(readScheduler.isRunning());
@@ -128,7 +128,7 @@ public class SortMergeResultPartitionReadSchedulerTest extends TestLogger {
@Test
public void testOnSubpartitionReaderError() throws Exception {
SortMergeSubpartitionReader subpartitionReader =
- readScheduler.crateSubpartitionReader(
+ readScheduler.createSubpartitionReader(
new NoOpBufferAvailablityListener(), 0, partitionedFile);
subpartitionReader.releaseAllResources();
@@ -139,7 +139,7 @@ public class SortMergeResultPartitionReadSchedulerTest extends TestLogger {
@Test
public void testReleaseWhileReading() throws Exception {
SortMergeSubpartitionReader subpartitionReader =
- readScheduler.crateSubpartitionReader(
+ readScheduler.createSubpartitionReader(
new NoOpBufferAvailablityListener(), 0, partitionedFile);
Thread.sleep(1000);
@@ -158,7 +158,7 @@ public class SortMergeResultPartitionReadSchedulerTest extends TestLogger {
public void testCreateSubpartitionReaderAfterReleased() throws Exception {
readScheduler.release();
try {
- readScheduler.crateSubpartitionReader(
+ readScheduler.createSubpartitionReader(
new NoOpBufferAvailablityListener(), 0, partitionedFile);
} finally {
assertAllResourcesReleased();
@@ -168,7 +168,7 @@ public class SortMergeResultPartitionReadSchedulerTest extends TestLogger {
@Test
public void testOnDataReadError() throws Exception {
SortMergeSubpartitionReader subpartitionReader =
- readScheduler.crateSubpartitionReader(
+ readScheduler.createSubpartitionReader(
new NoOpBufferAvailablityListener(), 0, partitionedFile);
// close file channel to trigger data read exception
@@ -191,7 +191,7 @@ public class SortMergeResultPartitionReadSchedulerTest extends TestLogger {
@Test
public void testOnReadBufferRequestError() throws Exception {
SortMergeSubpartitionReader subpartitionReader =
- readScheduler.crateSubpartitionReader(
+ readScheduler.createSubpartitionReader(
new NoOpBufferAvailablityListener(), 0, partitionedFile);
bufferPool.destroy();
@@ -212,7 +212,7 @@ public class SortMergeResultPartitionReadSchedulerTest extends TestLogger {
bufferPool, executor, this, bufferRequestTimeout);
SortMergeSubpartitionReader subpartitionReader =
- readScheduler.crateSubpartitionReader(
+ readScheduler.createSubpartitionReader(
new NoOpBufferAvailablityListener(), 0, partitionedFile);
PriorityQueue<SortMergeSubpartitionReader> allReaders = new PriorityQueue<>();