java.lang.AssertionError: 
PLAN FRAGMENT 0
 OUTPUT EXPRS:8449: count
  PARTITION: UNPARTITIONED

  RESULT SINK

  525: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, 2532: case

  STREAM DATA SINK
    EXCHANGE ID: 525
    UNPARTITIONED

  524:Project
  |  <slot 8449> : 8449: count
  |  limit: 100
  |  
  523:AGGREGATE (merge finalize)
  |  output: count(8449: count)
  |  group by: 24: mock_038, 15: mock_003, 108: mock_109, 4: mock_005, 2: mock_110, 2532: case
  |  limit: 100
  |  
  522:EXCHANGE

PLAN FRAGMENT 2
 OUTPUT EXPRS:
  PARTITION: HASH_PARTITIONED: 2797: mock_275, 2795: mock_110

  STREAM DATA SINK
    EXCHANGE ID: 522
    HASH_PARTITIONED: 24: mock_038, 15: mock_003, 108: mock_109, 4: mock_005, 2: mock_110, 2532: case

  521:AGGREGATE (update serialize)
  |  STREAMING
  |  output: count(1)
  |  group by: 24: mock_038, 15: mock_003, 108: mock_109, 4: mock_005, 2: mock_110, 2532: case
  |  
  520: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 2532> : 2532: case
  |  
  519:HASH JOIN
  |  join op: LEFT OUTER JOIN (BUCKET_SHUFFLE(S))
  |  colocate: false, reason: 
  |  equal join conjunct: 1: mock_021 = 8433: mock_459
  |  equal join conjunct: 2: mock_110 = 8434: mock_110
  |  
  |----518:EXCHANGE
  |    
  315: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 2532> : 2532: case
  |  
  314:HASH JOIN
  |  join op: LEFT OUTER JOIN (BUCKET_SHUFFLE(S))
  |  colocate: false, reason: 
  |  equal join conjunct: 1: mock_021 = 2797: mock_275
  |  equal join conjunct: 2: mock_110 = 2795: mock_110
  |  
  |----313:AGGREGATE (merge finalize)
  |    |  group by: 2797: mock_275, 2795: mock_110
  |    |  
  |    312:EXCHANGE
  |    
  166:EXCHANGE

PLAN FRAGMENT 3
 OUTPUT EXPRS:
  PARTITION: HASH_PARTITIONED: 5972: mock_459, 5967: mock_110, 7187: coalesce

  STREAM DATA SINK
    EXCHANGE ID: 518
    HASH_PARTITIONED: 8433: mock_459, 8434: mock_110

  517:Project
  |  <slot 8433> : 5972: mock_459
  |  <slot 8434> : 5967: mock_110
  |  
  516:AGGREGATE (merge finalize)
  |  group by: 5972: mock_459, 5967: mock_110, 7187: coalesce
  |  
  515:EXCHANGE

PLAN FRAGMENT 4
 OUTPUT EXPRS:
  PARTITION: HASH_PARTITIONED: 7059: mock_433, 7055: mock_110

  STREAM DATA SINK
    EXCHANGE ID: 515
    HASH_PARTITIONED: 5972: mock_459, 5967: mock_110, 7187: coalesce

  514:AGGREGATE (update serialize)
  |  STREAMING
  |  group by: 5972: mock_459, 5967: mock_110, 7187: coalesce
  |  
  513:Project
  |  <slot 5967> : 5967: mock_110
  |  <slot 5972> : 5972: mock_459
  |  <slot 7187> : coalesce(5969: mock_458, '')
  |  
  512:HASH JOIN
  |  join op: INNER JOIN (PARTITIONED)
  |  colocate: false, reason: 
  |  equal join conjunct: 7059: mock_433 = 7063: mock_423
  |  equal join conjunct: 7055: mock_110 = 7062: mock_110
  |  
  |----511:EXCHANGE
  |    
  508:EXCHANGE

PLAN FRAGMENT 5
 OUTPUT EXPRS:
  PARTITION: RANDOM

  STREAM DATA SINK
    EXCHANGE ID: 511
    HASH_PARTITIONED: 7063: mock_423, 7062: mock_110

  510:Project
  |  <slot 7062> : 7062: mock_110
  |  <slot 7063> : 7063: mock_423
  |  
  509:OlapScanNode
     TABLE: tbl_mock_421
     PREAGGREGATION: ON
     PREDICATES: 7062: mock_110 IS NOT NULL, 7065: mock_425 = '1'
     partitions=1/1
     rollup: tbl_mock_421
     tabletRatio=10/10
     tabletList=22706,22708,22710,22712,22714,22716,22718,22720,22722,22724
     cardinality=1
     avgRowSize=3.0

PLAN FRAGMENT 6
 OUTPUT EXPRS:
  PARTITION: HASH_PARTITIONED: 7055: mock_110, 7058: mock_433

  STREAM DATA SINK
    EXCHANGE ID: 508
    HASH_PARTITIONED: 7059: mock_433, 7055: mock_110

  507:Project
  |  <slot 5967> : 5967: mock_110
  |  <slot 5969> : 5969: mock_458
  |  <slot 5972> : 5972: mock_459
  |  <slot 7055> : 7055: mock_110
  |  <slot 7059> : 7059: mock_433
  |  
  506:HASH JOIN
  |  join op: INNER JOIN (BUCKET_SHUFFLE(S))
  |  colocate: false, reason: 
  |  equal join conjunct: 7055: mock_110 = 7154: mock_110
  |  equal join conjunct: 7058: mock_433 = 7153: mock_355
  |  
  |----505:EXCHANGE
  |    
  498:Project
  |  <slot 5967> : 5967: mock_110
  |  <slot 5969> : 5969: mock_458
  |  <slot 5972> : 5972: mock_459
  |  <slot 7055> : 7055: mock_110
  |  <slot 7058> : 7058: mock_433
  |  <slot 7059> : 7059: mock_433
  |  
  497:HASH JOIN
  |  join op: INNER JOIN (PARTITIONED)
  |  colocate: false, reason: 
  |  equal join conjunct: 7055: mock_110 = 6092: mock_110
  |  equal join conjunct: 7058: mock_433 = 6140: mock_355
  |  other join predicates: 5973: mock_464 >= 7056: case, 5973: mock_464 < coalesce(7057: cast, '2099-12-12')
  |  
  |----496:EXCHANGE
  |    
  482:EXCHANGE

PLAN FRAGMENT 7
 OUTPUT EXPRS:
  PARTITION: HASH_PARTITIONED: 7117: mock_355, 7069: mock_110

  STREAM DATA SINK
    EXCHANGE ID: 505
    HASH_PARTITIONED: 7154: mock_110, 7153: mock_355

  504:Project
  |  <slot 7153> : 7117: mock_355
  |  <slot 7154> : 7069: mock_110
  |  
  503:AGGREGATE (merge finalize)
  |  group by: 7117: mock_355, 7069: mock_110
  |  
  502:EXCHANGE

PLAN FRAGMENT 8
 OUTPUT EXPRS:
  PARTITION: RANDOM

  STREAM DATA SINK
    EXCHANGE ID: 502
    HASH_PARTITIONED: 7117: mock_355, 7069: mock_110

  501:AGGREGATE (update serialize)
  |  STREAMING
  |  group by: 7117: mock_355, 7069: mock_110
  |  
  500:Project
  |  <slot 7069> : 7069: mock_110
  |  <slot 7117> : 7117: mock_355
  |  
  499:OlapScanNode
     TABLE: tbl_mock_350
     PREAGGREGATION: ON
     PREDICATES: coalesce(7105: mock_414, '') != 'd'
     partitions=1/1
     rollup: tbl_mock_350
     tabletRatio=10/10
     tabletList=22683,22685,22687,22689,22691,22693,22695,22697,22699,22701
     cardinality=1
     avgRowSize=3.0

PLAN FRAGMENT 9
 OUTPUT EXPRS:
  PARTITION: HASH_PARTITIONED: 5968: mock_463, 5967: mock_110

  STREAM DATA SINK
    EXCHANGE ID: 496
    HASH_PARTITIONED: 6092: mock_110, 6140: mock_355

  495:Project
  |  <slot 5967> : 5967: mock_110
  |  <slot 5969> : 5969: mock_458
  |  <slot 5972> : 5972: mock_459
  |  <slot 5973> : 5973: mock_464
  |  <slot 6092> : 6092: mock_110
  |  <slot 6140> : 6140: mock_355
  |  
  494:HASH JOIN
  |  join op: INNER JOIN (PARTITIONED)
  |  colocate: false, reason: 
  |  equal join conjunct: 5968: mock_463 = 5984: mock_487
  |  equal join conjunct: 5967: mock_110 = 5985: mock_110
  |  
  |----493:EXCHANGE
  |    
  485:EXCHANGE

PLAN FRAGMENT 10
 OUTPUT EXPRS:
  PARTITION: HASH_PARTITIONED: 6027: mock_109, 5985: mock_110

  STREAM DATA SINK
    EXCHANGE ID: 493
    HASH_PARTITIONED: 5984: mock_487, 5985: mock_110

  492:Project
  |  <slot 5984> : 5984: mock_487
  |  <slot 5985> : 5985: mock_110
  |  <slot 6092> : 6092: mock_110
  |  <slot 6140> : 6140: mock_355
  |  
  491:HASH JOIN
  |  join op: INNER JOIN (PARTITIONED)
  |  colocate: false, reason: 
  |  equal join conjunct: 6027: mock_109 = 6091: mock_109
  |  equal join conjunct: 5985: mock_110 = 6092: mock_110
  |  
  |----490:EXCHANGE
  |    
  487:EXCHANGE

PLAN FRAGMENT 11
 OUTPUT EXPRS:
  PARTITION: RANDOM

  STREAM DATA SINK
    EXCHANGE ID: 490
    HASH_PARTITIONED: 6091: mock_109, 6092: mock_110

  489:Project
  |  <slot 6091> : 6091: mock_109
  |  <slot 6092> : 6092: mock_110
  |  <slot 6140> : 6140: mock_355
  |  
  488:OlapScanNode
     TABLE: tbl_mock_350
     PREAGGREGATION: ON
     PREDICATES: coalesce(6128: mock_414, '') != 'd', coalesce(6146: mock_372, '') = '1'
     partitions=1/1
     rollup: tbl_mock_350
     tabletRatio=10/10
     tabletList=22683,22685,22687,22689,22691,22693,22695,22697,22699,22701
     cardinality=1
     avgRowSize=5.0

PLAN FRAGMENT 12
 OUTPUT EXPRS:
  PARTITION: RANDOM

  STREAM DATA SINK
    EXCHANGE ID: 487
    HASH_PARTITIONED: 6027: mock_109, 5985: mock_110

  486:OlapScanNode
     TABLE: tbl_mock_471
     PREAGGREGATION: ON
     partitions=1/1
     rollup: tbl_mock_471
     tabletRatio=10/10
     tabletList=22844,22846,22848,22850,22852,22854,22856,22858,22860,22862
     cardinality=1
     avgRowSize=3.0

PLAN FRAGMENT 13
 OUTPUT EXPRS:
  PARTITION: RANDOM

  STREAM DATA SINK
    EXCHANGE ID: 485
    HASH_PARTITIONED: 5968: mock_463, 5967: mock_110

  484:Project
  |  <slot 5967> : 5967: mock_110
  |  <slot 5968> : 5968: mock_463
  |  <slot 5969> : 5969: mock_458
  |  <slot 5972> : 5972: mock_459
  |  <slot 5973> : 5973: mock_464
  |  
  483:OlapScanNode
     TABLE: tbl_mock_456
     PREAGGREGATION: ON
     PREDICATES: coalesce(5969: mock_458, '') = 'check', 5974: mock_470 LIKE 'incl_sc_ref%', 5969: mock_458 IN ('item', 'check')
     partitions=1/1
     rollup: tbl_mock_456
     tabletRatio=10/10
     tabletList=22821,22823,22825,22827,22829,22831,22833,22835,22837,22839
     cardinality=1
     avgRowSize=6.0

PLAN FRAGMENT 14
 OUTPUT EXPRS:
  PARTITION: RANDOM

  STREAM DATA SINK
    EXCHANGE ID: 482
    HASH_PARTITIONED: 7055: mock_110, 7058: mock_433

  316:UNION
  |  
  |----481:EXCHANGE
  |    
  472:EXCHANGE

PLAN FRAGMENT 15
 OUTPUT EXPRS:
  PARTITION: HASH_PARTITIONED: 7035: mock_110

  STREAM DATA SINK
    EXCHANGE ID: 481
    RANDOM

  480:Project
  |  <slot 7030> : 7030: mock_453
  |  <slot 7031> : 7031: mock_451
  |  <slot 7033> : 7033: mock_452
  |  <slot 7034> : 7034: mock_447
  |  <slot 7035> : 7035: mock_110
  |  
  479:HASH JOIN
  |  join op: INNER JOIN (PARTITIONED)
  |  colocate: false, reason: 
  |  equal join conjunct: 7035: mock_110 = 7044: mock_110
  |  
  |----478:EXCHANGE
  |    
  475:EXCHANGE

PLAN FRAGMENT 16
 OUTPUT EXPRS:
  PARTITION: RANDOM

  STREAM DATA SINK
    EXCHANGE ID: 478
    HASH_PARTITIONED: 7044: mock_110

  477:Project
  |  <slot 7044> : 7044: mock_110
  |  
  476:OlapScanNode
     TABLE: tbl_mock_437
     PREAGGREGATION: ON
     PREDICATES: 7048: mock_440 = '1', 7044: mock_110 IS NOT NULL, 7046: mock_441 = '1'
     partitions=1/1
     rollup: tbl_mock_437
     tabletRatio=10/10
     tabletList=22775,22777,22779,22781,22783,22785,22787,22789,22791,22793
     cardinality=1
     avgRowSize=3.0

