From dc5fb1a487635294f35dd952764ffaf6ec423b6c Mon Sep 17 00:00:00 2001 From: xuejiaming <326308290@qq.com> Date: Thu, 27 Apr 2023 17:19:45 +0800 Subject: [PATCH] =?UTF-8?q?=E8=BF=98=E6=98=AF=E9=9C=80=E8=A6=81=E8=81=9A?= =?UTF-8?q?=E5=90=88?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../MergeEngines/ShardingExecutors/ShardingExecutor.cs | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/src/ShardingCore/Sharding/MergeEngines/ShardingExecutors/ShardingExecutor.cs b/src/ShardingCore/Sharding/MergeEngines/ShardingExecutors/ShardingExecutor.cs index 233d77e9..34e80d9d 100644 --- a/src/ShardingCore/Sharding/MergeEngines/ShardingExecutors/ShardingExecutor.cs +++ b/src/ShardingCore/Sharding/MergeEngines/ShardingExecutors/ShardingExecutor.cs @@ -34,10 +34,10 @@ namespace ShardingCore.Sharding.MergeEngines.ShardingExecutors if (results.IsEmpty()) throw new ShardingCoreException("sharding execute result empty"); //不需要merge - if (results.Count == 1) - { - return results[0]; - } + //if (results.Count == 1) + //{ + // return results[0]; + //} var streamMerge = executor.GetShardingMerger().StreamMerge(results); return streamMerge; }