Skip to content

Commit 9c23984

Browse files
fix: Azure ADLS Lakekeeper Rest Catalog Issue (#591)
Signed-off-by: badalprasadsingh <[email protected]>
1 parent 2e3918d commit 9c23984

File tree

1 file changed

+2
-7
lines changed

1 file changed

+2
-7
lines changed

destination/iceberg/java_client.go

Lines changed: 2 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -114,16 +114,11 @@ func getServerConfigJSON(config *Config, partitionInfo []PartitionInfo, port int
114114
logger.Warnf("No region explicitly provided for Glue catalog, the Java process will attempt to use region from AWS environment")
115115
}
116116

117-
// Configure custom endpoint for S3-compatible services (like MinIO)
118117
if config.S3Endpoint != "" {
119118
serverConfig["s3.endpoint"] = config.S3Endpoint
120-
serverConfig["io-impl"] = "org.apache.iceberg.io.ResolvingFileIO"
121-
// Set SSL/TLS configuration
122-
serverConfig["s3.ssl-enabled"] = utils.Ternary(config.S3UseSSL, "true", "false").(string)
123119
}
124-
125-
// Configure S3 or GCP file IO
126-
serverConfig["io-impl"] = utils.Ternary(strings.HasPrefix(config.IcebergS3Path, "gs://"), "org.apache.iceberg.gcp.gcs.GCSFileIO", "org.apache.iceberg.aws.s3.S3FileIO")
120+
serverConfig["io-impl"] = "org.apache.iceberg.io.ResolvingFileIO"
121+
serverConfig["s3.ssl-enabled"] = utils.Ternary(config.S3UseSSL, "true", "false").(string)
127122

128123
// Marshal the config to JSON
129124
return json.Marshal(serverConfig)

0 commit comments

Comments
 (0)