[UT][WIP] test fe shared-data ut #60346
ci-doc-checker.yml
on: pull_request_target
Annotations
8 errors and 1 warning
|
REMOVE DOC LABEL
Error: failed to remove labels: documentation
|
|
LakeTableSchemaChangeJobTest.com.starrocks.alter.LakeTableSchemaChangeJobTest:
fe/fe-core/src/test/java/com/starrocks/alter/LakeTableSchemaChangeJobTest.java#L70
expected:<shared_data> but was:<shared_nothing>
|
|
CreateLakeTableTest.com.starrocks.lake.CreateLakeTableTest:
fe/fe-core/src/test/java/com/starrocks/lake/CreateLakeTableTest.java#L54
expected:<shared_data> but was:<shared_nothing>
|
|
MvRefreshAndRewriteIcebergTest.testStr2DateMVRefreshRewriteSingleTableWithDateTruc_Day:
fe/fe-core/src/test/java/com/starrocks/sql/optimizer/rule/transformation/materialization/MvRefreshAndRewriteIcebergTest.java#L1839
PLAN FRAGMENT 0
OUTPUT EXPRS:1: a | 2: b | 5: date_trunc | 6: count
PARTITION: UNPARTITIONED
RESULT SINK
6:EXCHANGE
PLAN FRAGMENT 1
OUTPUT EXPRS:
PARTITION: HASH_PARTITIONED: 1: a, 2: b, 5: date_trunc
STREAM DATA SINK
EXCHANGE ID: 06
UNPARTITIONED
5:AGGREGATE (update finalize)
| output: count(3: c)
| group by: 1: a, 2: b, 5: date_trunc
|
4:AGGREGATE (merge serialize)
| group by: 1: a, 2: b, 3: c, 5: date_trunc
|
3:EXCHANGE
PLAN FRAGMENT 2
OUTPUT EXPRS:
PARTITION: RANDOM
STREAM DATA SINK
EXCHANGE ID: 03
HASH_PARTITIONED: 1: a, 2: b, 5: date_trunc
2:AGGREGATE (update serialize)
| STREAMING
| group by: 1: a, 2: b, 3: c, 5: date_trunc
|
1:Project
| <slot 1> : 1: a
| <slot 2> : 2: b
| <slot 3> : 3: c
| <slot 5> : str2date(4: d, '%Y-%m-%d')
|
0:IcebergScanNode
TABLE: partitioned_db.part_tbl1
PREDICATES: str2date(4: d, '%Y-%m-%d') = '2023-08-01'
cardinality=50
avgRowSize=5.0
|
|
|
|
|
|
MvRewritePartialPartitionTest.testViewBaseMvRewriteWithPartitionExpr:
fe/fe-core/src/test/java/com/starrocks/sql/optimizer/rule/transformation/materialization/MvRewritePartialPartitionTest.java#L1116
PLAN FRAGMENT 0
OUTPUT EXPRS:6: date_trunc | 7: count
PARTITION: UNPARTITIONED
RESULT SINK
5:EXCHANGE
PLAN FRAGMENT 1
OUTPUT EXPRS:
PARTITION: HASH_PARTITIONED: 6: date_trunc
STREAM DATA SINK
EXCHANGE ID: 05
UNPARTITIONED
4:AGGREGATE (merge finalize)
| output: count(7: count)
| group by: 6: date_trunc
|
3:EXCHANGE
PLAN FRAGMENT 2
OUTPUT EXPRS:
colocate exec groups: ExecGroup{groupId=1, nodeIds=[0, 1, 2]}
PARTITION: RANDOM
STREAM DATA SINK
EXCHANGE ID: 03
HASH_PARTITIONED: 6: date_trunc
2:AGGREGATE (update serialize)
| STREAMING
| output: count(1: t1a)
| group by: 6: date_trunc
|
1:Project
| <slot 1> : 1: t1a
| <slot 6> : date_trunc('day', 2: id_datetime)
|
0:OlapScanNode
TABLE: table_with_datetime_partition
PREAGGREGATION: ON
partitions=4/4
rollup: table_with_datetime_partition
tabletRatio=12/12
tabletList=10161,10163,10165,10168,10170,10172,10182,10184,10186,10175 ...
cardinality=1
avgRowSize=3.0
|
|
ReplayFromDumpTest.testNestedViewWithCTE:
fe/fe-core/src/test/java/com/starrocks/sql/plan/ReplayFromDumpTest.java#L769
PLAN FRAGMENT 0
OUTPUT EXPRS:8694: count
PARTITION: UNPARTITIONED
RESULT SINK
618:EXCHANGE
limit: 100
PLAN FRAGMENT 1
OUTPUT EXPRS:
PARTITION: HASH_PARTITIONED: 24: mock_038, 15: mock_003, 108: mock_109, 4: mock_005, 2: mock_110, 2133: case
STREAM DATA SINK
EXCHANGE ID: 618
UNPARTITIONED
617:Project
| <slot 8694> : 8694: count
| limit: 100
|
616:AGGREGATE (merge finalize)
| output: count(8694: count)
| group by: 24: mock_038, 15: mock_003, 108: mock_109, 4: mock_005, 2: mock_110, 2133: case
| limit: 100
|
615:EXCHANGE
PLAN FRAGMENT 2
OUTPUT EXPRS:
PARTITION: HASH_PARTITIONED: 2196: mock_275, 2194: mock_110
STREAM DATA SINK
EXCHANGE ID: 615
HASH_PARTITIONED: 24: mock_038, 15: mock_003, 108: mock_109, 4: mock_005, 2: mock_110, 2133: case
614:AGGREGATE (update serialize)
| STREAMING
| output: count(1)
| group by: 24: mock_038, 15: mock_003, 108: mock_109, 4: mock_005, 2: mock_110, 2133: case
|
613:Project
| <slot 2> : 2: mock_110
| <slot 4> : 4: mock_005
| <slot 15> : 15: mock_003
| <slot 24> : 24: mock_038
| <slot 108> : 108: mock_109
| <slot 2133> : 2133: case
|
612:HASH JOIN
| join op: LEFT OUTER JOIN (BUCKET_SHUFFLE(S))
| colocate: false, reason:
| equal join conjunct: 1: mock_021 = 8686: mock_459
| equal join conjunct: 2: mock_110 = 8687: mock_110
|
|----611:EXCHANGE
|
408:Project
| <slot 1> : 1: mock_021
| <slot 2> : 2: mock_110
| <slot 4> : 4: mock_005
| <slot 15> : 15: mock_003
| <slot 24> : 24: mock_038
| <slot 108> : 108: mock_109
| <slot 2133> : 2133: case
|
407:HASH JOIN
| join op: LEFT OUTER JOIN (BUCKET_SHUFFLE(S))
| colocate: false, reason:
| equal join conjunct: 1: mock_021 = 2196: mock_275
| equal join conjunct: 2: mock_110 = 2194: mock_110
|
|----406:AGGREGATE (merge finalize)
| | group by: 2196: mock_275, 2194: mock_110
| |
| 405:EXCHANGE
|
212:EXCHANGE
PLAN FRAGMENT 3
OUTPUT EXPRS:
PARTITION: HASH_PARTITIONED: 5433: mock_459, 5428: mock_110, 7044: coalesce
STREAM DATA SINK
EXCHANGE ID: 611
HASH_PARTITIONED: 8686: mock_459, 8687: mock_110
610:Project
| <slot 8686> : 5433: mock_459
| <slot 8687> : 5428: mock_110
|
609:AGGREGATE (merge finalize)
| group by: 5433: mock_459, 5428: mock_110, 7044: coalesce
|
608:EXCHANGE
PLAN FRAGMENT 4
OUTPUT EXPRS:
PARTITION: HASH_PARTITIONED: 6937: mock_433, 6933: mock_110
STREAM DATA SINK
EXCHANGE ID: 608
HASH_PARTITIONED: 5433: mock_459, 5428: mock_110, 7044: coalesce
607:AGGREGATE (update serialize)
| STREAMING
| group by: 5433: mock_459, 5428: mock_110, 7044: coalesce
|
606:Project
| <slot 5428> : 5428: mock_110
| <slot 5433> : 5433: mock_459
| <slot 7044> : coalesce(5430: mock_458, '')
|
605:HASH JOIN
| join op: INNER JOIN (PARTITIONED)
| colocate: false, reason:
| equal join conjunct: 6937: mock_433 = 6941: mock_423
| equal join conjunct: 6933: mock_110 = 6940: mock_110
|
|----604:EXCHANGE
|
601:EXCHANGE
PLAN FRAGMENT 5
OUTPUT EXPRS:
PARTITION: RANDOM
STREAM DATA SINK
EXCHANGE ID: 604
HASH_PARTITIONED: 6941: mock_423, 6940: mock_110
603:Project
| <slot 6940> : 6940: mock_110
| <slot 6941> : 6941: mock_423
|
602:OlapScanNode
TABLE: tbl_mock_421
PREAGGREGATION: ON
PREDICATES: 6940: mock_110 IS NOT NULL, 6943: mock_425 = '1'
partitions=1/1
rollup: tbl_mock_421
tabletRatio=10/10
tabletList=28178,28180,28182,28184,28186,28188,28190,28192,28194,28196
cardinality=1
avgRowSize=3.0
PLAN FRAGMENT 6
OUTPUT EXPRS:
PARTITION: HASH_PARTITIONED: 6933: mock_110, 6936: mock_433
STREAM DATA SINK
EXCHANGE ID: 601
HASH_PARTITIONED: 6937: mock_433, 6933: mock_110
600:Project
| <slot 5428> : 5428: mock_110
| <slot 5430> : 5430: mock_458
| <slot 5433> : 5433: mock_459
| <slot 6933> : 6933: mock_110
| <slot 6937> : 6937: mock_433
|
599:HASH JOIN
| join op: INNER JOIN (BUCKET_SHUFFLE(S))
| colocate: false, reason:
| equal join conjunct: 6933: mock_110 = 7032: mock_110
| equal join conjunct: 6936: mock_433 = 7031: mock_355
|
|----598:EXCHANGE
|
591:Project
| <slot 5428> : 5428: mock_110
| <slot 5430> : 5430: mock_458
| <slot 5433> : 5433: mock_459
| <slot 6933> : 6933: mock_110
| <slot 6936> : 6936: mock_433
| <slot 6937> : 6937: mock_433
|
590:HASH JOIN
| join op: INNER JOIN (PARTITIONED)
| colocate: false, reason:
| equal join conjunct: 6933: mock_110 = 5509: mock_110
| equal join conjunct: 6936: mock_433 = 5557: mock_355
| other join predicates: 5434: mock_464 >= 6934: case, 5434: mock_464 < coalesce(6935: cast, '2099-12-12')
|
|----589:EXCHANGE
|
575:EXCHANGE
PLAN FRAGMENT 7
OUTPUT EXPRS:
PARTITION: HASH_PARTITIONED: 6995: mock_355, 6947: mock_110
STREAM DATA SINK
EXCHANGE ID: 598
HASH_PARTITIONED: 7032: mock_110, 7031: mock_355
597:Project
| <slot 7031> : 6995: mock_355
| <slot 7032> : 6947: mock_110
|
596:AGGREGATE (merge finalize)
| group by: 6995: mock_355, 6947: mock_110
|
595:EXCHANGE
PLAN FRAGMENT 8
OUTPUT EXPRS:
PARTITION: RANDOM
STREAM DATA SINK
EXCHANGE ID: 595
HASH_PARTITIONED: 6995: mock_355, 6947: mock_110
594:AGGREGATE (update serialize)
| STREAMING
| group by: 6995: mock_355, 6947: mock_110
|
593:Project
| <slot 6947> : 6947: mock_110
| <slot 6995> : 6995: mock_355
|
592:OlapScanNode
TABLE: tbl_mock_350
PREAGGREGATION: ON
PREDICATES: coalesce(6983: mock_414, '') != 'd'
partitions=1/1
rollup: tbl_mock_350
tabletRatio=10/10
tabletList=28154,28156,28158,28160,28162,28164,28166,28168,28170,28172
cardinality=1
avgRowSize=3.0
PLAN FRAGMENT 9
OUTPUT EXPRS:
PARTITION: HASH_PARTITIONED: 5429: mock_463, 5428: mock_110
STREAM DATA SINK
EXCHANGE ID: 589
HASH_PARTITIONED: 5509: mock_110, 5557: mock_355
588:Project
| <slot 5428> : 5428: mock_110
| <slot 5430> : 5430: mock_458
| <slot 5433> : 5433: mock_459
| <slot 5434> : 5434: mock_464
| <slot 5509> : 5509: mock_110
| <slot 5557> : 5557: mock_355
|
587:HASH JOIN
| join op: INNER JOIN (PARTITIONED)
| colocate: false, reason:
| equal join conjunct: 5429: mock_463 = 5445: mock_487
| equal join conjunct: 5428: mock_110 = 5446: mock_110
|
|----586:EXCHANGE
|
578:EXCHANGE
PLAN FRAGMENT 10
OUTPUT EXPRS:
PARTITION: HASH_PARTITIONED: 5488: mock_109, 5446: mock_110
STREAM DATA SINK
EXCHANGE ID: 586
HASH_PARTITIONED: 5445: mock_487, 5446: mock_110
585:Project
| <slot 5445> : 5445: mock_487
| <slot 5446> : 5446: mock_110
| <slot 5509> : 5509: mock_110
| <slot 5557> : 5557: mock_355
|
584:HASH JOIN
| join op: INNER JOIN (PARTITIONED)
| colocate: false, reason:
| equal join conjunct: 5488: mock_109 = 5508: mock_109
| equal join conjunct: 5446: mock_110 = 5509: mock_110
|
|----583:EXCHANGE
|
580:EXCHANGE
PLAN FRAGMENT 11
OUTPUT EXPRS:
PARTITION: RANDOM
STREAM DATA SINK
EXCHANGE ID: 583
HASH_PARTITIONED: 5508: mock_109, 5509: mock_110
582:Project
| <slot 5508> : 5508: mock_109
| <slot 5509> : 5509: mock_110
| <slot 5557> : 5557: mock_355
|
581:OlapScanNode
TABLE: tbl_mock_350
PREAGGREGATION: ON
PREDICATES: coalesce(5545: mock_414, '') != 'd', coalesce(5563: mock_372, '') = '1'
partitions=1/1
rollup: tbl_mock_350
tabletRatio=10/10
tabletList=28154,28156,28158,28160,28162,28164,28166,28168,28170,28172
cardinality=1
avgRowSize=5.0
PLAN FRAGMENT 12
OUTPUT EXPRS:
PARTITION: RANDOM
STREAM DATA SINK
EXCHANGE ID: 580
HASH_PARTITIONED: 5488: mock_109, 5446: mock_110
579:OlapScanNode
TABLE: tbl_mock_471
PREAGGREGATION: ON
partitions=1/1
rollup: tbl_mock_471
tabletRatio=10/10
tabletList=28322,28324,28326,28328,28330,28332,28334,28336,28338,28340
cardinality=1
avgRowSize=3.0
PLAN FRAGMENT 13
OUTPUT EXPRS:
PARTITION: RANDOM
STREAM DATA SINK
EXCHANGE ID: 578
HASH_PARTITIONED: 5429: mock_463, 5428: mock_110
577:Project
| <slot 5428> : 5428: mock_110
| <slot 5429> : 5429: mock_463
| <slot 5430> : 5430: mock_458
| <slot 5433> : 5433: mock_459
| <slot 5434> : 5434: mock_464
|
576:OlapScanNode
TABLE: tbl_mock_456
PREAGGREGATION: ON
PREDICATES: coalesce(5430: mock_458, '') = 'check', 5435: mock_470 LIKE 'incl_sc_ref%', 5430: mock_458 IN ('item', 'check')
partitions=1/1
rollup: tbl_mock_456
tabletRatio=10/10
tabletList=28298,28300,28302,28304,28306,28308,28310,28312,28314,28316
cardinality=1
avgRowSize=6.0
PLAN FRAGMENT 14
OUTPUT EXPRS:
PARTITION: RANDOM
STREAM DATA SINK
EXCHANGE ID: 575
HASH_PARTITIONED: 6933: mock_110, 6936: mock_433
409:UNION
|
|----574:EXCHANGE
|
565:EXCHANGE
PLAN FRAGMENT 15
OUTPUT EXPRS:
PARTITION: HASH_PARTITIONED: 6913: mock_110
STREAM DATA SINK
EXCHANGE ID: 574
RANDOM
573:Project
| <slot 6908> : 6908: mock_453
| <slot 6909> : 6909: mock_451
| <slot 6911> : 6911: mock_452
| <slot 6912> : 6912: mock_447
| <slot 6913> : 6913: mock_110
|
572:HASH JOIN
| join op: INNER JOIN (PARTITIONED)
| colocate: false, reason:
| equal join conjunct: 6913: mock_110 = 6922: mock_110
|
|----571:EXCHANGE
|
568:EXCHANGE
PLAN FRAGMENT 16
OUTPUT EXPRS:
PARTITION: RANDOM
STREAM DATA SINK
EXCHANGE ID: 571
HASH_PARTITIONED: 6922: mock_110
570:Project
| <slot 6922> : 6922: mock_110
|
569:OlapScanNode
TABLE: tbl_mock_437
PREAGGREGATION: ON
PREDICATES: 6926: mock_440 = '1', 6922: mock_110 IS NOT NULL, 6924: mock_441 = '1'
partitions=1/1
rollup: tbl_mock_437
tabletRatio=10/10
tabletList=28250,28252,28254,28256,28258,28260,28262,28264,28266,28268
cardinality=1
avgRowSize=3.0
PLAN FRAGMENT 17
OUTPUT EXPRS:
PARTITION: RANDOM
STREAM DATA SINK
EXCHANGE ID: 568
HASH_PARTITIONED: 6913: mock_110
567:Project
| <slot 6908> : 6908: mock_453
| <slot 6909> : 6909: mock_451
| <slot 6911> : 6911: mock_452
| <slot 6912> : 6912: mock_447
| <slot 6913> : 6913: mock_110
|
566:OlapScanNode
TABLE: tbl_mock_444
PREAGGREGATION: ON
PREDICATES: 6913: mock_110 IS NOT NULL, 6909: mock_451 IS NOT NULL, 6914: mock_446 = '0'
partitions=1/1
rollup: tbl_mock_444
tabletRatio=10/10
tabletList=28274,28276,28278,28280,28282,28284,28286,28288,28290,28292
cardinality=1
avgRowSize=6.0
PLAN FRAGMENT 18
OUTPUT EXPRS:
PARTITION: HASH_PARTITIONED: 6403: case
STREAM DATA SINK
EXCHANGE ID: 565
RANDOM
564:NESTLOOP JOIN
| join op: CROSS JOIN
| colocate: false, reason:
|
|----563:EXCHANGE
|
560:Project
| <slot 6403> : 6403: case
| <slot 6404> : 6404: cast
| <slot 6405> : 6405: mock_433
| <slot 6714> : 6714: mock_433
|
559:HASH JOIN
| join op: LEFT SEMI JOIN (BROADCAST)
| colocate: false, reason:
| equal join conjunct: 6714: mock_433 = 6890: mock_355
|
|----558:EXCHANGE
|
554:Project
| <slot 6403> : 6403: case
| <slot 6404> : 6404: cast
| <slot 6405> : 6405: mock_433
| <slot 6714> : 6714: mock_433
|
553:HASH JOIN
| join op: LEFT SEMI JOIN (BROADCAST)
| colocate: false, reason:
| equal join conjunct: 6405: mock_433 = 6801: mock_355
|
|----552:EXCHANGE
|
545:Project
| <slot 6403> : 6403: case
| <slot 6404> : 6404: cast
| <slot 6405> : 6405: mock_433
| <slot 6714> : 6714: mock_433
|
544:HASH JOIN
| join op: LEFT OUTER JOIN (PARTITIONED)
| colocate: false, reason:
| equal join conjunct: 6403: case = 6712: case
|
|----543:EXCHANGE
|
476:EXCHANGE
PLAN FRAGMENT 19
OUTPUT EXPRS:
PARTITION: RANDOM
STREAM DATA SINK
EXCHANGE ID: 563
UNPARTITIONED
562:Project
| <slot 6896> : 6896: mock_110
|
561:OlapScanNode
TABLE: tbl_mock_437
PREAGGREGATION: ON
PREDICATES: 6896: mock_110 IS NOT NULL, 6900: mock_440 = '2', 6898: mock_441 = '1'
partitions=1/1
rollup: tbl_mock_437
tabletRatio=10/10
tabletList=28250,28252,28254,28256,28258,28260,28262,28264,28266,28268
cardinality=1
avgRowSize=3.0
PLAN FRAGMENT 20
OUTPUT EXPRS:
PARTITION: RANDOM
STREAM DATA SINK
EXCHANGE ID: 558
UNPARTITIONED
557:Project
| <slot 6890> : 6882: mock_423
|
556:AGGREGATE (update finalize)
| group by: 6882: mock_423, 6881: mock_110
|
555:OlapScanNode
TABLE: tbl_mock_421
PREAGGREGATION: ON
PREDICATES: 6882: mock_423 IS NOT NULL
partitions=1/1
rollup: tbl_mock_421
tabletRatio=10/10
tabletList=28178,28180,28182,28184,28186,28188,28190,28192,28194,28196
cardinality=1
avgRowSize=2.0
PLAN FRAGMENT 21
OUTPUT EXPRS:
PARTITION: HASH_PARTITIONED: 6765: mock_355, 6717: mock_110
STREAM DATA SINK
EXCHANGE ID: 552
UNPARTITIONED
551:Project
| <slot 6801> : 6765: mock_355
|
550:AGGREGATE (merge finalize)
| group by: 6765: mock_355, 6717: mock_110
|
549:EXCHANGE
PLAN FRAGMENT 22
OUTPUT EXPRS:
PARTITION: RANDOM
STREAM DATA SINK
EXCHANGE ID: 549
HASH_PARTITIONED: 6765: mock_355, 6717: mock_110
548:AGGREGATE (update serialize)
| STREAMING
| group by: 6765: mock_355, 6717: mock_110
|
547:Project
| <slot 6717> : 6717: mock_110
| <slot 6765> : 6765: mock_355
|
546:OlapScanNode
TABLE: tbl_mock_350
PREAGGREGATION: ON
PREDICATES: 6765: mock_355 IS NOT NULL, coalesce(6753: mock_414, '') != 'd'
partitions=1/1
rollup: tbl_mock_350
tabletRatio=10/10
tabletList=28154,28156,28158,28160,28162,28164,28166,28168,28170,28172
cardinality=1
avgRowSize=3.0
PLAN FRAGMENT 23
OUTPUT EXPRS:
PARTITION: RANDOM
STREAM DATA SINK
EXCHANGE ID: 543
HASH_PARTITIONED: 6712: case
477:UNION
|
|----517:EXCHANGE
|
|----542:EXCHANGE
|
497:EXCHANGE
PLAN FRAGMENT 24
OUTPUT EXPRS:
PARTITION: RANDOM
STREAM DATA SINK
EXCHANGE ID: 542
RANDOM
541:Project
| <slot 6608> : 6608: mock_433
| <slot 6710> : date_format(days_add(CAST(date(CAST(6704: case AS DATETIME)) AS DATETIME), 1), '%Y-%m-%d')
|
540:SELECT
| predicates: 6707: row_number() = 1
|
539:ANALYTIC
| functions: [, row_number(), ]
| partition by: 6608: mock_433
| order by: 6704: case DESC
| window: ROWS BETWEEN UNBOUNDED PRECEDING AND CURRENT ROW
|
538:SORT
| order by: <slot 6608> 6608: mock_433 ASC, <slot 6704> 6704: case DESC
| analytic partition by: 6608: mock_433
| offset: 0
|
537:PARTITION-TOP-N
| partition by: 6608: mock_433
| partition limit: 1
| order by: <slot 6608> 6608: mock_433 ASC, <slot 6704> 6704: case DESC
| offset: 0
|
536:Project
| <slot 6608> : 6608: mock_433
| <slot 6704> : if(6609: mock_430 = '2017-01-01', '1970-01-01', 6609: mock_430)
|
535:HASH JOIN
| join op: LEFT SEMI JOIN (BUCKET_SHUFFLE)
| colocate: false, reason:
| equal join conjunct: 6608: mock_433 = 6700: mock_355
|
|----534:EXCHANGE
|
518:OlapScanNode
TABLE: tbl_mock_427
PREAGGREGATION: ON
PREDICATES: if(6609: mock_430 = '2017-01-01', '1970-01-01', 6609: mock_430) > '2021-08-28', 6609: mock_430 >= '2017-01-01'
partitions=1/1
rollup: tbl_mock_427
tabletRatio=10/10
tabletList=28202,28204,28206,28208,28210,28212,28214,28216,28218,28220
cardinality=1
avgRowSize=2.0
PLAN FRAGMENT 25
OUTPUT EXPRS:
PARTITION: HASH_PARTITIONED: 6700: mock_355
STREAM DATA SINK
EXCHANGE ID: 534
BUCKET_SHUFFLE_HASH_PARTITIONED: 6700: mock_355
533:AGGREGATE (merge finalize)
| group by: 6700: mock_355
|
532:EXCHANGE
PLAN FRAGMENT 26
OUTPUT EXPRS:
PARTITION: RANDOM
STREAM DATA SINK
EXCHANGE ID: 532
HASH_PARTITIONED: 6700: mock_355
531:AGGREGATE (update serialize)
| STREAMING
| group by: 6700: mock_355
|
519:UNION
|
|----530:EXCHANGE
|
526:EXCHANGE
PLAN FRAGMENT 27
OUTPUT EXPRS:
PARTITION: RANDOM
STREAM DATA SINK
EXCHANGE ID: 530
RANDOM
529:Project
| <slot 6698> : 6692: mock_423
|
528:AGGREGATE (update finalize)
| group by: 6692: mock_423, 6691: mock_110
|
527:OlapScanNode
TABLE: tbl_mock_421
PREAGGREGATION: ON
PREDICATES: 6692: mock_423 IS NOT NULL
partitions=1/1
rollup: tbl_mock_421
tabletRatio=10/10
tabletList=28178,28180,28182,28184,28186,28188,28190,28192,28194,28196
cardinality=1
avgRowSize=2.0
PLAN FRAGMENT 28
OUTPUT EXPRS:
PARTITION: HASH_PARTITIONED: 6664: mock_355, 6616: mock_110
STREAM DATA SINK
EXCHANGE ID: 526
RANDOM
525:Project
| <slot 6664> : 6664: mock_355
|
524:AGGREGATE (merge finalize)
| group by: 6664: mock_355, 6616: mock_110
|
523:EXCHANGE
PLAN FRAGMENT 29
OUTPUT EXPRS:
PARTITION: RANDOM
STREAM DATA SINK
EXCHANGE ID: 523
HASH_PARTITIONED: 6664: mock_355, 6616: mock_110
522:AGGREGATE (update serialize)
| STREAMING
| group by: 6664: mock_355, 6616: mock_110
|
521:Project
| <slot 6616> : 6616: mock_110
| <slot 6664> : 6664: mock_355
|
520:OlapScanNode
TABLE: tbl_mock_350
PREAGGREGATION: ON
PREDICATES: 6664: mock_355 IS NOT NULL, coalesce(6652: mock_414, '') != 'd'
partitions=1/1
rollup: tbl_mock_350
tabletRatio=10/10
tabletList=28154,28156,28158,28160,28162,28164,28166,28168,28170,28172
cardinality=1
avgRowSize=3.0
PLAN FRAGMENT 30
OUTPUT EXPRS:
PARTITION: RANDOM
STREAM DATA SINK
EXCHANGE ID: 517
RANDOM
516:Project
| <slot 6507> : 6507: mock_433
| <slot 6607> : if(6514: mock_436 = '0', '1970-01-01', date_format(days_add(CAST(date(CAST(6508: mock_430 AS DATETIME)) AS DATETIME), 1), '%Y-%m-%d'))
|
515:HASH JOIN
| join op: LEFT SEMI JOIN (BUCKET_SHUFFLE)
| colocate: false, reason:
| equal join conjunct: 6507: mock_433 = 6600: mock_355
|
|----514:EXCHANGE
|
498:OlapScanNode
TABLE: tbl_mock_435
PREAGGREGATION: ON
PREDICATES: 6508: mock_430 > '2017-01-01', 6514: mock_436 = '0'
partitions=1/1
rollup: tbl_mock_435
tabletRatio=10/10
tabletList=28226,28228,28230,28232,28234,28236,28238,28240,28242,28244
cardinality=1
avgRowSize=3.0
PLAN FRAGMENT 31
OUTPUT EXPRS:
PARTITION: HASH_PARTITIONED: 6600: mock_355
STREAM DATA SINK
EXCHANGE ID: 514
BUCKET_SHUFFLE_HASH_PARTITIONED: 6600: mock_355
513:AGGREGATE (merge finalize)
| group by: 6600: mock_355
|
512:EXCHANGE
PLAN FRAGMENT 32
OUTPUT EXPRS:
PARTITION: RANDOM
STREAM DATA SINK
EXCHANGE ID: 512
HASH_PARTITIONED: 6600: mock_355
511:AGGREGATE (update serialize)
| STREAMING
| group by: 6600: mock_355
|
499:UNION
|
|----510:EXCHANGE
|
506:EXCHANGE
PLAN FRAGMENT 33
OUTPUT EXPRS:
PARTITION: RANDOM
STREAM DATA SINK
EXCHANGE ID: 510
RANDOM
509:Project
| <slot 6598> : 6592: mock_423
|
508:AGGREGATE (update finalize)
| group by: 6592: mock_423, 6591: mock_110
|
507:OlapScanNode
TABLE: tbl_mock_421
PREAGGREGATION: ON
PREDICATES: 6592: mock_423 IS NOT NULL
partitions=1/1
rollup: tbl_mock_421
tabletRatio=10/10
tabletList=28178,28180,28182,28184,28186,28188,28190,28192,28194,28196
cardinality=1
avgRowSize=2.0
PLAN FRAGMENT 34
OUTPUT EXPRS:
PARTITION: HASH_PARTITIONED: 6564: mock_355, 6516: mock_110
STREAM DATA SINK
EXCHANGE ID: 506
RANDOM
505:Project
| <slot 6564> : 6564: mock_355
|
504:AGGREGATE (merge finalize)
| group by: 6564: mock_355, 6516: mock_110
|
503:EXCHANGE
PLAN FRAGMENT 35
OUTPUT EXPRS:
PARTITION: RANDOM
STREAM DATA SINK
EXCHANGE ID: 503
HASH_PARTITIONED: 6564: mock_355, 6516: mock_110
502:AGGREGATE (update serialize)
| STREAMING
| group by: 6564: mock_355, 6516: mock_110
|
501:Project
| <slot 6516> : 6516: mock_110
| <slot 6564> : 6564: mock_355
|
500:OlapScanNode
TABLE: tbl_mock_350
PREAGGREGATION: ON
PREDICATES: 6564: mock_355 IS NOT NULL, coalesce(6552: mock_414, '') != 'd'
partitions=1/1
rollup: tbl_mock_350
tabletRatio=10/10
tabletList=28154,28156,28158,28160,28162,28164,28166,28168,28170,28172
cardinality=1
avgRowSize=3.0
PLAN FRAGMENT 36
OUTPUT EXPRS:
PARTITION: RANDOM
STREAM DATA SINK
EXCHANGE ID: 497
RANDOM
496:Project
| <slot 6407> : 6407: mock_433
| <slot 6503> : if(6408: mock_430 = '2017-01-01', '1970-01-01', 6408: mock_430)
|
495:HASH JOIN
| join op: LEFT SEMI JOIN (BUCKET_SHUFFLE)
| colocate: false, reason:
| equal join conjunct: 6407: mock_433 = 6499: mock_355
|
|----494:EXCHANGE
|
478:OlapScanNode
TABLE: tbl_mock_427
PREAGGREGATION: ON
PREDICATES: 6408: mock_430 >= '2017-01-01'
partitions=1/1
rollup: tbl_mock_427
tabletRatio=10/10
tabletList=28202,28204,28206,28208,28210,28212,28214,28216,28218,28220
cardinality=1
avgRowSize=2.0
PLAN FRAGMENT 37
OUTPUT EXPRS:
PARTITION: HASH_PARTITIONED: 6499: mock_355
STREAM DATA SINK
EXCHANGE ID: 494
BUCKET_SHUFFLE_HASH_PARTITIONED: 6499: mock_355
493:AGGREGATE (merge finalize)
| group by: 6499: mock_355
|
492:EXCHANGE
PLAN FRAGMENT 38
OUTPUT EXPRS:
PARTITION: RANDOM
STREAM DATA SINK
EXCHANGE ID: 492
HASH_PARTITIONED: 6499: mock_355
491:AGGREGATE (update serialize)
| STREAMING
| group by: 6499: mock_355
|
479:UNION
|
|----490:EXCHANGE
|
486:EXCHANGE
PLAN FRAGMENT 39
OUTPUT EXPRS:
PARTITION: RANDOM
STREAM DATA SINK
EXCHANGE ID: 490
RANDOM
489:Project
| <slot 6497> : 6491: mock_423
|
488:AGGREGATE (update finalize)
| group by: 6491: mock_423, 6490: mock_110
|
487:OlapScanNode
TABLE: tbl_mock_421
PREAGGREGATION: ON
PREDICATES: 6491: mock_423 IS NOT NULL
partitions=1/1
rollup: tbl_mock_421
tabletRatio=10/10
tabletList=28178,28180,28182,28184,28186,28188,28190,28192,28194,28196
cardinality=1
avgRowSize=2.0
PLAN FRAGMENT 40
OUTPUT EXPRS:
PARTITION: HASH_PARTITIONED: 6463: mock_355, 6415: mock_110
STREAM DATA SINK
EXCHANGE ID: 486
RANDOM
485:Project
| <slot 6463> : 6463: mock_355
|
484:AGGREGATE (merge finalize)
| group by: 6463: mock_355, 6415: mock_110
|
483:EXCHANGE
PLAN FRAGMENT 41
OUTPUT EXPRS:
PARTITION: RANDOM
STREAM DATA SINK
EXCHANGE ID: 483
HASH_PARTITIONED: 6463: mock_355, 6415: mock_110
482:AGGREGATE (update serialize)
| STREAMING
| group by: 6463: mock_355, 6415: mock_110
|
481:Project
| <slot 6415> : 6415: mock_110
| <slot 6463> : 6463: mock_355
|
480:OlapScanNode
TABLE: tbl_mock_350
PREAGGREGATION: ON
PREDICATES: 6463: mock_355 IS NOT NULL, coalesce(6451: mock_414, '') != 'd'
partitions=1/1
rollup: tbl_mock_350
tabletRatio=10/10
tabletList=28154,28156,28158,28160,28162,28164,28166,28168,28170,28172
cardinality=1
avgRowSize=3.0
PLAN FRAGMENT 42
OUTPUT EXPRS:
PARTITION: RANDOM
STREAM DATA SINK
EXCHANGE ID: 476
HASH_PARTITIONED: 6403: case
410:UNION
|
|----450:EXCHANGE
|
|----475:EXCHANGE
|
430:EXCHANGE
PLAN FRAGMENT 43
OUTPUT EXPRS:
PARTITION: RANDOM
STREAM DATA SINK
EXCHANGE ID: 475
RANDOM
474:Project
| <slot 6299> : 6299: mock_433
| <slot 6401> : date_format(days_add(CAST(date(CAST(6395: case AS DATETIME)) AS DATETIME), 1), '%Y-%m-%d')
| <slot 6402> : '2099-12-31'
|
473:SELECT
| predicates: 6398: row_number() = 1
|
472:ANALYTIC
| functions: [, row_number(), ]
| partition by: 6299: mock_433
| order by: 6395: case DESC
| window: ROWS BETWEEN UNBOUNDED PRECEDING AND CURRENT ROW
|
471:SORT
| order by: <slot 6299> 6299: mock_433 ASC, <slot 6395> 6395: case DESC
| analytic partition by: 6299: mock_433
| offset: 0
|
470:PARTITION-TOP-N
| partition by: 6299: mock_433
| partition limit: 1
| order by: <slot 6299> 6299: mock_433 ASC, <slot 6395> 6395: case DESC
| offset: 0
|
469:Project
| <slot 6299> : 6299: mock_433
| <slot 6395> : if(6300: mock_430 = '2017-01-01', '1970-01-01', 6300: mock_430)
|
468:HASH JOIN
| join op: LEFT SEMI JOIN (BUCKET_SHUFFLE)
| colocate: false, reason:
| equal join conjunct: 6299: mock_433 = 6391: mock_355
|
|----467:EXCHANGE
|
451:OlapScanNode
TABLE: tbl_mock_427
PREAGGREGATION: ON
PREDICATES: 6299: mock_433 IS NOT NULL, if(6300: mock_430 = '2017-01-01', '1970-01-01', 6300: mock_430) > '2021-08-28', 6300: mock_430 >= '2017-01-01'
partitions=1/1
rollup: tbl_mock_427
tabletRatio=10/10
tabletList=28202,28204,28206,28208,28210,28212,28214,28216,28218,28220
cardinality=1
avgRowSize=2.0
PLAN FRAGMENT 44
OUTPUT EXPRS:
PARTITION: HASH_PARTITIONED: 6391: mock_355
STREAM DATA SINK
EXCHANGE ID: 467
BUCKET_SHUFFLE_HASH_PARTITIONED: 6391: mock_355
466:AGGREGATE (merge finalize)
| group by: 6391: mock_355
|
465:EXCHANGE
PLAN FRAGMENT 45
OUTPUT EXPRS:
PARTITION: RANDOM
STREAM DATA SINK
EXCHANGE ID: 465
HASH_PARTITIONED: 6391: mock_355
464:AGGREGATE (update serialize)
| STREAMING
| group by: 6391: mock_355
|
452:UNION
|
|----463:EXCHANGE
|
459:EXCHANGE
PLAN FRAGMENT 46
OUTPUT EXPRS:
PARTITION: RANDOM
STREAM DATA SINK
EXCHANGE ID: 463
RANDOM
462:Project
| <slot 6389> : 6383: mock_423
|
461:AGGREGATE (update finalize)
| group by: 6383: mock_423, 6382: mock_110
|
460:OlapScanNode
TABLE: tbl_mock_421
PREAGGREGATION: ON
PREDICATES: 6383: mock_423 IS NOT NULL
partitions=1/1
rollup: tbl_mock_421
tabletRatio=10/10
tabletList=28178,28180,28182,28184,28186,28188,28190,28192,28194,28196
cardinality=1
avgRowSize=2.0
PLAN FRAGMENT 47
OUTPUT EXPRS:
PARTITION: HASH_PARTITIONED: 6355: mock_355, 6307: mock_110
STREAM DATA SINK
EXCHANGE ID: 459
RANDOM
458:Project
| <slot 6355> : 6355: mock_355
|
457:AGGREGATE (merge finalize)
| group by: 6355: mock_355, 6307: mock_110
|
456:EXCHANGE
PLAN FRAGMENT 48
OUTPUT EXPRS:
PARTITION: RANDOM
STREAM DATA SINK
EXCHANGE ID: 456
HASH_PARTITIONED: 6355: mock_355, 6307: mock_110
455:AGGREGATE (update serialize)
| STREAMING
| group by: 6355: mock_355, 6307: mock_110
|
454:Project
| <slot 6307> : 6307: mock_110
| <slot 6355> : 6355: mock_355
|
453:OlapScanNode
TABLE: tbl_mock_350
PREAGGREGATION: ON
PREDICATES: 6355: mock_355 IS NOT NULL, coalesce(6343: mock_414, '') != 'd'
partitions=1/1
rollup: tbl_mock_350
tabletRatio=10/10
tabletList=28154,28156,28158,28160,28162,28164,28166,28168,28170,28172
cardinality=1
avgRowSize=3.0
PLAN FRAGMENT 49
OUTPUT EXPRS:
PARTITION: RANDOM
STREAM DATA SINK
EXCHANGE ID: 450
RANDOM
449:Project
| <slot 6198> : 6198: mock_433
| <slot 6296> : if(8697: expr, 6199: mock_430, '2099-12-12')
| <slot 6298> : if(8697: expr, '1970-01-01', date_format(days_add(CAST(date(CAST(6199: mock_430 AS DATETIME)) AS DATETIME), 1), '%Y-%m-%d'))
| common expressions:
| <slot 8697> : 6205: mock_436 = '0'
|
448:HASH JOIN
| join op: LEFT SEMI JOIN (BUCKET_SHUFFLE)
| colocate: false, reason:
| equal join conjunct: 6198: mock_433 = 6291: mock_355
|
|----447:EXCHANGE
|
431:OlapScanNode
TABLE: tbl_mock_435
PREAGGREGATION: ON
PREDICATES: 6198: mock_433 IS NOT NULL, 6199: mock_430 > '2017-01-01', 6205: mock_436 = '0'
partitions=1/1
rollup: tbl_mock_435
tabletRatio=10/10
tabletList=28226,28228,28230,28232,28234,28236,28238,28240,28242,28244
cardinality=1
avgRowSize=3.0
PLAN FRAGMENT 50
OUTPUT EXPRS:
PARTITION: HASH_PARTITIONED: 6291: mock_355
STREAM DATA SINK
EXCHANGE ID: 447
BUCKET_SHUFFLE_HASH_PARTITIONED: 6291: mock_355
446:AGGREGATE (merge finalize)
| group by: 6291: mock_355
|
445:EXCHANGE
PLAN FRAGMENT 51
OUTPUT EXPRS:
PARTITION: RANDOM
STREAM DATA SINK
EXCHANGE ID: 445
HASH_PARTITIONED: 6291: mock_355
444:AGGREGATE (update serialize)
| STREAMING
| group by: 6291: mock_355
|
432:UNION
|
|----443:EXCHANGE
|
439:EXCHANGE
PLAN FRAGMENT 52
OUTPUT EXPRS:
PARTITION: RANDOM
STREAM DATA SINK
EXCHANGE ID: 443
RANDOM
442:Project
| <slot 6289> : 6283: mock_423
|
441:AGGREGATE (update finalize)
| group by: 6283: mock_423, 6282: mock_110
|
440:OlapScanNode
TABLE: tbl_mock_421
PREAGGREGATION: ON
PREDICATES: 6283: mock_423 IS NOT NULL
partitions=1/1
rollup: tbl_mock_421
tabletRatio=10/10
tabletList=28178,28180,28182,28184,28186,28188,28190,28192,28194,28196
cardinality=1
avgRowSize=2.0
PLAN FRAGMENT 53
OUTPUT EXPRS:
PARTITION: HASH_PARTITIONED: 6255: mock_355, 6207: mock_110
STREAM DATA SINK
EXCHANGE ID: 439
RANDOM
438:Project
| <slot 6255> : 6255: mock_355
|
437:AGGREGATE (merge finalize)
| group by: 6255: mock_355, 6207: mock_110
|
436:EXCHANGE
PLAN FRAGMENT 54
OUTPUT EXPRS:
PARTITION: RANDOM
STREAM DATA SINK
EXCHANGE ID: 436
HASH_PARTITIONED: 6255: mock_355, 6207: mock_110
435:AGGREGATE (update serialize)
| STREAMING
| group by: 6255: mock_355, 6207: mock_110
|
434:Project
| <slot 6207> : 6207: mock_110
| <slot 6255> : 6255: mock_355
|
433:OlapScanNode
TABLE: tbl_mock_350
PREAGGREGATION: ON
PREDICATES: 6255: mock_355 IS NOT NULL, coalesce(6243: mock_414, '') != 'd'
partitions=1/1
rollup: tbl_mock_350
tabletRatio=10/10
tabletList=28154,28156,28158,28160,28162,28164,28166,28168,28170,28172
cardinality=1
avgRowSize=3.0
PLAN FRAGMENT 55
OUTPUT EXPRS:
PARTITION: RANDOM
STREAM DATA SINK
EXCHANGE ID: 430
RANDOM
429:Project
| <slot 6098> : 6098: mock_433
| <slot 6194> : if(6099: mock_430 = '2017-01-01', '1970-01-01', 6099: mock_430)
| <slot 6197> : date_format(days_add(CAST(date(CAST(6099: mock_430 AS DATETIME)) AS DATETIME), 1), '%Y-%m-%d')
|
428:HASH JOIN
| join op: LEFT SEMI JOIN (BUCKET_SHUFFLE)
| colocate: false, reason:
| equal join conjunct: 6098: mock_433 = 6190: mock_355
|
|----427:EXCHANGE
|
411:OlapScanNode
TABLE: tbl_mock_427
PREAGGREGATION: ON
PREDICATES: 6098: mock_433 IS NOT NULL, 6099: mock_430 >= '2017-01-01'
partitions=1/1
rollup: tbl_mock_427
tabletRatio=10/10
tabletList=28202,28204,28206,28208,28210,28212,28214,28216,28218,28220
cardinality=1
avgRowSize=2.0
PLAN FRAGMENT 56
OUTPUT EXPRS:
PARTITION: HASH_PARTITIONED: 6190: mock_355
STREAM DATA SINK
EXCHANGE ID: 427
BUCKET_SHUFFLE_HASH_PARTITIONED: 6190: mock_355
426:AGGREGATE (merge finalize)
| group by: 6190: mock_355
|
425:EXCHANGE
PLAN FRAGMENT 57
OUTPUT EXPRS:
PARTITION: RANDOM
STREAM DATA SINK
EXCHANGE ID: 425
HASH_PARTITIONED: 6190: mock_355
424:AGGREGATE (update serialize)
| STREAMING
| group by: 6190: mock_355
|
412:UNION
|
|----423:EXCHANGE
|
419:EXCHANGE
PLAN FRAGMENT 58
OUTPUT EXPRS:
PARTITION: RANDOM
STREAM DATA SINK
EXCHANGE ID: 423
RANDOM
422:Project
| <slot 6188> : 6182: mock_423
|
421:AGGREGATE (update finalize)
| group by: 6182: mock_423, 6181: mock_110
|
420:OlapScanNode
TABLE: tbl_mock_421
PREAGGREGATION: ON
PREDICATES: 6182: mock_423 IS NOT NULL
partitions=1/1
rollup: tbl_mock_421
tabletRatio=10/10
tabletList=28178,28180,28182,28184,28186,28188,28190,28192,28194,28196
cardinality=1
avgRowSize=2.0
PLAN FRAGMENT 59
OUTPUT EXPRS:
PARTITION: HASH_PARTITIONED: 6154: mock_355, 6106: mock_110
STREAM DATA SINK
EXCHANGE ID: 419
RANDOM
418:Project
| <slot 6154> : 6154: mock_355
|
417:AGGREGATE (merge finalize)
| group by: 6154: mock_355, 6106: mock_110
|
416:EXCHANGE
PLAN FRAGMENT 60
OUTPUT EXPRS:
PARTITION: RANDOM
STREAM DATA SINK
EXCHANGE ID: 416
HASH_PARTITIONED: 6154: mock_355, 6106: mock_110
415:AGGREGATE (update serialize)
| STREAMING
| group by: 6154: mock_355, 6106: mock_110
|
414:Project
| <slot 6106> : 6106: mock_110
| <slot 6154> : 6154: mock_355
|
413:OlapScanNode
TABLE: tbl_mock_350
PREAGGREGATION: ON
PREDICATES: 6154: mock_355 IS NOT NULL, coalesce(6142: mock_414, '') != 'd'
partitions=1/1
rollup: tbl_mock_350
tabletRatio=10/10
tabletList=28154,28156,28158,28160,28162,28164,28166,28168,28170,28172
cardinality=1
avgRowSize=3.0
PLAN FRAGMENT 61
OUTPUT EXPRS:
PARTITION: HASH_PARTITIONED: 3694: mock_433, 3690: mock_110
STREAM DATA SINK
EXCHANGE ID: 405
HASH_PARTITIONED: 2196: mock_275, 2194: mock_110
404:AGGREGATE (update serialize)
| STREAMING
| group by: 2196: mock_275, 2194: mock_110
|
403:Project
| <slot 2194> : 2194: mock_110
| <slot 2196> : 2196: mock_275
|
402:HASH JOIN
| join op: INNER JOIN (PARTITIONED)
| colocate: false, reason:
| equal join conjunct: 3694: mock_433 = 3698: mock_423
| equal join conjunct: 3690: mock_110 = 3697: mock_110
|
|----401:EXCHANGE
|
398:EXCHANGE
PLAN FRAGMENT 62
OUTPUT EXPRS:
PARTITION: RANDOM
STREAM DATA SINK
EXCHANGE ID: 401
HASH_PARTITIONED: 3698: mock_423, 3697: mock_110
400:Project
| <slot 3697> : 3697: mock_110
| <slot 3698> : 3698: mock_423
|
399:OlapScanNode
TABLE: tbl_mock_421
PREAGGREGATION: ON
PREDICATES: 3697: mock_110 IS NOT NULL, 3700: mock_425 = '1'
partitions=1/1
rollup: tbl_mock_421
tabletRatio=10/10
tabletList=28178,28180,28182,28184,28186,28188,28190,28192,28194,28196
cardinality=1
avgRowSize=3.0
PLAN FRAGMENT 63
OUTPUT EXPRS:
PARTITION: HASH_PARTITIONED: 3690: mock_110, 3693: mock_433
STREAM DATA SINK
EXCHANGE ID: 398
HASH_PARTITIONED: 3694: mock_433, 3690: mock_110
397:Project
| <slot 2194> : 2194: mock_110
| <slot 2196> : 2196: mock_275
| <slot 3690> : 3690: mock_110
| <slot 3694> : 3694: mock_433
|
396:HASH JOIN
| join op: INNER JOIN (BUCKET_SHUFFLE(S))
| colocate: false, reason:
| equal join conjunct: 3690: mock_110 = 3789: mock_110
| equal join conjunct: 3693: mock_433 = 3788: mock_355
|
|----395:EXCHANGE
|
388:Project
| <slot 2194> : 2194: mock_110
| <slot 2196> : 2196: mock_275
| <slot 3690> : 3690: mock_110
| <slot 3693> : 3693: mock_433
| <slot 3694> : 3694: mock_433
|
387:HASH JOIN
| join op: INNER JOIN (PARTITIONED)
| colocate: false, reason:
| equal join conjunct: 3690: mock_110 = 2266: mock_110
| equal join conjunct: 3693: mock_433 = 2314: mock_355
| other join predicates: 2215: mock_305 >= 3691: case, 2215: mock_305 < coalesce(3692: cast, '2099-12-12')
|
|----386:EXCHANGE
|
379:EXCHANGE
PLAN FRAGMENT 64
OUTPUT EXPRS:
PARTITION: HASH_PARTITIONED: 3752: mock_355, 3704: mock_110
STREAM DATA SINK
EXCHANGE ID: 395
HASH_PARTITIONED: 3789: mock_110, 3788: mock_355
394:Project
| <slot 3788> : 3752: mock_355
| <slot 3789> : 3704: mock_110
|
393:AGGREGATE (merge finalize)
| group by: 3752: mock_355, 3704: mock_110
|
392:EXCHANGE
PLAN FRAGMENT 65
OUTPUT EXPRS:
PARTITION: RANDOM
STREAM DATA SINK
EXCHANGE ID: 392
HASH_PARTITIONED: 3752: mock_355, 3704: mock_110
391:AGGREGATE (update serialize)
| STREAMING
| group by: 3752: mock_355, 3704: mock_110
|
390:Project
| <slot 3704> : 3704: mock_110
| <slot 3752> : 3752: mock_355
|
389:OlapScanNode
TABLE: tbl_mock_350
PREAGGREGATION: ON
PREDICATES: coalesce(3740: mock_414, '') != 'd'
partitions=1/1
rollup: tbl_mock_350
tabletRatio=10/10
tabletList=28154,28156,28158,28160,28162,28164,28166,28168,28170,28172
cardinality=1
avgRowSize=3.0
PLAN FRAGMENT 66
OUTPUT EXPRS:
PARTITION: RANDOM
STREAM DATA SINK
EXCHANGE ID: 386
HASH_PARTITIONED: 2266: mock_110, 2314: mock_355
385:Project
| <slot 2194> : 2194: mock_110
| <slot 2196> : 2196: mock_275
| <slot 2215> : 2215: mock_305
| <slot 2266> : 2266: mock_110
| <slot 2314> : 2314: mock_355
|
384:HASH JOIN
| join op: INNER JOIN (BUCKET_SHUFFLE)
| colocate: false, reason:
| equal join conjunct: 2265: mock_109 = 2247: mock_109
| equal join conjunct: 2266: mock_110 = 2194: mock_110
|
|----383:EXCHANGE
|
381:Project
| <slot 2265> : 2265: mock_109
| <slot 2266> : 2266: mock_110
| <slot 2314> : 2314: mock_355
|
380:OlapScanNode
TABLE: tbl_mock_350
PREAGGREGATION: ON
PREDICATES: coalesce(2302: mock_414, '') != 'd', coalesce(2320: mock_372, '') = '1'
partitions=1/1
rollup: tbl_mock_350
tabletRatio=10/10
tabletList=28154,28156,28158,28160,28162,28164,28166,28168,28170,28172
cardinality=1
avgRowSize=5.0
PLAN FRAGMENT 67
OUTPUT EXPRS:
PARTITION: RANDOM
STREAM DATA SINK
EXCHANGE ID: 383
BUCKET_SHUFFLE_HASH_PARTITIONED: 2247: mock_109
382:OlapScanNode
TABLE: tbl_mock_267
PREAGGREGATION: ON
PREDICATES: 2247: mock_109 IS NOT NULL, 2194: mock_110 IS NOT NULL
partitions=1/1
rollup: tbl_mock_267
tabletRatio=100/100
tabletList=27926,27928,27930,27932,27934,27936,27938,27940,27942,27944 ...
cardinality=1
avgRowSize=4.0
PLAN FRAGMENT 68
OUTPUT EXPRS:
PARTITION: RANDOM
STREAM DATA SINK
EXCHANGE ID: 379
HASH_PARTITIONED: 3690: mock_110, 3693: mock_433
213:UNION
|
|----378:EXCHANGE
|
369:EXCHANGE
PLAN FRAGMENT 69
OUTPUT EXPRS:
PARTITION: HASH_PARTITIONED: 3670: mock_110
STREAM DATA SINK
EXCHANGE ID: 378
RANDOM
377:Project
| <slot 3665> : 3665: mock_453
| <slot 3666> : 3666: mock_451
| <slot 3668> : 3668: mock_452
| <slot 3669> : 3669: mock_447
| <slot 3670> : 3670: mock_110
|
376:HASH JOIN
| join op: INNER JOIN (PARTITIONED)
| colocate: false, reason:
| equal join conjunct: 3670: mock_110 = 3679: mock_110
|
|----375:EXCHANGE
|
372:EXCHANGE
PLAN FRAGMENT 70
OUTPUT EXPRS:
PARTITION: RANDOM
STREAM DATA SINK
EXCHANGE ID: 375
HASH_PARTITIONED: 3679: mock_110
374:Project
| <slot 3679> : 3679: mock_110
|
373:OlapScanNode
TABLE: tbl_mock_437
PREAGGREGATION: ON
PREDICATES: 3683: mock_440 = '1', 3679: mock_110 IS NOT NULL, 3681: mock_441 = '1'
partitions=1/1
rollup: tbl_mock_437
tabletRatio=10/10
tabletList=28250,28252,28254,28256,28258,28260,28262,28264,28266,28268
cardinality=1
avgRowSize=3.0
PLAN FRAGMENT 71
OUTPUT EXPRS:
PARTITION: RANDOM
STREAM DATA SINK
EXCHANGE ID: 372
HASH_PARTITIONED: 3670: mock_110
371:Project
| <slot 3665> : 3665: mock_453
| <slot 3666> : 3666: mock_451
| <slot 3668> : 3668: mock_452
| <slot 3669> : 3669: mock_447
| <slot 3670> : 3670: mock_110
|
370:OlapScanNode
TABLE: tbl_mock_444
PREAGGREGATION: ON
PREDICATES: 3670: mock_110 IS NOT NULL, 3666: mock_451 IS NOT NULL, 3671: mock_446 = '0'
partitions=1/1
rollup: tbl_mock_444
tabletRatio=10/10
tabletList=28274,28276,28278,28280,28282,28284,28286,28288,28290,28292
cardinality=1
avgRowSize=6.0
PLAN FRAGMENT 72
OUTPUT EXPRS:
PARTITION: HASH_PARTITIONED: 3160: case
STREAM DATA SINK
EXCHANGE ID: 369
RANDOM
368:NESTLOOP JOIN
| join op: CROSS JOIN
| colocate: false, reason:
|
|----367:EXCHANGE
|
364:Project
| <slot 3160> : 3160: case
| <slot 3161> : 3161: cast
| <slot 3162> : 3162: mock_433
| <slot 3471> : 3471: mock_433
|
363:HASH JOIN
| join op: LEFT SEMI JOIN (BROADCAST)
| colocate: false, reason:
| equal join conjunct: 3471: mock_433 = 3647: mock_355
|
|----362:EXCHANGE
|
358:Project
| <slot 3160> : 3160: case
| <slot 3161> : 3161: cast
| <slot 3162> : 3162: mock_433
| <slot 3471> : 3471: mock_433
|
357:HASH JOIN
| join op: LEFT SEMI JOIN (BROADCAST)
| colocate: false, reason:
| equal join conjunct: 3162: mock_433 = 3558: mock_355
|
|----356:EXCHANGE
|
349:Project
| <slot 3160> : 3160: case
| <slot 3161> : 3161: cast
| <slot 3162> : 3162: mock_433
| <slot 3471> : 3471: mock_433
|
348:HASH JOIN
| join op: LEFT OUTER JOIN (PARTITIONED)
| colocate: false, reason:
| equal join conjunct: 3160: case = 3469: case
|
|----347:EXCHANGE
|
280:EXCHANGE
PLAN FRAGMENT 73
OUTPUT EXPRS:
PARTITION: RANDOM
STREAM DATA SINK
EXCHANGE ID: 367
UNPARTITIONED
366:Project
| <slot 3653> : 3653: mock_110
|
365:OlapScanNode
TABLE: tbl_mock_437
PREAGGREGATION: ON
PREDICATES: 3653: mock_110 IS NOT NULL, 3657: mock_440 = '2', 3655: mock_441 = '1'
partitions=1/1
rollup: tbl_mock_437
tabletRatio=10/10
tabletList=28250,28252,28254,28256,28258,28260,28262,28264,28266,28268
cardinality=1
avgRowSize=3.0
PLAN FRAGMENT 74
OUTPUT EXPRS:
PARTITION: RANDOM
STREAM DATA SINK
EXCHANGE ID: 362
UNPARTITIONED
361:Project
| <slot 3647> : 3639: mock_423
|
360:AGGREGATE (update finalize)
| group by: 3639: mock_423, 3638: mock_110
|
359:OlapScanNode
TABLE: tbl_mock_421
PREAGGREGATION: ON
PREDICATES: 3639: mock_423 IS NOT NULL
partitions=1/1
rollup: tbl_mock_421
tabletRatio=10/10
tabletList=28178,28180,28182,28184,28186,28188,28190,28192,28194,28196
cardinality=1
avgRowSize=2.0
PLAN FRAGMENT 75
OUTPUT EXPRS:
PARTITION: HASH_PARTITIONED: 3522: mock_355, 3474: mock_110
STREAM DATA SINK
EXCHANGE ID: 356
UNPARTITIONED
355:Project
| <slot 3558> : 3522: mock_355
|
354:AGGREGATE (merge finalize)
| group by: 3522: mock_355, 3474: mock_110
|
353:EXCHANGE
PLAN FRAGMENT 76
OUTPUT EXPRS:
PARTITION: RANDOM
STREAM DATA SINK
EXCHANGE ID: 353
HASH_PARTITIONED: 3522: mock_355, 3474: mock_110
352:AGGREGATE (update serialize)
| STREAMING
| group by: 3522: mock_355, 3474: mock_110
|
351:Project
| <slot 3474> : 3474: mock_110
| <slot 3522> : 3522: mock_355
|
350:OlapScanNode
TABLE: tbl_mock_350
PREAGGREGATION: ON
PREDICATES: 3522: mock_355 IS NOT NULL, coalesce(3510: mock_414, '') != 'd'
partitions=1/1
rollup: tbl_mock_350
tabletRatio=10/10
tabletList=28154,28156,28158,28160,28162,28164,28166,28168,28170,28172
cardinality=1
avgRowSize=3.0
PLAN FRAGMENT 77
OUTPUT EXPRS:
PARTITION: RANDOM
STREAM DATA SINK
EXCHANGE ID: 347
HASH_PARTITIONED: 3469: case
281:UNION
|
|----321:EXCHANGE
|
|----346:EXCHANGE
|
301:EXCHANGE
PLAN FRAGMENT 78
OUTPUT EXPRS:
PARTITION: RANDOM
STREAM DATA SINK
EXCHANGE ID: 346
RANDOM
345:Project
| <slot 3365> : 3365: mock_433
| <slot 3467> : date_format(days_add(CAST(date(CAST(3461: case AS DATETIME)) AS DATETIME), 1), '%Y-%m-%d')
|
344:SELECT
| predicates: 3464: row_number() = 1
|
343:ANALYTIC
| functions: [, row_number(), ]
| partition by: 3365: mock_433
| order by: 3461: case DESC
| window: ROWS BETWEEN UNBOUNDED PRECEDING AND CURRENT ROW
|
342:SORT
| order by: <slot 3365> 3365: mock_433 ASC, <slot 3461> 3461: case DESC
| analytic partition by: 3365: mock_433
| offset: 0
|
341:PARTITION-TOP-N
| partition by: 3365: mock_433
| partition limit: 1
| order by: <slot 3365> 3365: mock_433 ASC, <slot 3461> 3461: case DESC
| offset: 0
|
340:Project
| <slot 3365> : 3365: mock_433
| <slot 3461> : if(3366: mock_430 = '2017-01-01', '1970-01-01', 3366: mock_430)
|
339:HASH JOIN
| join op: LEFT SEMI JOIN (BUCKET_SHUFFLE)
| colocate: false, reason:
| equal join conjunct: 3365: mock_433 = 3457: mock_355
|
|----338:EXCHANGE
|
322:OlapScanNode
TABLE: tbl_mock_427
PREAGGREGATION: ON
PREDICATES: if(3366: mock_430 = '2017-01-01', '1970-01-01', 3366: mock_430) > '2021-08-28', 3366: mock_430 >= '2017-01-01'
partitions=1/1
rollup: tbl_mock_427
tabletRatio=10/10
tabletList=28202,28204,28206,28208,28210,28212,28214,28216,28218,28220
cardinality=1
avgRowSize=2.0
PLAN FRAGMENT 79
OUTPUT EXPRS:
PARTITION: HASH_PARTITIONED: 3457: mock_355
STREAM DATA SINK
EXCHANGE ID: 338
BUCKET_SHUFFLE_HASH_PARTITIONED: 3457: mock_355
337:AGGREGATE (merge finalize)
| group by: 3457: mock_355
|
336:EXCHANGE
PLAN FRAGMENT 80
OUTPUT EXPRS:
PARTITION: RANDOM
STREAM DATA SINK
EXCHANGE ID: 336
HASH_PARTITIONED: 3457: mock_355
335:AGGREGATE (update serialize)
| STREAMING
| group by: 3457: mock_355
|
323:UNION
|
|----334:EXCHANGE
|
330:EXCHANGE
PLAN FRAGMENT 81
OUTPUT EXPRS:
PARTITION: RANDOM
STREAM DATA SINK
EXCHANGE ID: 334
RANDOM
333:Project
| <slot 3455> : 3449: mock_423
|
332:AGGREGATE (update finalize)
| group by: 3449: mock_423, 3448: mock_110
|
331:OlapScanNode
TABLE: tbl_mock_421
PREAGGREGATION: ON
PREDICATES: 3449: mock_423 IS NOT NULL
partitions=1/1
rollup: tbl_mock_421
tabletRatio=10/10
tabletList=28178,28180,28182,28184,28186,28188,28190,28192,28194,28196
cardinality=1
avgRowSize=2.0
PLAN FRAGMENT 82
OUTPUT EXPRS:
PARTITION: HASH_PARTITIONED: 3421: mock_355, 3373: mock_110
STREAM DATA SINK
EXCHANGE ID: 330
RANDOM
329:Project
| <slot 3421> : 3421: mock_355
|
328:AGGREGATE (merge finalize)
| group by: 3421: mock_355, 3373: mock_110
|
327:EXCHANGE
PLAN FRAGMENT 83
OUTPUT EXPRS:
PARTITION: RANDOM
STREAM DATA SINK
EXCHANGE ID: 327
HASH_PARTITIONED: 3421: mock_355, 3373: mock_110
326:AGGREGATE (update serialize)
| STREAMING
| group by: 3421: mock_355, 3373: mock_110
|
325:Project
| <slot 3373> : 3373: mock_110
| <slot 3421> : 3421: mock_355
|
324:OlapScanNode
TABLE: tbl_mock_350
PREAGGREGATION: ON
PREDICATES: 3421: mock_355 IS NOT NULL, coalesce(3409: mock_414, '') != 'd'
partitions=1/1
rollup: tbl_mock_350
tabletRatio=10/10
tabletList=28154,28156,28158,28160,28162,28164,28166,28168,28170,28172
cardinality=1
avgRowSize=3.0
PLAN FRAGMENT 84
OUTPUT EXPRS:
PARTITION: RANDOM
STREAM DATA SINK
EXCHANGE ID: 321
RANDOM
320:Project
| <slot 3264> : 3264: mock_433
| <slot 3364> : if(3271: mock_436 = '0', '1970-01-01', date_format(days_add(CAST(date(CAST(3265: mock_430 AS DATETIME)) AS DATETIME), 1), '%Y-%m-%d'))
|
319:HASH JOIN
| join op: LEFT SEMI JOIN (BUCKET_SHUFFLE)
| colocate: false, reason:
| equal join conjunct: 3264: mock_433 = 3357: mock_355
|
|----318:EXCHANGE
|
302:OlapScanNode
TABLE: tbl_mock_435
PREAGGREGATION: ON
PREDICATES: 3265: mock_430 > '2017-01-01', 3271: mock_436 = '0'
partitions=1/1
rollup: tbl_mock_435
tabletRatio=10/10
tabletList=28226,28228,28230,28232,28234,28236,28238,28240,28242,28244
cardinality=1
avgRowSize=3.0
PLAN FRAGMENT 85
OUTPUT EXPRS:
PARTITION: HASH_PARTITIONED: 3357: mock_355
STREAM DATA SINK
EXCHANGE ID: 318
BUCKET_SHUFFLE_HASH_PARTITIONED: 3357: mock_355
317:AGGREGATE (merge finalize)
| group by: 3357: mock_355
|
316:EXCHANGE
PLAN FRAGMENT 86
OUTPUT EXPRS:
PARTITION: RANDOM
STREAM DATA SINK
EXCHANGE ID: 316
HASH_PARTITIONED: 3357: mock_355
315:AGGREGATE (update serialize)
| STREAMING
| group by: 3357: mock_355
|
303:UNION
|
|----314:EXCHANGE
|
310:EXCHANGE
PLAN FRAGMENT 87
OUTPUT EXPRS:
PARTITION: RANDOM
STREAM DATA SINK
EXCHANGE ID: 314
RANDOM
313:Project
| <slot 3355> : 3349: mock_423
|
312:AGGREGATE (update finalize)
| group by: 3349: mock_423, 3348: mock_110
|
311:OlapScanNode
TABLE: tbl_mock_421
PREAGGREGATION: ON
PREDICATES: 3349: mock_423 IS NOT NULL
partitions=1/1
rollup: tbl_mock_421
tabletRatio=10/10
tabletList=28178,28180,28182,28184,28186,28188,28190,28192,28194,28196
cardinality=1
avgRowSize=2.0
PLAN FRAGMENT 88
OUTPUT EXPRS:
PARTITION: HASH_PARTITIONED: 3321: mock_355, 3273: mock_110
STREAM DATA SINK
EXCHANGE ID: 310
RANDOM
309:Project
| <slot 3321> : 3321: mock_355
|
308:AGGREGATE (merge finalize)
| group by: 3321: mock_355, 3273: mock_110
|
307:EXCHANGE
PLAN FRAGMENT 89
OUTPUT EXPRS:
PARTITION: RANDOM
STREAM DATA SINK
EXCHANGE ID: 307
HASH_PARTITIONED: 3321: mock_355, 3273: mock_110
306:AGGREGATE (update serialize)
| STREAMING
| group by: 3321: mock_355, 3273: mock_110
|
305:Project
| <slot 3273> : 3273: mock_110
| <slot 3321> : 3321: mock_355
|
304:OlapScanNode
TABLE: tbl_mock_350
PREAGGREGATION: ON
PREDICATES: 3321: mock_355 IS NOT NULL, coalesce(3309: mock_414, '') != 'd'
partitions=1/1
rollup: tbl_mock_350
tabletRatio=10/10
tabletList=28154,28156,28158,28160,28162,28164,28166,28168,28170,28172
cardinality=1
avgRowSize=3.0
PLAN FRAGMENT 90
OUTPUT EXPRS:
PARTITION: RANDOM
STREAM DATA SINK
EXCHANGE ID: 301
RANDOM
300:Project
| <slot 3164> : 3164: mock_433
| <slot 3260> : if(3165: mock_430 = '2017-01-01', '1970-01-01', 3165: mock_430)
|
299:HASH JOIN
| join op: LEFT SEMI JOIN (BUCKET_SHUFFLE)
| colocate: false, reason:
| equal join conjunct: 3164: mock_433 = 3256: mock_355
|
|----298:EXCHANGE
|
282:OlapScanNode
TABLE: tbl_mock_427
PREAGGREGATION: ON
PREDICATES: 3165: mock_430 >= '2017-01-01'
partitions=1/1
rollup: tbl_mock_427
tabletRatio=10/10
tabletList=28202,28204,28206,28208,28210,28212,28214,28216,28218,28220
cardinality=1
avgRowSize=2.0
PLAN FRAGMENT 91
OUTPUT EXPRS:
PARTITION: HASH_PARTITIONED: 3256: mock_355
STREAM DATA SINK
EXCHANGE ID: 298
BUCKET_SHUFFLE_HASH_PARTITIONED: 3256: mock_355
297:AGGREGATE (merge finalize)
| group by: 3256: mock_355
|
296:EXCHANGE
PLAN FRAGMENT 92
OUTPUT EXPRS:
PARTITION: RANDOM
STREAM DATA SINK
EXCHANGE ID: 296
HASH_PARTITIONED: 3256: mock_355
295:AGGREGATE (update serialize)
| STREAMING
| group by: 3256: mock_355
|
283:UNION
|
|----294:EXCHANGE
|
290:EXCHANGE
PLAN FRAGMENT 93
OUTPUT EXPRS:
PARTITION: RANDOM
STREAM DATA SINK
EXCHANGE ID: 294
RANDOM
293:Project
| <slot 3254> : 3248: mock_423
|
292:AGGREGATE (update finalize)
| group by: 3248: mock_423, 3247: mock_110
|
291:OlapScanNode
TABLE: tbl_mock_421
PREAGGREGATION: ON
PREDICATES: 3248: mock_423 IS NOT NULL
partitions=1/1
rollup: tbl_mock_421
tabletRatio=10/10
tabletList=28178,28180,28182,28184,28186,28188,28190,28192,28194,28196
cardinality=1
avgRowSize=2.0
PLAN FRAGMENT 94
OUTPUT EXPRS:
PARTITION: HASH_PARTITIONED: 3220: mock_355, 3172: mock_110
STREAM DATA SINK
EXCHANGE ID: 290
RANDOM
289:Project
| <slot 3220> : 3220: mock_355
|
288:AGGREGATE (merge finalize)
| group by: 3220: mock_355, 3172: mock_110
|
287:EXCHANGE
PLAN FRAGMENT 95
OUTPUT EXPRS:
PARTITION: RANDOM
STREAM DATA SINK
EXCHANGE ID: 287
HASH_PARTITIONED: 3220: mock_355, 3172: mock_110
286:AGGREGATE (update serialize)
| STREAMING
| group by: 3220: mock_355, 3172: mock_110
|
285:Project
| <slot 3172> : 3172: mock_110
| <slot 3220> : 3220: mock_355
|
284:OlapScanNode
TABLE: tbl_mock_350
PREAGGREGATION: ON
PREDICATES: 3220: mock_355 IS NOT NULL, coalesce(3208: mock_414, '') != 'd'
partitions=1/1
rollup: tbl_mock_350
tabletRatio=10/10
tabletList=28154,28156,28158,28160,28162,28164,28166,28168,28170,28172
cardinality=1
avgRowSize=3.0
PLAN FRAGMENT 96
OUTPUT EXPRS:
PARTITION: RANDOM
STREAM DATA SINK
EXCHANGE ID: 280
HASH_PARTITIONED: 3160: case
214:UNION
|
|----254:EXCHANGE
|
|----279:EXCHANGE
|
234:EXCHANGE
PLAN FRAGMENT 97
OUTPUT EXPRS:
PARTITION: RANDOM
STREAM DATA SINK
EXCHANGE ID: 279
RANDOM
278:Project
| <slot 3056> : 3056: mock_433
| <slot 3158> : date_format(days_add(CAST(date(CAST(3152: case AS DATETIME)) AS DATETIME), 1), '%Y-%m-%d')
| <slot 3159> : '2099-12-31'
|
277:SELECT
| predicates: 3155: row_number() = 1
|
276:ANALYTIC
| functions: [, row_number(), ]
| partition by: 3056: mock_433
| order by: 3152: case DESC
| window: ROWS BETWEEN UNBOUNDED PRECEDING AND CURRENT ROW
|
275:SORT
| order by: <slot 3056> 3056: mock_433 ASC, <slot 3152> 3152: case DESC
| analytic partition by: 3056: mock_433
| offset: 0
|
274:PARTITION-TOP-N
| partition by: 3056: mock_433
| partition limit: 1
| order by: <slot 3056> 3056: mock_433 ASC, <slot 3152> 3152: case DESC
| offset: 0
|
273:Project
| <slot 3056> : 3056: mock_433
| <slot 3152> : if(3057: mock_430 = '2017-01-01', '1970-01-01', 3057: mock_430)
|
272:HASH JOIN
| join op: LEFT SEMI JOIN (BUCKET_SHUFFLE)
| colocate: false, reason:
| equal join conjunct: 3056: mock_433 = 3148: mock_355
|
|----271:EXCHANGE
|
255:OlapScanNode
TABLE: tbl_mock_427
PREAGGREGATION: ON
PREDICATES: 3056: mock_433 IS NOT NULL, if(3057: mock_430 = '2017-01-01', '1970-01-01', 3057: mock_430) > '2021-08-28', 3057: mock_430 >= '2017-01-01'
partitions=1/1
rollup: tbl_mock_427
tabletRatio=10/10
tabletList=28202,28204,28206,28208,28210,28212,28214,28216,28218,28220
cardinality=1
avgRowSize=2.0
PLAN FRAGMENT 98
OUTPUT EXPRS:
PARTITION: HASH_PARTITIONED: 3148: mock_355
STREAM DATA SINK
EXCHANGE ID: 271
BUCKET_SHUFFLE_HASH_PARTITIONED: 3148: mock_355
270:AGGREGATE (merge finalize)
| group by: 3148: mock_355
|
269:EXCHANGE
PLAN FRAGMENT 99
OUTPUT EXPRS:
PARTITION: RANDOM
STREAM DATA SINK
EXCHANGE ID: 269
HASH_PARTITIONED: 3148: mock_355
268:AGGREGATE (update serialize)
| STREAMING
| group by: 3148: mock_355
|
256:UNION
|
|----267:EXCHANGE
|
263:EXCHANGE
PLAN FRAGMENT 100
OUTPUT EXPRS:
PARTITION: RANDOM
STREAM DATA SINK
EXCHANGE ID: 267
RANDOM
266:Project
| <slot 3146> : 3140: mock_423
|
265:AGGREGATE (update finalize)
| group by: 3140: mock_423, 3139: mock_110
|
264:OlapScanNode
TABLE: tbl_mock_421
PREAGGREGATION: ON
PREDICATES: 3140: mock_423 IS NOT NULL
partitions=1/1
rollup: tbl_mock_421
tabletRatio=10/10
tabletList=28178,28180,28182,28184,28186,28188,28190,28192,28194,28196
cardinality=1
avgRowSize=2.0
PLAN FRAGMENT 101
OUTPUT EXPRS:
PARTITION: HASH_PARTITIONED: 3112: mock_355, 3064: mock_110
STREAM DATA SINK
EXCHANGE ID: 263
RANDOM
262:Project
| <slot 3112> : 3112: mock_355
|
261:AGGREGATE (merge finalize)
| group by: 3112: mock_355, 3064: mock_110
|
260:EXCHANGE
PLAN FRAGMENT 102
OUTPUT EXPRS:
PARTITION: RANDOM
STREAM DATA SINK
EXCHANGE ID: 260
HASH_PARTITIONED: 3112: mock_355, 3064: mock_110
259:AGGREGATE (update serialize)
| STREAMING
| group by: 3112: mock_355, 3064: mock_110
|
258:Project
| <slot 3064> : 3064: mock_110
| <slot 3112> : 3112: mock_355
|
257:OlapScanNode
TABLE: tbl_mock_350
PREAGGREGATION: ON
PREDICATES: 3112: mock_355 IS NOT NULL, coalesce(3100: mock_414, '') != 'd'
partitions=1/1
rollup: tbl_mock_350
tabletRatio=10/10
tabletList=28154,28156,28158,28160,28162,28164,28166,28168,28170,28172
cardinality=1
avgRowSize=3.0
PLAN FRAGMENT 103
OUTPUT EXPRS:
PARTITION: RANDOM
STREAM DATA SINK
EXCHANGE ID: 254
RANDOM
253:Project
| <slot 2955> : 2955: mock_433
| <slot 3053> : if(8696: expr, 2956: mock_430, '2099-12-12')
| <slot 3055> : if(8696: expr, '1970-01-01', date_format(days_add(CAST(date(CAST(2956: mock_430 AS DATETIME)) AS DATETIME), 1), '%Y-%m-%d'))
| common expressions:
| <slot 8696> : 2962: mock_436 = '0'
|
252:HASH JOIN
| join op: LEFT SEMI JOIN (BUCKET_SHUFFLE)
| colocate: false, reason:
| equal join conjunct: 2955: mock_433 = 3048: mock_355
|
|----251:EXCHANGE
|
235:OlapScanNode
TABLE: tbl_mock_435
PREAGGREGATION: ON
PREDICATES: 2955: mock_433 IS NOT NULL, 2956: mock_430 > '2017-01-01', 2962: mock_436 = '0'
partitions=1/1
rollup: tbl_mock_435
tabletRatio=10/10
tabletList=28226,28228,28230,28232,28234,28236,28238,28240,28242,28244
cardinality=1
avgRowSize=3.0
PLAN FRAGMENT 104
OUTPUT EXPRS:
PARTITION: HASH_PARTITIONED: 3048: mock_355
STREAM DATA SINK
EXCHANGE ID: 251
BUCKET_SHUFFLE_HASH_PARTITIONED: 3048: mock_355
250:AGGREGATE (merge finalize)
| group by: 3048: mock_355
|
249:EXCHANGE
PLAN FRAGMENT 105
OUTPUT EXPRS:
PARTITION: RANDOM
STREAM DATA SINK
EXCHANGE ID: 249
HASH_PARTITIONED: 3048: mock_355
248:AGGREGATE (update serialize)
| STREAMING
| group by: 3048: mock_355
|
236:UNION
|
|----247:EXCHANGE
|
243:EXCHANGE
PLAN FRAGMENT 106
OUTPUT EXPRS:
PARTITION: RANDOM
STREAM DATA SINK
EXCHANGE ID: 247
RANDOM
246:Project
| <slot 3046> : 3040: mock_423
|
245:AGGREGATE (update finalize)
| group by: 3040: mock_423, 3039: mock_110
|
244:OlapScanNode
TABLE: tbl_mock_421
PREAGGREGATION: ON
PREDICATES: 3040: mock_423 IS NOT NULL
partitions=1/1
rollup: tbl_mock_421
tabletRatio=10/10
tabletList=28178,28180,28182,28184,28186,28188,28190,28192,28194,28196
cardinality=1
avgRowSize=2.0
PLAN FRAGMENT 107
OUTPUT EXPRS:
PARTITION: HASH_PARTITIONED: 3012: mock_355, 2964: mock_110
STREAM DATA SINK
EXCHANGE ID: 243
RANDOM
242:Project
| <slot 3012> : 3012: mock_355
|
241:AGGREGATE (merge finalize)
| group by: 3012: mock_355, 2964: mock_110
|
240:EXCHANGE
PLAN FRAGMENT 108
OUTPUT EXPRS:
PARTITION: RANDOM
STREAM DATA SINK
EXCHANGE ID: 240
HASH_PARTITIONED: 3012: mock_355, 2964: mock_110
239:AGGREGATE (update serialize)
| STREAMING
| group by: 3012: mock_355, 2964: mock_110
|
238:Project
| <slot 2964> : 2964: mock_110
| <slot 3012> : 3012: mock_355
|
237:OlapScanNode
TABLE: tbl_mock_350
PREAGGREGATION: ON
PREDICATES: 3012: mock_355 IS NOT NULL, coalesce(3000: mock_414, '') != 'd'
partitions=1/1
rollup: tbl_mock_350
tabletRatio=10/10
tabletList=28154,28156,28158,28160,28162,28164,28166,28168,28170,28172
cardinality=1
avgRowSize=3.0
PLAN FRAGMENT 109
OUTPUT EXPRS:
PARTITION: RANDOM
STREAM DATA SINK
EXCHANGE ID: 234
RANDOM
233:Project
| <slot 2855> : 2855: mock_433
| <slot 2951> : if(2856: mock_430 = '2017-01-01', '1970-01-01', 2856: mock_430)
| <slot 2954> : date_format(days_add(CAST(date(CAST(2856: mock_430 AS DATETIME)) AS DATETIME), 1), '%Y-%m-%d')
|
232:HASH JOIN
| join op: LEFT SEMI JOIN (BUCKET_SHUFFLE)
| colocate: false, reason:
| equal join conjunct: 2855: mock_433 = 2947: mock_355
|
|----231:EXCHANGE
|
215:OlapScanNode
TABLE: tbl_mock_427
PREAGGREGATION: ON
PREDICATES: 2855: mock_433 IS NOT NULL, 2856: mock_430 >= '2017-01-01'
partitions=1/1
rollup: tbl_mock_427
tabletRatio=10/10
tabletList=28202,28204,28206,28208,28210,28212,28214,28216,28218,28220
cardinality=1
avgRowSize=2.0
PLAN FRAGMENT 110
OUTPUT EXPRS:
PARTITION: HASH_PARTITIONED: 2947: mock_355
STREAM DATA SINK
EXCHANGE ID: 231
BUCKET_SHUFFLE_HASH_PARTITIONED: 2947: mock_355
230:AGGREGATE (merge finalize)
| group by: 2947: mock_355
|
229:EXCHANGE
PLAN FRAGMENT 111
OUTPUT EXPRS:
PARTITION: RANDOM
STREAM DATA SINK
EXCHANGE ID: 229
HASH_PARTITIONED: 2947: mock_355
228:AGGREGATE (update serialize)
| STREAMING
| group by: 2947: mock_355
|
216:UNION
|
|----227:EXCHANGE
|
223:EXCHANGE
PLAN FRAGMENT 112
OUTPUT EXPRS:
PARTITION: RANDOM
STREAM DATA SINK
EXCHANGE ID: 227
RANDOM
226:Project
| <slot 2945> : 2939: mock_423
|
225:AGGREGATE (update finalize)
| group by: 2939: mock_423, 2938: mock_110
|
224:OlapScanNode
TABLE: tbl_mock_421
PREAGGREGATION: ON
PREDICATES: 2939: mock_423 IS NOT NULL
partitions=1/1
rollup: tbl_mock_421
tabletRatio=10/10
tabletList=28178,28180,28182,28184,28186,28188,28190,28192,28194,28196
cardinality=1
avgRowSize=2.0
PLAN FRAGMENT 113
OUTPUT EXPRS:
PARTITION: HASH_PARTITIONED: 2911: mock_355, 2863: mock_110
STREAM DATA SINK
EXCHANGE ID: 223
RANDOM
222:Project
| <slot 2911> : 2911: mock_355
|
221:AGGREGATE (merge finalize)
| group by: 2911: mock_355, 2863: mock_110
|
220:EXCHANGE
PLAN FRAGMENT 114
OUTPUT EXPRS:
PARTITION: RANDOM
STREAM DATA SINK
EXCHANGE ID: 220
HASH_PARTITIONED: 2911: mock_355, 2863: mock_110
219:AGGREGATE (update serialize)
| STREAMING
| group by: 2911: mock_355, 2863: mock_110
|
218:Project
| <slot 2863> : 2863: mock_110
| <slot 2911> : 2911: mock_355
|
217:OlapScanNode
TABLE: tbl_mock_350
PREAGGREGATION: ON
PREDICATES: 2911: mock_355 IS NOT NULL, coalesce(2899: mock_414, '') != 'd'
partitions=1/1
rollup: tbl_mock_350
tabletRatio=10/10
tabletList=28154,28156,28158,28160,28162,28164,28166,28168,28170,28172
cardinality=1
avgRowSize=3.0
PLAN FRAGMENT 115
OUTPUT EXPRS:
PARTITION: HASH_PARTITIONED: 597: mock_109, 598: mock_110
STREAM DATA SINK
EXCHANGE ID: 212
HASH_PARTITIONED: 1: mock_021, 2: mock_110
211:Project
| <slot 1> : 1: mock_021
| <slot 2> : 2: mock_110
| <slot 4> : 4: mock_005
| <slot 15> : 15: mock_003
| <slot 24> : 24: mock_038
| <slot 108> : 108: mock_109
| <slot 2133> : CASE WHEN 30: mock_037 = 'a' THEN 'Advance order' WHEN 30: mock_037 IN ('y', 'l') THEN 'Non-Revenue' ELSE 'Revenue' END
|
210:HASH JOIN
| join op: INNER JOIN (PARTITIONED)
| colocate: false, reason:
| equal join conjunct: 597: mock_109 = 108: mock_109
| equal join conjunct: 598: mock_110 = 2: mock_110
| other join predicates: 22: mock_068 >= 2023: case, 22: mock_068 < coalesce(2024: cast, '2099-12-12')
|
|----209:EXCHANGE
|
186:EXCHANGE
PLAN FRAGMENT 116
OUTPUT EXPRS:
PARTITION: HASH_PARTITIONED: 2: mock_110, 79: mock_017
STREAM DATA SINK
EXCHANGE ID: 209
HASH_PARTITIONED: 108: mock_109, 2: mock_110
208:Project
| <slot 1> : 1: mock_021
| <slot 2> : 2: mock_110
| <slot 4> : 4: mock_005
| <slot 15> : 15: mock_003
| <slot 22> : 22: mock_068
| <slot 24> : 24: mock_038
| <slot 30> : 30: mock_037
| <slot 108> : 108: mock_109
|
207:HASH JOIN
| join op: LEFT OUTER JOIN (PARTITIONED)
| colocate: false, reason:
| equal join conjunct: 2: mock_110 = 559: mock_110
| equal join conjunct: 79: mock_017 = 558: mock_331
|
|----206:EXCHANGE
|
203:EXCHANGE
PLAN FRAGMENT 117
OUTPUT EXPRS:
PARTITION: RANDOM
STREAM DATA SINK
EXCHANGE ID: 206
HASH_PARTITIONED: 559: mock_110, 558: mock_331
205:Project
| <slot 558> : 558: mock_331
| <slot 559> : 559: mock_110
|
204:OlapScanNode
TABLE: tbl_mock_318
PREAGGREGATION: ON
PREDICATES: coalesce(586: mock_347, '') != 'd', 559: mock_110 IS NOT NULL
partitions=1/1
rollup: tbl_mock_318
tabletRatio=10/10
tabletList=28130,28132,28134,28136,28138,28140,28142,28144,28146,28148
cardinality=1
avgRowSize=3.0
PLAN FRAGMENT 118
OUTPUT EXPRS:
PARTITION: RANDOM
STREAM DATA SINK
EXCHANGE ID: 203
HASH_PARTITIONED: 2: mock_110, 79: mock_017
202:Project
| <slot 1> : 1: mock_021
| <slot 2> : 2: mock_110
| <slot 4> : 4: mock_005
| <slot 15> : 15: mock_003
| <slot 22> : 22: mock_068
| <slot 24> : 24: mock_038
| <slot 30> : 30: mock_037
| <slot 79> : 79: mock_017
| <slot 108> : 108: mock_109
|
201:HASH JOIN
| join op: LEFT OUTER JOIN (BUCKET_SHUFFLE)
| colocate: false, reason:
| equal join conjunct: 1: mock_021 = 471: mock_275
| equal join conjunct: 2: mock_110 = 469: mock_110
|
|----200:EXCHANGE
|
194:Project
| <slot 1> : 1: mock_021
| <slot 2> : 2: mock
|
|
REMOVE DOC LABEL
failed to remove label: documentation: HttpError: Label does not exist
|