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 <[email protected]> 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<>();
