Fix Iceberg integration

Author: dolfinus

syncmaster/worker/handlers/db/iceberg.py

@@ -40,7 +40,7 @@ def connect(self, spark: SparkSession):
                 spark=spark,
                 catalog_name=self.transfer_dto.catalog_name,
                 catalog=Iceberg.RESTCatalog(
-                    uri=self.connection_dto.rest_catalog_url,
+                    url=self.connection_dto.rest_catalog_url,
                     auth=self._make_auth(),
                 ),
                 warehouse=Iceberg.S3Warehouse(
@@ -60,7 +60,7 @@ def connect(self, spark: SparkSession):
                 spark=spark,
                 catalog_name=self.transfer_dto.catalog_name,
                 catalog=Iceberg.RESTCatalog(
-                    uri=self.connection_dto.rest_catalog_url,
+                    url=self.connection_dto.rest_catalog_url,
                     auth=self._make_auth(),
                 ),
                 warehouse=Iceberg.DelegatedWarehouse(

tests/test_integration/test_run_transfer/connection_fixtures/iceberg_fixtures.py

@@ -77,7 +77,7 @@ def prepare_iceberg_rest_s3(
         spark=spark,
         catalog_name=catalog_name,
         catalog=Iceberg.RESTCatalog(
-            uri=iceberg.rest_catalog_url,
+            url=iceberg.rest_catalog_url,
             auth=Iceberg.RESTCatalog.BasicAuth(
                 user=iceberg.rest_catalog_username,
                 password=iceberg.rest_catalog_password,