We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 47385b6 commit e7a5da3Copy full SHA for e7a5da3
pglogical_receiver.c
@@ -550,8 +550,7 @@ pglogical_receiver_main(Datum main_arg)
550
if (stmt[0] == 'Z' || (stmt[0] == 'M' && (stmt[1] == 'L' || stmt[1] == 'A' || stmt[1] == 'C'))) {
551
MTM_LOG3("Process '%c' message from %d", stmt[1], nodeId);
552
if (stmt[0] == 'M' && stmt[1] == 'C') { /* concurrent DDL should be executed by parallel workers */
553
- //MtmExecute(stmt, msg_len);
554
- MtmExecutore(stmt, msg_len);
+ MtmExecute(stmt, msg_len);
555
} else {
556
MtmExecutor(stmt, msg_len); /* all other messages can be processed by receiver itself */
557
}
0 commit comments