Skip to content

Commit 0e6561d

Browse files
tulirensuhomud
authored andcommitted
🐞 Destination databricks: fix destination config (#12299)
* Fix databricks dest config * Add private constructor for constant class
1 parent 9c00492 commit 0e6561d

File tree

2 files changed

+6
-0
lines changed

2 files changed

+6
-0
lines changed

airbyte-integrations/connectors/destination-databricks/src/main/java/io/airbyte/integrations/destination/databricks/DatabricksConstants.java

+3
Original file line numberDiff line numberDiff line change
@@ -15,4 +15,7 @@ public class DatabricksConstants {
1515
"delta.autoOptimize.optimizeWrite = true",
1616
"delta.autoOptimize.autoCompact = true");
1717

18+
private DatabricksConstants() {
19+
}
20+
1821
}

airbyte-integrations/connectors/destination-databricks/src/main/java/io/airbyte/integrations/destination/databricks/DatabricksDestinationConfig.java

+3
Original file line numberDiff line numberDiff line change
@@ -63,6 +63,9 @@ public static S3DestinationConfig getDataSource(final JsonNode dataSource) {
6363
dataSource.get("s3_bucket_name").asText(),
6464
dataSource.get("s3_bucket_path").asText(),
6565
dataSource.get("s3_bucket_region").asText())
66+
.withAccessKeyCredential(
67+
dataSource.get("s3_access_key_id").asText(),
68+
dataSource.get("s3_secret_access_key").asText())
6669
.withFormatConfig(new S3ParquetFormatConfig(new ObjectMapper().createObjectNode()))
6770
.get();
6871
}

0 commit comments

Comments
 (0)