This is an automated email from the ASF dual-hosted git repository.
lzljs3620320 pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/paimon.git
The following commit(s) were added to refs/heads/master by this push:
new 94c0fd24c8 [core] let 'sequence.field' be mutable (#6196)
94c0fd24c8 is described below
commit 94c0fd24c8351196acb4d08861fcec238d057396
Author: Jingsong Lee <[email protected]>
AuthorDate: Thu Sep 4 17:17:00 2025 +0800
[core] let 'sequence.field' be mutable (#6196)
---
paimon-api/src/main/java/org/apache/paimon/CoreOptions.java | 2 --
.../src/test/java/org/apache/paimon/flink/SchemaChangeITCase.java | 8 --------
.../paimon/flink/action/cdc/mysql/MySqlSyncTableActionITCase.java | 4 ----
.../src/test/java/org/apache/paimon/flink/SchemaChangeITCase.java | 8 --------
4 files changed, 22 deletions(-)
diff --git a/paimon-api/src/main/java/org/apache/paimon/CoreOptions.java
b/paimon-api/src/main/java/org/apache/paimon/CoreOptions.java
index 00c5574d8d..626ca67a31 100644
--- a/paimon-api/src/main/java/org/apache/paimon/CoreOptions.java
+++ b/paimon-api/src/main/java/org/apache/paimon/CoreOptions.java
@@ -779,7 +779,6 @@ public class CoreOptions implements Serializable {
.withDescription(
"Fields that are ignored for comparison while
generating -U, +U changelog for the same record. This configuration is only
valid for the changelog-producer.row-deduplicate is true.");
- @Immutable
public static final ConfigOption<String> SEQUENCE_FIELD =
key("sequence.field")
.stringType()
@@ -788,7 +787,6 @@ public class CoreOptions implements Serializable {
"The field that generates the sequence number for
primary key table,"
+ " the sequence number determines which
data is the most recent.");
- @Immutable
public static final ConfigOption<SortOrder> SEQUENCE_FIELD_SORT_ORDER =
key("sequence.field.sort-order")
.enumType(SortOrder.class)
diff --git
a/paimon-flink/paimon-flink-1.16/src/test/java/org/apache/paimon/flink/SchemaChangeITCase.java
b/paimon-flink/paimon-flink-1.16/src/test/java/org/apache/paimon/flink/SchemaChangeITCase.java
index 19ad41cae5..d5599410ad 100644
---
a/paimon-flink/paimon-flink-1.16/src/test/java/org/apache/paimon/flink/SchemaChangeITCase.java
+++
b/paimon-flink/paimon-flink-1.16/src/test/java/org/apache/paimon/flink/SchemaChangeITCase.java
@@ -90,13 +90,5 @@ public class SchemaChangeITCase extends CatalogITCaseBase {
.rootCause()
.isInstanceOf(UnsupportedOperationException.class)
.hasMessage("Change 'merge-engine' is not supported yet.");
-
- // sequence.field is immutable
- sql("CREATE TABLE T5 (a STRING, b STRING, c STRING) WITH
('sequence.field' = 'b')");
- sql("INSERT INTO T5 VALUES ('a', 'b', 'c')");
- assertThatThrownBy(() -> sql("ALTER TABLE T5 SET ('sequence.field' =
'c')"))
- .rootCause()
- .isInstanceOf(UnsupportedOperationException.class)
- .hasMessage("Change 'sequence.field' is not supported yet.");
}
}
diff --git
a/paimon-flink/paimon-flink-cdc/src/test/java/org/apache/paimon/flink/action/cdc/mysql/MySqlSyncTableActionITCase.java
b/paimon-flink/paimon-flink-cdc/src/test/java/org/apache/paimon/flink/action/cdc/mysql/MySqlSyncTableActionITCase.java
index 1200629351..065b926204 100644
---
a/paimon-flink/paimon-flink-cdc/src/test/java/org/apache/paimon/flink/action/cdc/mysql/MySqlSyncTableActionITCase.java
+++
b/paimon-flink/paimon-flink-cdc/src/test/java/org/apache/paimon/flink/action/cdc/mysql/MySqlSyncTableActionITCase.java
@@ -1301,7 +1301,6 @@ public class MySqlSyncTableActionITCase extends
MySqlActionITCaseBase {
Map<String, String> options = new HashMap<>();
options.put("bucket", "1");
options.put("sink.parallelism", "1");
- options.put("sequence.field", "_timestamp");
createFileStoreTable(
RowType.of(
@@ -1318,8 +1317,6 @@ public class MySqlSyncTableActionITCase extends
MySqlActionITCaseBase {
mySqlConfig.put("database-name", DATABASE_NAME);
mySqlConfig.put("table-name", "test_exist_options_change");
Map<String, String> tableConfig = new HashMap<>();
- // update immutable options
- tableConfig.put("sequence.field", "_date");
// update existing options
tableConfig.put("sink.parallelism", "2");
// add new options
@@ -1335,7 +1332,6 @@ public class MySqlSyncTableActionITCase extends
MySqlActionITCaseBase {
FileStoreTable table = getFileStoreTable();
assertThat(table.options().get("bucket")).isEqualTo("1");
-
assertThat(table.options().get("sequence.field")).isEqualTo("_timestamp");
assertThat(table.options().get("sink.parallelism")).isEqualTo("2");
assertThat(table.options().get("snapshot.expire.limit")).isEqualTo("1000");
}
diff --git
a/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/SchemaChangeITCase.java
b/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/SchemaChangeITCase.java
index 8edc85a3c2..9084b55d60 100644
---
a/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/SchemaChangeITCase.java
+++
b/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/SchemaChangeITCase.java
@@ -896,14 +896,6 @@ public class SchemaChangeITCase extends CatalogITCaseBase {
.rootCause()
.isInstanceOf(UnsupportedOperationException.class)
.hasMessage("Change 'merge-engine' is not supported yet.");
-
- // sequence.field is immutable
- sql("CREATE TABLE T5 (a STRING, b STRING, c STRING) WITH
('sequence.field' = 'b')");
- sql("INSERT INTO T5 VALUES ('a', 'b', 'c')");
- assertThatThrownBy(() -> sql("ALTER TABLE T5 SET ('sequence.field' =
'c')"))
- .rootCause()
- .isInstanceOf(UnsupportedOperationException.class)
- .hasMessage("Change 'sequence.field' is not supported yet.");
}
@Test
