index ddcf6b294032b41271102ed112fd78169b418783..19dc9efedd46d55bc5888e59c948fa7a30d8f034 100644 (file)
@@ -262,6 +262,7 @@ libpqrcv_endstreaming(TimeLineID *next_tli)
ereport(ERROR,
(errmsg("error reading result of streaming command: %s",
PQerrorMessage(streamConn))));
+ PQclear(res);
/* Verify that there are no more results */
res = PQgetResult(streamConn);