提交 81857f72 编写于 作者: P Pengzhou Tang

Fix incorrect EOS warning message generated by direct-dispatch type queries

QD should not expect end-of-stream comes from QEs who is not members of
direct dispatch and should not report warning message.
上级 76b36429
......@@ -735,6 +735,13 @@ EndMotionLayerNode(MotionLayerState *mlStates, int16 motNodeID, bool flushCommLa
{
pCSEntry = &pMNEntry->ready_tuple_lists[i];
/*
* QD should not expect end-of-stream comes from QEs who is not members of
* direct dispatch
*/
if (!pCSEntry->init)
continue;
if (pMNEntry->preserve_order &&
gp_log_interconnect >= GPVARS_VERBOSITY_DEBUG)
{
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册