PLAN FRAGMENT 17
 OUTPUT EXPRS:
  PARTITION: RANDOM

  STREAM DATA SINK
    EXCHANGE ID: 475
    HASH_PARTITIONED: 7035: mock_110

  474:Project
  |  <slot 7030> : 7030: mock_453
  |  <slot 7031> : 7031: mock_451
  |  <slot 7033> : 7033: mock_452
  |  <slot 7034> : 7034: mock_447
  |  <slot 7035> : 7035: mock_110
  |  
  473:OlapScanNode
     TABLE: tbl_mock_444
     PREAGGREGATION: ON
     PREDICATES: 7035: mock_110 IS NOT NULL, 7031: mock_451 IS NOT NULL, 7036: mock_446 = '0'
     partitions=1/1
     rollup: tbl_mock_444
     tabletRatio=10/10
     tabletList=22798,22800,22802,22804,22806,22808,22810,22812,22814,22816
     cardinality=1
     avgRowSize=6.0

PLAN FRAGMENT 18
 OUTPUT EXPRS:
  PARTITION: HASH_PARTITIONED: 6525: case

  STREAM DATA SINK
    EXCHANGE ID: 472
    RANDOM

  471:NESTLOOP JOIN
  |  join op: CROSS JOIN
  |  colocate: false, reason: 
  |  
  |----470:EXCHANGE
  |    
  467:Project
  |  <slot 6525> : 6525: case
  |  <slot 6526> : 6526: cast
  |  <slot 6527> : 6527: mock_433
  |  <slot 6836> : 6836: mock_433
  |  
  466:HASH JOIN
  |  join op: LEFT SEMI JOIN (BROADCAST)
  |  colocate: false, reason: 
  |  equal join conjunct: 6836: mock_433 = 7012: mock_355
  |  
  |----465:EXCHANGE
  |    
  461:Project
  |  <slot 6525> : 6525: case
  |  <slot 6526> : 6526: cast
  |  <slot 6527> : 6527: mock_433
  |  <slot 6836> : 6836: mock_433
  |  
  460:HASH JOIN
  |  join op: LEFT SEMI JOIN (BROADCAST)
  |  colocate: false, reason: 
  |  equal join conjunct: 6527: mock_433 = 6923: mock_355
  |  
  |----459:EXCHANGE
  |    
  452:Project
  |  <slot 6525> : 6525: case
  |  <slot 6526> : 6526: cast
  |  <slot 6527> : 6527: mock_433
  |  <slot 6836> : 6836: mock_433
  |  
  451:HASH JOIN
  |  join op: LEFT OUTER JOIN (PARTITIONED)
  |  colocate: false, reason: 
  |  equal join conjunct: 6525: case = 6834: case
  |  
  |----450:EXCHANGE
  |    
  383:EXCHANGE

PLAN FRAGMENT 19
 OUTPUT EXPRS:
  PARTITION: RANDOM

  STREAM DATA SINK
    EXCHANGE ID: 470
    UNPARTITIONED

  469:Project
  |  <slot 7018> : 7018: mock_110
  |  
  468:OlapScanNode
     TABLE: tbl_mock_437
     PREAGGREGATION: ON
     PREDICATES: 7018: mock_110 IS NOT NULL, 7022: mock_440 = '2', 7020: mock_441 = '1'
     partitions=1/1
     rollup: tbl_mock_437
     tabletRatio=10/10
     tabletList=22775,22777,22779,22781,22783,22785,22787,22789,22791,22793
     cardinality=1
     avgRowSize=3.0

PLAN FRAGMENT 20
 OUTPUT EXPRS:
  PARTITION: RANDOM

  STREAM DATA SINK
    EXCHANGE ID: 465
    UNPARTITIONED

  464:Project
  |  <slot 7012> : 7004: mock_423
  |  
  463:AGGREGATE (update finalize)
  |  group by: 7004: mock_423, 7003: mock_110
  |  
  462:OlapScanNode
     TABLE: tbl_mock_421
     PREAGGREGATION: ON
     PREDICATES: 7004: mock_423 IS NOT NULL
     partitions=1/1
     rollup: tbl_mock_421
     tabletRatio=10/10
     tabletList=22706,22708,22710,22712,22714,22716,22718,22720,22722,22724
     cardinality=1
     avgRowSize=2.0

PLAN FRAGMENT 21
 OUTPUT EXPRS:
  PARTITION: HASH_PARTITIONED: 6887: mock_355, 6839: mock_110

  STREAM DATA SINK
    EXCHANGE ID: 459
    UNPARTITIONED

  458:Project
  |  <slot 6923> : 6887: mock_355
  |  
  457:AGGREGATE (merge finalize)
  |  group by: 6887: mock_355, 6839: mock_110
  |  
  456:EXCHANGE

PLAN FRAGMENT 22
 OUTPUT EXPRS:
  PARTITION: RANDOM

  STREAM DATA SINK
    EXCHANGE ID: 456
    HASH_PARTITIONED: 6887: mock_355, 6839: mock_110

  455:AGGREGATE (update serialize)
  |  STREAMING
  |  group by: 6887: mock_355, 6839: mock_110
  |  
  454:Project
  |  <slot 6839> : 6839: mock_110
  |  <slot 6887> : 6887: mock_355
  |  
  453:OlapScanNode
     TABLE: tbl_mock_350
     PREAGGREGATION: ON
     PREDICATES: 6887: mock_355 IS NOT NULL, coalesce(6875: mock_414, '') != 'd'
     partitions=1/1
     rollup: tbl_mock_350
     tabletRatio=10/10
     tabletList=22683,22685,22687,22689,22691,22693,22695,22697,22699,22701
     cardinality=1
     avgRowSize=3.0

PLAN FRAGMENT 23
 OUTPUT EXPRS:
  PARTITION: RANDOM

  STREAM DATA SINK
    EXCHANGE ID: 450
    HASH_PARTITIONED: 6834: case

  384:UNION
  |  
  |----424:EXCHANGE
  |    
  |----449:EXCHANGE
  |    
  404:EXCHANGE

PLAN FRAGMENT 24
 OUTPUT EXPRS:
  PARTITION: RANDOM

  STREAM DATA SINK
    EXCHANGE ID: 449
    RANDOM

  448:Project
  |  <slot 6730> : 6730: mock_433
  |  <slot 6832> : date_format(days_add(CAST(date(CAST(6826: case AS DATETIME)) AS DATETIME), 1), '%Y-%m-%d')
  |  
  447:SELECT
  |  predicates: 6829: row_number() = 1
  |  
  446:ANALYTIC
  |  functions: [, row_number(), ]
  |  partition by: 6730: mock_433
  |  order by: 6826: case DESC
  |  window: ROWS BETWEEN UNBOUNDED PRECEDING AND CURRENT ROW
  |  
  445:SORT
  |  order by: <slot 6730> 6730: mock_433 ASC, <slot 6826> 6826: case DESC
  |  analytic partition by: 6730: mock_433
  |  offset: 0
  |  
  444:PARTITION-TOP-N
  |  partition by: 6730: mock_433 
  |  partition limit: 1
  |  order by: <slot 6730> 6730: mock_433 ASC, <slot 6826> 6826: case DESC
  |  offset: 0
  |  
  443:Project
  |  <slot 6730> : 6730: mock_433
  |  <slot 6826> : if(6731: mock_430 = '2017-01-01', '1970-01-01', 6731: mock_430)
  |  
  442:HASH JOIN
  |  join op: LEFT SEMI JOIN (BUCKET_SHUFFLE)
  |  colocate: false, reason: 
  |  equal join conjunct: 6730: mock_433 = 6822: mock_355
  |  
  |----441:EXCHANGE
  |    
  425:OlapScanNode
     TABLE: tbl_mock_427
     PREAGGREGATION: ON
     PREDICATES: if(6731: mock_430 = '2017-01-01', '1970-01-01', 6731: mock_430) > '2021-08-28', 6731: mock_430 >= '2017-01-01'
     partitions=1/1
     rollup: tbl_mock_427
     tabletRatio=10/10
     tabletList=22729,22731,22733,22735,22737,22739,22741,22743,22745,22747
     cardinality=1
     avgRowSize=2.0

PLAN FRAGMENT 25
 OUTPUT EXPRS:
  PARTITION: HASH_PARTITIONED: 6822: mock_355

  STREAM DATA SINK
    EXCHANGE ID: 441
    BUCKET_SHUFFLE_HASH_PARTITIONED: 6822: mock_355

  440:AGGREGATE (merge finalize)
  |  group by: 6822: mock_355
  |  
  439:EXCHANGE

PLAN FRAGMENT 26
 OUTPUT EXPRS:
  PARTITION: RANDOM

  STREAM DATA SINK
    EXCHANGE ID: 439
    HASH_PARTITIONED: 6822: mock_355

  438:AGGREGATE (update serialize)
  |  STREAMING
  |  group by: 6822: mock_355
  |  
  426:UNION
  |  
  |----437:EXCHANGE
  |    
  433:EXCHANGE

PLAN FRAGMENT 27
 OUTPUT EXPRS:
  PARTITION: RANDOM

  STREAM DATA SINK
    EXCHANGE ID: 437
    RANDOM

  436:Project
  |  <slot 6820> : 6814: mock_423
  |  
  435:AGGREGATE (update finalize)
  |  group by: 6814: mock_423, 6813: mock_110
  |  
  434:OlapScanNode
     TABLE: tbl_mock_421
     PREAGGREGATION: ON
     PREDICATES: 6814: mock_423 IS NOT NULL
     partitions=1/1
     rollup: tbl_mock_421
     tabletRatio=10/10
     tabletList=22706,22708,22710,22712,22714,22716,22718,22720,22722,22724
     cardinality=1
     avgRowSize=2.0

PLAN FRAGMENT 28
 OUTPUT EXPRS:
  PARTITION: HASH_PARTITIONED: 6786: mock_355, 6738: mock_110

  STREAM DATA SINK
    EXCHANGE ID: 433
    RANDOM

  432:Project
  |  <slot 6786> : 6786: mock_355
  |  
  431:AGGREGATE (merge finalize)
  |  group by: 6786: mock_355, 6738: mock_110
  |  
  430:EXCHANGE

PLAN FRAGMENT 29
 OUTPUT EXPRS:
  PARTITION: RANDOM

  STREAM DATA SINK
    EXCHANGE ID: 430
    HASH_PARTITIONED: 6786: mock_355, 6738: mock_110

  429:AGGREGATE (update serialize)
  |  STREAMING
  |  group by: 6786: mock_355, 6738: mock_110
  |  
  428:Project
  |  <slot 6738> : 6738: mock_110
  |  <slot 6786> : 6786: mock_355
  |  
  427:OlapScanNode
     TABLE: tbl_mock_350
     PREAGGREGATION: ON
     PREDICATES: 6786: mock_355 IS NOT NULL, coalesce(6774: mock_414, '') != 'd'
     partitions=1/1
     rollup: tbl_mock_350
     tabletRatio=10/10
     tabletList=22683,22685,22687,22689,22691,22693,22695,22697,22699,22701
     cardinality=1
     avgRowSize=3.0

PLAN FRAGMENT 30
 OUTPUT EXPRS:
  PARTITION: RANDOM

  STREAM DATA SINK
    EXCHANGE ID: 424
    RANDOM

  423:Project
  |  <slot 6629> : 6629: mock_433
  |  <slot 6729> : if(6636: mock_436 = '0', '1970-01-01', date_format(days_add(CAST(date(CAST(6630: mock_430 AS DATETIME)) AS DATETIME), 1), '%Y-%m-%d'))
  |  
  422:HASH JOIN
  |  join op: LEFT SEMI JOIN (BUCKET_SHUFFLE)
  |  colocate: false, reason: 
  |  equal join conjunct: 6629: mock_433 = 6722: mock_355
  |  
  |----421:EXCHANGE
  |    
  405:OlapScanNode
     TABLE: tbl_mock_435
     PREAGGREGATION: ON
     PREDICATES: 6630: mock_430 > '2017-01-01', 6636: mock_436 = '0'
     partitions=1/1
     rollup: tbl_mock_435
     tabletRatio=10/10
     tabletList=22752,22754,22756,22758,22760,22762,22764,22766,22768,22770
     cardinality=1
     avgRowSize=3.0

PLAN FRAGMENT 31
 OUTPUT EXPRS:
  PARTITION: HASH_PARTITIONED: 6722: mock_355

  STREAM DATA SINK
    EXCHANGE ID: 421
    BUCKET_SHUFFLE_HASH_PARTITIONED: 6722: mock_355

  420:AGGREGATE (merge finalize)
  |  group by: 6722: mock_355
  |  
  419:EXCHANGE

PLAN FRAGMENT 32
 OUTPUT EXPRS:
  PARTITION: RANDOM

  STREAM DATA SINK
    EXCHANGE ID: 419
    HASH_PARTITIONED: 6722: mock_355

  418:AGGREGATE (update serialize)
  |  STREAMING
  |  group by: 6722: mock_355
  |  
  406:UNION
  |  
  |----417:EXCHANGE
  |    
  413:EXCHANGE

PLAN FRAGMENT 33
 OUTPUT EXPRS:
  PARTITION: RANDOM

  STREAM DATA SINK
    EXCHANGE ID: 417
    RANDOM

  416:Project
  |  <slot 6720> : 6714: mock_423
  |  
  415:AGGREGATE (update finalize)
  |  group by: 6714: mock_423, 6713: mock_110
  |  
  414:OlapScanNode
     TABLE: tbl_mock_421
     PREAGGREGATION: ON
     PREDICATES: 6714: mock_423 IS NOT NULL
     partitions=1/1
     rollup: tbl_mock_421
     tabletRatio=10/10
     tabletList=22706,22708,22710,22712,22714,22716,22718,22720,22722,22724
     cardinality=1
     avgRowSize=2.0

PLAN FRAGMENT 34
 OUTPUT EXPRS:
  PARTITION: HASH_PARTITIONED: 6686: mock_355, 6638: mock_110

  STREAM DATA SINK
    EXCHANGE ID: 413
    RANDOM

  412:Project
  |  <slot 6686> : 6686: mock_355
  |  
  411:AGGREGATE (merge finalize)
  |  group by: 6686: mock_355, 6638: mock_110
  |  
  410:EXCHANGE

