diff --git a/src/sql/dtl/ob_dtl_basic_channel.h b/src/sql/dtl/ob_dtl_basic_channel.h
index 1c0d70f21..8f6f4c2eb 100644
--- a/src/sql/dtl/ob_dtl_basic_channel.h
+++ b/src/sql/dtl/ob_dtl_basic_channel.h
@@ -113,6 +113,8 @@ static DtlWriterType msg_writer_map[] =
   CONTROL_WRITER, // DH_RD_WINFUNC_PX_WHOLE_MSG
   CONTROL_WRITER, // DH_JOIN_FILTER_COUNT_ROW_PIECE_MSG,
   CONTROL_WRITER, // DH_JOIN_FILTER_COUNT_ROW_WHOLE_MSG,
+  MAX_WRITER, // DH_STATISTICS_COLLECTOR_PIECE_MSG, placeholder
+  MAX_WRITER, // DH_STATISTICS_COLLECTOR_WHOLE_MSG, placeholder
 };
 
 static_assert(ARRAYSIZEOF(msg_writer_map) == ObDtlMsgType::MAX, "invalid ms_writer_map size");
diff --git a/src/sql/dtl/ob_dtl_msg_type.h b/src/sql/dtl/ob_dtl_msg_type.h
index 7e9b265cc..20880119a 100644
--- a/src/sql/dtl/ob_dtl_msg_type.h
+++ b/src/sql/dtl/ob_dtl_msg_type.h
@@ -59,6 +59,8 @@ enum ObDtlMsgType {
   DH_RD_WINFUNC_PX_WHOLE_MSG,
   DH_JOIN_FILTER_COUNT_ROW_PIECE_MSG,
   DH_JOIN_FILTER_COUNT_ROW_WHOLE_MSG,
+  DH_STATISTICS_COLLECTOR_PIECE_MSG, // 50  // placeholder
+  DH_STATISTICS_COLLECTOR_WHOLE_MSG, // placeholder
   MAX
 };