This is an automated email from the ASF dual-hosted git repository.
luoyuxia pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/fluss.git
The following commit(s) were added to refs/heads/main by this push:
new 0ee5f177f [coordinator] Avoid altering lake catalog for tables that
never enabled datalake (#3302)
0ee5f177f is described below
commit 0ee5f177f99447a60a0b268b7649777c72f979c2
Author: Mahesh Sambaram <[email protected]>
AuthorDate: Wed May 13 07:59:55 2026 +0530
[coordinator] Avoid altering lake catalog for tables that never enabled
datalake (#3302)
---
.../java/org/apache/fluss/server/coordinator/MetadataManager.java | 7 ++++++-
1 file changed, 6 insertions(+), 1 deletion(-)
diff --git
a/fluss-server/src/main/java/org/apache/fluss/server/coordinator/MetadataManager.java
b/fluss-server/src/main/java/org/apache/fluss/server/coordinator/MetadataManager.java
index 71cd2f9f4..65ba95d2a 100644
---
a/fluss-server/src/main/java/org/apache/fluss/server/coordinator/MetadataManager.java
+++
b/fluss-server/src/main/java/org/apache/fluss/server/coordinator/MetadataManager.java
@@ -603,7 +603,12 @@ public class MetadataManager {
// We should always alter lake table even though datalake is disabled.
// Otherwise, if user alter the fluss table when datalake is disabled,
then enable datalake
// again, the lake table will mismatch.
- if (lakeCatalog != null) {
+ // Only sync to lake if this table has ever opted into datalake (key
present regardless of
+ // value).
+ if (lakeCatalog != null
+ && tableDescriptor
+ .getProperties()
+
.containsKey(ConfigOptions.TABLE_DATALAKE_ENABLED.key())) {
try {
lakeCatalog.alterTable(tablePath, tableChanges,
lakeCatalogContext);
} catch (TableNotExistException e) {