PLAN FRAGMENT 35
 OUTPUT EXPRS:
  PARTITION: RANDOM

  STREAM DATA SINK
    EXCHANGE ID: 410
    HASH_PARTITIONED: 6686: mock_355, 6638: mock_110

  409:AGGREGATE (update serialize)
  |  STREAMING
  |  group by: 6686: mock_355, 6638: mock_110
  |  
  408:Project
  |  <slot 6638> : 6638: mock_110
  |  <slot 6686> : 6686: mock_355
  |  
  407:OlapScanNode
     TABLE: tbl_mock_350
     PREAGGREGATION: ON
     PREDICATES: 6686: mock_355 IS NOT NULL, coalesce(6674: mock_414, '') != 'd'
     partitions=1/1
     rollup: tbl_mock_350
     tabletRatio=10/10
     tabletList=22683,22685,22687,22689,22691,22693,22695,22697,22699,22701
     cardinality=1
     avgRowSize=3.0

PLAN FRAGMENT 36
 OUTPUT EXPRS:
  PARTITION: RANDOM

  STREAM DATA SINK
    EXCHANGE ID: 404
    RANDOM

  403:Project
  |  <slot 6529> : 6529: mock_433
  |  <slot 6625> : if(6530: mock_430 = '2017-01-01', '1970-01-01', 6530: mock_430)
  |  
  402:HASH JOIN
  |  join op: LEFT SEMI JOIN (BUCKET_SHUFFLE)
  |  colocate: false, reason: 
  |  equal join conjunct: 6529: mock_433 = 6621: mock_355
  |  
  |----401:EXCHANGE
  |    
  385:OlapScanNode
     TABLE: tbl_mock_427
     PREAGGREGATION: ON
     PREDICATES: 6530: mock_430 >= '2017-01-01'
     partitions=1/1
     rollup: tbl_mock_427
     tabletRatio=10/10
     tabletList=22729,22731,22733,22735,22737,22739,22741,22743,22745,22747
     cardinality=1
     avgRowSize=2.0

PLAN FRAGMENT 37
 OUTPUT EXPRS:
  PARTITION: HASH_PARTITIONED: 6621: mock_355

  STREAM DATA SINK
    EXCHANGE ID: 401
    BUCKET_SHUFFLE_HASH_PARTITIONED: 6621: mock_355

  400:AGGREGATE (merge finalize)
  |  group by: 6621: mock_355
  |  
  399:EXCHANGE

PLAN FRAGMENT 38
 OUTPUT EXPRS:
  PARTITION: RANDOM

  STREAM DATA SINK
    EXCHANGE ID: 399
    HASH_PARTITIONED: 6621: mock_355

  398:AGGREGATE (update serialize)
  |  STREAMING
  |  group by: 6621: mock_355
  |  
  386:UNION
  |  
  |----397:EXCHANGE
  |    
  393:EXCHANGE

PLAN FRAGMENT 39
 OUTPUT EXPRS:
  PARTITION: RANDOM

  STREAM DATA SINK
    EXCHANGE ID: 397
    RANDOM

  396:Project
  |  <slot 6619> : 6613: mock_423
  |  
  395:AGGREGATE (update finalize)
  |  group by: 6613: mock_423, 6612: mock_110
  |  
  394:OlapScanNode
     TABLE: tbl_mock_421
     PREAGGREGATION: ON
     PREDICATES: 6613: mock_423 IS NOT NULL
     partitions=1/1
     rollup: tbl_mock_421
     tabletRatio=10/10
     tabletList=22706,22708,22710,22712,22714,22716,22718,22720,22722,22724
     cardinality=1
     avgRowSize=2.0

PLAN FRAGMENT 40
 OUTPUT EXPRS:
  PARTITION: HASH_PARTITIONED: 6585: mock_355, 6537: mock_110

  STREAM DATA SINK
    EXCHANGE ID: 393
    RANDOM

  392:Project
  |  <slot 6585> : 6585: mock_355
  |  
  391:AGGREGATE (merge finalize)
  |  group by: 6585: mock_355, 6537: mock_110
  |  
  390:EXCHANGE

PLAN FRAGMENT 41
 OUTPUT EXPRS:
  PARTITION: RANDOM

  STREAM DATA SINK
    EXCHANGE ID: 390
    HASH_PARTITIONED: 6585: mock_355, 6537: mock_110

  389:AGGREGATE (update serialize)
  |  STREAMING
  |  group by: 6585: mock_355, 6537: mock_110
  |  
  388:Project
  |  <slot 6537> : 6537: mock_110
  |  <slot 6585> : 6585: mock_355
  |  
  387:OlapScanNode
     TABLE: tbl_mock_350
     PREAGGREGATION: ON
     PREDICATES: 6585: mock_355 IS NOT NULL, coalesce(6573: mock_414, '') != 'd'
     partitions=1/1
     rollup: tbl_mock_350
     tabletRatio=10/10
     tabletList=22683,22685,22687,22689,22691,22693,22695,22697,22699,22701
     cardinality=1
     avgRowSize=3.0

PLAN FRAGMENT 42
 OUTPUT EXPRS:
  PARTITION: RANDOM

  STREAM DATA SINK
    EXCHANGE ID: 383
    HASH_PARTITIONED: 6525: case

  317:UNION
  |  
  |----357:EXCHANGE
  |    
  |----382:EXCHANGE
  |    
  337:EXCHANGE

PLAN FRAGMENT 43
 OUTPUT EXPRS:
  PARTITION: RANDOM

  STREAM DATA SINK
    EXCHANGE ID: 382
    RANDOM

  381:Project
  |  <slot 6421> : 6421: mock_433
  |  <slot 6523> : date_format(days_add(CAST(date(CAST(6517: case AS DATETIME)) AS DATETIME), 1), '%Y-%m-%d')
  |  <slot 6524> : '2099-12-31'
  |  
  380:SELECT
  |  predicates: 6520: row_number() = 1
  |  
  379:ANALYTIC
  |  functions: [, row_number(), ]
  |  partition by: 6421: mock_433
  |  order by: 6517: case DESC
  |  window: ROWS BETWEEN UNBOUNDED PRECEDING AND CURRENT ROW
  |  
  378:SORT
  |  order by: <slot 6421> 6421: mock_433 ASC, <slot 6517> 6517: case DESC
  |  analytic partition by: 6421: mock_433
  |  offset: 0
  |  
  377:PARTITION-TOP-N
  |  partition by: 6421: mock_433 
  |  partition limit: 1
  |  order by: <slot 6421> 6421: mock_433 ASC, <slot 6517> 6517: case DESC
  |  offset: 0
  |  
  376:Project
  |  <slot 6421> : 6421: mock_433
  |  <slot 6517> : if(6422: mock_430 = '2017-01-01', '1970-01-01', 6422: mock_430)
  |  
  375:HASH JOIN
  |  join op: LEFT SEMI JOIN (BUCKET_SHUFFLE)
  |  colocate: false, reason: 
  |  equal join conjunct: 6421: mock_433 = 6513: mock_355
  |  
  |----374:EXCHANGE
  |    
  358:OlapScanNode
     TABLE: tbl_mock_427
     PREAGGREGATION: ON
     PREDICATES: 6421: mock_433 IS NOT NULL, if(6422: mock_430 = '2017-01-01', '1970-01-01', 6422: mock_430) > '2021-08-28', 6422: mock_430 >= '2017-01-01'
     partitions=1/1
     rollup: tbl_mock_427
     tabletRatio=10/10
     tabletList=22729,22731,22733,22735,22737,22739,22741,22743,22745,22747
     cardinality=1
     avgRowSize=2.0

PLAN FRAGMENT 44
 OUTPUT EXPRS:
  PARTITION: HASH_PARTITIONED: 6513: mock_355

  STREAM DATA SINK
    EXCHANGE ID: 374
    BUCKET_SHUFFLE_HASH_PARTITIONED: 6513: mock_355

  373:AGGREGATE (merge finalize)
  |  group by: 6513: mock_355
  |  
  372:EXCHANGE

PLAN FRAGMENT 45
 OUTPUT EXPRS:
  PARTITION: RANDOM

  STREAM DATA SINK
    EXCHANGE ID: 372
    HASH_PARTITIONED: 6513: mock_355

  371:AGGREGATE (update serialize)
  |  STREAMING
  |  group by: 6513: mock_355
  |  
  359:UNION
  |  
  |----370:EXCHANGE
  |    
  366:EXCHANGE

PLAN FRAGMENT 46
 OUTPUT EXPRS:
  PARTITION: RANDOM

  STREAM DATA SINK
    EXCHANGE ID: 370
    RANDOM

  369:Project
  |  <slot 6511> : 6505: mock_423
  |  
  368:AGGREGATE (update finalize)
  |  group by: 6505: mock_423, 6504: mock_110
  |  
  367:OlapScanNode
     TABLE: tbl_mock_421
     PREAGGREGATION: ON
     PREDICATES: 6505: mock_423 IS NOT NULL
     partitions=1/1
     rollup: tbl_mock_421
     tabletRatio=10/10
     tabletList=22706,22708,22710,22712,22714,22716,22718,22720,22722,22724
     cardinality=1
     avgRowSize=2.0

PLAN FRAGMENT 47
 OUTPUT EXPRS:
  PARTITION: HASH_PARTITIONED: 6477: mock_355, 6429: mock_110

  STREAM DATA SINK
    EXCHANGE ID: 366
    RANDOM

  365:Project
  |  <slot 6477> : 6477: mock_355
  |  
  364:AGGREGATE (merge finalize)
  |  group by: 6477: mock_355, 6429: mock_110
  |  
  363:EXCHANGE

PLAN FRAGMENT 48
 OUTPUT EXPRS:
  PARTITION: RANDOM

  STREAM DATA SINK
    EXCHANGE ID: 363
    HASH_PARTITIONED: 6477: mock_355, 6429: mock_110

  362:AGGREGATE (update serialize)
  |  STREAMING
  |  group by: 6477: mock_355, 6429: mock_110
  |  
  361:Project
  |  <slot 6429> : 6429: mock_110
  |  <slot 6477> : 6477: mock_355
  |  
  360:OlapScanNode
     TABLE: tbl_mock_350
     PREAGGREGATION: ON
     PREDICATES: 6477: mock_355 IS NOT NULL, coalesce(6465: mock_414, '') != 'd'
     partitions=1/1
     rollup: tbl_mock_350
     tabletRatio=10/10
     tabletList=22683,22685,22687,22689,22691,22693,22695,22697,22699,22701
     cardinality=1
     avgRowSize=3.0

PLAN FRAGMENT 49
 OUTPUT EXPRS:
  PARTITION: RANDOM

  STREAM DATA SINK
    EXCHANGE ID: 357
    RANDOM

  356:Project
  |  <slot 6320> : 6320: mock_433
  |  <slot 6418> : if(8452: expr, 6321: mock_430, '2099-12-12')
  |  <slot 6420> : if(8452: expr, '1970-01-01', date_format(days_add(CAST(date(CAST(6321: mock_430 AS DATETIME)) AS DATETIME), 1), '%Y-%m-%d'))
  |  common expressions:
  |  <slot 8452> : 6327: mock_436 = '0'
  |  
  355:HASH JOIN
  |  join op: LEFT SEMI JOIN (BUCKET_SHUFFLE)
  |  colocate: false, reason: 
  |  equal join conjunct: 6320: mock_433 = 6413: mock_355
  |  
  |----354:EXCHANGE
  |    
  338:OlapScanNode
     TABLE: tbl_mock_435
     PREAGGREGATION: ON
     PREDICATES: 6320: mock_433 IS NOT NULL, 6321: mock_430 > '2017-01-01', 6327: mock_436 = '0'
     partitions=1/1
     rollup: tbl_mock_435
     tabletRatio=10/10
     tabletList=22752,22754,22756,22758,22760,22762,22764,22766,22768,22770
     cardinality=1
     avgRowSize=3.0

PLAN FRAGMENT 50
 OUTPUT EXPRS:
  PARTITION: HASH_PARTITIONED: 6413: mock_355

  STREAM DATA SINK
    EXCHANGE ID: 354
    BUCKET_SHUFFLE_HASH_PARTITIONED: 6413: mock_355

  353:AGGREGATE (merge finalize)
  |  group by: 6413: mock_355
  |  
  352:EXCHANGE

PLAN FRAGMENT 51
 OUTPUT EXPRS:
  PARTITION: RANDOM

  STREAM DATA SINK
    EXCHANGE ID: 352
    HASH_PARTITIONED: 6413: mock_355

  351:AGGREGATE (update serialize)
  |  STREAMING
  |  group by: 6413: mock_355
  |  
  339:UNION
  |  
  |----350:EXCHANGE
  |    
  346:EXCHANGE

PLAN FRAGMENT 52
 OUTPUT EXPRS:
  PARTITION: RANDOM

  STREAM DATA SINK
    EXCHANGE ID: 350
    RANDOM

  349:Project
  |  <slot 6411> : 6405: mock_423
  |  
  348:AGGREGATE (update finalize)
  |  group by: 6405: mock_423, 6404: mock_110
  |  
  347:OlapScanNode
     TABLE: tbl_mock_421
     PREAGGREGATION: ON
     PREDICATES: 6405: mock_423 IS NOT NULL
     partitions=1/1
     rollup: tbl_mock_421
     tabletRatio=10/10
     tabletList=22706,22708,22710,22712,22714,22716,22718,22720,22722,22724
     cardinality=1
     avgRowSize=2.0

PLAN FRAGMENT 53
 OUTPUT EXPRS:
  PARTITION: HASH_PARTITIONED: 6377: mock_355, 6329: mock_110

  STREAM DATA SINK
    EXCHANGE ID: 346
    RANDOM

  345:Project
  |  <slot 6377> : 6377: mock_355
  |  
  344:AGGREGATE (merge finalize)
  |  group by: 6377: mock_355, 6329: mock_110
  |  
  343:EXCHANGE

