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:09 UTC
[flink] 09/13: [hotfix][tests] fix codestyle issues in
ResultPartitionFactoryTest
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 <az...@gmail.com>
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(