🐞 Destination databricks: fix destination config (#12299)

* Fix databricks dest config * Add private constructor for constant class
airbytehq · May 23, 2022 · 0e6561d · 0e6561d
1 parent 9c00492
commit 0e6561d
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 0 deletions.
diff --git a/...cks/src/main/java/io/airbyte/integrations/destination/databricks/DatabricksConstants.java b/...cks/src/main/java/io/airbyte/integrations/destination/databricks/DatabricksConstants.java
@@ -15,4 +15,7 @@ public class DatabricksConstants {
       "delta.autoOptimize.optimizeWrite = true",
       "delta.autoOptimize.autoCompact = true");
 
+  private DatabricksConstants() {
+  }
+
 }
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();
   }