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 index b200d8e17..91de01307 100644 --- 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 }