replace 1024 with maxFineGrainedStreamCount

dbms/src/Flash/Coprocessor/FineGrainedShuffle.h

@@ -21,6 +21,8 @@ namespace DB
 {
 static constexpr std::string_view enableFineGrainedShuffleExtraInfo = "enable fine grained shuffle";
 
+static constexpr size_t maxFineGrainedStreamCount = 1024;
+
 inline bool enableFineGrainedShuffle(uint64_t stream_count)
 {
     return stream_count > 0;

dbms/src/Flash/Planner/Plans/PhysicalExchangeSender.cpp

@@ -65,7 +65,7 @@ void PhysicalExchangeSender::buildBlockInputStreamImpl(DAGPipeline & pipeline, C
     {
         extra_info = String(enableFineGrainedShuffleExtraInfo);
         RUNTIME_CHECK(exchange_type == tipb::ExchangeType::Hash, ExchangeType_Name(exchange_type));
-        RUNTIME_CHECK(fine_grained_shuffle.stream_count <= 1024, fine_grained_shuffle.stream_count);
+        RUNTIME_CHECK(fine_grained_shuffle.stream_count <= maxFineGrainedStreamCount, fine_grained_shuffle.stream_count);
     }
     pipeline.transform([&](auto & stream) {
         // construct writer
@@ -96,7 +96,7 @@ void PhysicalExchangeSender::buildPipelineExecGroup(
     if (fine_grained_shuffle.enable())
     {
         RUNTIME_CHECK(exchange_type == tipb::ExchangeType::Hash, ExchangeType_Name(exchange_type));
-        RUNTIME_CHECK(fine_grained_shuffle.stream_count <= 1024, fine_grained_shuffle.stream_count);
+        RUNTIME_CHECK(fine_grained_shuffle.stream_count <= maxFineGrainedStreamCount, fine_grained_shuffle.stream_count);
     }
 
     group_builder.transform([&](auto & builder) {