stabellize e2e check in test

end_to_end/end_to_end_suite_test.go

@@ -2196,7 +2196,7 @@ LANGUAGE plpgsql NO SQL;`)
 					Expect(numSegments).To(Equal(strconv.Itoa(segmentCount)))
 
 					// check there is no pipe errors on segments
-					errSegments := dbconn.MustSelectString(restoreConn, "SELECT exists (SELECT * FROM gp_toolkit.__gp_log_segment_ext WHERE logtime > now() - '1 min'::interval AND logmessage LIKE 'read err msg from pipe%No such file or directory%' ORDER BY logtime DESC)")
+					errSegments := dbconn.MustSelectString(restoreConn, fmt.Sprintf("SELECT exists (SELECT * FROM gp_toolkit.__gp_log_segment_ext WHERE logdatabase = current_database() AND logmessage LIKE 'read err msg from pipe%%_%06d_%%')", gprestoreCmd.Process.Pid))
 					Expect(errSegments).To(Equal("false"))
 				},
 				Entry("Can backup a 1-segment cluster and restore to current cluster with replicated tables", "20221104023842", "1-segment-db-replicated"),