This is an automated email from the ASF dual-hosted git repository.
guoweijie 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 21092bf229d [FLINK-3992][core] Do not implement deprecated Key
interface
21092bf229d is described below
commit 21092bf229d0acdbac47a7d4d83cc5327b06325d
Author: Weijie Guo <[email protected]>
AuthorDate: Fri Sep 27 10:07:36 2024 +0800
[FLINK-3992][core] Do not implement deprecated Key interface
---
flink-core/src/main/java/org/apache/flink/types/DoubleValue.java | 3 +--
flink-core/src/main/java/org/apache/flink/types/FloatValue.java | 5 +----
flink-core/src/main/java/org/apache/flink/types/NormalizableKey.java | 2 +-
pom.xml | 4 ++++
4 files changed, 7 insertions(+), 7 deletions(-)
diff --git a/flink-core/src/main/java/org/apache/flink/types/DoubleValue.java
b/flink-core/src/main/java/org/apache/flink/types/DoubleValue.java
index 15f3a854cb4..45f0346b1c3 100644
--- a/flink-core/src/main/java/org/apache/flink/types/DoubleValue.java
+++ b/flink-core/src/main/java/org/apache/flink/types/DoubleValue.java
@@ -32,8 +32,7 @@ import java.io.IOException;
public class DoubleValue
implements Comparable<DoubleValue>,
ResettableValue<DoubleValue>,
- CopyableValue<DoubleValue>,
- Key<DoubleValue> {
+ CopyableValue<DoubleValue> {
private static final long serialVersionUID = 1L;
private double value;
diff --git a/flink-core/src/main/java/org/apache/flink/types/FloatValue.java
b/flink-core/src/main/java/org/apache/flink/types/FloatValue.java
index 287fbaf08df..3bc83cd3e04 100644
--- a/flink-core/src/main/java/org/apache/flink/types/FloatValue.java
+++ b/flink-core/src/main/java/org/apache/flink/types/FloatValue.java
@@ -30,10 +30,7 @@ import java.io.IOException;
*/
@Public
public class FloatValue
- implements Comparable<FloatValue>,
- ResettableValue<FloatValue>,
- CopyableValue<FloatValue>,
- Key<FloatValue> {
+ implements Comparable<FloatValue>, ResettableValue<FloatValue>,
CopyableValue<FloatValue> {
private static final long serialVersionUID = 1L;
private float value;
diff --git
a/flink-core/src/main/java/org/apache/flink/types/NormalizableKey.java
b/flink-core/src/main/java/org/apache/flink/types/NormalizableKey.java
index 72c0a3e483f..0433518af0f 100644
--- a/flink-core/src/main/java/org/apache/flink/types/NormalizableKey.java
+++ b/flink-core/src/main/java/org/apache/flink/types/NormalizableKey.java
@@ -34,7 +34,7 @@ import org.apache.flink.core.memory.MemorySegment;
* normalized key length.
*/
@Public
-public interface NormalizableKey<T> extends Comparable<T>, Key<T> {
+public interface NormalizableKey<T> extends Comparable<T> {
/**
* Gets the maximal length of normalized keys that the data type would
produce to determine the
diff --git a/pom.xml b/pom.xml
index d29130b1793..907b938e62d 100644
--- a/pom.xml
+++ b/pom.xml
@@ -2393,6 +2393,10 @@ under the License.
<exclude>
org.apache.flink.api.common.functions.RuntimeContext#getExecutionConfig()
</exclude>
+ <!-- FLINK-3992
Do not implement deprecated Key interface in flink 2.0 -->
+
<exclude>org.apache.flink.types.DoubleValue</exclude>
+
<exclude>org.apache.flink.types.FloatValue</exclude>
+
<exclude>org.apache.flink.types.NormalizableKey</exclude>
<!-- FLINK-5336
Remove IOReadableWritable from Path in flink-2.0. -->
<exclude>org.apache.flink.core.fs.Path</exclude>
<!-- The
following exclusions are due to the
flink-hadoop-compatibility_${scala.binary.version} module has renamed to
flink-hadoop-compatibility. -->