PLAN FRAGMENT 54
 OUTPUT EXPRS:
  PARTITION: RANDOM

  STREAM DATA SINK
    EXCHANGE ID: 343
    HASH_PARTITIONED: 6377: mock_355, 6329: mock_110

  342:AGGREGATE (update serialize)
  |  STREAMING
  |  group by: 6377: mock_355, 6329: mock_110
  |  
  341:Project
  |  <slot 6329> : 6329: mock_110
  |  <slot 6377> : 6377: mock_355
  |  
  340:OlapScanNode
     TABLE: tbl_mock_350
     PREAGGREGATION: ON
     PREDICATES: 6377: mock_355 IS NOT NULL, coalesce(6365: mock_414, '') != 'd'
     partitions=1/1
     rollup: tbl_mock_350
     tabletRatio=10/10
     tabletList=22683,22685,22687,22689,22691,22693,22695,22697,22699,22701
     cardinality=1
     avgRowSize=3.0

PLAN FRAGMENT 55
 OUTPUT EXPRS:
  PARTITION: RANDOM

  STREAM DATA SINK
    EXCHANGE ID: 337
    RANDOM

  336:Project
  |  <slot 6220> : 6220: mock_433
  |  <slot 6316> : if(6221: mock_430 = '2017-01-01', '1970-01-01', 6221: mock_430)
  |  <slot 6319> : date_format(days_add(CAST(date(CAST(6221: mock_430 AS DATETIME)) AS DATETIME), 1), '%Y-%m-%d')
  |  
  335:HASH JOIN
  |  join op: LEFT SEMI JOIN (BUCKET_SHUFFLE)
  |  colocate: false, reason: 
  |  equal join conjunct: 6220: mock_433 = 6312: mock_355
  |  
  |----334:EXCHANGE
  |    
  318:OlapScanNode
     TABLE: tbl_mock_427
     PREAGGREGATION: ON
     PREDICATES: 6220: mock_433 IS NOT NULL, 6221: mock_430 >= '2017-01-01'
     partitions=1/1
     rollup: tbl_mock_427
     tabletRatio=10/10
     tabletList=22729,22731,22733,22735,22737,22739,22741,22743,22745,22747
     cardinality=1
     avgRowSize=2.0

PLAN FRAGMENT 56
 OUTPUT EXPRS:
  PARTITION: HASH_PARTITIONED: 6312: mock_355

  STREAM DATA SINK
    EXCHANGE ID: 334
    BUCKET_SHUFFLE_HASH_PARTITIONED: 6312: mock_355

  333:AGGREGATE (merge finalize)
  |  group by: 6312: mock_355
  |  
  332:EXCHANGE

PLAN FRAGMENT 57
 OUTPUT EXPRS:
  PARTITION: RANDOM

  STREAM DATA SINK
    EXCHANGE ID: 332
    HASH_PARTITIONED: 6312: mock_355

  331:AGGREGATE (update serialize)
  |  STREAMING
  |  group by: 6312: mock_355
  |  
  319:UNION
  |  
  |----330:EXCHANGE
  |    
  326:EXCHANGE

PLAN FRAGMENT 58
 OUTPUT EXPRS:
  PARTITION: RANDOM

  STREAM DATA SINK
    EXCHANGE ID: 330
    RANDOM

  329:Project
  |  <slot 6310> : 6304: mock_423
  |  
  328:AGGREGATE (update finalize)
  |  group by: 6304: mock_423, 6303: mock_110
  |  
  327:OlapScanNode
     TABLE: tbl_mock_421
     PREAGGREGATION: ON
     PREDICATES: 6304: mock_423 IS NOT NULL
     partitions=1/1
     rollup: tbl_mock_421
     tabletRatio=10/10
     tabletList=22706,22708,22710,22712,22714,22716,22718,22720,22722,22724
     cardinality=1
     avgRowSize=2.0

PLAN FRAGMENT 59
 OUTPUT EXPRS:
  PARTITION: HASH_PARTITIONED: 6276: mock_355, 6228: mock_110

  STREAM DATA SINK
    EXCHANGE ID: 326
    RANDOM

  325:Project
  |  <slot 6276> : 6276: mock_355
  |  
  324:AGGREGATE (merge finalize)
  |  group by: 6276: mock_355, 6228: mock_110
  |  
  323:EXCHANGE

PLAN FRAGMENT 60
 OUTPUT EXPRS:
  PARTITION: RANDOM

  STREAM DATA SINK
    EXCHANGE ID: 323
    HASH_PARTITIONED: 6276: mock_355, 6228: mock_110

  322:AGGREGATE (update serialize)
  |  STREAMING
  |  group by: 6276: mock_355, 6228: mock_110
  |  
  321:Project
  |  <slot 6228> : 6228: mock_110
  |  <slot 6276> : 6276: mock_355
  |  
  320:OlapScanNode
     TABLE: tbl_mock_350
     PREAGGREGATION: ON
     PREDICATES: 6276: mock_355 IS NOT NULL, coalesce(6264: mock_414, '') != 'd'
     partitions=1/1
     rollup: tbl_mock_350
     tabletRatio=10/10
     tabletList=22683,22685,22687,22689,22691,22693,22695,22697,22699,22701
     cardinality=1
     avgRowSize=3.0

PLAN FRAGMENT 61
 OUTPUT EXPRS:
  PARTITION: HASH_PARTITIONED: 4387: mock_110, 4390: mock_433

  STREAM DATA SINK
    EXCHANGE ID: 312
    HASH_PARTITIONED: 2797: mock_275, 2795: mock_110

  311:AGGREGATE (update serialize)
  |  STREAMING
  |  group by: 2797: mock_275, 2795: mock_110
  |  
  310:Project
  |  <slot 2795> : 2795: mock_110
  |  <slot 2797> : 2797: mock_275
  |  
  309:HASH JOIN
  |  join op: INNER JOIN (PARTITIONED)
  |  colocate: false, reason: 
  |  equal join conjunct: 4387: mock_110 = 2918: mock_110
  |  equal join conjunct: 4390: mock_433 = 2966: mock_355
  |  other join predicates: 2816: mock_305 >= 4388: case, 2816: mock_305 < coalesce(4389: cast, '2099-12-12')
  |  
  |----308:EXCHANGE
  |    
  301:EXCHANGE

PLAN FRAGMENT 62
 OUTPUT EXPRS:
  PARTITION: RANDOM

  STREAM DATA SINK
    EXCHANGE ID: 308
    HASH_PARTITIONED: 2918: mock_110, 2966: mock_355

  307:Project
  |  <slot 2795> : 2795: mock_110
  |  <slot 2797> : 2797: mock_275
  |  <slot 2816> : 2816: mock_305
  |  <slot 2918> : 2918: mock_110
  |  <slot 2966> : 2966: mock_355
  |  
  306:HASH JOIN
  |  join op: INNER JOIN (BUCKET_SHUFFLE)
  |  colocate: false, reason: 
  |  equal join conjunct: 2917: mock_109 = 2848: mock_109
  |  equal join conjunct: 2918: mock_110 = 2795: mock_110
  |  
  |----305:EXCHANGE
  |    
  303:Project
  |  <slot 2917> : 2917: mock_109
  |  <slot 2918> : 2918: mock_110
  |  <slot 2966> : 2966: mock_355
  |  
  302:OlapScanNode
     TABLE: tbl_mock_350
     PREAGGREGATION: ON
     PREDICATES: coalesce(2954: mock_414, '') != 'd', coalesce(2972: mock_372, '') = '1'
     partitions=1/1
     rollup: tbl_mock_350
     tabletRatio=10/10
     tabletList=22683,22685,22687,22689,22691,22693,22695,22697,22699,22701
     cardinality=1
     avgRowSize=5.0

PLAN FRAGMENT 63
 OUTPUT EXPRS:
  PARTITION: RANDOM

  STREAM DATA SINK
    EXCHANGE ID: 305
    BUCKET_SHUFFLE_HASH_PARTITIONED: 2848: mock_109

  304:OlapScanNode
     TABLE: tbl_mock_267
     PREAGGREGATION: ON
     PREDICATES: 2848: mock_109 IS NOT NULL, 2795: mock_110 IS NOT NULL
     partitions=1/1
     rollup: tbl_mock_267
     tabletRatio=100/100
     tabletList=22457,22459,22461,22463,22465,22467,22469,22471,22473,22475 ...
     cardinality=1
     avgRowSize=4.0

PLAN FRAGMENT 64
 OUTPUT EXPRS:
  PARTITION: RANDOM

  STREAM DATA SINK
    EXCHANGE ID: 301
    HASH_PARTITIONED: 4387: mock_110, 4390: mock_433

  300:Project
  |  <slot 4387> : 4387: mock_110
  |  <slot 4388> : 4388: case
  |  <slot 4389> : 4389: cast
  |  <slot 4390> : 4390: mock_433
  |  
  299:HASH JOIN
  |  join op: INNER JOIN (BROADCAST)
  |  colocate: false, reason: 
  |  equal join conjunct: 4387: mock_110 = 4486: mock_110
  |  equal join conjunct: 4390: mock_433 = 4485: mock_355
  |  
  |----298:EXCHANGE
  |    
  294:Project
  |  <slot 4387> : 4387: mock_110
  |  <slot 4388> : 4388: case
  |  <slot 4389> : 4389: cast
  |  <slot 4390> : 4390: mock_433
  |  
  293:HASH JOIN
  |  join op: INNER JOIN (BROADCAST)
  |  colocate: false, reason: 
  |  equal join conjunct: 4391: mock_433 = 4395: mock_423
  |  equal join conjunct: 4387: mock_110 = 4394: mock_110
  |  
  |----292:EXCHANGE
  |    
  179:UNION
  |  
  |----289:EXCHANGE
  |    
  280:EXCHANGE

PLAN FRAGMENT 65
 OUTPUT EXPRS:
  PARTITION: RANDOM

  STREAM DATA SINK
    EXCHANGE ID: 298
    UNPARTITIONED

  297:SELECT
  |  predicates: 4487: expr = 'from'
  |  
  296:Project
  |  <slot 4485> : 3131: mock_355
  |  <slot 4486> : 3132: mock_110
  |  <slot 4487> : 3133: expr
  |  
  295:EXCHANGE

PLAN FRAGMENT 66
 OUTPUT EXPRS:
  PARTITION: RANDOM

  STREAM DATA SINK
    EXCHANGE ID: 292
    UNPARTITIONED

  291:Project
  |  <slot 4394> : 4394: mock_110
  |  <slot 4395> : 4395: mock_423
  |  
  290:OlapScanNode
     TABLE: tbl_mock_421
     PREAGGREGATION: ON
     PREDICATES: 4394: mock_110 IS NOT NULL, 4397: mock_425 = '1'
     partitions=1/1
     rollup: tbl_mock_421
     tabletRatio=10/10
     tabletList=22706,22708,22710,22712,22714,22716,22718,22720,22722,22724
     cardinality=1
     avgRowSize=3.0

PLAN FRAGMENT 67
 OUTPUT EXPRS:
  PARTITION: HASH_PARTITIONED: 4367: mock_110

  STREAM DATA SINK
    EXCHANGE ID: 289
    RANDOM

  288:Project
  |  <slot 4362> : 4362: mock_453
  |  <slot 4363> : 4363: mock_451
  |  <slot 4365> : 4365: mock_452
  |  <slot 4366> : 4366: mock_447
  |  <slot 4367> : 4367: mock_110
  |  
  287:HASH JOIN
  |  join op: INNER JOIN (PARTITIONED)
  |  colocate: false, reason: 
  |  equal join conjunct: 4367: mock_110 = 4376: mock_110
  |  
  |----286:EXCHANGE
  |    
  283:EXCHANGE

PLAN FRAGMENT 68
 OUTPUT EXPRS:
  PARTITION: RANDOM

  STREAM DATA SINK
    EXCHANGE ID: 286
    HASH_PARTITIONED: 4376: mock_110

  285:Project
  |  <slot 4376> : 4376: mock_110
  |  
  284:OlapScanNode
     TABLE: tbl_mock_437
     PREAGGREGATION: ON
     PREDICATES: 4380: mock_440 = '1', 4376: mock_110 IS NOT NULL, 4378: mock_441 = '1'
     partitions=1/1
     rollup: tbl_mock_437
     tabletRatio=10/10
     tabletList=22775,22777,22779,22781,22783,22785,22787,22789,22791,22793
     cardinality=1
     avgRowSize=3.0

PLAN FRAGMENT 69
 OUTPUT EXPRS:
  PARTITION: RANDOM

  STREAM DATA SINK
    EXCHANGE ID: 283
    HASH_PARTITIONED: 4367: mock_110

  282:Project
  |  <slot 4362> : 4362: mock_453
  |  <slot 4363> : 4363: mock_451
  |  <slot 4365> : 4365: mock_452
  |  <slot 4366> : 4366: mock_447
  |  <slot 4367> : 4367: mock_110
  |  
  281:OlapScanNode
     TABLE: tbl_mock_444
     PREAGGREGATION: ON
     PREDICATES: 4367: mock_110 IS NOT NULL, 4363: mock_451 IS NOT NULL, 4368: mock_446 = '0'
     partitions=1/1
     rollup: tbl_mock_444
     tabletRatio=10/10
     tabletList=22798,22800,22802,22804,22806,22808,22810,22812,22814,22816
     cardinality=1
     avgRowSize=6.0

