Dear Hou, > Thanks for the suggestion. > > I tried to add a WaitLatch, but it seems affect the performance > because the Latch might not be set when leader send some > message to parallel apply worker which means it will wait until > timeout.
Yes, currently it leader does not notify anything. To handle that leader must set a latch in parallel_apply_send_data(). It can be done if leader accesses to winfo->shared-> logicalrep_worker_slot_no, and sets a latch for LogicalRepCtxStruct->worker[slot_no]. Best Regards, Hayato Kuroda FUJITSU LIMITED