!3875 修改spi_priv、execRemote告警信息
Merge pull request !3875 from duzhuolin/bugfix_Q24
This commit is contained in:
@ -5299,11 +5299,11 @@ void do_query_for_first_tuple(RemoteQueryState* node, bool vectorized, int regul
|
|||||||
pfree_ext(node->cursor_connections);
|
pfree_ext(node->cursor_connections);
|
||||||
|
|
||||||
if (!node->need_error_check) {
|
if (!node->need_error_check) {
|
||||||
int error_code;
|
int error_code = 0;
|
||||||
char* error_msg = getSocketError(&error_code);
|
char* error_msg = getSocketError(&error_code);
|
||||||
|
|
||||||
ereport(ERROR,
|
ereport(ERROR,
|
||||||
(errcode(error_code), errmsg("Failed to read response from Datanodes Detail: %s\n", error_msg)));
|
(errcode(error_code), errmsg("Failed to read response from Datanodes Detail: %s\n", error_msg == NULL ? "null" : error_msg)));
|
||||||
} else {
|
} else {
|
||||||
node->need_error_check = false;
|
node->need_error_check = false;
|
||||||
pgxc_node_report_error(node);
|
pgxc_node_report_error(node);
|
||||||
|
@ -110,7 +110,7 @@ inline void spi_stack_record_log(const char* action, const char* filename, int l
|
|||||||
ereport(DEBUG3, (errmodule(MOD_SPI), errcode(ERRCODE_LOG),
|
ereport(DEBUG3, (errmodule(MOD_SPI), errcode(ERRCODE_LOG),
|
||||||
errmsg("SPISTACK(Action:%s, Location %s,%d, Funcname:%s): cur spiconnected:%d, cur spi:%d, query string:%s",
|
errmsg("SPISTACK(Action:%s, Location %s,%d, Funcname:%s): cur spiconnected:%d, cur spi:%d, query string:%s",
|
||||||
action, filename, lineno, funcname, u_sess->SPI_cxt._connected, u_sess->SPI_cxt._curid,
|
action, filename, lineno, funcname, u_sess->SPI_cxt._connected, u_sess->SPI_cxt._curid,
|
||||||
query != NULL ? maskPassword(query) : NULL)));
|
query != NULL ? maskPassword(query) : "null")));
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
Reference in New Issue
Block a user