This is an automated email from the ASF dual-hosted git repository.
zhuzh 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 5cda33d87be [FLINK-32654][configuration] Deprecate
ExecutionConfig#canEqual(obj)
5cda33d87be is described below
commit 5cda33d87be1a39e63f24d3c564c5a23ecb699d0
Author: Zhu Zhu <[email protected]>
AuthorDate: Mon Jul 24 16:00:13 2023 +0800
[FLINK-32654][configuration] Deprecate ExecutionConfig#canEqual(obj)
This closes #23061.
---
.../main/java/org/apache/flink/api/common/ExecutionConfig.java | 9 +++++++--
1 file changed, 7 insertions(+), 2 deletions(-)
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 e09cd74a8a8..19f82fdfe74 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
@@ -941,8 +941,7 @@ public class ExecutionConfig implements Serializable,
Archiveable<ArchivedExecut
if (obj instanceof ExecutionConfig) {
ExecutionConfig other = (ExecutionConfig) obj;
- return other.canEqual(this)
- && Objects.equals(configuration, other.configuration)
+ return Objects.equals(configuration, other.configuration)
&& ((restartStrategyConfiguration == null
&& other.restartStrategyConfiguration ==
null)
|| (null != restartStrategyConfiguration
@@ -998,6 +997,12 @@ public class ExecutionConfig implements Serializable,
Archiveable<ArchivedExecut
+ '}';
}
+ /**
+ * This method simply checks whether the object is an {@link
ExecutionConfig} instance.
+ *
+ * @deprecated It is not intended to be used by users.
+ */
+ @Deprecated
public boolean canEqual(Object obj) {
return obj instanceof ExecutionConfig;
}