From af793e0f17e43b446980ff4f25edca4ce2e6c8e5 Mon Sep 17 00:00:00 2001
From: SgtBurns <shubham.jaiswal@razorpay.com>
Date: Wed, 24 Jul 2024 12:43:49 +0530
Subject: [PATCH] DE-6380 checking if schema defined

---
 .../src/main/scala/com/razorpay/spark/jdbc/JDBCImport.scala     | 2 +-
 1 file changed, 1 insertion(+), 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
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
   }