Fix databricks dest config

airbytehq · Apr 23, 2022 · 7d9c771 · 7d9c771 · github-actions · Apr 23, 2022
1 parent ead3356
commit 7d9c771
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/...main/java/io/airbyte/integrations/destination/databricks/DatabricksDestinationConfig.java b/...main/java/io/airbyte/integrations/destination/databricks/DatabricksDestinationConfig.java
@@ -63,6 +63,9 @@ public static S3DestinationConfig getDataSource(final JsonNode dataSource) {
         dataSource.get("s3_bucket_name").asText(),
         dataSource.get("s3_bucket_path").asText(),
         dataSource.get("s3_bucket_region").asText())
+        .withAccessKeyCredential(
+            dataSource.get("s3_access_key_id").asText(),
+            dataSource.get("s3_secret_access_key").asText())
         .withFormatConfig(new S3ParquetFormatConfig(new ObjectMapper().createObjectNode()))
         .get();
   }