@@ -133,9 +133,9 @@ skipif madsim
133133system ok
134134psql_validate.py --db $__DATABASE__ --sql "DESCRIBE FRAGMENTS describe_plan_test.idx" \
135135--expected 'Fragment % (Actor %)
136- StreamMaterialize { columns: [name, age, created_at, tbl.id(hidden)], stream_key: [tbl.id], pk_columns: [name, age, tbl.id], pk_conflict: NoCheck }
136+ StreamMaterialize { columns: [name, age, created_at, tbl.id(hidden)], stream_key: [name, tbl.id], pk_columns: [name, age, tbl.id], pk_conflict: NoCheck }
137137├── output: [ tbl.name, tbl.age, tbl.created_at, tbl.id ]
138- ├── stream key: [ tbl.id ]
138+ ├── stream key: [ tbl.name, tbl. id ]
139139└── MergeExecutor { output: [ tbl.name, tbl.age, tbl.created_at, tbl.id ], stream key: [ tbl.id ] }
140140(empty)
141141Fragment % (Actor %)
@@ -146,22 +146,6 @@ StreamTableScan { table: tbl, columns: [name, age, created_at, id] }
146146└── BatchPlanNode { output: [ name, age, created_at, id ], stream key: [] }'
147147
148148
149- skipif madsim
150- system ok
151- psql_validate.py --db $__DATABASE__ --sql "DESCRIBE FRAGMENTS describe_plan_test.idx" \
152- --expected 'Fragment % (Actor %)
153- StreamMaterialize { columns: [name, age, created_at, tbl.id(hidden)], stream_key: [tbl.id], pk_columns: [name, age, tbl.id], pk_conflict: NoCheck }
154- ├── output: [ tbl.name, tbl.age, tbl.created_at, tbl.id ]
155- ├── stream key: [ tbl.id ]
156- └── MergeExecutor { output: [ tbl.name, tbl.age, tbl.created_at, tbl.id ], stream key: [ tbl.id ] }
157- (empty)
158- Fragment % (Actor %)
159- StreamTableScan { table: tbl, columns: [name, age, created_at, id] }
160- ├── output: [ tbl.name, tbl.age, tbl.created_at, tbl.id ]
161- ├── stream key: [ tbl.id ]
162- ├── Upstream { output: [ name, age, created_at, id ], stream key: [] }
163- └── BatchPlanNode { output: [ name, age, created_at, id ], stream key: [] }'
164-
165149
166150skipif madsim
167151system ok
0 commit comments