external
/
citus
mirror of https://github.com/citusdata/citus.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #1616 from citusdata/deadlock_detection_warning 

Don't error out if deadlock detection fails to connect to worker
pull/1613/head
Marco Slot 2017-08-24 10:31:15 +02:00 committed by GitHub
parent 7e59c0b019 dbf18df995
commit 7ce2308dc1
1 changed files with 6 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
src/backend/distributed/transaction/lock_graph.c
View File

@ -134,7 +134,7 @@ BuildGlobalWaitGraph(void)
querySent = SendRemoteCommand(connection, command); querySent = SendRemoteCommand(connection, command);
if (querySent == 0) if (querySent == 0)
{ {
ReportConnectionError(connection, ERROR); ReportConnectionError(connection, WARNING);
} }
} }
@ -151,7 +151,8 @@ BuildGlobalWaitGraph(void)
result = GetRemoteCommandResult(connection, raiseInterrupts); result = GetRemoteCommandResult(connection, raiseInterrupts);
if (!IsResponseOK(result)) if (!IsResponseOK(result))
{ {
ReportResultError(connection, result, ERROR); ReportResultError(connection, result, WARNING);
continue;
} }
rowCount = PQntuples(result); rowCount = PQntuples(result);
@ -159,8 +160,9 @@ BuildGlobalWaitGraph(void)
if (colCount != 9) if (colCount != 9)
{ {
ereport(ERROR, (errmsg("unexpected number of columns from " ereport(WARNING, (errmsg("unexpected number of columns from "
"dump_local_wait_edges"))); "dump_local_wait_edges")));
continue;
} }
for (rowIndex = 0; rowIndex < rowCount; rowIndex++) for (rowIndex = 0; rowIndex < rowCount; rowIndex++)