show the correct number of threads of agg in explain analyze

[SeaRise]

What problem does this PR solve?

Issue Number: close #5314

Problem Summary:

What is changed and how it works?

Check List

Tests

• Unit test
• Integration test
• Manual test (add detailed scripts or steps below)
• No code

Side effects

• Performance regression: Consumes more CPU
• Performance regression: Consumes more Memory
• Breaking backward compatibility

Documentation

• Affects user behaviors
• Contains syntax changes
• Contains variable changes
• Contains experimental features
• Changes MySQL compatibility

Release note

Show the correct number of threads of agg in explain analyze.

[ti-chi-bot]

[REVIEW NOTIFICATION]

This pull request has been approved by:

• ywqzzy

To complete the pull request process, please ask the reviewers in the list to review by filling /cc @reviewer in the comment.
After your PR has acquired the required number of LGTMs, you can assign this pull request to the committer in the list by filling /assign @committer in the comment to help you merge this pull request.

The full list of commands accepted by this bot can be found here.

Reviewer can indicate their review by submitting an approval review.
Reviewer can cancel approval by submitting a request changes review.

[SeaRise]

+----------------------------------+---------+---------+--------------+---------------+--------------------------------------------------------------------------------------------+--------------------------------------------------------------------------------------------------------------------------+--------+------+
| id                               | estRows | actRows | task         | access object | execution info                                                                             | operator info                                                                                                            | memory | disk |
+----------------------------------+---------+---------+--------------+---------------+--------------------------------------------------------------------------------------------+--------------------------------------------------------------------------------------------------------------------------+--------+------+
| TableReader_24                   | 12.00   | 5       | root         |               | time:1.44s, loops:2, cop_task: {num: 1, max: 0s, proc_keys: 0, copr_cache_hit_ratio: 0.00} | data:ExchangeSender_23                                                                                                   | N/A    | N/A  |
| └─ExchangeSender_23              | 12.00   | 5       | mpp[tiflash] |               | tiflash_task:{time:1.25s, loops:1, threads:20}                                             | ExchangeType: PassThrough                                                                                                | N/A    | N/A  |
|   └─Projection_22                | 12.00   | 5       | mpp[tiflash] |               | tiflash_task:{time:1.25s, loops:1, threads:20}                                             | Column#7                                                                                                                 | N/A    | N/A  |
|     └─HashAgg_8                  | 12.00   | 5       | mpp[tiflash] |               | tiflash_task:{time:1.24s, loops:1, threads:20}                                             | group by:test.test.col1, test.test.col3, funcs:count(1)->Column#7                                                        | N/A    | N/A  |
|       └─ExchangeReceiver_21      | 15.00   | 15      | mpp[tiflash] |               | tiflash_task:{time:1.24s, loops:1, threads:20}                                             |                                                                                                                          | N/A    | N/A  |
|         └─ExchangeSender_20      | 15.00   | 15      | mpp[tiflash] |               | tiflash_task:{time:1.24s, loops:1, threads:1}                                              | ExchangeType: HashPartition, Hash Cols: [name: test.test.col1, collate: binary], [name: test.test.col3, collate: binary] | N/A    | N/A  |
|           └─TableFullScan_19     | 15.00   | 15      | mpp[tiflash] | table:test    | tiflash_task:{time:1.24s, loops:1, threads:1}                                              | keep order:false, stats:pseudo                                                                                           | N/A    | N/A  |
+----------------------------------+---------+---------+--------------+---------------+--------------------------------------------------------------------------------------------+--------------------------------------------------------------------------------------------------------------------------+--------+------+

[SeaRise]

/run-all-tests

[SeaRise]

/check-issue-triage-complete

[JaySon-Huang]

Do we fill the concurrency to the response in here?

tiflash/dbms/src/Flash/Coprocessor/DAGResponseWriter.cpp

Lines 94 to 103 in f97567a

	/// part 1: local execution info
	for (const auto & stream_ptr : streams)
	{
	if (auto * p_stream = dynamic_cast<IProfilingBlockInputStream *>(stream_ptr.get()))
	{
	current.time_processed_ns = std::max(current.time_processed_ns, p_stream->getProfileInfo().execution_time);
	current.num_produced_rows += p_stream->getProfileInfo().rows;
	current.num_iterations += p_stream->getProfileInfo().blocks;
	}
	current.concurrency++;

I don't get it that why using NullBlockInputStream here won't affect the number of actual rows, actual process time, etc.

[SeaRise]

because NullBlockInputStream is not IProfilingBlockInputStream..

[sre-bot]

Coverage for changed files

Filename                                     Regions    Missed Regions     Cover   Functions  Missed Functions  Executed       Lines      Missed Lines     Cover    Branches   Missed Branches     Cover
--------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------
Coprocessor/DAGQueryBlockInterpreter.cpp         259                90    65.25%          34                 5    85.29%         607               156    74.30%         164                60    63.41%
Coprocessor/DAGQueryBlockInterpreter.h             2                 0   100.00%           2                 0   100.00%           2                 0   100.00%           0                 0         -
Statistics/ExecutorStatistics.h                   17                17     0.00%           8                 8     0.00%          63                63     0.00%           6                 6     0.00%
--------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------
TOTAL                                            278               107    61.51%          44                13    70.45%         672               219    67.41%         170                66    61.18%

Coverage summary

Functions  MissedFunctions  Executed  Lines   MissedLines  Cover
18529      9572             48.34%    208802  96359        53.85%

full coverage report (for internal network access only)

[SeaRise]

/hold

[ywqzzy]

LGTM

[SeaRise]

will fixed by #5321