Skip to content

Instantly share code, notes, and snippets.

@benesch
Last active July 24, 2020 15:14
Show Gist options
  • Star 0 You must be signed in to star a gist
  • Fork 0 You must be signed in to fork a gist
  • Save benesch/288674bae2fcd6376ceaa2714547ed03 to your computer and use it in GitHub Desktop.
Save benesch/288674bae2fcd6376ceaa2714547ed03 to your computer and use it in GitHub Desktop.
select * from generate_series(100,200) g,
lateral (select * from int8_tbl a where g = q1 union all
select * from int8_tbl b where g = q2) ss
building:
%0 =
| Constant (100) (101) (102) (103) (104) (105) (106) (107) (108) (109) (110) (111) (112) (113) (114) (115) (116) (117) (118) (119) (120) (121) (122) (123) (124) (125) (126) (127) (128) (129) (130) (131) (132) (133) (134) (135) (136) (137) (138) (139) (140) (141) (142) (143) (144) (145) (146) (147) (148) (149) (150) (151) (152) (153) (154) (155) (156) (157) (158) (159) (160) (161) (162) (163) (164) (165) (166) (167) (168) (169) (170) (171) (172) (173) (174) (175) (176) (177) (178) (179) (180) (181) (182) (183) (184) (185) (186) (187) (188) (189) (190) (191) (192) (193) (194) (195) (196) (197) (198) (199) (200)
%1 =
| Constant (100) (101) (102) (103) (104) (105) (106) (107) (108) (109) (110) (111) (112) (113) (114) (115) (116) (117) (118) (119) (120) (121) (122) (123) (124) (125) (126) (127) (128) (129) (130) (131) (132) (133) (134) (135) (136) (137) (138) (139) (140) (141) (142) (143) (144) (145) (146) (147) (148) (149) (150) (151) (152) (153) (154) (155) (156) (157) (158) (159) (160) (161) (162) (163) (164) (165) (166) (167) (168) (169) (170) (171) (172) (173) (174) (175) (176) (177) (178) (179) (180) (181) (182) (183) (184) (185) (186) (187) (188) (189) (190) (191) (192) (193) (194) (195) (196) (197) (198) (199) (200)
%2 =
| Get ? (u5)
| Filter !(isnull(#0))
| ArrangeBy (#0)
%3 =
| Join %1 %2 (= #1 i32toi64(#0))
| | implementation = Differential %1 %2.(#0)
| | demand = (#0..#2)
%4 =
| Constant (100) (101) (102) (103) (104) (105) (106) (107) (108) (109) (110) (111) (112) (113) (114) (115) (116) (117) (118) (119) (120) (121) (122) (123) (124) (125) (126) (127) (128) (129) (130) (131) (132) (133) (134) (135) (136) (137) (138) (139) (140) (141) (142) (143) (144) (145) (146) (147) (148) (149) (150) (151) (152) (153) (154) (155) (156) (157) (158) (159) (160) (161) (162) (163) (164) (165) (166) (167) (168) (169) (170) (171) (172) (173) (174) (175) (176) (177) (178) (179) (180) (181) (182) (183) (184) (185) (186) (187) (188) (189) (190) (191) (192) (193) (194) (195) (196) (197) (198) (199) (200)
%5 =
| Get ? (u5)
| Filter !(isnull(#1))
| ArrangeBy (#1)
%6 =
| Join %4 %5 (= #2 i32toi64(#0))
| | implementation = Differential %4 %5.(#1)
| | demand = (#0..#2)
%7 =
| Union %3 %6
%8 =
| Join %0 %7 (= #0 #1)
| | implementation = Differential %7 %0.(#0)
| | demand = (#0, #2, #3)
| Project (#0, #2, #3)
thread 'timely:work-1' panicked at 'Arrangement alarmingly absent: Constant { rows: [(Row{[Int32(100)]}, 1), (Row{[Int32(101)]}, 1), (Row{[Int32(102)]}, 1), (Row{[Int32(103)]}, 1), (Row{[Int32(104)]}, 1), (Row{[Int32(105)]}, 1), (Row{[Int32(106)]}, 1), (Row{[Int32(107)]}, 1), (Row{[Int32(108)]}, 1), (Row{[Int32(109)]}, 1), (Row{[Int32(110)]}, 1), (Row{[Int32(111)]}, 1), (Row{[Int32(112)]}, 1), (Row{[Int32(113)]}, 1), (Row{[Int32(114)]}, 1), (Row{[Int32(115)]}, 1), (Row{[Int32(116)]}, 1), (Row{[Int32(117)]}, 1), (Row{[Int32(118)]}, 1), (Row{[Int32(119)]}, 1), (Row{[Int32(120)]}, 1), (Row{[Int32(121)]}, 1), (Row{[Int32(122)]}, 1), (Row{[Int32(123)]}, 1), (Row{[Int32(124)]}, 1), (Row{[Int32(125)]}, 1), (Row{[Int32(126)]}, 1), (Row{[Int32(127)]}, 1), (Row{[Int32(128)]}, 1), (Row{[Int32(129)]}, 1), (Row{[Int32(130)]}, 1), (Row{[Int32(131)]}, 1), (Row{[Int32(132)]}, 1), (Row{[Int32(133)]}, 1), (Row{[Int32(134)]}, 1), (Row{[Int32(135)]}, 1), (Row{[Int32(136)]}, 1), (Row{[Int32(137)]}, 1), (Row{[Int32(138)]}, 1), (Row{[Int32(139)]}, 1), (Row{[Int32(140)]}, 1), (Row{[Int32(141)]}, 1), (Row{[Int32(142)]}, 1), (Row{[Int32(143)]}, 1), (Row{[Int32(144)]}, 1), (Row{[Int32(145)]}, 1), (Row{[Int32(146)]}, 1), (Row{[Int32(147)]}, 1), (Row{[Int32(148)]}, 1), (Row{[Int32(149)]}, 1), (Row{[Int32(150)]}, 1), (Row{[Int32(151)]}, 1), (Row{[Int32(152)]}, 1), (Row{[Int32(153)]}, 1), (Row{[Int32(154)]}, 1), (Row{[Int32(155)]}, 1), (Row{[Int32(156)]}, 1), (Row{[Int32(157)]}, 1), (Row{[Int32(158)]}, 1), (Row{[Int32(159)]}, 1), (Row{[Int32(160)]}, 1), (Row{[Int32(161)]}, 1), (Row{[Int32(162)]}, 1), (Row{[Int32(163)]}, 1), (Row{[Int32(164)]}, 1), (Row{[Int32(165)]}, 1), (Row{[Int32(166)]}, 1), (Row{[Int32(167)]}, 1), (Row{[Int32(168)]}, 1), (Row{[Int32(169)]}, 1), (Row{[Int32(170)]}, 1), (Row{[Int32(171)]}, 1), (Row{[Int32(172)]}, 1), (Row{[Int32(173)]}, 1), (Row{[Int32(174)]}, 1), (Row{[Int32(175)]}, 1), (Row{[Int32(176)]}, 1), (Row{[Int32(177)]}, 1), (Row{[Int32(178)]}, 1), (Row{[Int32(179)]}, 1), (Row{[Int32(180)]}, 1), (Row{[Int32(181)]}, 1), (Row{[Int32(182)]}, 1), (Row{[Int32(183)]}, 1), (Row{[Int32(184)]}, 1), (Row{[Int32(185)]}, 1), (Row{[Int32(186)]}, 1), (Row{[Int32(187)]}, 1), (Row{[Int32(188)]}, 1), (Row{[Int32(189)]}, 1), (Row{[Int32(190)]}, 1), (Row{[Int32(191)]}, 1), (Row{[Int32(192)]}, 1), (Row{[Int32(193)]}, 1), (Row{[Int32(194)]}, 1), (Row{[Int32(195)]}, 1), (Row{[Int32(196)]}, 1), (Row{[Int32(197)]}, 1), (Row{[Int32(198)]}, 1), (Row{[Int32(199)]}, 1), (Row{[Int32(200)]}, 1)], typ: RelationType { column_types: [ColumnType { nullable: false, scalar_type: Int32 }], keys: [] } }', src/dataflow/src/render/join.rs:239:25
thread 'stack backtrace:
timely:work-2' panicked at 'Arrangement alarmingly absent: Constant { rows: [(Row{[Int32(100)]}, 1), (Row{[Int32(101)]}, 1), (Row{[Int32(102)]}, 1), (Row{[Int32(103)]}, 1), (Row{[Int32(104)]}, 1), (Row{[Int32(105)]}, 1), (Row{[Int32(106)]}, 1), (Row{[Int32(107)]}, 1), (Row{[Int32(108)]}, 1), (Row{[Int32(109)]}, 1), (Row{[Int32(110)]}, 1), (Row{[Int32(111)]}, 1), (Row{[Int32(112)]}, 1), (Row{[Int32(113)]}, 1), (Row{[Int32(114)]}, 1), (Row{[Int32(115)]}, 1), (Row{[Int32(116)]}, 1), (Row{[Int32(117)]}, 1), (Row{[Int32(118)]}, 1), (Row{[Int32(119)]}, 1), (Row{[Int32(120)]}, 1), (Row{[Int32(121)]}, 1), (Row{[Int32(122)]}, 1), (Row{[Int32(123)]}, 1), (Row{[Int32(124)]}, 1), (Row{[Int32(125)]}, 1), (Row{[Int32(126)]}, 1), (Row{[Int32(127)]}, 1), (Row{[Int32(128)]}, 1), (Row{[Int32(129)]}, 1), (Row{[Int32(130)]}, 1), (Row{[Int32(131)]}, 1), (Row{[Int32(132)]}, 1), (Row{[Int32(133)]}, 1), (Row{[Int32(134)]}, 1), (Row{[Int32(135)]}, 1), (Row{[Int32(136)]}, 1), (Row{[Int32(137)]}, 1), (Row{[Int32(138)]}, 1), (Row{[Int32(139)]}, 1), (Row{[Int32(140)]}, 1), (Row{[Int32(141)]}, 1), (Row{[Int32(142)]}, 1), (Row{[Int32(143)]}, 1), (Row{[Int32(144)]}, 1), (Row{[Int32(145)]}, 1), (Row{[Int32(146)]}, 1), (Row{[Int32(147)]}, 1), (Row{[Int32(148)]}, 1), (Row{[Int32(149)]}, 1), (Row{[Int32(150)]}, 1), (Row{[Int32(151)]}, 1), (Row{[Int32(152)]}, 1), (Row{[Int32(153)]}, 1), (Row{[Int32(154)]}, 1), (Row{[Int32(155)]}, 1), (Row{[Int32(156)]}, 1), (Row{[Int32(157)]}, 1), (Row{[Int32(158)]}, 1), (Row{[Int32(159)]}, 1), (Row{[Int32(160)]}, 1), (Row{[Int32(161)]}, 1), (Row{[Int32(162)]}, 1), (Row{[Int32(163)]}, 1), (Row{[Int32(164)]}, 1), (Row{[Int32(165)]}, 1), (Row{[Int32(166)]}, 1), (Row{[Int32(167)]}, 1), (Row{[Int32(168)]}, 1), (Row{[Int32(169)]}, 1), (Row{[Int32(170)]}, 1), (Row{[Int32(171)]}, 1), (Row{[Int32(172)]}, 1), (Row{[Int32(173)]}, 1), (Row{[Int32(174)]}, 1), (Row{[Int32(175)]}, 1), (Row{[Int32(176)]}, 1), (Row{[Int32(177)]}, 1), (Row{[Int32(178)]}, 1), (Row{[Int32(179)]}, 1), (Row{[Int32(180)]}, 1), (Row{[Int32(181)]}, 1), (Row{[Int32(182)]}, 1), (Row{[Int32(183)]}, 1), (Row{[Int32(184)]}, 1), (Row{[Int32(185)]}, 1), (Row{[Int32(186)]}, 1), (Row{[Int32(187)]}, 1), (Row{[Int32(188)]}, 1), (Row{[Int32(189)]}, 1), (Row{[Int32(190)]}, 1), (Row{[Int32(191)]}, 1), (Row{[Int32(192)]}, 1), (Row{[Int32(193)]}, 1), (Row{[Int32(194)]}, 1), (Row{[Int32(195)]}, 1), (Row{[Int32(196)]}, 1), (Row{[Int32(197)]}, 1), (Row{[Int32(198)]}, 1), (Row{[Int32(199)]}, 1), (Row{[Int32(200)]}, 1)], typ: RelationType { column_types: [ColumnType { nullable: false, scalar_type: Int32 }], keys: [] } }', src/dataflow/src/render/join.rs:239:25
thread 'timely:work-0' panicked at 'Arrangement alarmingly absent: Constant { rows: [(Row{[Int32(100)]}, 1), (Row{[Int32(101)]}, 1), (Row{[Int32(102)]}, 1), (Row{[Int32(103)]}, 1), (Row{[Int32(104)]}, 1), (Row{[Int32(105)]}, 1), (Row{[Int32(106)]}, 1), (Row{[Int32(107)]}, 1), (Row{[Int32(108)]}, 1), (Row{[Int32(109)]}, 1), (Row{[Int32(110)]}, 1), (Row{[Int32(111)]}, 1), (Row{[Int32(112)]}, 1), (Row{[Int32(113)]}, 1), (Row{[Int32(114)]}, 1), (Row{[Int32(115)]}, 1), (Row{[Int32(116)]}, 1), (Row{[Int32(117)]}, 1), (Row{[Int32(118)]}, 1), (Row{[Int32(119)]}, 1), (Row{[Int32(120)]}, 1), (Row{[Int32(121)]}, 1), (Row{[Int32(122)]}, 1), (Row{[Int32(123)]}, 1), (Row{[Int32(124)]}, 1), (Row{[Int32(125)]}, 1), (Row{[Int32(126)]}, 1), (Row{[Int32(127)]}, 1), (Row{[Int32(128)]}, 1), (Row{[Int32(129)]}, 1), (Row{[Int32(130)]}, 1), (Row{[Int32(131)]}, 1), (Row{[Int32(132)]}, 1), (Row{[Int32(133)]}, 1), (Row{[Int32(134)]}, 1), (Row{[Int32(135)]}, 1), (Row{[Int32(136)]}, 1), (Row{[Int32(137)]}, 1), (Row{[Int32(138)]}, 1), (Row{[Int32(139)]}, 1), (Row{[Int32(140)]}, 1), (Row{[Int32(141)]}, 1), (Row{[Int32(142)]}, 1), (Row{[Int32(143)]}, 1), (Row{[Int32(144)]}, 1), (Row{[Int32(145)]}, 1), (Row{[Int32(146)]}, 1), (Row{[Int32(147)]}, 1), (Row{[Int32(148)]}, 1), (Row{[Int32(149)]}, 1), (Row{[Int32(150)]}, 1), (Row{[Int32(151)]}, 1), (Row{[Int32(152)]}, 1), (Row{[Int32(153)]}, 1), (Row{[Int32(154)]}, 1), (Row{[Int32(155)]}, 1), (Row{[Int32(156)]}, 1), (Row{[Int32(157)]}, 1), (Row{[Int32(158)]}, 1), (Row{[Int32(159)]}, 1), (Row{[Int32(160)]}, 1), (Row{[Int32(161)]}, 1), (Row{[Int32(162)]}, 1), (Row{[Int32(163)]}, 1), (Row{[Int32(164)]}, 1), (Row{[Int32(165)]}, 1), (Row{[Int32(166)]}, 1), (Row{[Int32(167)]}, 1), (Row{[Int32(168)]}, 1), (Row{[Int32(169)]}, 1), (Row{[Int32(170)]}, 1), (Row{[Int32(171)]}, 1), (Row{[Int32(172)]}, 1), (Row{[Int32(173)]}, 1), (Row{[Int32(174)]}, 1), (Row{[Int32(175)]}, 1), (Row{[Int32(176)]}, 1), (Row{[Int32(177)]}, 1), (Row{[Int32(178)]}, 1), (Row{[Int32(179)]}, 1), (Row{[Int32(180)]}, 1), (Row{[Int32(181)]}, 1), (Row{[Int32(182)]}, 1), (Row{[Int32(183)]}, 1), (Row{[Int32(184)]}, 1), (Row{[Int32(185)]}, 1), (Row{[Int32(186)]}, 1), (Row{[Int32(187)]}, 1), (Row{[Int32(188)]}, 1), (Row{[Int32(189)]}, 1), (Row{[Int32(190)]}, 1), (Row{[Int32(191)]}, 1), (Row{[Int32(192)]}, 1), (Row{[Int32(193)]}, 1), (Row{[Int32(194)]}, 1), (Row{[Int32(195)]}, 1), (Row{[Int32(196)]}, 1), (Row{[Int32(197)]}, 1), (Row{[Int32(198)]}, 1), (Row{[Int32(199)]}, 1), (Row{[Int32(200)]}, 1)], typ: RelationType { column_types: [ColumnType { nullable: false, scalar_type: Int32 }], keys: [] } }', src/dataflow/src/render/join.rs:239:25
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment