diff --git a/e2e_test/ddl/alter_parallelism.slt b/e2e_test/ddl/alter_parallelism.slt index 723dd8e08b75d..e030b44273575 100644 --- a/e2e_test/ddl/alter_parallelism.slt +++ b/e2e_test/ddl/alter_parallelism.slt @@ -13,6 +13,9 @@ create view mview_parallelism as select m.name, tf.parallelism from rw_materiali statement ok create view sink_parallelism as select s.name, tf.parallelism from rw_sinks s, rw_table_fragments tf where s.id = tf.table_id; +statement ok +create view fragment_parallelism as select t.name as table_name, f.fragment_id, f.parallelism from rw_fragments f, rw_tables t where f.table_id = t.id; + statement ok create table t (v int); @@ -30,7 +33,7 @@ select parallelism from table_parallelism where name = 't'; FIXED(2) query I -select parallelism from rw_fragments; +select parallelism from fragment_parallelism where table_name = 't'; ---- 2 2 @@ -152,4 +155,7 @@ statement ok drop view mview_parallelism; statement ok -drop view sink_parallelism; \ No newline at end of file +drop view sink_parallelism; + +statement ok +drop view fragment_parallelism; \ No newline at end of file