PLAN FRAGMENT 70
 OUTPUT EXPRS:
  PARTITION: HASH_PARTITIONED: 3857: case

  STREAM DATA SINK
    EXCHANGE ID: 280
    RANDOM

  279:NESTLOOP JOIN
  |  join op: CROSS JOIN
  |  colocate: false, reason: 
  |  
  |----278:EXCHANGE
  |    
  275:Project
  |  <slot 3857> : 3857: case
  |  <slot 3858> : 3858: cast
  |  <slot 3859> : 3859: mock_433
  |  <slot 4168> : 4168: mock_433
  |  
  274:HASH JOIN
  |  join op: LEFT SEMI JOIN (BROADCAST)
  |  colocate: false, reason: 
  |  equal join conjunct: 4168: mock_433 = 4344: mock_355
  |  
  |----273:EXCHANGE
  |    
  268:Project
  |  <slot 3857> : 3857: case
  |  <slot 3858> : 3858: cast
  |  <slot 3859> : 3859: mock_433
  |  <slot 4168> : 4168: mock_433
  |  
  267:HASH JOIN
  |  join op: LEFT SEMI JOIN (BROADCAST)
  |  colocate: false, reason: 
  |  equal join conjunct: 3859: mock_433 = 4255: mock_355
  |  
  |----266:EXCHANGE
  |    
  261:Project
  |  <slot 3857> : 3857: case
  |  <slot 3858> : 3858: cast
  |  <slot 3859> : 3859: mock_433
  |  <slot 4168> : 4168: mock_433
  |  
  260:HASH JOIN
  |  join op: LEFT OUTER JOIN (PARTITIONED)
  |  colocate: false, reason: 
  |  equal join conjunct: 3857: case = 4166: case
  |  
  |----259:EXCHANGE
  |    
  219:EXCHANGE

PLAN FRAGMENT 71
 OUTPUT EXPRS:
  PARTITION: RANDOM

  STREAM DATA SINK
    EXCHANGE ID: 278
    UNPARTITIONED

  277:Project
  |  <slot 4350> : 4350: mock_110
  |  
  276:OlapScanNode
     TABLE: tbl_mock_437
     PREAGGREGATION: ON
     PREDICATES: 4350: mock_110 IS NOT NULL, 4354: mock_440 = '2', 4352: mock_441 = '1'
     partitions=1/1
     rollup: tbl_mock_437
     tabletRatio=10/10
     tabletList=22775,22777,22779,22781,22783,22785,22787,22789,22791,22793
     cardinality=1
     avgRowSize=3.0

PLAN FRAGMENT 72
 OUTPUT EXPRS:
  PARTITION: RANDOM

  STREAM DATA SINK
    EXCHANGE ID: 273
    UNPARTITIONED

  272:Project
  |  <slot 4344> : 4344: mock_355
  |  
  271:SELECT
  |  predicates: 4344: mock_355 IS NOT NULL, 4346: expr = 'to'
  |  
  270:Project
  |  <slot 4344> : 3131: mock_355
  |  <slot 4346> : 3133: expr
  |  
  269:EXCHANGE

PLAN FRAGMENT 73
 OUTPUT EXPRS:
  PARTITION: RANDOM

  STREAM DATA SINK
    EXCHANGE ID: 266
    UNPARTITIONED

  265:Project
  |  <slot 4255> : 4255: mock_355
  |  
  264:SELECT
  |  predicates: 4255: mock_355 IS NOT NULL, 4255: mock_355 IS NOT NULL, 4257: expr = 'from'
  |  
  263:Project
  |  <slot 4255> : 3131: mock_355
  |  <slot 4257> : 3133: expr
  |  
  262:EXCHANGE

PLAN FRAGMENT 74
 OUTPUT EXPRS:
  PARTITION: RANDOM

  STREAM DATA SINK
    EXCHANGE ID: 259
    HASH_PARTITIONED: 4166: case

  220:UNION
  |  
  |----242:EXCHANGE
  |    
  |----258:EXCHANGE
  |    
  231:EXCHANGE

PLAN FRAGMENT 75
 OUTPUT EXPRS:
  PARTITION: RANDOM

  STREAM DATA SINK
    EXCHANGE ID: 258
    RANDOM

  257:Project
  |  <slot 4062> : 4062: mock_433
  |  <slot 4164> : date_format(days_add(CAST(date(CAST(4158: case AS DATETIME)) AS DATETIME), 1), '%Y-%m-%d')
  |  
  256:SELECT
  |  predicates: 4161: row_number() = 1
  |  
  255:ANALYTIC
  |  functions: [, row_number(), ]
  |  partition by: 4062: mock_433
  |  order by: 4158: case DESC
  |  window: ROWS BETWEEN UNBOUNDED PRECEDING AND CURRENT ROW
  |  
  254:SORT
  |  order by: <slot 4062> 4062: mock_433 ASC, <slot 4158> 4158: case DESC
  |  analytic partition by: 4062: mock_433
  |  offset: 0
  |  
  253:PARTITION-TOP-N
  |  partition by: 4062: mock_433 
  |  partition limit: 1
  |  order by: <slot 4062> 4062: mock_433 ASC, <slot 4158> 4158: case DESC
  |  offset: 0
  |  
  252:Project
  |  <slot 4062> : 4062: mock_433
  |  <slot 4158> : if(4063: mock_430 = '2017-01-01', '1970-01-01', 4063: mock_430)
  |  
  251:HASH JOIN
  |  join op: LEFT SEMI JOIN (BUCKET_SHUFFLE)
  |  colocate: false, reason: 
  |  equal join conjunct: 4062: mock_433 = 4154: mock_355
  |  
  |----250:EXCHANGE
  |    
  243:OlapScanNode
     TABLE: tbl_mock_427
     PREAGGREGATION: ON
     PREDICATES: if(4063: mock_430 = '2017-01-01', '1970-01-01', 4063: mock_430) > '2021-08-28', 4063: mock_430 >= '2017-01-01'
     partitions=1/1
     rollup: tbl_mock_427
     tabletRatio=10/10
     tabletList=22729,22731,22733,22735,22737,22739,22741,22743,22745,22747
     cardinality=1
     avgRowSize=2.0

PLAN FRAGMENT 76
 OUTPUT EXPRS:
  PARTITION: HASH_PARTITIONED: 4154: mock_355

  STREAM DATA SINK
    EXCHANGE ID: 250
    BUCKET_SHUFFLE_HASH_PARTITIONED: 4154: mock_355

  249:AGGREGATE (merge finalize)
  |  group by: 4154: mock_355
  |  
  248:EXCHANGE

PLAN FRAGMENT 77
 OUTPUT EXPRS:
  PARTITION: RANDOM

  STREAM DATA SINK
    EXCHANGE ID: 248
    HASH_PARTITIONED: 4154: mock_355

  247:AGGREGATE (update serialize)
  |  STREAMING
  |  group by: 4154: mock_355
  |  
  246:SELECT
  |  predicates: 4154: mock_355 IS NOT NULL
  |  
  245:Project
  |  <slot 4154> : 3131: mock_355
  |  
  244:EXCHANGE

PLAN FRAGMENT 78
 OUTPUT EXPRS:
  PARTITION: RANDOM

  STREAM DATA SINK
    EXCHANGE ID: 242
    RANDOM

  241:Project
  |  <slot 3961> : 3961: mock_433
  |  <slot 4061> : if(3968: mock_436 = '0', '1970-01-01', date_format(days_add(CAST(date(CAST(3962: mock_430 AS DATETIME)) AS DATETIME), 1), '%Y-%m-%d'))
  |  
  240:HASH JOIN
  |  join op: LEFT SEMI JOIN (BUCKET_SHUFFLE)
  |  colocate: false, reason: 
  |  equal join conjunct: 3961: mock_433 = 4054: mock_355
  |  
  |----239:EXCHANGE
  |    
  232:OlapScanNode
     TABLE: tbl_mock_435
     PREAGGREGATION: ON
     PREDICATES: 3962: mock_430 > '2017-01-01', 3968: mock_436 = '0'
     partitions=1/1
     rollup: tbl_mock_435
     tabletRatio=10/10
     tabletList=22752,22754,22756,22758,22760,22762,22764,22766,22768,22770
     cardinality=1
     avgRowSize=3.0

PLAN FRAGMENT 79
 OUTPUT EXPRS:
  PARTITION: HASH_PARTITIONED: 4054: mock_355

  STREAM DATA SINK
    EXCHANGE ID: 239
    BUCKET_SHUFFLE_HASH_PARTITIONED: 4054: mock_355

  238:AGGREGATE (merge finalize)
  |  group by: 4054: mock_355
  |  
  237:EXCHANGE

PLAN FRAGMENT 80
 OUTPUT EXPRS:
  PARTITION: RANDOM

  STREAM DATA SINK
    EXCHANGE ID: 237
    HASH_PARTITIONED: 4054: mock_355

  236:AGGREGATE (update serialize)
  |  STREAMING
  |  group by: 4054: mock_355
  |  
  235:SELECT
  |  predicates: 4054: mock_355 IS NOT NULL
  |  
  234:Project
  |  <slot 4054> : 3131: mock_355
  |  
  233:EXCHANGE

PLAN FRAGMENT 81
 OUTPUT EXPRS:
  PARTITION: RANDOM

  STREAM DATA SINK
    EXCHANGE ID: 231
    RANDOM

  230:Project
  |  <slot 3861> : 3861: mock_433
  |  <slot 3957> : if(3862: mock_430 = '2017-01-01', '1970-01-01', 3862: mock_430)
  |  
  229:HASH JOIN
  |  join op: LEFT SEMI JOIN (BUCKET_SHUFFLE)
  |  colocate: false, reason: 
  |  equal join conjunct: 3861: mock_433 = 3953: mock_355
  |  
  |----228:EXCHANGE
  |    
  221:OlapScanNode
     TABLE: tbl_mock_427
     PREAGGREGATION: ON
     PREDICATES: 3862: mock_430 >= '2017-01-01'
     partitions=1/1
     rollup: tbl_mock_427
     tabletRatio=10/10
     tabletList=22729,22731,22733,22735,22737,22739,22741,22743,22745,22747
     cardinality=1
     avgRowSize=2.0

PLAN FRAGMENT 82
 OUTPUT EXPRS:
  PARTITION: HASH_PARTITIONED: 3953: mock_355

  STREAM DATA SINK
    EXCHANGE ID: 228
    BUCKET_SHUFFLE_HASH_PARTITIONED: 3953: mock_355

  227:AGGREGATE (merge finalize)
  |  group by: 3953: mock_355
  |  
  226:EXCHANGE

PLAN FRAGMENT 83
 OUTPUT EXPRS:
  PARTITION: RANDOM

  STREAM DATA SINK
    EXCHANGE ID: 226
    HASH_PARTITIONED: 3953: mock_355

  225:AGGREGATE (update serialize)
  |  STREAMING
  |  group by: 3953: mock_355
  |  
  224:SELECT
  |  predicates: 3953: mock_355 IS NOT NULL
  |  
  223:Project
  |  <slot 3953> : 3131: mock_355
  |  
  222:EXCHANGE

PLAN FRAGMENT 84
 OUTPUT EXPRS:
  PARTITION: RANDOM

  STREAM DATA SINK
    EXCHANGE ID: 219
    HASH_PARTITIONED: 3857: case

  180:UNION
  |  
  |----202:EXCHANGE
  |    
  |----218:EXCHANGE
  |    
  191:EXCHANGE

PLAN FRAGMENT 85
 OUTPUT EXPRS:
  PARTITION: RANDOM

  STREAM DATA SINK
    EXCHANGE ID: 218
    RANDOM

  217:Project
  |  <slot 3753> : 3753: mock_433
  |  <slot 3855> : date_format(days_add(CAST(date(CAST(3849: case AS DATETIME)) AS DATETIME), 1), '%Y-%m-%d')
  |  <slot 3856> : '2099-12-31'
  |  
  216:SELECT
  |  predicates: 3852: row_number() = 1
  |  
  215:ANALYTIC
  |  functions: [, row_number(), ]
  |  partition by: 3753: mock_433
  |  order by: 3849: case DESC
  |  window: ROWS BETWEEN UNBOUNDED PRECEDING AND CURRENT ROW
  |  
  214:SORT
  |  order by: <slot 3753> 3753: mock_433 ASC, <slot 3849> 3849: case DESC
  |  analytic partition by: 3753: mock_433
  |  offset: 0
  |  
  213:PARTITION-TOP-N
  |  partition by: 3753: mock_433 
  |  partition limit: 1
  |  order by: <slot 3753> 3753: mock_433 ASC, <slot 3849> 3849: case DESC
  |  offset: 0
  |  
  212:Project
  |  <slot 3753> : 3753: mock_433
  |  <slot 3849> : if(3754: mock_430 = '2017-01-01', '1970-01-01', 3754: mock_430)
  |  
  211:HASH JOIN
  |  join op: LEFT SEMI JOIN (BUCKET_SHUFFLE)
  |  colocate: false, reason: 
  |  equal join conjunct: 3753: mock_433 = 3845: mock_355
  |  
  |----210:EXCHANGE
  |    
  203:OlapScanNode
     TABLE: tbl_mock_427
     PREAGGREGATION: ON
     PREDICATES: 3753: mock_433 IS NOT NULL, if(3754: mock_430 = '2017-01-01', '1970-01-01', 3754: mock_430) > '2021-08-28', 3754: mock_430 >= '2017-01-01'
     partitions=1/1
     rollup: tbl_mock_427
     tabletRatio=10/10
     tabletList=22729,22731,22733,22735,22737,22739,22741,22743,22745,22747
     cardinality=1
     avgRowSize=2.0

PLAN FRAGMENT 86
 OUTPUT EXPRS:
  PARTITION: HASH_PARTITIONED: 3845: mock_355

  STREAM DATA SINK
    EXCHANGE ID: 210
    BUCKET_SHUFFLE_HASH_PARTITIONED: 3845: mock_355

  209:AGGREGATE (merge finalize)
  |  group by: 3845: mock_355
  |  
  208:EXCHANGE

PLAN FRAGMENT 87
 OUTPUT EXPRS:
  PARTITION: RANDOM

  STREAM DATA SINK
    EXCHANGE ID: 208
    HASH_PARTITIONED: 3845: mock_355

  207:AGGREGATE (update serialize)
  |  STREAMING
  |  group by: 3845: mock_355
  |  
  206:SELECT
  |  predicates: 3845: mock_355 IS NOT NULL, 3845: mock_355 IS NOT NULL
  |  
  205:Project
  |  <slot 3845> : 3131: mock_355
  |  
  204:EXCHANGE

