Commit5076166

committed

1 parent429d225 commit5076166Copy full SHA for 5076166

File tree

-2

lines changed

-2

lines changed

Lines changed: 3 additions & 2 deletions

Original file line number	Diff line number	Diff line change
`@@ -1196,8 +1196,8 @@ EXCHANGE_Execute(CustomScanState *node)`
`1196`	`1196`
`1197`	`1197`	`if ((state->activeRemotes==0)&& (!state->hasLocal))`
`1198`	`1198`	`{`
`1199`		`-//elog(LOG, "[%s] Exchange returns NULL. Tuples: local=%d, remote=%d",`
`1200`		`-//state->stream, state->ltuples, state->rtuples);`
	`1199`	`+elog(LOG,"[%s] Exchange returns NULL. Tuples: local=%d, remote=%d, send=%d",`
	`1200`	`+state->stream,state->ltuples,state->rtuples,state->stuples);`
`1201`	`1201`	`returnNULL;`
`1202`	`1202`	`}`
`1203`	`1203`
`@@ -1234,6 +1234,7 @@ EXCHANGE_Execute(CustomScanState *node)`
`1234`	`1234`	`{`
`1235`	`1235`	`state->stuples++;`
`1236`	`1236`	`SendTuple(dest,state->stream,slot, false);`
	`1237`	`+elog(LOG,"Send tuple: %d",state->stuples);`
`1237`	`1238`	`}`
`1238`	`1239`	`}`
`1239`	`1240`	`returnNULL;`

Comments

(0)