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

hequn pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git


The following commit(s) were added to refs/heads/master by this push:
     new 7470e44  [FLINK-13906][core] Implement hashCode() method in class 
`GlobalJobParameters`
7470e44 is described below

commit 7470e44354b97a0320c35eccb80342affa654714
Author: Wei Zhong <[email protected]>
AuthorDate: Mon Sep 2 14:54:41 2019 +0800

    [FLINK-13906][core] Implement hashCode() method in class 
`GlobalJobParameters`
    
    This closes #9593
---
 .../main/java/org/apache/flink/api/common/ExecutionConfig.java   | 5 +++++
 .../java/org/apache/flink/api/common/ExecutionConfigTest.java    | 9 +++++++++
 2 files changed, 14 insertions(+)

diff --git 
a/flink-core/src/main/java/org/apache/flink/api/common/ExecutionConfig.java 
b/flink-core/src/main/java/org/apache/flink/api/common/ExecutionConfig.java
index 7719610..a02a180 100644
--- a/flink-core/src/main/java/org/apache/flink/api/common/ExecutionConfig.java
+++ b/flink-core/src/main/java/org/apache/flink/api/common/ExecutionConfig.java
@@ -1075,6 +1075,11 @@ public class ExecutionConfig implements Serializable, 
Archiveable<ArchivedExecut
 
                        return true;
                }
+
+               @Override
+               public int hashCode() {
+                       return Objects.hash();
+               }
        }
 
        /**
diff --git 
a/flink-core/src/test/java/org/apache/flink/api/common/ExecutionConfigTest.java 
b/flink-core/src/test/java/org/apache/flink/api/common/ExecutionConfigTest.java
index b415743..5ea2f09 100644
--- 
a/flink-core/src/test/java/org/apache/flink/api/common/ExecutionConfigTest.java
+++ 
b/flink-core/src/test/java/org/apache/flink/api/common/ExecutionConfigTest.java
@@ -159,4 +159,13 @@ public class ExecutionConfigTest extends TestLogger {
 
                assertNotNull(config.getGlobalJobParameters());
        }
+
+       @Test
+       public void testGlobalParametersHashCode() {
+               ExecutionConfig config = new ExecutionConfig();
+               ExecutionConfig anotherConfig = new ExecutionConfig();
+
+               assertEquals(config.getGlobalJobParameters().hashCode(),
+                       anotherConfig.getGlobalJobParameters().hashCode());
+       }
 }

Reply via email to