Skip to content

[Bug] Avoid altering lake catalog for tables that never enabled datalake #3302

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
luoyuxia merged 3 commits into from
May 13, 2026
+6 −1
Merged

[Bug] Avoid altering lake catalog for tables that never enabled datalake #3302

Changes from all commits
Commits
Show all changes
3 commits
Select commit Hold shift + click to select a range
3285a2f
Bug#3297:Avoid altering lake catalog for tables that never enabled da…
May 12, 2026
de09a19
Added comments for bug fix #3297
May 12, 2026
2de090d
Fixed formatting issues for CI check
MaheshS08 May 12, 2026
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
7 changes: 6 additions & 1 deletion fluss-server/src/main/java/org/apache/fluss/server/coordinator/MetadataManager.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -603,7 +603,12 @@ private void preAlterTableProperties(
// 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) {
Expand Down