You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by zh...@apache.org on 2019/08/01 11:45:07 UTC
[flink] 07/13: [hotfix][tests] Make PartitionTestUtils enum
singleton and fix codestyle
This is an automated email from the ASF dual-hosted git repository.
zhijiang pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
commit e408636a831b63b414c9705b9c3a006fc0572cdc
Author: Andrey Zagrebin <az...@gmail.com>
AuthorDate: Mon Jul 29 17:36:07 2019 +0300
[hotfix][tests] Make PartitionTestUtils enum singleton and fix codestyle
---
.../runtime/io/network/partition/PartitionTestUtils.java | 11 ++++++++---
1 file changed, 8 insertions(+), 3 deletions(-)
diff --git a/flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/PartitionTestUtils.java b/flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/PartitionTestUtils.java
index cf50051..72892d6 100644
--- a/flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/PartitionTestUtils.java
+++ b/flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/PartitionTestUtils.java
@@ -21,6 +21,7 @@ package org.apache.flink.runtime.io.network.partition;
import org.apache.flink.runtime.deployment.ResultPartitionDeploymentDescriptor;
import org.apache.flink.runtime.io.disk.FileChannelManager;
import org.apache.flink.runtime.io.network.NettyShuffleEnvironment;
+import org.apache.flink.runtime.io.network.api.writer.ResultPartitionWriter;
import org.apache.flink.runtime.jobgraph.IntermediateDataSetID;
import org.apache.flink.runtime.shuffle.PartitionDescriptor;
import org.apache.flink.runtime.shuffle.ShuffleDescriptor;
@@ -39,7 +40,8 @@ import static org.junit.Assert.fail;
* While using Mockito internally (for now), the use of Mockito should not
* leak out of this class.
*/
-public class PartitionTestUtils {
+public enum PartitionTestUtils {
+ ;
public static ResultPartition createPartition() {
return createPartition(ResultPartitionType.PIPELINED_BOUNDED);
@@ -83,7 +85,7 @@ public class PartitionTestUtils {
}
static void verifyCreateSubpartitionViewThrowsException(
- ResultPartitionManager partitionManager,
+ ResultPartitionProvider partitionManager,
ResultPartitionID partitionId) throws IOException {
try {
partitionManager.createSubpartitionView(partitionId, 0, new NoOpBufferAvailablityListener());
@@ -114,7 +116,10 @@ public class PartitionTestUtils {
return createPartitionDeploymentDescriptor(ResultPartitionType.BLOCKING);
}
- public static void writeBuffers(ResultPartition partition, int numberOfBuffers, int bufferSize) throws IOException {
+ public static void writeBuffers(
+ ResultPartitionWriter partition,
+ int numberOfBuffers,
+ int bufferSize) throws IOException {
for (int i = 0; i < numberOfBuffers; i++) {
partition.addBufferConsumer(createFilledBufferConsumer(bufferSize, bufferSize), 0);
}