PLAN FRAGMENT 88
 OUTPUT EXPRS:
  PARTITION: RANDOM

  STREAM DATA SINK
    EXCHANGE ID: 202
    RANDOM

  201:Project
  |  <slot 3652> : 3652: mock_433
  |  <slot 3750> : if(8451: expr, 3653: mock_430, '2099-12-12')
  |  <slot 3752> : if(8451: expr, '1970-01-01', date_format(days_add(CAST(date(CAST(3653: mock_430 AS DATETIME)) AS DATETIME), 1), '%Y-%m-%d'))
  |  common expressions:
  |  <slot 8451> : 3659: mock_436 = '0'
  |  
  200:HASH JOIN
  |  join op: LEFT SEMI JOIN (BUCKET_SHUFFLE)
  |  colocate: false, reason: 
  |  equal join conjunct: 3652: mock_433 = 3745: mock_355
  |  
  |----199:EXCHANGE
  |    
  192:OlapScanNode
     TABLE: tbl_mock_435
     PREAGGREGATION: ON
     PREDICATES: 3652: mock_433 IS NOT NULL, 3653: mock_430 > '2017-01-01', 3659: mock_436 = '0'
     partitions=1/1
     rollup: tbl_mock_435
     tabletRatio=10/10
     tabletList=22752,22754,22756,22758,22760,22762,22764,22766,22768,22770
     cardinality=1
     avgRowSize=3.0

PLAN FRAGMENT 89
 OUTPUT EXPRS:
  PARTITION: HASH_PARTITIONED: 3745: mock_355

  STREAM DATA SINK
    EXCHANGE ID: 199
    BUCKET_SHUFFLE_HASH_PARTITIONED: 3745: mock_355

  198:AGGREGATE (merge finalize)
  |  group by: 3745: mock_355
  |  
  197:EXCHANGE

PLAN FRAGMENT 90
 OUTPUT EXPRS:
  PARTITION: RANDOM

  STREAM DATA SINK
    EXCHANGE ID: 197
    HASH_PARTITIONED: 3745: mock_355

  196:AGGREGATE (update serialize)
  |  STREAMING
  |  group by: 3745: mock_355
  |  
  195:SELECT
  |  predicates: 3745: mock_355 IS NOT NULL, 3745: mock_355 IS NOT NULL
  |  
  194:Project
  |  <slot 3745> : 3131: mock_355
  |  
  193:EXCHANGE

PLAN FRAGMENT 91
 OUTPUT EXPRS:
  PARTITION: RANDOM

  STREAM DATA SINK
    EXCHANGE ID: 191
    RANDOM

  190:Project
  |  <slot 3552> : 3552: mock_433
  |  <slot 3648> : if(3553: mock_430 = '2017-01-01', '1970-01-01', 3553: mock_430)
  |  <slot 3651> : date_format(days_add(CAST(date(CAST(3553: mock_430 AS DATETIME)) AS DATETIME), 1), '%Y-%m-%d')
  |  
  189:HASH JOIN
  |  join op: LEFT SEMI JOIN (BUCKET_SHUFFLE)
  |  colocate: false, reason: 
  |  equal join conjunct: 3552: mock_433 = 3644: mock_355
  |  
  |----188:EXCHANGE
  |    
  181:OlapScanNode
     TABLE: tbl_mock_427
     PREAGGREGATION: ON
     PREDICATES: 3552: mock_433 IS NOT NULL, 3553: mock_430 >= '2017-01-01'
     partitions=1/1
     rollup: tbl_mock_427
     tabletRatio=10/10
     tabletList=22729,22731,22733,22735,22737,22739,22741,22743,22745,22747
     cardinality=1
     avgRowSize=2.0

PLAN FRAGMENT 92
 OUTPUT EXPRS:
  PARTITION: HASH_PARTITIONED: 3644: mock_355

  STREAM DATA SINK
    EXCHANGE ID: 188
    BUCKET_SHUFFLE_HASH_PARTITIONED: 3644: mock_355

  187:AGGREGATE (merge finalize)
  |  group by: 3644: mock_355
  |  
  186:EXCHANGE

PLAN FRAGMENT 93
 OUTPUT EXPRS:
  PARTITION: RANDOM

  STREAM DATA SINK
    EXCHANGE ID: 186
    HASH_PARTITIONED: 3644: mock_355

  185:AGGREGATE (update serialize)
  |  STREAMING
  |  group by: 3644: mock_355
  |  
  184:SELECT
  |  predicates: 3644: mock_355 IS NOT NULL, 3644: mock_355 IS NOT NULL
  |  
  183:Project
  |  <slot 3644> : 3131: mock_355
  |  
  182:EXCHANGE

PLAN FRAGMENT 94
 OUTPUT EXPRS:3131: mock_355 | 3132: mock_110 | 3133: expr
  PARTITION: RANDOM

  MultiCastDataSinks
  STREAM DATA SINK
    EXCHANGE ID: 182
    RANDOM
  STREAM DATA SINK
    EXCHANGE ID: 193
    RANDOM
  STREAM DATA SINK
    EXCHANGE ID: 204
    RANDOM
  STREAM DATA SINK
    EXCHANGE ID: 222
    RANDOM
  STREAM DATA SINK
    EXCHANGE ID: 233
    RANDOM
  STREAM DATA SINK
    EXCHANGE ID: 244
    RANDOM
  STREAM DATA SINK
    EXCHANGE ID: 262
    RANDOM
  STREAM DATA SINK
    EXCHANGE ID: 269
    RANDOM
  STREAM DATA SINK
    EXCHANGE ID: 295
    RANDOM

  167:UNION
  |  
  |----178:EXCHANGE
  |    
  174:EXCHANGE

PLAN FRAGMENT 95
 OUTPUT EXPRS:
  PARTITION: RANDOM

  STREAM DATA SINK
    EXCHANGE ID: 178
    RANDOM

  177:Project
  |  <slot 3128> : 'to'
  |  <slot 3129> : 3123: mock_423
  |  <slot 3130> : 3122: mock_110
  |  
  176:AGGREGATE (update finalize)
  |  group by: 3123: mock_423, 3122: mock_110
  |  
  175:OlapScanNode
     TABLE: tbl_mock_421
     PREAGGREGATION: ON
     PREDICATES: 3123: mock_423 IS NOT NULL
     partitions=1/1
     rollup: tbl_mock_421
     tabletRatio=10/10
     tabletList=22706,22708,22710,22712,22714,22716,22718,22720,22722,22724
     cardinality=1
     avgRowSize=2.0

PLAN FRAGMENT 96
 OUTPUT EXPRS:
  PARTITION: HASH_PARTITIONED: 3095: mock_355, 3047: mock_110

  STREAM DATA SINK
    EXCHANGE ID: 174
    RANDOM

  173:Project
  |  <slot 3047> : 3047: mock_110
  |  <slot 3095> : 3095: mock_355
  |  <slot 3121> : 'from'
  |  
  172:AGGREGATE (merge finalize)
  |  group by: 3095: mock_355, 3047: mock_110
  |  
  171:EXCHANGE

PLAN FRAGMENT 97
 OUTPUT EXPRS:
  PARTITION: RANDOM

  STREAM DATA SINK
    EXCHANGE ID: 171
    HASH_PARTITIONED: 3095: mock_355, 3047: mock_110

  170:AGGREGATE (update serialize)
  |  STREAMING
  |  group by: 3095: mock_355, 3047: mock_110
  |  
  169:Project
  |  <slot 3047> : 3047: mock_110
  |  <slot 3095> : 3095: mock_355
  |  
  168:OlapScanNode
     TABLE: tbl_mock_350
     PREAGGREGATION: ON
     PREDICATES: coalesce(3083: mock_414, '') != 'd'
     partitions=1/1
     rollup: tbl_mock_350
     tabletRatio=10/10
     tabletList=22683,22685,22687,22689,22691,22693,22695,22697,22699,22701
     cardinality=1
     avgRowSize=3.0

PLAN FRAGMENT 98
 OUTPUT EXPRS:
  PARTITION: HASH_PARTITIONED: 930: mock_109, 931: mock_110

  STREAM DATA SINK
    EXCHANGE ID: 166
    HASH_PARTITIONED: 1: mock_021, 2: mock_110

  165: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 2532> : CASE WHEN 30: mock_037 = 'a' THEN 'Advance order' WHEN 30: mock_037 IN ('y', 'l') THEN 'Non-Revenue' ELSE 'Revenue' END
  |  
  164:HASH JOIN
  |  join op: INNER JOIN (PARTITIONED)
  |  colocate: false, reason: 
  |  equal join conjunct: 930: mock_109 = 108: mock_109
  |  equal join conjunct: 931: mock_110 = 2: mock_110
  |  other join predicates: 22: mock_068 >= 2401: case, 22: mock_068 < coalesce(2402: cast, '2099-12-12')
  |  
  |----163:EXCHANGE
  |    
  140:EXCHANGE

PLAN FRAGMENT 99
 OUTPUT EXPRS:
  PARTITION: HASH_PARTITIONED: 2: mock_110, 79: mock_017

  STREAM DATA SINK
    EXCHANGE ID: 163
    HASH_PARTITIONED: 108: mock_109, 2: mock_110

  162: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
  |  
  161:HASH JOIN
  |  join op: LEFT OUTER JOIN (PARTITIONED)
  |  colocate: false, reason: 
  |  equal join conjunct: 2: mock_110 = 872: mock_110
  |  equal join conjunct: 79: mock_017 = 871: mock_331
  |  
  |----160:EXCHANGE
  |    
  157:EXCHANGE

PLAN FRAGMENT 100
 OUTPUT EXPRS:
  PARTITION: RANDOM

  STREAM DATA SINK
    EXCHANGE ID: 160
    HASH_PARTITIONED: 872: mock_110, 871: mock_331

  159:Project
  |  <slot 871> : 871: mock_331
  |  <slot 872> : 872: mock_110
  |  
  158:OlapScanNode
     TABLE: tbl_mock_318
     PREAGGREGATION: ON
     PREDICATES: coalesce(899: mock_347, '') != 'd', 872: mock_110 IS NOT NULL
     partitions=1/1
     rollup: tbl_mock_318
     tabletRatio=10/10
     tabletList=22660,22662,22664,22666,22668,22670,22672,22674,22676,22678
     cardinality=1
     avgRowSize=3.0

PLAN FRAGMENT 101
 OUTPUT EXPRS:
  PARTITION: RANDOM

  STREAM DATA SINK
    EXCHANGE ID: 157
    HASH_PARTITIONED: 2: mock_110, 79: mock_017

  156: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
  |  
  155:HASH JOIN
  |  join op: LEFT OUTER JOIN (BUCKET_SHUFFLE)
  |  colocate: false, reason: 
  |  equal join conjunct: 1: mock_021 = 733: mock_275
  |  equal join conjunct: 2: mock_110 = 731: mock_110
  |  
  |----154:EXCHANGE
  |    
  148: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
  |  
  147:HASH JOIN
  |  join op: LEFT OUTER JOIN (BUCKET_SHUFFLE)
  |  colocate: false, reason: 
  |  equal join conjunct: 1: mock_021 = 311: mock_152
  |  equal join conjunct: 2: mock_110 = 279: mock_110
  |  
  |----146:EXCHANGE
  |    
  141:OlapScanNode
     TABLE: tbl_mock_001
     PREAGGREGATION: ON
     PREDICATES: 108: mock_109 IS NOT NULL, 2: mock_110 IS NOT NULL
     partitions=1/1
     rollup: tbl_mock_001
     tabletRatio=100/100
     tabletList=22051,22053,22055,22057,22059,22061,22063,22065,22067,22069 ...
     cardinality=1
     avgRowSize=9.0

PLAN FRAGMENT 102
 OUTPUT EXPRS:
  PARTITION: HASH_PARTITIONED: 733: mock_275, 731: mock_110

  STREAM DATA SINK
    EXCHANGE ID: 154
    BUCKET_SHUFFLE_HASH_PARTITIONED: 733: mock_275

  153:AGGREGATE (merge finalize)
  |  group by: 733: mock_275, 731: mock_110
  |  
  152:EXCHANGE

PLAN FRAGMENT 103
 OUTPUT EXPRS:
  PARTITION: RANDOM

  STREAM DATA SINK
    EXCHANGE ID: 152
    HASH_PARTITIONED: 733: mock_275, 731: mock_110

  151:AGGREGATE (update serialize)
  |  STREAMING
  |  group by: 733: mock_275, 731: mock_110
  |  
  150:Project
  |  <slot 731> : 731: mock_110
  |  <slot 733> : 733: mock_275
  |  
  149:OlapScanNode
     TABLE: tbl_mock_267
     PREAGGREGATION: ON
     PREDICATES: 731: mock_110 IS NOT NULL, coalesce(coalesce(781: mock_308, ''), 'e') != 'd'
     partitions=1/1
     rollup: tbl_mock_267
     tabletRatio=100/100
     tabletList=22457,22459,22461,22463,22465,22467,22469,22471,22473,22475 ...
     cardinality=1
     avgRowSize=3.0

PLAN FRAGMENT 104
 OUTPUT EXPRS:
  PARTITION: HASH_PARTITIONED: 311: mock_152, 279: mock_110

  STREAM DATA SINK
    EXCHANGE ID: 146
    BUCKET_SHUFFLE_HASH_PARTITIONED: 311: mock_152

  145:AGGREGATE (merge finalize)
  |  group by: 311: mock_152, 279: mock_110
  |  
  144:EXCHANGE

PLAN FRAGMENT 105
 OUTPUT EXPRS:
  PARTITION: RANDOM

  STREAM DATA SINK
    EXCHANGE ID: 144
    HASH_PARTITIONED: 311: mock_152, 279: mock_110

  143:AGGREGATE (update serialize)
  |  STREAMING
  |  group by: 311: mock_152, 279: mock_110
  |  
  142:OlapScanNode
     TABLE: tbl_mock_111
     PREAGGREGATION: ON
     PREDICATES: 279: mock_110 IS NOT NULL
     partitions=1/1
     rollup: tbl_mock_111
     tabletRatio=100/100
     tabletList=22254,22256,22258,22260,22262,22264,22266,22268,22270,22272 ...
     cardinality=1
     avgRowSize=2.0

