bug: 'create table t as select ....'

[JackTan25]

Search before asking

• [X] I had searched in the issues and found no similar issues.

Version

936ffc9

What's Wrong?

the pipeline is not distributed, and explain sql will do "create table t4".

How to Reproduce?

mysql> explain pipeline  create table t4 as select * from target_table;
+--------------------------------------------------------------------------------------------+
| explain                                                                                    |
+--------------------------------------------------------------------------------------------+
| CommitSink × 1 processor                                                                   |
|   MutationAggregator × 1 processor                                                         |
|     TransformSerializeSegment × 1 processor                                                |
|       Merge (TransformSerializeBlock × 10 processors) to (TransformSerializeSegment × 1)   |
|         TransformSerializeBlock × 10 processors                                            |
|           BlockCompactTransform × 10 processors                                            |
|             CompoundBlockOperator(Project) × 10 processors                                 |
|               DeserializeDataTransform × 10 processors                                     |
|                 SyncReadParquetDataSource × 10 processors                                  |
+--------------------------------------------------------------------------------------------+
9 rows in set (0.10 sec)
Read 0 rows, 0.00 B in 0.047 sec., 0 rows/sec., 0.00 B/sec.

mysql> show tables;
+-------------------+
| Tables_in_default |
+-------------------+
| source_table      |
| t3                |
| t4                |
| target_table      |
| tmp               |
+-------------------+
5 rows in set (0.05 sec)
Read 5 rows, 1.00 KiB in 0.035 sec., 142.36 rows/sec., 28.56 KiB/sec.

Are you willing to submit PR?

• [X] Yes I am willing to submit a PR!