Skip to content
Open
Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
25 commits
Select commit Hold shift + click to select a range
e93ce1c
Fix alter operations for iceberg
subkanthi Aug 3, 2026
fa311a9
Merge branch 'antalya-26.6' into antalya_26_6_fix_alter_table_iceberg
subkanthi Aug 4, 2026
818f446
Merge branch 'antalya-26.6' into antalya_26_6_fix_alter_table_iceberg
subkanthi Aug 4, 2026
d62b9ac
Merge branch 'antalya-26.6' into antalya_26_6_fix_alter_table_iceberg
subkanthi Aug 6, 2026
0eb31fc
fix medium defects with retries
subkanthi Aug 6, 2026
f76fd1d
Added support for boolean and decimal
subkanthi Aug 6, 2026
bdb0d15
Add missing include to gtest_iceberg_type_mapping
subkanthi Aug 6, 2026
d3b65e3
Merge branch 'antalya-26.6' into antalya_26_6_fix_alter_table_iceberg
subkanthi Aug 6, 2026
04c009e
Restored removed tests
subkanthi Aug 7, 2026
a4e6f39
Merge branch 'antalya_26_6_fix_alter_table_iceberg' of https://github…
subkanthi Aug 7, 2026
6e6f1f7
Fix to support decimal datatypes in iceberg
subkanthi Aug 7, 2026
ad9e5c7
Merge branch 'antalya-26.6' into antalya_26_6_fix_alter_table_iceberg
subkanthi Aug 7, 2026
8e9c6f7
Fix nullptr exception when there are no snapshots
subkanthi Aug 11, 2026
3da03ba
Merge branch 'antalya_26_6_fix_alter_table_iceberg' of https://github…
subkanthi Aug 11, 2026
bedcad9
Fix compiler error
subkanthi Aug 11, 2026
304fc24
Merge branch 'antalya-26.6' into antalya_26_6_fix_alter_table_iceberg
subkanthi Aug 11, 2026
12df291
Fix compiler error
subkanthi Aug 11, 2026
7f35e6c
Merge branch 'antalya_26_6_fix_alter_table_iceberg' of https://github…
subkanthi Aug 11, 2026
d4c5df2
Revert back change to settings regarding iceberg manifest compaction,…
subkanthi Aug 11, 2026
422f409
Reverted back settings changes(removal)
subkanthi Aug 11, 2026
8bbea38
Reverted back settings changes(removal)
subkanthi Aug 11, 2026
c72983e
Address medium defects
subkanthi Aug 11, 2026
a73db85
Fix high defect with nullptr in failsafe
subkanthi Aug 12, 2026
846e827
Fix wrong doc comment
subkanthi Aug 13, 2026
5968163
Remove dead code, fix/remove failpoint
subkanthi Aug 13, 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
2 changes: 2 additions & 0 deletions src/Common/FailPoint.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -163,6 +163,8 @@ static struct InitFiu
ONCE(write_file_operation_fail_on_read) \
REGULAR(slowdown_parallel_replicas_local_plan_read) \
ONCE(iceberg_writes_cleanup) \
ONCE(iceberg_alter_catalog_update_schema_fail) \
ONCE(iceberg_alter_catalog_commit_reported_as_failed) \
REGULAR(storage_cluster_read_sleep) \
ONCE(backup_add_empty_memory_table) \
PAUSEABLE_ONCE(backup_pause_on_start) \
Expand Down
4 changes: 3 additions & 1 deletion src/Databases/DataLake/GlueCatalog.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -679,7 +679,9 @@ bool GlueCatalog::updateSchema(
const String & table_name,
const String & new_metadata_path,
Poco::JSON::Object::Ptr /*new_schema*/,
Int32 /*previous_schema_id*/) const
Int32 /*previous_schema_id*/,
Int32 /*new_last_column_id*/,
Poco::JSON::Object::Ptr /*metadata*/) const
{
return updateMetadata(namespace_name, table_name, new_metadata_path, nullptr);
}
Expand Down
4 changes: 3 additions & 1 deletion src/Databases/DataLake/GlueCatalog.h
Original file line number Diff line number Diff line change
Expand Up @@ -73,7 +73,9 @@ class GlueCatalog final : public ICatalog, private DB::WithContext
const String & table_name,
const String & new_metadata_path,
Poco::JSON::Object::Ptr new_schema,
Int32 previous_schema_id) const override;
Int32 previous_schema_id,
Int32 new_last_column_id,
Poco::JSON::Object::Ptr metadata = nullptr) const override;

void dropTable(const String & namespace_name, const String & table_name) const override;

Expand Down
4 changes: 3 additions & 1 deletion src/Databases/DataLake/ICatalog.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -325,7 +325,9 @@ bool ICatalog::updateSchema(
const String & /*table_name*/,
const String & /*new_metadata_path*/,
Poco::JSON::Object::Ptr /*new_schema*/,
Int32 /*previous_schema_id*/) const
Int32 /*previous_schema_id*/,
Int32 /*new_last_column_id*/,
Poco::JSON::Object::Ptr /*metadata*/) const
{
throw DB::Exception(DB::ErrorCodes::NOT_IMPLEMENTED, "updateSchema is not implemented");
}
Expand Down
4 changes: 3 additions & 1 deletion src/Databases/DataLake/ICatalog.h
Original file line number Diff line number Diff line change
Expand Up @@ -196,7 +196,9 @@ class ICatalog
const String & table_name,
const String & new_metadata_path,
Poco::JSON::Object::Ptr new_schema,
Int32 previous_schema_id) const;
Int32 previous_schema_id,
Int32 new_last_column_id,
Poco::JSON::Object::Ptr metadata = nullptr) const;

/// Drop table from catalog.
virtual void dropTable(const String & namespace_name, const String & table_name) const;
Expand Down
Loading
Loading