thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-09-20 08:40:50 +00:00
Code Issues Packages Projects Releases Wiki Activity

Update MaterializedPostgreSQLConsumer.cpp

Browse Source
This commit is contained in:
Kseniia Sumarokova 2022-08-25 00:23:59 +02:00 committed by GitHub
parent 38c4094f89
commit ba4dfe8308
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 1 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
src/Storages/PostgreSQL/MaterializedPostgreSQLConsumer.cpp
View File

@ -45,7 +45,6 @@ MaterializedPostgreSQLConsumer::MaterializedPostgreSQLConsumer(
, schema_as_a_part_of_table_name(schema_as_a_part_of_table_name_)
, allow_automatic_update(allow_automatic_update_)
{
committed = false;
final_lsn = start_lsn;
auto tx = std::make_shared<pqxx::nontransaction>(connection->getRef());
current_lsn = advanceLSN(tx);
@ -780,7 +779,7 @@ bool MaterializedPostgreSQLConsumer::readFromReplicationSlot()
try
{
LOG_DEBUG(log, "Current message: {}", (*row)[1]);
/// LOG_DEBUG(log, "Current message: {}", (*row)[1]);
processReplicationMessage((*row)[1].c_str(), (*row)[1].size());
}
catch (const Exception & e)