PLAN FRAGMENT 106
 OUTPUT EXPRS:
  PARTITION: HASH_PARTITIONED: 2400: mock_110, 2403: mock_433

  STREAM DATA SINK
    EXCHANGE ID: 140
    HASH_PARTITIONED: 930: mock_109, 931: mock_110

  139:Project
  |  <slot 930> : 930: mock_109
  |  <slot 931> : 931: mock_110
  |  <slot 2401> : 2401: case
  |  <slot 2402> : 2402: cast
  |  
  138:HASH JOIN
  |  join op: RIGHT OUTER JOIN (PARTITIONED)
  |  colocate: false, reason: 
  |  equal join conjunct: 2400: mock_110 = 931: mock_110
  |  equal join conjunct: 2403: mock_433 = 979: mock_355
  |  
  |----137:EXCHANGE
  |    
  134:EXCHANGE

PLAN FRAGMENT 107
 OUTPUT EXPRS:
  PARTITION: RANDOM

  STREAM DATA SINK
    EXCHANGE ID: 137
    HASH_PARTITIONED: 931: mock_110, 979: mock_355

  136:Project
  |  <slot 930> : 930: mock_109
  |  <slot 931> : 931: mock_110
  |  <slot 979> : 979: mock_355
  |  
  135:OlapScanNode
     TABLE: tbl_mock_350
     PREAGGREGATION: ON
     PREDICATES: 930: mock_109 IS NOT NULL, 931: mock_110 IS NOT NULL, coalesce(967: mock_414, '') != 'd', coalesce(985: mock_372, '') = '1'
     partitions=1/1
     rollup: tbl_mock_350
     tabletRatio=10/10
     tabletList=22683,22685,22687,22689,22691,22693,22695,22697,22699,22701
     cardinality=1
     avgRowSize=5.0

PLAN FRAGMENT 108
 OUTPUT EXPRS:
  PARTITION: RANDOM

  STREAM DATA SINK
    EXCHANGE ID: 134
    HASH_PARTITIONED: 2400: mock_110, 2403: mock_433

  133:Project
  |  <slot 2400> : 2400: mock_110
  |  <slot 2401> : 2401: case
  |  <slot 2402> : 2402: cast
  |  <slot 2403> : 2403: mock_433
  |  
  132:HASH JOIN
  |  join op: INNER JOIN (BROADCAST)
  |  colocate: false, reason: 
  |  equal join conjunct: 2400: mock_110 = 2499: mock_110
  |  equal join conjunct: 2403: mock_433 = 2498: mock_355
  |  
  |----131:EXCHANGE
  |    
  127:Project
  |  <slot 2400> : 2400: mock_110
  |  <slot 2401> : 2401: case
  |  <slot 2402> : 2402: cast
  |  <slot 2403> : 2403: mock_433
  |  
  126:HASH JOIN
  |  join op: INNER JOIN (BROADCAST)
  |  colocate: false, reason: 
  |  equal join conjunct: 2404: mock_433 = 2408: mock_423
  |  equal join conjunct: 2400: mock_110 = 2407: mock_110
  |  
  |----125:EXCHANGE
  |    
  12:UNION
  |  
  |----122:EXCHANGE
  |    
  113:EXCHANGE

PLAN FRAGMENT 109
 OUTPUT EXPRS:
  PARTITION: RANDOM

  STREAM DATA SINK
    EXCHANGE ID: 131
    UNPARTITIONED

  130:SELECT
  |  predicates: 2499: mock_110 IS NOT NULL, 2500: expr = 'from'
  |  
  129:Project
  |  <slot 2498> : 1144: mock_355
  |  <slot 2499> : 1145: mock_110
  |  <slot 2500> : 1146: expr
  |  
  128:EXCHANGE

PLAN FRAGMENT 110
 OUTPUT EXPRS:
  PARTITION: RANDOM

  STREAM DATA SINK
    EXCHANGE ID: 125
    UNPARTITIONED

  124:Project
  |  <slot 2407> : 2407: mock_110
  |  <slot 2408> : 2408: mock_423
  |  
  123:OlapScanNode
     TABLE: tbl_mock_421
     PREAGGREGATION: ON
     PREDICATES: 2407: mock_110 IS NOT NULL, 2410: mock_425 = '1'
     partitions=1/1
     rollup: tbl_mock_421
     tabletRatio=10/10
     tabletList=22706,22708,22710,22712,22714,22716,22718,22720,22722,22724
     cardinality=1
     avgRowSize=3.0

PLAN FRAGMENT 111
 OUTPUT EXPRS:
  PARTITION: HASH_PARTITIONED: 2380: mock_110

  STREAM DATA SINK
    EXCHANGE ID: 122
    RANDOM

  121:Project
  |  <slot 2375> : 2375: mock_453
  |  <slot 2376> : 2376: mock_451
  |  <slot 2378> : 2378: mock_452
  |  <slot 2379> : 2379: mock_447
  |  <slot 2380> : 2380: mock_110
  |  
  120:HASH JOIN
  |  join op: INNER JOIN (PARTITIONED)
  |  colocate: false, reason: 
  |  equal join conjunct: 2380: mock_110 = 2389: mock_110
  |  
  |----119:EXCHANGE
  |    
  116:EXCHANGE

PLAN FRAGMENT 112
 OUTPUT EXPRS:
  PARTITION: RANDOM

  STREAM DATA SINK
    EXCHANGE ID: 119
    HASH_PARTITIONED: 2389: mock_110

  118:Project
  |  <slot 2389> : 2389: mock_110
  |  
  117:OlapScanNode
     TABLE: tbl_mock_437
     PREAGGREGATION: ON
     PREDICATES: 2393: mock_440 = '1', 2389: mock_110 IS NOT NULL, 2391: mock_441 = '1'
     partitions=1/1
     rollup: tbl_mock_437
     tabletRatio=10/10
     tabletList=22775,22777,22779,22781,22783,22785,22787,22789,22791,22793
     cardinality=1
     avgRowSize=3.0

PLAN FRAGMENT 113
 OUTPUT EXPRS:
  PARTITION: RANDOM

  STREAM DATA SINK
    EXCHANGE ID: 116
    HASH_PARTITIONED: 2380: mock_110

  115:Project
  |  <slot 2375> : 2375: mock_453
  |  <slot 2376> : 2376: mock_451
  |  <slot 2378> : 2378: mock_452
  |  <slot 2379> : 2379: mock_447
  |  <slot 2380> : 2380: mock_110
  |  
  114:OlapScanNode
     TABLE: tbl_mock_444
     PREAGGREGATION: ON
     PREDICATES: 2380: mock_110 IS NOT NULL, 2376: mock_451 IS NOT NULL, 2381: mock_446 = '0'
     partitions=1/1
     rollup: tbl_mock_444
     tabletRatio=10/10
     tabletList=22798,22800,22802,22804,22806,22808,22810,22812,22814,22816
     cardinality=1
     avgRowSize=6.0

PLAN FRAGMENT 114
 OUTPUT EXPRS:
  PARTITION: HASH_PARTITIONED: 1870: case

  STREAM DATA SINK
    EXCHANGE ID: 113
    RANDOM

  112:NESTLOOP JOIN
  |  join op: CROSS JOIN
  |  colocate: false, reason: 
  |  
  |----111:EXCHANGE
  |    
  108:Project
  |  <slot 1870> : 1870: case
  |  <slot 1871> : 1871: cast
  |  <slot 1872> : 1872: mock_433
  |  <slot 2181> : 2181: mock_433
  |  
  107:HASH JOIN
  |  join op: LEFT SEMI JOIN (BROADCAST)
  |  colocate: false, reason: 
  |  equal join conjunct: 2181: mock_433 = 2357: mock_355
  |  
  |----106:EXCHANGE
  |    
  101:Project
  |  <slot 1870> : 1870: case
  |  <slot 1871> : 1871: cast
  |  <slot 1872> : 1872: mock_433
  |  <slot 2181> : 2181: mock_433
  |  
  100:HASH JOIN
  |  join op: LEFT SEMI JOIN (BROADCAST)
  |  coloca

java.lang.AssertionError: 
PLAN COST
  CPU: 1.0888027859121333E8
  Memory: 5.304235152163989E7

PLAN FRAGMENT 0(F02)
  Output Exprs:52: COUNTRY | 12: TAG_GROUP | 13: TAG_CATEGORY | 14: TAG_SUBCATEGORY | 16: TAG_TYPE | 15: TAG_BRAND | 20: TAG_SKU | 58: sum
  Input Partition: UNPARTITIONED
  RESULT SINK

  5:EXCHANGE
     cardinality: 380372

PLAN FRAGMENT 1(F01)

  Input Partition: HASH_PARTITIONED: 60: COUNTRY, 61: TAG_GROUP, 62: TAG_CATEGORY, 63: TAG_SUBCATEGORY, 64: TAG_TYPE, 65: TAG_BRAND, 66: TAG_SKU
  OutPut Partition: UNPARTITIONED
  OutPut Exchange Id: 05

  4:Project
  |  output columns:
  |  12 <-> [61: TAG_GROUP, VARCHAR, true]
  |  13 <-> [62: TAG_CATEGORY, VARCHAR, true]
  |  14 <-> [63: TAG_SUBCATEGORY, VARCHAR, true]
  |  15 <-> [65: TAG_BRAND, VARCHAR, true]
  |  16 <-> [64: TAG_TYPE, VARCHAR, true]
  |  20 <-> [66: TAG_SKU, VARCHAR, true]
  |  52 <-> [60: COUNTRY, VARCHAR, false]
  |  58 <-> [110: sum, DOUBLE, true]
  |  cardinality: 380372
  |  column statistics: 
  |  * TAG_GROUP-->[-Infinity, Infinity, 0.0, 6.0, 1.0] ESTIMATE
  |  * TAG_CATEGORY-->[-Infinity, Infinity, 0.0, 4.0, 1.0] ESTIMATE
  |  * TAG_SUBCATEGORY-->[-Infinity, Infinity, 0.14285714285714285, 11.224555682462514, 6.0] ESTIMATE
  |  * TAG_BRAND-->[-Infinity, Infinity, 0.0015174506828528073, 9.602714603132402, 658.0] ESTIMATE
  |  * TAG_TYPE-->[-Infinity, Infinity, 0.04, 5.828510115328582, 24.0] ESTIMATE
  |  * TAG_SKU-->[-Infinity, Infinity, 5.408328826392645E-4, 10.748382388449237, 1848.0] ESTIMATE
  |  * COUNTRY-->[-Infinity, Infinity, 0.0, 11.0, 1.0] ESTIMATE
  |  * sum-->[0.0, 183135.22645007257, 0.0, 8.0, 39074.0] ESTIMATE
  |  
  3:AGGREGATE (merge finalize)
  |  aggregate: sum[([110: sum, DOUBLE, true]); args: DOUBLE; result: DOUBLE; args nullable: true; result nullable: true]
  |  group by: [60: COUNTRY, VARCHAR, false], [61: TAG_GROUP, VARCHAR, true], [62: TAG_CATEGORY, VARCHAR, true], [63: TAG_SUBCATEGORY, VARCHAR, true], [64: TAG_TYPE, VARCHAR, true], [65: TAG_BRAND, VARCHAR, true], [66: TAG_SKU, VARCHAR, true]
  |  cardinality: 380372
  |  column statistics: 
  |  * TAG_GROUP-->[-Infinity, Infinity, 0.0, 6.0, 1.0] ESTIMATE
  |  * TAG_CATEGORY-->[-Infinity, Infinity, 0.0, 4.0, 1.0] ESTIMATE
  |  * TAG_SUBCATEGORY-->[-Infinity, Infinity, 0.14285714285714285, 11.224555682462514, 6.0] ESTIMATE
  |  * TAG_BRAND-->[-Infinity, Infinity, 0.0015174506828528073, 9.602714603132402, 658.0] ESTIMATE
  |  * TAG_TYPE-->[-Infinity, Infinity, 0.04, 5.828510115328582, 24.0] ESTIMATE
  |  * TAG_SKU-->[-Infinity, Infinity, 5.408328826392645E-4, 10.748382388449237, 1848.0] ESTIMATE
  |  * COUNTRY-->[-Infinity, Infinity, 0.0, 11.0, 1.0] ESTIMATE
  |  * sum-->[0.0, 183135.22645007257, 0.0, 8.0, 39074.0] ESTIMATE
  |  * COUNTRY-->[-Infinity, Infinity, 0.0, 11.0, 1.0] ESTIMATE
  |  * TAG_GROUP-->[-Infinity, Infinity, 0.0, 6.0, 1.0] ESTIMATE
  |  * TAG_CATEGORY-->[-Infinity, Infinity, 0.0, 4.0, 1.0] ESTIMATE
  |  * TAG_SUBCATEGORY-->[-Infinity, Infinity, 0.14285714285714285, 11.224555682462514, 6.0] ESTIMATE
  |  * TAG_TYPE-->[-Infinity, Infinity, 0.04, 5.828510115328582, 24.0] ESTIMATE
  |  * TAG_BRAND-->[-Infinity, Infinity, 0.0015174506828528073, 9.602714603132402, 658.0] ESTIMATE
  |  * TAG_SKU-->[-Infinity, Infinity, 5.408328826392645E-4, 10.748382388449237, 1848.0] ESTIMATE
  |  * sum-->[0.0, 183135.22645007257, 0.0, 8.0, 39074.0] ESTIMATE
  |  
  2:EXCHANGE
     distribution type: SHUFFLE
     partition exprs: [60: COUNTRY, VARCHAR, false], [61: TAG_GROUP, VARCHAR, true], [62: TAG_CATEGORY, VARCHAR, true], [63: TAG_SUBCATEGORY, VARCHAR, true], [64: TAG_TYPE, VARCHAR, true], [65: TAG_BRAND, VARCHAR, true], [66: TAG_SKU, VARCHAR, true]
     cardinality: 380372

