diff --git a/exchange-common/src/main/scala/com/vesoft/exchange/common/config/Configs.scala b/exchange-common/src/main/scala/com/vesoft/exchange/common/config/Configs.scala
index 07d80984..11fc1942 100644
--- a/exchange-common/src/main/scala/com/vesoft/exchange/common/config/Configs.scala
+++ b/exchange-common/src/main/scala/com/vesoft/exchange/common/config/Configs.scala
@@ -665,7 +665,6 @@ object Configs {
           config.getString("host"),
           config.getInt("port"),
           config.getString("database"),
-          config.getString("schema"),
           config.getString("table"),
           config.getString("user"),
           config.getString("password"),
diff --git a/exchange-common/src/main/scala/com/vesoft/exchange/common/config/SourceConfigs.scala b/exchange-common/src/main/scala/com/vesoft/exchange/common/config/SourceConfigs.scala
index d8fb2a4b..ec66cc0a 100644
--- a/exchange-common/src/main/scala/com/vesoft/exchange/common/config/SourceConfigs.scala
+++ b/exchange-common/src/main/scala/com/vesoft/exchange/common/config/SourceConfigs.scala
@@ -174,7 +174,6 @@ case class PostgresSQLSourceConfigEntry(override val category: SourceCategory.Va
                                         host: String,
                                         port: Int,
                                         database: String,
-                                        schema: String,
                                         table: String,
                                         user: String,
                                         password: String,
diff --git a/exchange-common/src/test/scala/com/vesoft/exchange/common/config/ConfigsSuite.scala b/exchange-common/src/test/scala/com/vesoft/exchange/common/config/ConfigsSuite.scala
index 7fff13c4..e7cd8077 100644
--- a/exchange-common/src/test/scala/com/vesoft/exchange/common/config/ConfigsSuite.scala
+++ b/exchange-common/src/test/scala/com/vesoft/exchange/common/config/ConfigsSuite.scala
@@ -165,7 +165,6 @@ class ConfigsSuite {
           assert(postgresql.port == 5432)
           assert(postgresql.user.equals("root"))
           assert(postgresql.password.equals("nebula"))
-          assert(postgresql.schema.equals("public"))
           assert(postgresql.database.equals("database"))
           assert(postgresql.table.equals("table"))
         }
diff --git a/nebula-exchange_spark_3.0/src/main/scala/com/vesoft/nebula/exchange/reader/ServerBaseReader.scala b/nebula-exchange_spark_3.0/src/main/scala/com/vesoft/nebula/exchange/reader/ServerBaseReader.scala
index 76cd78be..34158b2c 100644
--- a/nebula-exchange_spark_3.0/src/main/scala/com/vesoft/nebula/exchange/reader/ServerBaseReader.scala
+++ b/nebula-exchange_spark_3.0/src/main/scala/com/vesoft/nebula/exchange/reader/ServerBaseReader.scala
@@ -84,7 +84,7 @@ class PostgreSQLReader(override val session: SparkSession, postgreConfig: Postgr
     val df = session.read
       .format("jdbc")
       .option("url", url)
-      .option("dbtable", s"${postgreConfig.schema}.${postgreConfig.table}")
+      .option("dbtable", postgreConfig.table)
       .option("user", postgreConfig.user)
       .option("password", postgreConfig.password)
       .load()