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

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

commit d13e5377947d0594523fbd6950b0b1d9789d431c
Author: ifndef-SleePy <mmyy1...@gmail.com>
AuthorDate: Fri Aug 30 20:02:23 2019 +0800

    [hotfix][tests] Fix code style problem of JobMasterTest
---
 .../test/java/org/apache/flink/runtime/jobmaster/JobMasterTest.java | 6 ++----
 1 file changed, 2 insertions(+), 4 deletions(-)

diff --git 
a/flink-runtime/src/test/java/org/apache/flink/runtime/jobmaster/JobMasterTest.java
 
b/flink-runtime/src/test/java/org/apache/flink/runtime/jobmaster/JobMasterTest.java
index 3e308d0..e3475e7 100644
--- 
a/flink-runtime/src/test/java/org/apache/flink/runtime/jobmaster/JobMasterTest.java
+++ 
b/flink-runtime/src/test/java/org/apache/flink/runtime/jobmaster/JobMasterTest.java
@@ -1779,7 +1779,7 @@ public class JobMasterTest extends TestLogger {
        }
 
        /**
-        * Tests the updateGlobalAggregate functionality
+        * Tests the updateGlobalAggregate functionality.
         */
        @Test
        public void testJobMasterAggregatesValuesCorrectly() throws Exception {
@@ -1837,9 +1837,7 @@ public class JobMasterTest extends TestLogger {
 
                        @Override
                        public Integer add(Integer value, Integer accumulator) {
-                               Integer _acc = (Integer) accumulator;
-                               Integer _value = (Integer) value;
-                               return _acc + _value;
+                               return accumulator + value;
                        }
 
                        @Override

Reply via email to