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