diff --git a/src/Core/PostgreSQL/PostgreSQLConnection.cpp b/src/Core/PostgreSQL/PostgreSQLConnection.cpp
index b6128e909ef..a6edf3e150e 100644
--- a/src/Core/PostgreSQL/PostgreSQLConnection.cpp
+++ b/src/Core/PostgreSQL/PostgreSQLConnection.cpp
@@ -42,13 +42,6 @@ ConnectionPtr createReplicationConnection(const ConnectionInfo & connection_info
 }
 
 
-template <typename T>
-std::shared_ptr<T> createTransaction(pqxx::connection & connection)
-{
-    return std::make_shared<T>(connection);
-}
-
-
 Connection::Connection(const ConnectionInfo & connection_info_)
     : connection_info(connection_info_)
 {
diff --git a/src/DataStreams/PostgreSQLBlockInputStream.h b/src/DataStreams/PostgreSQLBlockInputStream.h
index d62c11ccef7..5c637015f18 100644
--- a/src/DataStreams/PostgreSQLBlockInputStream.h
+++ b/src/DataStreams/PostgreSQLBlockInputStream.h
@@ -61,11 +61,10 @@ private:
 };
 
 
-/// Passes transaction object into PostgreSQLBlockInputStream and does not close transaction after read if finished.
+/// Passes transaction object into PostgreSQLBlockInputStream and does not close transaction after read is finished.
 template <typename T>
 class PostgreSQLTransactionBlockInputStream : public PostgreSQLBlockInputStream<T>
 {
-
 public:
     using Base = PostgreSQLBlockInputStream<T>;
 
diff --git a/src/Storages/PostgreSQL/PostgreSQLReplicationHandler.cpp b/src/Storages/PostgreSQL/PostgreSQLReplicationHandler.cpp
index cce84892ed6..a1825afe622 100644
--- a/src/Storages/PostgreSQL/PostgreSQLReplicationHandler.cpp
+++ b/src/Storages/PostgreSQL/PostgreSQLReplicationHandler.cpp
@@ -17,6 +17,8 @@ namespace DB
 static const auto reschedule_ms = 500;
 
 
+/// TODO: fetch replica identity index
+
 PostgreSQLReplicationHandler::PostgreSQLReplicationHandler(
     const std::string & database_name_,
     const postgres::ConnectionInfo & connection_info_,
@@ -279,9 +281,8 @@ bool PostgreSQLReplicationHandler::isReplicationSlotExist(pqxx::nontransaction &
     if (result.empty())
         return false;
 
-    bool is_active = result[0][0].as<bool>();
     LOG_TRACE(log, "Replication slot {} already exists (active: {}). Restart lsn position is {}",
-            slot_name, is_active, result[0][0].as<std::string>());
+            slot_name, result[0][0].as<bool>(), result[0][0].as<std::string>());
 
     return true;
 }
diff --git a/src/Storages/PostgreSQL/StorageMaterializePostgreSQL.cpp b/src/Storages/PostgreSQL/StorageMaterializePostgreSQL.cpp
index 65b38086db9..a680a5bfd84 100644
--- a/src/Storages/PostgreSQL/StorageMaterializePostgreSQL.cpp
+++ b/src/Storages/PostgreSQL/StorageMaterializePostgreSQL.cpp
@@ -77,7 +77,6 @@ StorageMaterializePostgreSQL::StorageMaterializePostgreSQL(
     , nested_storage(nested_storage_)
     , is_postgresql_replica_database(true)
 {
-
 }