From 4dcec0e5272abbf4ebd3e3cddc3e3913fd86b7f6 Mon Sep 17 00:00:00 2001
From: qianchanger <qianchanger@gmail.com>
Date: Mon, 12 Dec 2022 06:38:12 +0000
Subject: [PATCH] [CP] Fix winbuf datahub report -4016

---
 src/sql/engine/px/datahub/components/ob_dh_winbuf.cpp | 1 +
 1 file changed, 1 insertion(+)

diff --git a/src/sql/engine/px/datahub/components/ob_dh_winbuf.cpp b/src/sql/engine/px/datahub/components/ob_dh_winbuf.cpp
index c3386abb48..54cebe5197 100644
--- a/src/sql/engine/px/datahub/components/ob_dh_winbuf.cpp
+++ b/src/sql/engine/px/datahub/components/ob_dh_winbuf.cpp
@@ -83,6 +83,7 @@ int ObWinbufPieceMsgListener::on_message(
       LOG_WARN("failed to wait response", K(ret));
     }
     ctx.whole_msg_.reset();
+    ctx.received_ = 0;
   }
   return ret;
 }
-- 
GitLab