diff --git a/destination/iceberg/java_client.go b/destination/iceberg/java_client.go index bc8d48d2..72f86402 100644 --- a/destination/iceberg/java_client.go +++ b/destination/iceberg/java_client.go @@ -114,16 +114,11 @@ func getServerConfigJSON(config *Config, partitionInfo []PartitionInfo, port int logger.Warnf("No region explicitly provided for Glue catalog, the Java process will attempt to use region from AWS environment") } - // Configure custom endpoint for S3-compatible services (like MinIO) if config.S3Endpoint != "" { serverConfig["s3.endpoint"] = config.S3Endpoint - serverConfig["io-impl"] = "org.apache.iceberg.io.ResolvingFileIO" - // Set SSL/TLS configuration - serverConfig["s3.ssl-enabled"] = utils.Ternary(config.S3UseSSL, "true", "false").(string) } - - // Configure S3 or GCP file IO - serverConfig["io-impl"] = utils.Ternary(strings.HasPrefix(config.IcebergS3Path, "gs://"), "org.apache.iceberg.gcp.gcs.GCSFileIO", "org.apache.iceberg.aws.s3.S3FileIO") + serverConfig["io-impl"] = "org.apache.iceberg.io.ResolvingFileIO" + serverConfig["s3.ssl-enabled"] = utils.Ternary(config.S3UseSSL, "true", "false").(string) // Marshal the config to JSON return json.Marshal(serverConfig)