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 e593c5d7deb7b786fd67b1772d0438da2f6a70ad Author: Andrey Zagrebin <[email protected]> AuthorDate: Mon Jul 29 17:43:41 2019 +0300 [hotfix][tests] fix codestyle issues in ResultPartitionFactoryTest --- .../runtime/io/network/partition/ResultPartitionFactoryTest.java | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/ResultPartitionFactoryTest.java b/flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/ResultPartitionFactoryTest.java index 8065829..1c8591f 100644 --- a/flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/ResultPartitionFactoryTest.java +++ b/flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/ResultPartitionFactoryTest.java @@ -39,9 +39,11 @@ import static org.hamcrest.MatcherAssert.assertThat; /** * Tests for the {@link ResultPartitionFactory}. */ +@SuppressWarnings("StaticVariableUsedBeforeInitialization") public class ResultPartitionFactoryTest extends TestLogger { private static final String tempDir = EnvironmentInformation.getTemporaryFileDirectory(); + private static final int SEGMENT_SIZE = 64; private static FileChannelManager fileChannelManager; @@ -79,11 +81,11 @@ public class ResultPartitionFactoryTest extends TestLogger { ResultPartitionFactory factory = new ResultPartitionFactory( new ResultPartitionManager(), fileChannelManager, - new NetworkBufferPool(1, 64, 1), + new NetworkBufferPool(1, SEGMENT_SIZE, 1), BoundedBlockingSubpartitionType.AUTO, 1, 1, - 64, + SEGMENT_SIZE, releasePartitionOnConsumption); final ResultPartitionDeploymentDescriptor descriptor = new ResultPartitionDeploymentDescriptor(
