DE-6380 checking if schema defined

razorpay · Jul 24, 2024 · af793e0 · af793e0
1 parent a771ba4
commit af793e0
Showing 1 changed file with 1 addition and 1 deletion.
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
@@ -62,7 +62,7 @@ case class ImportConfig(
 
   var inputTableEscaped: String = escapeCharacter + inputTable + escapeCharacter
 
-  if (dbType == Constants.POSTGRESQL){
+  if (dbType == Constants.POSTGRESQL && schema.isDefined){
     inputTableEscaped = schema.get + "."+ inputTableEscaped
   }