diff --git a/etl-jobs/pom.xml b/etl-jobs/pom.xml index 6633d8803..c8736aa82 100644 --- a/etl-jobs/pom.xml +++ b/etl-jobs/pom.xml @@ -153,7 +153,7 @@ org.sunbird cloud-store-sdk_${scala.maj.version} - 1.3.0 + 1.4.6 com.microsoft.azure diff --git a/etl-jobs/src/main/scala/org/sunbird/analytics/jobs/ESCloudUploader.scala b/etl-jobs/src/main/scala/org/sunbird/analytics/jobs/ESCloudUploader.scala index 17e6a2bd8..56768500a 100644 --- a/etl-jobs/src/main/scala/org/sunbird/analytics/jobs/ESCloudUploader.scala +++ b/etl-jobs/src/main/scala/org/sunbird/analytics/jobs/ESCloudUploader.scala @@ -46,7 +46,7 @@ object ESCloudUploader { .saveAsTextFile(outputFilePath) // backup the output file to cloud - val storageService = StorageServiceFactory.getStorageService(StorageConfig(config.getString("cloudStorage.provider"), config.getString("cloudStorage.accountName"), config.getString("cloudStorage.accountKey"))) + val storageService = StorageServiceFactory.getStorageService(StorageConfig(config.getString("cloudStorage.provider"), config.getString("cloudStorage.accountName"), config.getString("cloudStorage.accountKey"),Option.apply(config.getString("cloudStorage.accountEndpoint")))) storageService.upload(config.getString("cloudStorage.container"), outputFilePath + "/part-00000", config.getString("cloudStorage.objectKey"), isDirectory = Option(false)) println("successfully backed up file to cloud!") System.exit(0)