This is an automated email from the ASF dual-hosted git repository. guoweijie pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git
commit cd3d6efb4932d2e3558a590b5b88540d9a8178f8 Author: Weijie Guo <[email protected]> AuthorDate: Tue May 9 13:50:38 2023 +0800 [hotfix] Remove unnecessary public modifier for PartitionedFileWriteReadTest --- .../io/network/partition/PartitionedFileWriteReadTest.java | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/PartitionedFileWriteReadTest.java b/flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/PartitionedFileWriteReadTest.java index cbcaf758b37..5883c242542 100644 --- a/flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/PartitionedFileWriteReadTest.java +++ b/flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/PartitionedFileWriteReadTest.java @@ -230,7 +230,7 @@ class PartitionedFileWriteReadTest { } @Test - public void testNotWriteDataOfTheSameSubpartitionTogether() throws Exception { + void testNotWriteDataOfTheSameSubpartitionTogether() throws Exception { PartitionedFileWriter partitionedFileWriter = createPartitionedFileWriter(2); try { MemorySegment segment = MemorySegmentFactory.allocateUnpooledSegment(1024); @@ -257,7 +257,7 @@ class PartitionedFileWriteReadTest { } @Test - public void testWriteFinishedPartitionedFile() throws Exception { + void testWriteFinishedPartitionedFile() throws Exception { PartitionedFileWriter partitionedFileWriter = createAndFinishPartitionedFileWriter(); MemorySegment segment = MemorySegmentFactory.allocateUnpooledSegment(1024); @@ -269,14 +269,14 @@ class PartitionedFileWriteReadTest { } @Test - public void testFinishPartitionedFileWriterTwice() throws Exception { + void testFinishPartitionedFileWriterTwice() throws Exception { PartitionedFileWriter partitionedFileWriter = createAndFinishPartitionedFileWriter(); assertThatThrownBy(() -> partitionedFileWriter.finish()) .isInstanceOf(IllegalStateException.class); } @Test - public void testReadEmptyPartitionedFile() throws Exception { + void testReadEmptyPartitionedFile() throws Exception { int bufferSize = 1024; int numSubpartitions = 2; int targetSubpartition = 1;
