[flink] 01/02: [hotfix] Fix a code style local variable name issue in JobManagerProcessUtilsTest

[azagrebin]

This is an automated email from the ASF dual-hosted git repository.

azagrebin pushed a commit to branch release-1.11
in repository https://gitbox.apache.org/repos/asf/flink.git

commit c24bc0e1077946b987e2f116b94e488e28b11462
Author: Andrey Zagrebin <azagre...@apache.org>
AuthorDate: Wed Jun 10 18:09:46 2020 +0300

    [hotfix] Fix a code style local variable name issue in 
JobManagerProcessUtilsTest
---
 .../jobmanager/JobManagerProcessUtilsTest.java     | 30 +++++++++++-----------
 1 file changed, 15 insertions(+), 15 deletions(-)

diff --git 
a/flink-runtime/src/test/java/org/apache/flink/runtime/jobmanager/JobManagerProcessUtilsTest.java
 
b/flink-runtime/src/test/java/org/apache/flink/runtime/jobmanager/JobManagerProcessUtilsTest.java
index 840520f..d6c202e 100644
--- 
a/flink-runtime/src/test/java/org/apache/flink/runtime/jobmanager/JobManagerProcessUtilsTest.java
+++ 
b/flink-runtime/src/test/java/org/apache/flink/runtime/jobmanager/JobManagerProcessUtilsTest.java
@@ -63,8 +63,8 @@ public class JobManagerProcessUtilsTest extends 
ProcessMemoryUtilsTestBase<JobMa
                Configuration conf = new Configuration();
                conf.set(JobManagerOptions.JVM_HEAP_MEMORY, jvmHeapSize);
 
-               JobManagerProcessSpec JobManagerProcessSpec = 
JobManagerProcessUtils.processSpecFromConfig(conf);
-               assertThat(JobManagerProcessSpec.getJvmHeapMemorySize(), 
is(jvmHeapSize));
+               JobManagerProcessSpec jobManagerProcessSpec = 
JobManagerProcessUtils.processSpecFromConfig(conf);
+               assertThat(jobManagerProcessSpec.getJvmHeapMemorySize(), 
is(jvmHeapSize));
        }
 
        @Test
@@ -207,9 +207,9 @@ public class JobManagerProcessUtilsTest extends 
ProcessMemoryUtilsTestBase<JobMa
                log.info("Validating in configuration with explicit jvm heap.");
                Configuration config = configWithExplicitJvmHeap();
                config.addAll(customConfig);
-               JobManagerProcessSpec JobManagerProcessSpec = 
JobManagerProcessUtils.processSpecFromConfig(config);
-               assertThat(JobManagerProcessSpec.getJvmHeapMemorySize(), 
is(JVM_HEAP_SIZE));
-               validateFunc.accept(JobManagerProcessSpec);
+               JobManagerProcessSpec jobManagerProcessSpec = 
JobManagerProcessUtils.processSpecFromConfig(config);
+               assertThat(jobManagerProcessSpec.getJvmHeapMemorySize(), 
is(JVM_HEAP_SIZE));
+               validateFunc.accept(jobManagerProcessSpec);
        }
 
        private void validateFailInConfigWithExplicitJvmHeap(Configuration 
customConfig) {
@@ -224,9 +224,9 @@ public class JobManagerProcessUtilsTest extends 
ProcessMemoryUtilsTestBase<JobMa
                log.info("Validating in configuration with explicit total flink 
memory size.");
                Configuration config = configWithExplicitTotalFlinkMem();
                config.addAll(customConfig);
-               JobManagerProcessSpec JobManagerProcessSpec = 
JobManagerProcessUtils.processSpecFromConfig(config);
-               assertThat(JobManagerProcessSpec.getTotalFlinkMemorySize(), 
is(TOTAL_FLINK_MEM_SIZE));
-               validateFunc.accept(JobManagerProcessSpec);
+               JobManagerProcessSpec jobManagerProcessSpec = 
JobManagerProcessUtils.processSpecFromConfig(config);
+               assertThat(jobManagerProcessSpec.getTotalFlinkMemorySize(), 
is(TOTAL_FLINK_MEM_SIZE));
+               validateFunc.accept(jobManagerProcessSpec);
        }
 
        private void 
validateFailInConfigWithExplicitTotalFlinkMem(Configuration customConfig) {
@@ -242,10 +242,10 @@ public class JobManagerProcessUtilsTest extends 
ProcessMemoryUtilsTestBase<JobMa
                log.info("Validating in configuration with explicit total flink 
and jvm heap memory size.");
                Configuration config = 
configWithExplicitTotalFlinkAndJvmHeapMem();
                config.addAll(customConfig);
-               JobManagerProcessSpec JobManagerProcessSpec = 
JobManagerProcessUtils.processSpecFromConfig(config);
-               assertThat(JobManagerProcessSpec.getTotalFlinkMemorySize(), 
is(TOTAL_FLINK_MEM_SIZE));
-               assertThat(JobManagerProcessSpec.getJvmHeapMemorySize(), 
is(JVM_HEAP_SIZE));
-               validateFunc.accept(JobManagerProcessSpec);
+               JobManagerProcessSpec jobManagerProcessSpec = 
JobManagerProcessUtils.processSpecFromConfig(config);
+               assertThat(jobManagerProcessSpec.getTotalFlinkMemorySize(), 
is(TOTAL_FLINK_MEM_SIZE));
+               assertThat(jobManagerProcessSpec.getJvmHeapMemorySize(), 
is(JVM_HEAP_SIZE));
+               validateFunc.accept(jobManagerProcessSpec);
        }
 
        private void 
validateFailInConfigWithExplicitTotalFlinkAndJvmHeapMem(Configuration 
customConfig) {
@@ -260,9 +260,9 @@ public class JobManagerProcessUtilsTest extends 
ProcessMemoryUtilsTestBase<JobMa
                log.info("Validating in configuration with explicit total 
process memory size.");
                Configuration config = configWithExplicitTotalProcessMem();
                config.addAll(customConfig);
-               JobManagerProcessSpec JobManagerProcessSpec = 
JobManagerProcessUtils.processSpecFromConfig(config);
-               assertThat(JobManagerProcessSpec.getTotalProcessMemorySize(), 
is(TOTAL_PROCESS_MEM_SIZE));
-               validateFunc.accept(JobManagerProcessSpec);
+               JobManagerProcessSpec jobManagerProcessSpec = 
JobManagerProcessUtils.processSpecFromConfig(config);
+               assertThat(jobManagerProcessSpec.getTotalProcessMemorySize(), 
is(TOTAL_PROCESS_MEM_SIZE));
+               validateFunc.accept(jobManagerProcessSpec);
        }
 
        private void 
validateFailInConfigWithExplicitTotalProcessMem(Configuration customConfig) {