This is an automated email from the ASF dual-hosted git repository. xuyangzhong pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git
commit ce310b5384264d5fc02daa152315dbf3087b76e2 Author: xuyang <[email protected]> AuthorDate: Thu Mar 26 19:51:18 2026 +0800 [hotfix] Fix unused field in ImmutableColumnsConstraint --- .../org/apache/flink/table/catalog/ImmutableColumnsConstraint.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/flink-table/flink-table-common/src/main/java/org/apache/flink/table/catalog/ImmutableColumnsConstraint.java b/flink-table/flink-table-common/src/main/java/org/apache/flink/table/catalog/ImmutableColumnsConstraint.java index e1426d0b659..1190231aeea 100644 --- a/flink-table/flink-table-common/src/main/java/org/apache/flink/table/catalog/ImmutableColumnsConstraint.java +++ b/flink-table/flink-table-common/src/main/java/org/apache/flink/table/catalog/ImmutableColumnsConstraint.java @@ -61,7 +61,7 @@ public final class ImmutableColumnsConstraint extends AbstractConstraint { @Override public ConstraintType getType() { - return ConstraintType.IMMUTABLE_COLUMNS; + return type; } @Override @@ -87,11 +87,11 @@ public final class ImmutableColumnsConstraint extends AbstractConstraint { return false; } ImmutableColumnsConstraint that = (ImmutableColumnsConstraint) o; - return Objects.equals(columns, that.columns); + return Objects.equals(columns, that.columns) && type == that.type; } @Override public int hashCode() { - return Objects.hash(super.hashCode(), columns); + return Objects.hash(super.hashCode(), columns, type); } }
