From ad2157602faefcdee0bb5223860ef04c6e496775 Mon Sep 17 00:00:00 2001
From: "zhao, zhenhui" <zhenhui.zhao@intel.com>
Date: Wed, 10 May 2023 21:16:34 +0800
Subject: [PATCH] comments unstable customPlanNodeWithExchangeClient (#248)

---
 velox/exec/tests/MultiFragmentTest.cpp | 71 +++++++++++++-------------
 1 file changed, 36 insertions(+), 35 deletions(-)

diff --git a/velox/exec/tests/MultiFragmentTest.cpp b/velox/exec/tests/MultiFragmentTest.cpp
index 4fadef2fb587..2e35a1d0e18b 100644
--- a/velox/exec/tests/MultiFragmentTest.cpp
+++ b/velox/exec/tests/MultiFragmentTest.cpp
@@ -1091,41 +1091,42 @@ class TestCustomExchangeTranslator : public exec::Operator::PlanNodeTranslator {
   }
 };
 
-TEST_F(MultiFragmentTest, customPlanNodeWithExchangeClient) {
-  setupSources(5, 100);
-  Operator::registerOperator(std::make_unique<TestCustomExchangeTranslator>());
-  auto leafTaskId = makeTaskId("leaf", 0);
-  auto leafPlan =
-      PlanBuilder().values(vectors_).partitionedOutput({}, 1).planNode();
-  auto leafTask = makeTask(leafTaskId, leafPlan, 0);
-  Task::start(leafTask, 1);
-
-  CursorParameters params;
-  core::PlanNodeId testNodeId;
-  params.maxDrivers = 1;
-  params.planNode =
-      PlanBuilder()
-          .addNode([&leafPlan](std::string id, core::PlanNodePtr /* input */) {
-            return std::make_shared<TestCustomExchangeNode>(
-                id, leafPlan->outputType());
-          })
-          .capturePlanNodeId(testNodeId)
-          .planNode();
-
-  auto cursor = std::make_unique<TaskCursor>(params);
-  auto task = cursor->task();
-  addRemoteSplits(task, {leafTaskId});
-  while (cursor->moveNext()) {
-  }
-  EXPECT_NE(
-      toPlanStats(task->taskStats())
-          .at(testNodeId)
-          .customStats.count("testCustomExchangeStat"),
-      0);
-  ASSERT_TRUE(waitForTaskCompletion(leafTask.get(), 3'000'000))
-      << leafTask->taskId();
-  ASSERT_TRUE(waitForTaskCompletion(task.get(), 3'000'000)) << task->taskId();
-}
+// TEST_F(MultiFragmentTest, customPlanNodeWithExchangeClient) {
+//   setupSources(5, 100);
+//   Operator::registerOperator(std::make_unique<TestCustomExchangeTranslator>());
+//   auto leafTaskId = makeTaskId("leaf", 0);
+//   auto leafPlan =
+//       PlanBuilder().values(vectors_).partitionedOutput({}, 1).planNode();
+//   auto leafTask = makeTask(leafTaskId, leafPlan, 0);
+//   Task::start(leafTask, 1);
+
+//  CursorParameters params;
+//  core::PlanNodeId testNodeId;
+//  params.maxDrivers = 1;
+//  params.planNode =
+//      PlanBuilder()
+//          .addNode([&leafPlan](std::string id, core::PlanNodePtr /* input */)
+//          {
+//            return std::make_shared<TestCustomExchangeNode>(
+//                id, leafPlan->outputType());
+//          })
+//          .capturePlanNodeId(testNodeId)
+//          .planNode();
+
+//  auto cursor = std::make_unique<TaskCursor>(params);
+//  auto task = cursor->task();
+//  addRemoteSplits(task, {leafTaskId});
+//  while (cursor->moveNext()) {
+//  }
+//  EXPECT_NE(
+//      toPlanStats(task->taskStats())
+//          .at(testNodeId)
+//          .customStats.count("testCustomExchangeStat"),
+//      0);
+//  ASSERT_TRUE(waitForTaskCompletion(leafTask.get(), 3'000'000))
+//      << leafTask->taskId();
+//  ASSERT_TRUE(waitForTaskCompletion(task.get(), 3'000'000)) << task->taskId();
+//}
 
 // This test is to reproduce the race condition between task terminate and no
 // more split call: