diff --git a/src/gausskernel/process/stream/streamProducer.cpp b/src/gausskernel/process/stream/streamProducer.cpp
index 64d8f5285..9ad1c0a36 100755
--- a/src/gausskernel/process/stream/streamProducer.cpp
+++ b/src/gausskernel/process/stream/streamProducer.cpp
@@ -1376,30 +1376,16 @@ void StreamProducer::DispatchBatchRedistrFunctionByRedisType()
         case PARALLEL_NONE:
 #ifdef ENABLE_MULTIPLE_NODES
         case REMOTE_DISTRIBUTE:
-            if (m_hasExprKey) {
-                m_channelCalFun = ((list_length(m_consumerNodes->nodeList) == 1) ?
-                                  &StreamProducer::redistributeTupleChannelWithExpr<REMOTE_DIRECT_DISTRIBUTE> :
-                                  &StreamProducer::redistributeTupleChannelWithExpr<REMOTE_DISTRIBUTE>);
-            } else {
-                m_channelCalFun = ((list_length(m_consumerNodes->nodeList) == 1) ?
-                                  &StreamProducer::redistributeTupleChannel<len, REMOTE_DIRECT_DISTRIBUTE> :
-                                  &StreamProducer::redistributeTupleChannel<len, REMOTE_DISTRIBUTE>);
-            }
+            m_channelCalVecFun = (list_length(m_consumerNodes->nodeList) == 1) ?
+                                 &StreamProducer::redistributeBatchChannel<len, REMOTE_DIRECT_DISTRIBUTE> :
+                                 &StreamProducer::redistributeBatchChannel<len, REMOTE_DISTRIBUTE>;
             break;
         case REMOTE_SPLIT_DISTRIBUTE:
-            if (m_hasExprKey) {
-                m_channelCalFun = &StreamProducer::redistributeTupleChannelWithExpr<REMOTE_SPLIT_DISTRIBUTE>;
-            } else {
-                m_channelCalFun = &StreamProducer::redistributeTupleChannel<len, REMOTE_SPLIT_DISTRIBUTE>;
-            }
+            m_channelCalVecFun = &StreamProducer::redistributeBatchChannel<len, REMOTE_SPLIT_DISTRIBUTE>;
             break;
 #endif
         case LOCAL_DISTRIBUTE:
-            if (m_hasExprKey) {
-                m_channelCalFun = &StreamProducer::redistributeTupleChannelWithExpr<LOCAL_DISTRIBUTE>;
-            } else {
-                m_channelCalFun = &StreamProducer::redistributeTupleChannel<len, LOCAL_DISTRIBUTE>;
-            }
+            m_channelCalVecFun = &StreamProducer::redistributeBatchChannel<len, LOCAL_DISTRIBUTE>;
             break;
 
         default: