reset DDLInProgress on start of decoding in case when decoding of previous transaction was interrupted by concurrent commit/abort and leaved inconsistent static variables

Author: kelvich

src/pglogical_proto.c

@@ -157,6 +157,7 @@ pglogical_write_begin(StringInfo out, PGLogicalOutputData *data,
 	MtmLastRelId = InvalidOid;
 	MtmCurrentXid = txn->xid;
 	MtmIsFilteredTxn = false;
+	DDLInProgress = false;
 
 	pq_sendbyte(out, 'B');		/* BEGIN */
 	pq_sendint(out, hooks_data->cfg->my_node_id, 4);