PLAN FRAGMENT 2(F00)

  Input Partition: RANDOM
  OutPut Partition: HASH_PARTITIONED: 60: COUNTRY, 61: TAG_GROUP, 62: TAG_CATEGORY, 63: TAG_SUBCATEGORY, 64: TAG_TYPE, 65: TAG_BRAND, 66: TAG_SKU
  OutPut Exchange Id: 02

  1:AGGREGATE (update serialize)
  |  STREAMING
  |  aggregate: sum[([67: total_volume, DOUBLE, true]); args: DOUBLE; result: DOUBLE; args nullable: true; result nullable: true]
  |  group by: [60: COUNTRY, VARCHAR, false], [61: TAG_GROUP, VARCHAR, true], [62: TAG_CATEGORY, VARCHAR, true], [63: TAG_SUBCATEGORY, VARCHAR, true], [64: TAG_TYPE, VARCHAR, true], [65: TAG_BRAND, VARCHAR, true], [66: TAG_SKU, VARCHAR, true]
  |  cardinality: 380372
  |  column statistics: 
  |  * COUNTRY-->[-Infinity, Infinity, 0.0, 11.0, 1.0] ESTIMATE
  |  * TAG_GROUP-->[-Infinity, Infinity, 0.0, 6.0, 1.0] ESTIMATE
  |  * TAG_CATEGORY-->[-Infinity, Infinity, 0.0, 4.0, 1.0] ESTIMATE
  |  * TAG_SUBCATEGORY-->[-Infinity, Infinity, 0.14285714285714285, 11.224555682462514, 6.0] ESTIMATE
  |  * TAG_TYPE-->[-Infinity, Infinity, 0.04, 5.828510115328582, 24.0] ESTIMATE
  |  * TAG_BRAND-->[-Infinity, Infinity, 0.0015174506828528073, 9.602714603132402, 658.0] ESTIMATE
  |  * TAG_SKU-->[-Infinity, Infinity, 5.408328826392645E-4, 10.748382388449237, 1848.0] ESTIMATE
  |  * sum-->[0.0, 183135.22645007257, 0.0, 8.0, 39074.0] ESTIMATE
  |  
  0:OlapScanNode
     table: partition_flat_consumptions_partition_drinks_dates, rollup: partition_flat_consumptions_partition_drinks_dates
     preAggregation: on
     Predicates: [59: LOCAL_ORDERED_DATE, DATE, false] >= '2023-04-01', date_trunc[('month', [59: LOCAL_ORDERED_DATE, DATE, false]); args: VARCHAR,DATE; result: DATE; args nullable: false; result nullable: true] <= '2023-05-31'
     partitionsRatio=1/1, tabletsRatio=6/6
     tabletList=60277,60279,60281,60283,60285,60287
     actualRows=0, avgRowSize=70.40416
     MaterializedView: true
     cardinality: 1047151
     column statistics: 
     * LOCAL_ORDERED_DATE-->[1.6802784E9, 4.1339232E9, 0.0, 4.0, 37025.0] ESTIMATE
     * COUNTRY-->[-Infinity, Infinity, 0.0, 11.0, 1.0] ESTIMATE
     * TAG_GROUP-->[-Infinity, Infinity, 0.0, 6.0, 1.0] ESTIMATE
     * TAG_CATEGORY-->[-Infinity, Infinity, 0.0, 4.0, 1.0] ESTIMATE
     * TAG_SUBCATEGORY-->[-Infinity, Infinity, 0.0010038008784614173, 11.224555682462514, 6.0] ESTIMATE
     * TAG_TYPE-->[-Infinity, Infinity, 0.0260798320125665, 5.828510115328582, 24.0] ESTIMATE
     * TAG_BRAND-->[-Infinity, Infinity, 0.03056166728612937, 9.602714603132402, 658.0] ESTIMATE
     * TAG_SKU-->[-Infinity, Infinity, 0.07836971885436476, 10.748382388449237, 1848.0] ESTIMATE
     * total_volume-->[0.0, 18812.720052540302, 0.0, 8.0, 39074.0] ESTIMATE

	at com.starrocks.sql.plan.ReplayFromDumpTest.testForceRuleBasedRewriteMonth(ReplayFromDumpTest.java:56)

java.lang.AssertionError: 
PLAN COST
  CPU: 1.3233251760955513E8
  Memory: 2.576355194517157E7

PLAN FRAGMENT 0(F02)
  Output Exprs:52: COUNTRY | 12: TAG_GROUP | 13: TAG_CATEGORY | 14: TAG_SUBCATEGORY | 16: TAG_TYPE | 15: TAG_BRAND | 20: TAG_SKU | 58: sum
  Input Partition: UNPARTITIONED
  RESULT SINK

  5:EXCHANGE
     cardinality: 380372

PLAN FRAGMENT 1(F01)

  Input Partition: HASH_PARTITIONED: 52: COUNTRY, 12: TAG_GROUP, 13: TAG_CATEGORY, 14: TAG_SUBCATEGORY, 16: TAG_TYPE, 15: TAG_BRAND, 20: TAG_SKU
  OutPut Partition: UNPARTITIONED
  OutPut Exchange Id: 05

  4:AGGREGATE (merge finalize)
  |  aggregate: sum[([58: sum, DOUBLE, true]); args: DOUBLE; result: DOUBLE; args nullable: true; result nullable: true]
  |  group by: [52: COUNTRY, VARCHAR, false], [12: TAG_GROUP, VARCHAR, true], [13: TAG_CATEGORY, VARCHAR, true], [14: TAG_SUBCATEGORY, VARCHAR, true], [16: TAG_TYPE, VARCHAR, true], [15: TAG_BRAND, VARCHAR, true], [20: TAG_SKU, VARCHAR, true]
  |  cardinality: 380372
  |  column statistics: 
  |  * TAG_GROUP-->[-Infinity, Infinity, 0.0, 6.0, 1.0] ESTIMATE
  |  * TAG_CATEGORY-->[-Infinity, Infinity, 0.0, 4.0, 1.0] ESTIMATE
  |  * TAG_SUBCATEGORY-->[-Infinity, Infinity, 0.14285714285714285, 9.184868810453802, 6.0] ESTIMATE
  |  * TAG_BRAND-->[-Infinity, Infinity, 0.0015174506828528073, 8.502326957883204, 658.0] ESTIMATE
  |  * TAG_TYPE-->[-Infinity, Infinity, 0.04, 5.496174603043697, 24.0] ESTIMATE
  |  * TAG_SKU-->[-Infinity, Infinity, 5.408328826392645E-4, 9.391695272557946, 1848.0] ESTIMATE
  |  * COUNTRY-->[-Infinity, Infinity, 0.0, 11.0, 1.0] ESTIMATE
  |  * sum-->[0.0, 5067988.209488497, 0.0, 8.0, 1413.0] ESTIMATE
  |  
  3:EXCHANGE
     distribution type: SHUFFLE
     partition exprs: [52: COUNTRY, VARCHAR, false], [12: TAG_GROUP, VARCHAR, true], [13: TAG_CATEGORY, VARCHAR, true], [14: TAG_SUBCATEGORY, VARCHAR, true], [16: TAG_TYPE, VARCHAR, true], [15: TAG_BRAND, VARCHAR, true], [20: TAG_SKU, VARCHAR, true]
     cardinality: 380372

PLAN FRAGMENT 2(F00)

  Input Partition: RANDOM
  OutPut Partition: HASH_PARTITIONED: 52: COUNTRY, 12: TAG_GROUP, 13: TAG_CATEGORY, 14: TAG_SUBCATEGORY, 16: TAG_TYPE, 15: TAG_BRAND, 20: TAG_SKU
  OutPut Exchange Id: 03

  2:AGGREGATE (update serialize)
  |  STREAMING
  |  aggregate: sum[([57: expr, DOUBLE, true]); args: DOUBLE; result: DOUBLE; args nullable: true; result nullable: true]
  |  group by: [52: COUNTRY, VARCHAR, false], [12: TAG_GROUP, VARCHAR, true], [13: TAG_CATEGORY, VARCHAR, true], [14: TAG_SUBCATEGORY, VARCHAR, true], [16: TAG_TYPE, VARCHAR, true], [15: TAG_BRAND, VARCHAR, true], [20: TAG_SKU, VARCHAR, true]
  |  cardinality: 380372
  |  column statistics: 
  |  * TAG_GROUP-->[-Infinity, Infinity, 0.0, 6.0, 1.0] ESTIMATE
  |  * TAG_CATEGORY-->[-Infinity, Infinity, 0.0, 4.0, 1.0] ESTIMATE
  |  * TAG_SUBCATEGORY-->[-Infinity, Infinity, 0.14285714285714285, 9.184868810453802, 6.0] ESTIMATE
  |  * TAG_BRAND-->[-Infinity, Infinity, 0.0015174506828528073, 8.502326957883204, 658.0] ESTIMATE
  |  * TAG_TYPE-->[-Infinity, Infinity, 0.04, 5.496174603043697, 24.0] ESTIMATE
  |  * TAG_SKU-->[-Infinity, Infinity, 5.408328826392645E-4, 9.391695272557946, 1848.0] ESTIMATE
  |  * COUNTRY-->[-Infinity, Infinity, 0.0, 11.0, 1.0] ESTIMATE
  |  * sum-->[0.0, 5067988.209488497, 0.0, 8.0, 1413.0] ESTIMATE
  |  
  1:Project
  |  output columns:
  |  12 <-> [61: TAG_GROUP, VARCHAR, true]
  |  13 <-> [62: TAG_CATEGORY, VARCHAR, true]
  |  14 <-> [63: TAG_SUBCATEGORY, VARCHAR, true]
  |  15 <-> [65: TAG_BRAND, VARCHAR, true]
  |  16 <-> [64: TAG_TYPE, VARCHAR, true]
  |  20 <-> [66: TAG_SKU, VARCHAR, true]
  |  52 <-> [59: COUNTRY, VARCHAR, false]
  |  57 <-> cast([67: SALES, INT, false] as DOUBLE) * cast([68: TAG_VOLUME, FLOAT, true] as DOUBLE)
  |  cardinality: 1187629
  |  column statistics: 
  |  * TAG_GROUP-->[-Infinity, Infinity, 0.0, 6.0, 1.0] ESTIMATE
  |  * TAG_CATEGORY-->[-Infinity, Infinity, 0.0, 4.0, 1.0] ESTIMATE
  |  * TAG_SUBCATEGORY-->[-Infinity, Infinity, 0.0020633670979066897, 9.184868810453802, 6.0] ESTIMATE
  |  * TAG_BRAND-->[-Infinity, Infinity, 0.016956405065764475, 8.502326957883204, 658.0] ESTIMATE
  |  * TAG_TYPE-->[-Infinity, Infinity, 0.008757494574343704, 5.496174603043697, 24.0] ESTIMATE
  |  * TAG_SKU-->[-Infinity, Infinity, 0.023504939075954114, 9.391695272557946, 1848.0] ESTIMATE
  |  * COUNTRY-->[-Infinity, Infinity, 0.0, 11.0, 1.0] ESTIMATE
  |  * expr-->[0.0, 18826.5, 0.0, 8.0, 1413.0] ESTIMATE
  |  
  0:OlapScanNode
     table: partition_flat_consumptions_partition, rollup: partition_flat_consumptions_partition
     preAggregation: on
     Predicates: [61: TAG_GROUP, VARCHAR, true] = 'Drinks', [62: TAG_CATEGORY, VARCHAR, true] = 'Bier', [59: COUNTRY, VARCHAR, false] = 'Netherlands', [72: INCLUDED_IN_LIKE_FOR_LIKE, TINYINT, false] = 1, [70: EXCLUDE_FROM_BENCHMARK, TINYINT, false] = 0, cast([71: TAGS_CONFORMED_TO_HIERARCHY, VARCHAR, true] as DOUBLE) = 1.0, date_trunc[('month', [73: LOCAL_ORDERED_DATE, DATE, false]); args: VARCHAR,DATE; result: DATE; args nullable: false; result nullable: true] <= '2023-05-31', [73: LOCAL_ORDERED_DATE, DATE, false] >= '2023-04-01', 69: VENUE_CLUSTER IN (1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11)
     partitionsRatio=1/101, tabletsRatio=6/6
     tabletList=72894,72896,72898,72900,72902,72904
     actualRows=0, avgRowSize=81.575066
     MaterializedView: true
     cardinality: 1187629
     column statistics: 
     * VENUE_ID-->[12.0, 12160.0, 0.0, 4.0, 1054.8999999999999] ESTIMATE
     * SALES-->[1.0, 12411.0, 0.0, 4.0, 430.0] ESTIMATE
     * TAG_GROUP-->[-Infinity, Infinity, 0.0, 6.0, 1.0] ESTIMATE
     * TAG_CATEGORY-->[-Infinity, Infinity, 0.0, 4.0, 1.0] ESTIMATE
     * TAG_SUBCATEGORY-->[-Infinity, Infinity, 0.0020633670979066897, 9.184868810453802, 6.0] ESTIMATE
     * TAG_BRAND-->[-Infinity, Infinity, 0.016956405065764475, 8.502326957883204, 658.0] ESTIMATE
     * TAG_TYPE-->[-Infinity, Infinity, 0.008757494574343704, 5.496174603043697, 24.0] ESTIMATE
     * TAG_VOLUME-->[0.0, 135.0, 0.0, 8.0, 260.0] ESTIMATE
     * TAG_SKU-->[-Infinity, Infinity, 0.023504939075954114, 9.391695272557946, 1848.0] ESTIMATE
     * VENUE_ID-->[12.0, 12160.0, 0.0, 4.0, 1054.8999999999999] ESTIMATE
     * COUNTRY-->[-Infinity, Infinity, 0.0, 11.0, 1.0] ESTIMATE
     * expr-->[0.0, 18826.5, 0.0, 8.0, 1413.0] ESTIMATE

	at com.starrocks.sql.plan.ReplayFromDumpTest.testCBONestedMvRewriteMonth(ReplayFromDumpTest.java:822)

java.lang.AssertionError
	at com.starrocks.sql.plan.ReplayFromDumpTest.testQueryCacheSetOperator(ReplayFromDumpTest.java:952)