hardcoding sqoop bucket for now

razorpay · Nov 29, 2024 · 01c5a6d · 01c5a6d
1 parent ce9b41a
commit 01c5a6d
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/sql-delta-import/src/main/scala/com/razorpay/spark/jdbc/JDBCImport.scala b/sql-delta-import/src/main/scala/com/razorpay/spark/jdbc/JDBCImport.scala
@@ -93,7 +93,7 @@ class JDBCImport(
 
 
   def createDbIfNotExists(outputDbName: String): Unit = {
-    val s3Bucket = Credentials.getSecretValue("SQOOP_S3_BUCKET")
+    val s3Bucket = "rzp-de-sg-cell-101-payment"
     val baseS3Path = s"s3a://$s3Bucket/sqoop"
 
     if (!spark.catalog.databaseExists(outputDbName)) {
@@ -307,7 +307,7 @@ class JDBCImport(
     val s3BucketConf = importConfig.s3Bucket
 
     val s3Bucket = if (s3BucketConf.isDefined) { s3BucketConf.get }
-    else { Credentials.getSecretValue("SQOOP_S3_BUCKET") }
+    else { "rzp-de-sg-cell-101-payment" }
 
     val dbtable = importConfig.outputTable.split("\\.")