RWM Console cluster: risingwave.platform.svc.cluster.local

← cluster RW health await trees
Await trees
Where each streaming actor is parked in the current barrier. A long wait deep in a tree is a stall; long-lived background loops (a decoupled sink's log reader) are dimmed, not flagged.
1624 actors 0 stalled > 1s 504ms worst current barrier barriers flowing
504ms parties · Source 2 actors actor 32543
Epoch 11231927239573504 504ms
Dml 7F1F00000002 504ms
Source 7F1F00002717 504ms
504ms fee_transactions_dm · Source 2 actors actor 32588
Epoch 11231927239573504 504ms
Dml 7F4C00000002 504ms
Source 7F4C00002717 504ms
504ms transaction_types_dm · Source 2 actors actor 32590
Epoch 11231927239573504 504ms
Dml 7F4E00000002 504ms
Source 7F4E00002717 504ms
504ms fixed_deposit_accounts_ft · Source 2 actors actor 32628
Epoch 11231927239573504 504ms
Dml 7F7400000002 504ms
Source 7F7400002717 504ms
504ms accruals_ft · Source 2 actors actor 32679
Epoch 11231927239573504 504ms
Dml 7FA700000002 504ms
Source 7FA700002717 504ms
504ms accounts_to_clients_dm · Source 2 actors actor 32684
Epoch 11231927239573504 504ms
Dml 7FAC00000002 504ms
Source 7FAC00002717 504ms
504ms _rwm_migrations · Source 2 actors actor 32688
Epoch 11231927239573504 504ms
Dml 7FB000000001 504ms
Source 7FB000002715 504ms
504ms asset_snapshots_ft · Source 2 actors actor 32759
Epoch 11231927239573504 504ms
Dml 7FF700000002 504ms
Source 7FF700002717 504ms
504ms asset_adjusted_prices_ft · Source 2 actors actor 32800
Epoch 11231927239573504 504ms
Dml 802000000002 504ms
Source 802000002717 504ms
504ms benchmark_values_ft · Source 2 actors actor 32810
Epoch 11231927239573504 504ms
Dml 802A00000002 504ms
Source 802A00002717 504ms
504ms asset_prices_eod_ft · Source 2 actors actor 32966
Epoch 11231927239573504 504ms
Dml 80C600000002 504ms
Source 80C600002717 504ms
504ms active_parties_to_accounts_mv · Now 2 actors actor 33094
Epoch 11231927239573504 504ms
Now 8146000027D8 504ms
504ms parties · CdcFilter 1 actor actor 32520
Epoch 11231927239573504 504ms
CdcFilter 7F0800002723 504ms
Merge 7F0800000000 504ms
LocalInput (actor 32522) 504ms
504ms benchmark_constituents_ft · CdcFilter 1 actor actor 32525
Epoch 11231927239573504 504ms
CdcFilter 7F0D00002725 504ms
Merge 7F0D00000000 504ms
LocalInput (actor 32524) 504ms
504ms assets_dm · CdcFilter 1 actor actor 32527
Epoch 11231927239573504 504ms
CdcFilter 7F0F00002723 504ms
Merge 7F0F00000000 504ms
LocalInput (actor 32524) 504ms
504ms foreign_exchange_rates_eod_ft · CdcFilter 1 actor actor 32533
Epoch 11231927239573504 504ms
CdcFilter 7F1500002723 504ms
Merge 7F1500000000 504ms
LocalInput (actor 32524) 504ms
504ms parties · StreamCdcScan 1 actor actor 32542
Epoch 11231927239573504 504ms
StreamCdcScan 7F1E00002715 504ms
Merge 7F1E00002724 504ms
LocalInput (actor 32520) 504ms
504ms taxonomy_dimensions_dm · StreamCdcScan 1 actor actor 32730
Epoch 11231927239573504 504ms
StreamCdcScan 7FDA00002715 504ms
Merge 7FDA00002724 504ms
LocalInput (actor 32531) 504ms
504ms benchmark_values_ft · StreamCdcScan 1 actor actor 32809
Epoch 11231927239573504 504ms
StreamCdcScan 802900002715 504ms
Merge 802900002726 504ms
LocalInput (actor 32529) 504ms
500ms transactions_merged_mv · StreamScan 11 actors actor 32969
Epoch 11231927239573504 500ms
StreamScan 80C9000029F0 500ms
LocalInput (actor 32723) 500ms
500ms party_to_account_groups_mv · StreamScan 10 actors actor 33470
Epoch 11231927239573504 500ms
Project 82BE00000002 500ms
Filter 82BE00000001 500ms
StreamScan 82BE0000294E 500ms
LocalInput (actor 32540) 500ms
LocalInput (actor 32541) 500ms
500ms position_values_mv · StreamScan 8 actors actor 33886
Epoch 11231927239573504 500ms
StreamScan 845E000027CD 500ms
LocalInput (actor 32890) 500ms
LocalInput (actor 32891) 500ms
500ms asset_distributions_for_consumers_mv · StreamScan 6 actors actor 33071
Epoch 11231927239573504 500ms
StreamScan 812F0000277F 500ms
LocalInput (actor 32648) 500ms
LocalInput (actor 32647) 500ms
500ms abor_settlement_positions_mv · StreamScan 6 actors actor 32887
Epoch 11231927239573504 500ms
StreamScan 80770000281F 500ms
Merge 807700000000 500ms
LocalInput (actor 32891) 500ms
500ms settled_position_series_mv · StreamScan 4 actors actor 32881
Epoch 11231927239573504 500ms
StreamScan 80710000279C 500ms
Merge 807100000000 500ms
LocalInput (actor 32891) 500ms
500ms benchmark_values_by_asset_sink__rwm_shim · StreamScan 4 actors actor 33269
Epoch 11231927239573504 500ms
Project 81F500000003 500ms
Filter 81F500000002 500ms
StreamScan 81F50000275D 500ms
LocalInput (actor 32817) 500ms
LocalInput (actor 32816) 500ms
500ms _rwm_function_checksums · Source 2 actors actor 32485
Epoch 11231927239573504 500ms
Dml 7EE500000001 500ms
Source 7EE500002715 500ms
500ms subscription_progress · Source 2 actors actor 32516
Epoch 11231927239573504 500ms
Dml 7F0400000001 500ms
Source 7F0400002715 500ms
500ms parties · UpstreamSinkUnion 2 actors actor 32541
Epoch 11231927239573504 500ms
Materialize 7F1D00000005 500ms
Union 7F1D00000004 500ms
Merge 7F1D00000001 500ms
LocalInput (actor 32542) 500ms
UpstreamSinkUnion 7F1D0000271B 500ms
Merge 7F1D00000003 500ms
LocalInput (actor 32543) 500ms
LocalInput (actor 32544) 500ms
500ms portfolios_dm · Source 2 actors actor 32553
Epoch 11231927239573504 500ms
Dml 7F2900000002 500ms
Source 7F2900002717 500ms
500ms accounts_dm · Source 2 actors actor 32560
Epoch 11231927239573504 500ms
Dml 7F3000000002 500ms
Source 7F3000002717 500ms
500ms account_to_portfolios_dm · Source 2 actors actor 32567
Epoch 11231927239573504 500ms
Dml 7F3700000002 500ms
Source 7F3700002717 500ms
500ms clients_portfolios_dm · Source 2 actors actor 32573
Epoch 11231927239573504 500ms
Dml 7F3D00000002 500ms
Source 7F3D00002717 500ms
500ms private_assets_dm · Source 2 actors actor 32577
Epoch 11231927239573504 500ms
Dml 7F4100000002 500ms
Source 7F4100002717 500ms
500ms teams_dm · Source 2 actors actor 32595
Epoch 11231927239573504 500ms
Dml 7F5300000002 500ms
Source 7F5300002717 500ms
500ms private_holdings_dm · Source 2 actors actor 32602
Epoch 11231927239573504 500ms
Dml 7F5A00000002 500ms
Source 7F5A00002717 500ms
500ms teams_memberships_dm · Source 2 actors actor 32608
Epoch 11231927239573504 500ms
Dml 7F6000000002 500ms
Source 7F6000002717 500ms
500ms party_involvements_dm · Source 2 actors actor 32612
Epoch 11231927239573504 500ms
Dml 7F6400000002 500ms
Source 7F6400002717 500ms
500ms transactions_intraday_dm · Source 2 actors actor 32620
Epoch 11231927239573504 500ms
Dml 7F6C00000002 500ms
Source 7F6C00002717 500ms
500ms entity_to_teams_dm · Source 2 actors actor 32625
Epoch 11231927239573504 500ms
Dml 7F7100000002 500ms
Source 7F7100002717 500ms
500ms service_types_dm · Source 2 actors actor 32633
Epoch 11231927239573504 500ms
Dml 7F7900000002 500ms
Source 7F7900002717 500ms
500ms users_dm · Source 2 actors actor 32638
Epoch 11231927239573504 500ms
Dml 7F7E00000002 500ms
Source 7F7E00002717 500ms
500ms clients_dm · Source 2 actors actor 32641
Epoch 11231927239573504 500ms
Dml 7F8100000002 500ms
Source 7F8100002717 500ms
500ms taxonomy_nodes_dm · Source 2 actors actor 32645
Epoch 11231927239573504 500ms
Dml 7F8500000002 500ms
Source 7F8500002717 500ms
500ms asset_distributions_dm · UpstreamSinkUnion 2 actors actor 32647
Epoch 11231927239573504 500ms
Materialize 7F8700000005 500ms
Union 7F8700000004 500ms
Merge 7F8700000003 500ms
LocalInput (actor 32692) 500ms
LocalInput (actor 32691) 500ms
Merge 7F8700000001 500ms
LocalInput (actor 32649) 500ms
UpstreamSinkUnion 7F870000271B 500ms
500ms investment_accounts_ft · Source 2 actors actor 32669
Epoch 11231927239573504 500ms
Dml 7F9D00000002 500ms
Source 7F9D00002717 500ms
500ms product_types_dm · Source 2 actors actor 32673
Epoch 11231927239573504 500ms
Dml 7FA100000002 500ms
Source 7FA100002717 500ms
500ms _rwm_migrations · UpstreamSinkUnion 2 actors actor 32685
Epoch 11231927239573504 500ms
Materialize 7FAD00000005 500ms
Filter 7FAD00000004 500ms
Union 7FAD00000003 500ms
Merge 7FAD00000002 500ms
LocalInput (actor 32688) 500ms
LocalInput (actor 32687) 500ms
UpstreamSinkUnion 7FAD00002718 500ms
500ms asset_distributions_dm · Source 2 actors actor 32691
Epoch 11231927239573504 500ms
Dml 7FB300000002 500ms
Source 7FB300002717 500ms
500ms holding_values_raw_ft · Source 2 actors actor 32711
Epoch 11231927239573504 500ms
Dml 7FC700000002 500ms
Source 7FC700002717 500ms
500ms foreign_exchange_rates_eod_ft · Source 2 actors actor 32715
Epoch 11231927239573504 500ms
Dml 7FCB00000002 500ms
Source 7FCB00002717 500ms
500ms tasks_dm · Source 2 actors actor 32724
Epoch 11231927239573504 500ms
Dml 7FD400000002 500ms
Source 7FD400002717 500ms
500ms taxonomy_dimensions_dm · Source 2 actors actor 32732
Epoch 11231927239573504 500ms
Dml 7FDC00000002 500ms
Source 7FDC00002717 500ms
500ms asset_snapshots_ft · UpstreamSinkUnion 2 actors actor 32738
Epoch 11231927239573504 500ms
Materialize 7FE200000006 500ms
WatermarkFilter 7FE200000005 500ms
Union 7FE200000004 500ms
Merge 7FE200000001 500ms
LocalInput (actor 32757) 500ms
Merge 7FE200000003 500ms
LocalInput (actor 32758) 500ms
LocalInput (actor 32759) 500ms
UpstreamSinkUnion 7FE20000271B 500ms
500ms orders · Source 2 actors actor 32739
Epoch 11231927239573504 500ms
Dml 7FE300000002 500ms
Source 7FE300002717 500ms
500ms benchmark_constituents_ft · Source 2 actors actor 32767
Epoch 11231927239573504 500ms
Dml 7FFF00000002 500ms
Source 7FFF00002717 500ms
500ms benchmarks_dm · Source 2 actors actor 32819
Epoch 11231927239573504 500ms
Dml 803300000002 500ms
Source 803300002717 500ms
500ms assets_sink · StreamScan 2 actors actor 32885
Epoch 11231927239573504 500ms
Sink 807500000003 500ms
consume_log (sink_id 20048) background loop alive 468211.9s
log_reader_next_item alive 500ms
Wait Next Item from Buffer alive 500ms
Wait For New Buffer Item alive 500ms
Project 807500000002 500ms
Filter 807500000001 500ms
StreamScan 80750000273B 500ms
Merge 807500000000 500ms
LocalInput (actor 32891) 500ms
500ms assets_dm · Source 2 actors actor 32897
Epoch 11231927239573504 500ms
Dml 808100000002 500ms
Source 808100002717 500ms
500ms reference_identifiers · Source 2 actors actor 32910
Epoch 11231927239573504 500ms
Dml 808E00000002 500ms
Source 808E00002717 500ms
500ms customer_relationships · Source 2 actors actor 33036
Epoch 11231927239573504 500ms
Dml 810C00000002 500ms
Source 810C00002717 500ms
500ms active_parties_to_portfolios_mv · Now 2 actors actor 33167
Epoch 11231927239573504 500ms
Now 818F000027C3 500ms
500ms team_to_parties_mv · Now 2 actors actor 33242
Epoch 11231927239573504 500ms
Now 81DA0000281D 500ms
500ms lifecycle_profiles · CdcFilter 1 actor actor 32518
Epoch 11231927239573504 500ms
CdcFilter 7F0600002723 500ms
Merge 7F0600000000 500ms
LocalInput (actor 32522) 500ms
500ms customer_relationships · CdcFilter 1 actor actor 32519
Epoch 11231927239573504 500ms
CdcFilter 7F0700002723 500ms
Merge 7F0700000000 500ms
LocalInput (actor 32522) 500ms
500ms reference_identifiers · CdcFilter 1 actor actor 32521
Epoch 11231927239573504 500ms
CdcFilter 7F0900002723 500ms
Merge 7F0900000000 500ms
LocalInput (actor 32522) 500ms
500ms party_source · receive_barrier 1 actor actor 32522
Epoch 11231927239573504 500ms
Source 7F0A00002712 500ms
receive_barrier 500ms
500ms asset_distributions_dm · CdcFilter 1 actor actor 32523
Epoch 11231927239573504 500ms
CdcFilter 7F0B00002723 500ms
Merge 7F0B00000000 500ms
LocalInput (actor 32524) 500ms
500ms asset_service_source · receive_barrier 1 actor actor 32524
Epoch 11231927239573504 500ms
Source 7F0C00002712 500ms
receive_barrier 500ms
500ms asset_snapshots_ft · CdcFilter 1 actor actor 32526
Epoch 11231927239573504 500ms
CdcFilter 7F0E00002725 500ms
Merge 7F0E00000000 500ms
LocalInput (actor 32524) 500ms
500ms asset_prices_eod_ft · CdcFilter 1 actor actor 32528
Epoch 11231927239573504 500ms
CdcFilter 7F1000002725 500ms
Merge 7F1000000000 500ms
LocalInput (actor 32524) 500ms
500ms benchmark_values_ft · CdcFilter 1 actor actor 32529
Epoch 11231927239573504 500ms
CdcFilter 7F1100002725 500ms
Merge 7F1100000000 500ms
LocalInput (actor 32524) 500ms
500ms taxonomy_dimensions_dm · CdcFilter 1 actor actor 32531
Epoch 11231927239573504 500ms
CdcFilter 7F1300002723 500ms
Merge 7F1300000000 500ms
LocalInput (actor 32524) 500ms
500ms benchmarks_dm · CdcFilter 1 actor actor 32534
Epoch 11231927239573504 500ms
CdcFilter 7F1600002723 500ms
Merge 7F1600000000 500ms
LocalInput (actor 32524) 500ms
500ms asset_distributions_dm · StreamCdcScan 1 actor actor 32649
Epoch 11231927239573504 500ms
StreamCdcScan 7F8900002715 500ms
Merge 7F8900002724 500ms
LocalInput (actor 32523) 500ms
500ms accruals_ft · StreamCdcScan 1 actor actor 32677
Epoch 11231927239573504 500ms
StreamCdcScan 7FA500002715 500ms
Merge 7FA500002726 500ms
LocalInput (actor 32494) 500ms
500ms active_transaction_status_id_mv · Values 1 actor actor 32723
Epoch 11231927239573504 500ms
Materialize 7FD300000002 500ms
Project 7FD300000001 500ms
Values 7FD300002724 500ms
500ms benchmark_constituents_ft · StreamCdcScan 1 actor actor 32762
Epoch 11231927239573504 500ms
StreamCdcScan 7FFA00002715 500ms
Merge 7FFA00002726 500ms
LocalInput (actor 32525) 500ms
500ms active_clients_portfolios_mv · Now 1 actor actor 32769
Epoch 11231927239573504 500ms
Now 800100002743 500ms
500ms active_entity_to_teams_mv · Now 1 actor actor 32863
Epoch 11231927239573504 500ms
Now 805F00002743 500ms
500ms customer_relationships · StreamCdcScan 1 actor actor 33034
Epoch 11231927239573504 500ms
StreamCdcScan 810A00002715 500ms
Merge 810A00002724 500ms
LocalInput (actor 32519) 500ms
496ms flow_values_mv · StreamScan 22 actors actor 33762
Epoch 11231927239573504 496ms
Filter 83E20000002E 496ms
StreamScan 83E200002A70 496ms
LocalInput (actor 32712) 496ms
LocalInput (actor 32713) 496ms
496ms team_to_tasks_mv · StreamScan 16 actors actor 33566
Epoch 11231927239573504 496ms
Project 831E00000002 496ms
Filter 831E00000001 496ms
StreamScan 831E00002898 496ms
LocalInput (actor 32547) 496ms
LocalInput (actor 32548) 496ms
496ms party_account_via_portfolio_mv · StreamScan 12 actors actor 33254
Epoch 11231927239573504 496ms
Project 81E600000008 496ms
Filter 81E600000007 496ms
StreamScan 81E600002965 496ms
LocalInput (actor 33032) 496ms
LocalInput (actor 33033) 496ms
496ms accruals_agg_mv · StreamScan 8 actors actor 33601
Epoch 11231927239573504 496ms
Filter 83410000000C 496ms
StreamScan 8341000027E1 496ms
LocalInput (actor 32712) 496ms
LocalInput (actor 32713) 496ms
496ms benchmark_values_by_currency_mv · StreamScan 6 actors actor 32827
Epoch 11231927239573504 496ms
Project 803B00000007 496ms
Filter 803B00000006 496ms
StreamScan 803B000027A7 496ms
LocalInput (actor 32817) 496ms
LocalInput (actor 32816) 496ms
496ms benchmark_values_by_distribution_mv · StreamScan 6 actors actor 33077
Epoch 11231927239573504 496ms
Project 813500000008 496ms
Filter 813500000007 496ms
StreamScan 8135000027BD 496ms
LocalInput (actor 32817) 496ms
LocalInput (actor 32816) 496ms
496ms team_to_parties_mv · StreamScan 6 actors actor 33247
Epoch 11231927239573504 496ms
Project 81DF00000017 496ms
Filter 81DF00000016 496ms
StreamScan 81DF000028AD 496ms
LocalInput (actor 32540) 496ms
LocalInput (actor 32541) 496ms
496ms benchmark_twrr_by_asset_mv · StreamScan 6 actors actor 33592
Epoch 11231927239573504 496ms
Project 833800000007 496ms
Filter 833800000006 496ms
StreamScan 8338000027A0 496ms
LocalInput (actor 32817) 496ms
LocalInput (actor 32816) 496ms
496ms holding_values_with_accruals_mv · StreamScan 6 actors actor 33707
Epoch 11231927239573504 496ms
Filter 83AB00000005 496ms
StreamScan 83AB0000277D 496ms
LocalInput (actor 32712) 496ms
LocalInput (actor 32713) 496ms
496ms position_by_asset_mv · StreamScan 6 actors actor 33928
Epoch 11231927239573504 496ms
StreamScan 8488000027D6 496ms
LocalInput (actor 32712) 496ms
LocalInput (actor 32713) 496ms
496ms benchmark_twrr_mv · StreamScan 4 actors actor 32926
Epoch 11231927239573504 496ms
Project 809E00000003 496ms
Filter 809E00000002 496ms
StreamScan 809E00002796 496ms
LocalInput (actor 32817) 496ms
LocalInput (actor 32816) 496ms
496ms settled_cash_series_mv · StreamScan 4 actors actor 32877
Epoch 11231927239573504 496ms
StreamScan 806D0000278D 496ms
Merge 806D00000000 496ms
LocalInput (actor 32891) 496ms
496ms asset_distributions_for_consumers_mv · hash_join_barrier_align 4 actors actor 33056
Epoch 11231927239573504 496ms
HashJoin 812000000005 496ms
hash_join_barrier_align 496ms
Merge 812000000004 496ms
LocalInput (actor 32852) 496ms
LocalInput (actor 32851) 496ms
Merge 812000000001 496ms
LocalInput (actor 33071) 496ms
LocalInput (actor 33072) 496ms
496ms _rwm_function_checksums · UpstreamSinkUnion 2 actors actor 32482
Epoch 11231927239573504 496ms
Materialize 7EE200000005 496ms
Filter 7EE200000004 496ms
Union 7EE200000003 496ms
Merge 7EE200000002 496ms
LocalInput (actor 32484) 496ms
LocalInput (actor 32485) 496ms
UpstreamSinkUnion 7EE200002718 496ms
496ms subscription_progress · UpstreamSinkUnion 2 actors actor 32514
Epoch 11231927239573504 496ms
Materialize 7F0200000005 496ms
Filter 7F0200000004 496ms
Union 7F0200000003 496ms
Merge 7F0200000002 496ms
LocalInput (actor 32516) 496ms
LocalInput (actor 32517) 496ms
UpstreamSinkUnion 7F0200002718 496ms
496ms lifecycle_profiles · UpstreamSinkUnion 2 actors actor 32536
Epoch 11231927239573504 496ms
Materialize 7F1800000005 496ms
Union 7F1800000004 496ms
Merge 7F1800000001 496ms
LocalInput (actor 32537) 496ms
Merge 7F1800000003 496ms
LocalInput (actor 32539) 496ms
LocalInput (actor 32538) 496ms
UpstreamSinkUnion 7F180000271B 496ms
496ms lifecycle_profiles · Source 2 actors actor 32538
Epoch 11231927239573504 496ms
Dml 7F1A00000002 496ms
Source 7F1A00002717 496ms
496ms private_assets_dm · UpstreamSinkUnion 2 actors actor 32574
Epoch 11231927239573504 496ms
Materialize 7F3E00000005 496ms
Union 7F3E00000004 496ms
Merge 7F3E00000003 496ms
LocalInput (actor 32578) 496ms
LocalInput (actor 32577) 496ms
Merge 7F3E00000001 496ms
LocalInput (actor 32576) 496ms
UpstreamSinkUnion 7F3E0000271B 496ms
496ms income_transactions_dm · Source 2 actors actor 32582
Epoch 11231927239573504 496ms
Dml 7F4600000002 496ms
Source 7F4600002717 496ms
496ms taxonomy_nodes_dm · UpstreamSinkUnion 2 actors actor 32642
Epoch 11231927239573504 496ms
Materialize 7F8200000005 496ms
Union 7F8200000004 496ms
Merge 7F8200000001 496ms
LocalInput (actor 32644) 496ms
Merge 7F8200000003 496ms
LocalInput (actor 32645) 496ms
LocalInput (actor 32646) 496ms
UpstreamSinkUnion 7F820000271B 496ms
496ms private_asset_valuations_ft · Source 2 actors actor 32651
Epoch 11231927239573504 496ms
Dml 7F8B00000002 496ms
Source 7F8B00002717 496ms
496ms accruals_ft · UpstreamSinkUnion 2 actors actor 32675
Epoch 11231927239573504 496ms
Materialize 7FA300000006 496ms
WatermarkFilter 7FA300000005 496ms
Union 7FA300000004 496ms
Merge 7FA300000001 496ms
LocalInput (actor 32677) 496ms
UpstreamSinkUnion 7FA30000271B 496ms
Merge 7FA300000003 496ms
LocalInput (actor 32679) 496ms
LocalInput (actor 32678) 496ms
496ms transactions_dm · Source 2 actors actor 32696
Epoch 11231927239573504 496ms
Dml 7FB800000002 496ms
Source 7FB800002717 496ms
496ms foreign_exchange_rates_eod_ft · UpstreamSinkUnion 2 actors actor 32712
Epoch 11231927239573504 496ms
Materialize 7FC800000005 496ms
Union 7FC800000004 496ms
Merge 7FC800000001 496ms
LocalInput (actor 32714) 496ms
Merge 7FC800000003 496ms
LocalInput (actor 32716) 496ms
LocalInput (actor 32715) 496ms
UpstreamSinkUnion 7FC80000271B 496ms
496ms taxonomy_dimensions_dm · UpstreamSinkUnion 2 actors actor 32728
Epoch 11231927239573504 496ms
Materialize 7FD800000005 496ms
Union 7FD800000004 496ms
Merge 7FD800000003 496ms
LocalInput (actor 32731) 496ms
LocalInput (actor 32732) 496ms
UpstreamSinkUnion 7FD80000271B 496ms
Merge 7FD800000001 496ms
LocalInput (actor 32730) 496ms
496ms benchmark_values_ft · UpstreamSinkUnion 2 actors actor 32807
Epoch 11231927239573504 496ms
Materialize 802700000006 496ms
WatermarkFilter 802700000005 496ms
Union 802700000004 496ms
Merge 802700000001 496ms
LocalInput (actor 32809) 496ms
Merge 802700000003 496ms
LocalInput (actor 32810) 496ms
LocalInput (actor 32811) 496ms
UpstreamSinkUnion 80270000271B 496ms
496ms benchmarks_dm · UpstreamSinkUnion 2 actors actor 32816
Epoch 11231927239573504 496ms
Materialize 803000000005 496ms
Union 803000000004 496ms
Merge 803000000001 496ms
LocalInput (actor 32818) 496ms
UpstreamSinkUnion 80300000271B 496ms
Merge 803000000003 496ms
LocalInput (actor 32820) 496ms
LocalInput (actor 32819) 496ms
496ms asset_latest_yield_to_maturity_mv · GroupTopN 2 actors actor 32853
Epoch 11231927239573504 496ms
Materialize 805500000005 496ms
Project 805500000004 496ms
GroupTopN 805500000003 496ms
Merge 805500000002 496ms
LocalInput (actor 32866) 496ms
LocalInput (actor 32867) 496ms
496ms asset_latest_yield_to_maturity_mv · StreamScan 2 actors actor 32866
Epoch 11231927239573504 496ms
Filter 806200000001 496ms
StreamScan 806200002765 496ms
LocalInput (actor 32737) 496ms
LocalInput (actor 32738) 496ms
496ms assets_dm · UpstreamSinkUnion 2 actors actor 32890
Epoch 11231927239573504 496ms
Materialize 807A00000005 496ms
Union 807A00000004 496ms
Merge 807A00000003 496ms
LocalInput (actor 32897) 496ms
LocalInput (actor 32898) 496ms
Merge 807A00000001 496ms
LocalInput (actor 32894) 496ms
UpstreamSinkUnion 807A0000271B 496ms
496ms customer_relationships · UpstreamSinkUnion 2 actors actor 33033
Epoch 11231927239573504 496ms
Materialize 810900000005 496ms
Union 810900000004 496ms
Merge 810900000003 496ms
LocalInput (actor 33035) 496ms
LocalInput (actor 33036) 496ms
Merge 810900000001 496ms
LocalInput (actor 33034) 496ms
UpstreamSinkUnion 81090000271B 496ms
496ms asset_distributions_sink_input_mv · HashAgg 2 actors actor 33233
Epoch 11231927239573504 496ms
Materialize 81D100000004 496ms
Project 81D100000003 496ms
HashAgg 81D100000002 496ms
Merge 81D100000001 496ms
LocalInput (actor 33376) 496ms
LocalInput (actor 33375) 496ms
496ms holding_values_raw_ft · CdcFilter 1 actor actor 32487
Epoch 11231927239573504 496ms
CdcFilter 7EE700002725 496ms
Merge 7EE700000000 496ms
LocalInput (actor 32495) 496ms
496ms accruals_ft · CdcFilter 1 actor actor 32494
Epoch 11231927239573504 496ms
CdcFilter 7EEE00002725 496ms
Merge 7EEE00000000 496ms
LocalInput (actor 32495) 496ms
496ms olap_source · receive_barrier 1 actor actor 32495
Epoch 11231927239573504 496ms
Source 7EEF00002712 496ms
receive_barrier 496ms
496ms taxonomy_nodes_dm · CdcFilter 1 actor actor 32530
Epoch 11231927239573504 496ms
CdcFilter 7F1200002723 496ms
Merge 7F1200000000 496ms
LocalInput (actor 32524) 496ms
496ms asset_adjusted_prices_ft · CdcFilter 1 actor actor 32532
Epoch 11231927239573504 496ms
CdcFilter 7F1400002725 496ms
Merge 7F1400000000 496ms
LocalInput (actor 32524) 496ms
496ms tasks_dm · StreamCdcScan 1 actor actor 32549
Epoch 11231927239573504 496ms
StreamCdcScan 7F2500002715 496ms
Merge 7F2500002724 496ms
LocalInput (actor 32481) 496ms
496ms taxonomy_nodes_dm · StreamCdcScan 1 actor actor 32644
Epoch 11231927239573504 496ms
StreamCdcScan 7F8400002715 496ms
Merge 7F8400002724 496ms
LocalInput (actor 32530) 496ms
496ms orders · StreamCdcScan 1 actor actor 32655
Epoch 11231927239573504 496ms
StreamCdcScan 7F8F00002715 496ms
Merge 7F8F00002726 496ms
LocalInput (actor 32513) 496ms
496ms foreign_exchange_rates_eod_ft · StreamCdcScan 1 actor actor 32714
Epoch 11231927239573504 496ms
StreamCdcScan 7FCA00002715 496ms
Merge 7FCA00002724 496ms
LocalInput (actor 32533) 496ms
496ms asset_snapshots_ft · StreamCdcScan 1 actor actor 32757
Epoch 11231927239573504 496ms
StreamCdcScan 7FF500002715 496ms
Merge 7FF500002726 496ms
LocalInput (actor 32526) 496ms
496ms asset_adjusted_prices_ft · StreamCdcScan 1 actor actor 32798
Epoch 11231927239573504 496ms
StreamCdcScan 801E00002715 496ms
Merge 801E00002726 496ms
LocalInput (actor 32532) 496ms
496ms benchmarks_dm · StreamCdcScan 1 actor actor 32818
Epoch 11231927239573504 496ms
StreamCdcScan 803200002715 496ms
Merge 803200002724 496ms
LocalInput (actor 32534) 496ms
496ms assets_dm · StreamCdcScan 1 actor actor 32894
Epoch 11231927239573504 496ms
StreamCdcScan 807E00002715 496ms
Merge 807E00002724 496ms
LocalInput (actor 32527) 496ms
496ms asset_prices_eod_ft · StreamCdcScan 1 actor actor 32952
Epoch 11231927239573504 496ms
StreamCdcScan 80B800002715 496ms
Merge 80B800002726 496ms
LocalInput (actor 32528) 496ms
496ms settled_position_valuations_mv · Now 1 actor actor 33563
Epoch 11231927239573504 496ms
Now 831B000027E5 496ms
492ms account_groups_mv · StreamScan 40 actors actor 33397
Epoch 11231927239573504 492ms
Project 827500000047 492ms
Filter 827500000046 492ms
StreamScan 827500002B62 492ms
LocalInput (actor 32535) 492ms
LocalInput (actor 32536) 492ms
492ms flow_by_transaction_type_mv · StreamScan 12 actors actor 33858
Epoch 11231927239573504 492ms
StreamScan 8442000028F1 492ms
LocalInput (actor 32712) 492ms
LocalInput (actor 32713) 492ms
492ms active_party_memberships_mv · StreamScan 6 actors actor 32726
Epoch 11231927239573504 492ms
Project 7FD600000002 492ms
Filter 7FD600000001 492ms
StreamScan 7FD6000027A3 492ms
LocalInput (actor 32899) 492ms
LocalInput (actor 32900) 492ms
492ms private_asset_holdings_mv · StreamScan 6 actors actor 32786
Epoch 11231927239573504 492ms
Project 801200000005 492ms
Filter 801200000004 492ms
StreamScan 8012000027A1 492ms
LocalInput (actor 32575) 492ms
LocalInput (actor 32574) 492ms
492ms party_account_direct_mv · StreamScan 6 actors actor 33274
Epoch 11231927239573504 492ms
Project 81FA00000002 492ms
Filter 81FA00000001 492ms
StreamScan 81FA00002821 492ms
LocalInput (actor 32609) 492ms
LocalInput (actor 32610) 492ms
492ms orphan_accruals_mv · StreamScan 6 actors actor 33686
Epoch 11231927239573504 492ms
Filter 839600000006 492ms
StreamScan 83960000278E 492ms
LocalInput (actor 32712) 492ms
LocalInput (actor 32713) 492ms
492ms active_parties_to_accounts_mv · StreamScan 4 actors actor 33114
Epoch 11231927239573504 492ms
Project 815A00000013 492ms
Filter 815A00000012 492ms
StreamScan 815A0000285C 492ms
LocalInput (actor 33032) 492ms
LocalInput (actor 33033) 492ms
492ms active_parties_to_portfolios_mv · StreamScan 4 actors actor 33115
Epoch 11231927239573504 492ms
Project 815B00000013 492ms
Filter 815B00000012 492ms
StreamScan 815B00002849 492ms
LocalInput (actor 33032) 492ms
LocalInput (actor 33033) 492ms
492ms asset_price_with_lag_mv · StreamScan 4 actors actor 33281
Epoch 11231927239573504 492ms
StreamScan 820100002767 492ms
LocalInput (actor 32792) 492ms
LocalInput (actor 32793) 492ms
492ms benchmark_twrr_by_currency_mv · StreamScan 4 actors actor 33662
Epoch 11231927239573504 492ms
Filter 837E00000002 492ms
StreamScan 837E00002758 492ms
LocalInput (actor 32890) 492ms
LocalInput (actor 32891) 492ms
492ms benchmark_twrr_by_distribution_mv · StreamScan 4 actors actor 33632
Epoch 11231927239573504 492ms
StreamScan 836000002761 492ms
LocalInput (actor 32970) 492ms
LocalInput (actor 32971) 492ms
492ms benchmark_twrr_by_asset_type_mv · StreamScan 4 actors actor 33672
Epoch 11231927239573504 492ms
StreamScan 83880000274E 492ms
LocalInput (actor 32890) 492ms
LocalInput (actor 32891) 492ms
492ms flow_by_asset_mv · StreamScan 4 actors actor 33838
Epoch 11231927239573504 492ms
StreamScan 842E000027E7 492ms
LocalInput (actor 32712) 492ms
LocalInput (actor 32713) 492ms
492ms flow_by_distribution_mv · StreamScan 4 actors actor 33881
Epoch 11231927239573504 492ms
StreamScan 845900002777 492ms
LocalInput (actor 32970) 492ms
LocalInput (actor 32971) 492ms
492ms fx_rates_snapshot_mv · GroupTopN 2 actors actor 32545
Epoch 11231927239573504 492ms
Materialize 7F2100000005 492ms
Project 7F2100000004 492ms
GroupTopN 7F2100000003 492ms
Merge 7F2100000002 492ms
LocalInput (actor 32703) 492ms
LocalInput (actor 32702) 492ms
492ms tasks_dm · UpstreamSinkUnion 2 actors actor 32547
Epoch 11231927239573504 492ms
Materialize 7F2300000005 492ms
Union 7F2300000004 492ms
Merge 7F2300000001 492ms
LocalInput (actor 32549) 492ms
Merge 7F2300000003 492ms
LocalInput (actor 32725) 492ms
LocalInput (actor 32724) 492ms
UpstreamSinkUnion 7F230000271B 492ms
492ms party_involvements_dm · UpstreamSinkUnion 2 actors actor 32609
Epoch 11231927239573504 492ms
Materialize 7F6100000005 492ms
Union 7F6100000004 492ms
Merge 7F6100000001 492ms
LocalInput (actor 32611) 492ms
UpstreamSinkUnion 7F610000271B 492ms
Merge 7F6100000003 492ms
LocalInput (actor 32612) 492ms
LocalInput (actor 32613) 492ms
492ms transactions_intraday_dm · UpstreamSinkUnion 2 actors actor 32615
Epoch 11231927239573504 492ms
Materialize 7F6700000005 492ms
Union 7F6700000004 492ms
Merge 7F6700000001 492ms
LocalInput (actor 32616) 492ms
Merge 7F6700000003 492ms
LocalInput (actor 32619) 492ms
LocalInput (actor 32620) 492ms
UpstreamSinkUnion 7F670000271B 492ms
492ms investment_accounts_ft · UpstreamSinkUnion 2 actors actor 32617
Epoch 11231927239573504 492ms
Materialize 7F6900000006 492ms
WatermarkFilter 7F6900000005 492ms
Union 7F6900000004 492ms
Merge 7F6900000003 492ms
LocalInput (actor 32668) 492ms
LocalInput (actor 32669) 492ms
Merge 7F6900000001 492ms
LocalInput (actor 32667) 492ms
UpstreamSinkUnion 7F690000271B 492ms
492ms holding_values_raw_ft · UpstreamSinkUnion 2 actors actor 32626
Epoch 11231927239573504 492ms
Materialize 7F7200000006 492ms
WatermarkFilter 7F7200000005 492ms
Union 7F7200000004 492ms
Merge 7F7200000001 492ms
LocalInput (actor 32709) 492ms
Merge 7F7200000003 492ms
LocalInput (actor 32710) 492ms
LocalInput (actor 32711) 492ms
UpstreamSinkUnion 7F720000271B 492ms
492ms users_dm · UpstreamSinkUnion 2 actors actor 32636
Epoch 11231927239573504 492ms
Materialize 7F7C00000005 492ms
Union 7F7C00000004 492ms
Merge 7F7C00000001 492ms
LocalInput (actor 32637) 492ms
UpstreamSinkUnion 7F7C0000271B 492ms
Merge 7F7C00000003 492ms
LocalInput (actor 32639) 492ms
LocalInput (actor 32638) 492ms
492ms orders · UpstreamSinkUnion 2 actors actor 32653
Epoch 11231927239573504 492ms
Materialize 7F8D00000006 492ms
WatermarkFilter 7F8D00000005 492ms
Union 7F8D00000004 492ms
Merge 7F8D00000001 492ms
LocalInput (actor 32655) 492ms
Merge 7F8D00000003 492ms
LocalInput (actor 32739) 492ms
LocalInput (actor 32740) 492ms
UpstreamSinkUnion 7F8D0000271B 492ms
492ms teams_memberships_dm · UpstreamSinkUnion 2 actors actor 32658
Epoch 11231927239573504 492ms
Materialize 7F9200000005 492ms
Union 7F9200000004 492ms
Merge 7F9200000003 492ms
LocalInput (actor 32607) 492ms
LocalInput (actor 32608) 492ms
Merge 7F9200000001 492ms
LocalInput (actor 32660) 492ms
UpstreamSinkUnion 7F920000271B 492ms
492ms active_party_direct_memberships_mv · HashAgg 2 actors actor 32701
Epoch 11231927239573504 492ms
Materialize 7FBD00000006 492ms
Project 7FBD00000005 492ms
HashAgg 7FBD00000004 492ms
Merge 7FBD00000003 492ms
LocalInput (actor 32721) 492ms
LocalInput (actor 32722) 492ms
492ms fx_rates_snapshot_mv · StreamScan 2 actors actor 32702
Epoch 11231927239573504 492ms
Filter 7FBE00000001 492ms
StreamScan 7FBE0000276A 492ms
LocalInput (actor 32712) 492ms
LocalInput (actor 32713) 492ms
492ms active_party_direct_memberships_mv · StreamScan 2 actors actor 32721
Epoch 11231927239573504 492ms
Project 7FD100000002 492ms
Filter 7FD100000001 492ms
StreamScan 7FD100002749 492ms
LocalInput (actor 32899) 492ms
LocalInput (actor 32900) 492ms
492ms benchmark_constituents_ft · UpstreamSinkUnion 2 actors actor 32760
Epoch 11231927239573504 492ms
Materialize 7FF800000006 480ms
WatermarkFilter 7FF800000005 480ms
Union 7FF800000004 480ms
Merge 7FF800000003 480ms
LocalInput (actor 32768) 480ms
LocalInput (actor 32767) 480ms
UpstreamSinkUnion 7FF80000271B 480ms
Merge 7FF800000001 480ms
LocalInput (actor 32762) 480ms
492ms asset_adjusted_prices_ft · UpstreamSinkUnion 2 actors actor 32792
Epoch 11231927239573504 492ms
Materialize 801800000006 492ms
WatermarkFilter 801800000005 492ms
Union 801800000004 492ms
Merge 801800000003 492ms
LocalInput (actor 32799) 492ms
LocalInput (actor 32800) 492ms
Merge 801800000001 492ms
LocalInput (actor 32798) 492ms
UpstreamSinkUnion 80180000271B 492ms
492ms reference_identifiers · UpstreamSinkUnion 2 actors actor 32899
Epoch 11231927239573504 492ms
Materialize 808300000005 492ms
Union 808300000004 492ms
Merge 808300000001 492ms
LocalInput (actor 32909) 492ms
UpstreamSinkUnion 80830000271B 492ms
Merge 808300000003 492ms
LocalInput (actor 32911) 492ms
LocalInput (actor 32910) 492ms
492ms settled_cost_basis_dedup_mv · GroupTopN 2 actors actor 32904
Epoch 11231927239573504 492ms
Materialize 808800000006 492ms
Project 808800000005 492ms
GroupTopN 808800000004 492ms
Merge 808800000003 488ms
LocalInput (actor 32958) 488ms
LocalInput (actor 32957) 488ms
492ms active_orders_mv · StreamScan 2 actors actor 32959
Epoch 11231927239573504 492ms
Materialize 80BF00000002 492ms
Project 80BF00000001 492ms
StreamScan 80BF0000272A 492ms
LocalInput (actor 32654) 492ms
LocalInput (actor 32653) 492ms
492ms asset_distributions_sink_input_mv · StreamScan 2 actors actor 33375
Epoch 11231927239573504 492ms
StreamScan 825F0000273C 492ms
LocalInput (actor 32970) 492ms
LocalInput (actor 32971) 492ms
492ms party_to_account_groups_mv · Project 2 actors actor 33500
Epoch 11231927239573504 492ms
Project 82DC0000000B 492ms
Merge 82DC0000000A 492ms
LocalInput (actor 33498) 492ms
492ms asset_distributions_sink · Sink 2 actors actor 33575
Epoch 11231927239573504 492ms
Sink 832700000003 492ms
consume_log (sink_id 18671) background loop alive 468211.9s
log_reader_next_item alive 492ms
Wait Next Item from Buffer alive 492ms
Wait For New Buffer Item alive 492ms
Merge 832700000002 492ms
LocalInput (actor 33576) 492ms
LocalInput (actor 33577) 492ms
492ms crm_service_source · receive_barrier 1 actor actor 32480
Epoch 11231927239573504 492ms
Source 7EE000002712 492ms
receive_barrier 492ms
492ms tasks_dm · CdcFilter 1 actor actor 32481
Epoch 11231927239573504 492ms
CdcFilter 7EE100002723 492ms
Merge 7EE100000000 492ms
LocalInput (actor 32480) 492ms
492ms clients_dm · CdcFilter 1 actor actor 32488
Epoch 11231927239573504 492ms
CdcFilter 7EE800002723 492ms
Merge 7EE800000000 492ms
LocalInput (actor 32495) 492ms
492ms transactions_dm · CdcFilter 1 actor actor 32493
Epoch 11231927239573504 492ms
CdcFilter 7EED00002723 492ms
Merge 7EED00000000 492ms
LocalInput (actor 32495) 492ms
492ms private_assets_dm · CdcFilter 1 actor actor 32498
Epoch 11231927239573504 492ms
CdcFilter 7EF200002723 492ms
Merge 7EF200000000 492ms
LocalInput (actor 32495) 492ms
492ms investment_accounts_ft · CdcFilter 1 actor actor 32501
Epoch 11231927239573504 492ms
CdcFilter 7EF500002725 492ms
Merge 7EF500000000 492ms
LocalInput (actor 32495) 492ms
492ms income_transactions_dm · CdcFilter 1 actor actor 32502
Epoch 11231927239573504 492ms
CdcFilter 7EF600002723 492ms
Merge 7EF600000000 492ms
LocalInput (actor 32495) 492ms
492ms fixed_deposit_accounts_ft · CdcFilter 1 actor actor 32507
Epoch 11231927239573504 492ms
CdcFilter 7EFB00002725 492ms
Merge 7EFB00000000 492ms
LocalInput (actor 32495) 492ms
492ms party_involvements_dm · CdcFilter 1 actor actor 32511
Epoch 11231927239573504 492ms
CdcFilter 7EFF00002723 492ms
Merge 7EFF00000000 492ms
LocalInput (actor 32495) 492ms
492ms order_service_source · receive_barrier 1 actor actor 32512
Epoch 11231927239573504 492ms
Source 7F0000002712 492ms
receive_barrier 492ms
492ms orders · CdcFilter 1 actor actor 32513
Epoch 11231927239573504 492ms
CdcFilter 7F0100002725 492ms
Merge 7F0100000000 492ms
LocalInput (actor 32512) 492ms
492ms lifecycle_profiles · StreamCdcScan 1 actor actor 32537
Epoch 11231927239573504 492ms
StreamCdcScan 7F1900002715 492ms
Merge 7F1900002724 492ms
LocalInput (actor 32518) 492ms
492ms accounts_dm · StreamCdcScan 1 actor actor 32559
Epoch 11231927239573504 492ms
StreamCdcScan 7F2F00002715 492ms
Merge 7F2F00002724 492ms
LocalInput (actor 32491) 492ms
492ms private_assets_dm · StreamCdcScan 1 actor actor 32576
Epoch 11231927239573504 492ms
StreamCdcScan 7F4000002715 492ms
Merge 7F4000002724 492ms
LocalInput (actor 32498) 492ms
492ms party_involvements_dm · StreamCdcScan 1 actor actor 32611
Epoch 11231927239573504 492ms
StreamCdcScan 7F6300002715 492ms
Merge 7F6300002724 492ms
LocalInput (actor 32511) 492ms
492ms service_types_dm · StreamCdcScan 1 actor actor 32632
Epoch 11231927239573504 492ms
StreamCdcScan 7F7800002715 492ms
Merge 7F7800002724 492ms
LocalInput (actor 32490) 492ms
492ms investment_accounts_ft · StreamCdcScan 1 actor actor 32667
Epoch 11231927239573504 492ms
StreamCdcScan 7F9B00002715 492ms
Merge 7F9B00002726 492ms
LocalInput (actor 32501) 492ms
492ms holding_values_raw_ft · StreamCdcScan 1 actor actor 32709
Epoch 11231927239573504 492ms
StreamCdcScan 7FC500002715 492ms
Merge 7FC500002726 492ms
LocalInput (actor 32487) 492ms
492ms reference_identifiers · StreamCdcScan 1 actor actor 32909
Epoch 11231927239573504 492ms
StreamCdcScan 808D00002715 492ms
Merge 808D00002724 492ms
LocalInput (actor 32521) 492ms
488ms user_account_membership_mv · StreamScan 22 actors actor 33145
Epoch 11231927239573504 488ms
Project 817900000017 488ms
Filter 817900000016 488ms
StreamScan 817900002BDE 488ms
LocalInput (actor 32570) 488ms
LocalInput (actor 32569) 488ms
488ms client_account_via_portfolio_mv · StreamScan 12 actors actor 32858
Epoch 11231927239573504 488ms
Filter 805A00000001 488ms
StreamScan 805A000029E4 488ms
LocalInput (actor 32565) 488ms
LocalInput (actor 32564) 488ms
488ms party_account_via_portfolio_mv · hash_join_barrier_align 10 actors actor 33244
Epoch 11231927239573504 488ms
HashJoin 81DC0000000D 488ms
hash_join_barrier_align 488ms
Merge 81DC00000009 488ms
LocalInput (actor 33254) 488ms
LocalInput (actor 33253) 488ms
Merge 81DC0000000C 488ms
LocalInput (actor 33255) 488ms
LocalInput (actor 33256) 488ms
488ms team_to_portfolios_mv · StreamScan 10 actors actor 33346
Epoch 11231927239573504 488ms
Project 824200000005 488ms
Filter 824200000004 488ms
StreamScan 824200002809 488ms
LocalInput (actor 32570) 488ms
LocalInput (actor 32569) 488ms
488ms settled_position_valuations_mv · StreamScan 8 actors actor 33578
Epoch 11231927239573504 488ms
Filter 832A0000000E 488ms
StreamScan 832A00002835 488ms
LocalInput (actor 32546) 488ms
LocalInput (actor 32545) 488ms
488ms investment_account_purchasing_power_mv · StreamScan 6 actors actor 33183
Epoch 11231927239573504 488ms
Filter 819F00000006 488ms
StreamScan 819F0000278C 488ms
LocalInput (actor 32546) 488ms
LocalInput (actor 32545) 488ms
488ms private_asset_valuations_mv · StreamScan 6 actors actor 33229
Epoch 11231927239573504 488ms
Filter 81CD00000004 488ms
StreamScan 81CD000027B4 488ms
LocalInput (actor 32546) 488ms
LocalInput (actor 32545) 488ms
488ms position_snapshot_mv · StreamScan 6 actors actor 33884
Epoch 11231927239573504 488ms
StreamScan 845C000027DA 488ms
LocalInput (actor 32546) 488ms
LocalInput (actor 32545) 488ms
488ms portfolios_sink · StreamScan 4 actors actor 32795
Epoch 11231927239573504 488ms
StreamScan 801B0000275F 488ms
LocalInput (actor 32630) 488ms
LocalInput (actor 32631) 488ms
488ms user_to_clients_mv · StreamScan 4 actors actor 32918
Epoch 11231927239573504 488ms
Project 809600000002 488ms
Filter 809600000001 488ms
StreamScan 809600002771 488ms
LocalInput (actor 32659) 488ms
LocalInput (actor 32658) 488ms
488ms user_to_portfolios_mv · StreamScan 4 actors actor 32938
Epoch 11231927239573504 488ms
Project 80AA00000002 488ms
Filter 80AA00000001 488ms
StreamScan 80AA00002771 488ms
LocalInput (actor 32659) 488ms
LocalInput (actor 32658) 488ms
488ms user_team_memberships_mv · StreamScan 4 actors actor 32946
Epoch 11231927239573504 488ms
Project 80B200000002 488ms
Filter 80B200000001 488ms
StreamScan 80B200002764 488ms
LocalInput (actor 32659) 488ms
LocalInput (actor 32658) 488ms
488ms client_account_direct_mv · StreamScan 4 actors actor 33020
Epoch 11231927239573504 488ms
Filter 80FC00000001 488ms
StreamScan 80FC00002846 488ms
LocalInput (actor 32680) 488ms
LocalInput (actor 32681) 488ms
488ms portfolio_account_group_types_mv · StreamScan 4 actors actor 33086
Epoch 11231927239573504 488ms
Filter 813E00000001 488ms
StreamScan 813E00002894 488ms
LocalInput (actor 32565) 488ms
LocalInput (actor 32564) 488ms
488ms active_parties_to_accounts_mv · Filter 4 actors actor 33106
Epoch 11231927239573504 488ms
Project 81520000000B 488ms
DynamicFilter 81520000000A 488ms
Merge 815200000009 488ms
LocalInput (actor 33094) 488ms
Project 815200000008 488ms
Filter 815200000007 488ms
Merge 815200000006 488ms
LocalInput (actor 33102) 488ms
488ms asset_distributions_week_binned_mv · StreamScan 4 actors actor 33904
Epoch 11231927239573504 488ms
Project 847000000001 488ms
StreamScan 847000002776 488ms
LocalInput (actor 32970) 488ms
LocalInput (actor 32971) 488ms
488ms portfolios_dm · UpstreamSinkUnion 2 actors actor 32550
Epoch 11231927239573504 488ms
Materialize 7F2600000005 488ms
Union 7F2600000004 488ms
Merge 7F2600000001 488ms
LocalInput (actor 32552) 488ms
Merge 7F2600000003 488ms
LocalInput (actor 32554) 488ms
LocalInput (actor 32553) 488ms
UpstreamSinkUnion 7F260000271B 488ms
488ms transaction_types_dm · UpstreamSinkUnion 2 actors actor 32555
Epoch 11231927239573504 488ms
Materialize 7F2B00000005 488ms
Union 7F2B00000004 488ms
Merge 7F2B00000001 488ms
LocalInput (actor 32589) 488ms
Merge 7F2B00000003 488ms
LocalInput (actor 32591) 488ms
LocalInput (actor 32590) 488ms
UpstreamSinkUnion 7F2B0000271B 488ms
488ms accounts_dm · UpstreamSinkUnion 2 actors actor 32557
Epoch 11231927239573504 488ms
Materialize 7F2D00000005 488ms
Union 7F2D00000004 488ms
Merge 7F2D00000001 488ms
LocalInput (actor 32559) 488ms
Merge 7F2D00000003 488ms
LocalInput (actor 32561) 488ms
LocalInput (actor 32560) 488ms
UpstreamSinkUnion 7F2D0000271B 488ms
488ms asset_prices_eod_ft · UpstreamSinkUnion 2 actors actor 32562
Epoch 11231927239573504 488ms
Materialize 7F3200000006 476ms
WatermarkFilter 7F3200000005 476ms
Union 7F3200000004 476ms
Merge 7F3200000001 476ms
LocalInput (actor 32952) 476ms
Merge 7F3200000003 476ms
LocalInput (actor 32965) 476ms
LocalInput (actor 32966) 476ms
UpstreamSinkUnion 7F320000271B 476ms
488ms account_to_portfolios_dm · UpstreamSinkUnion 2 actors actor 32564
Epoch 11231927239573504 488ms
Materialize 7F3400000005 488ms
Union 7F3400000004 488ms
Merge 7F3400000001 488ms
LocalInput (actor 32566) 488ms
UpstreamSinkUnion 7F340000271B 488ms
Merge 7F3400000003 488ms
LocalInput (actor 32568) 488ms
LocalInput (actor 32567) 488ms
488ms clients_portfolios_dm · UpstreamSinkUnion 2 actors actor 32569
Epoch 11231927239573504 488ms
Materialize 7F3900000005 488ms
Union 7F3900000004 488ms
Merge 7F3900000001 488ms
LocalInput (actor 32571) 488ms
Merge 7F3900000003 488ms
LocalInput (actor 32572) 488ms
LocalInput (actor 32573) 488ms
UpstreamSinkUnion 7F390000271B 488ms
488ms income_transactions_dm · UpstreamSinkUnion 2 actors actor 32580
Epoch 11231927239573504 488ms
Materialize 7F4400000005 488ms
Union 7F4400000004 488ms
Merge 7F4400000001 488ms
LocalInput (actor 32581) 488ms
Merge 7F4400000003 488ms
LocalInput (actor 32583) 488ms
LocalInput (actor 32582) 488ms
UpstreamSinkUnion 7F440000271B 488ms
488ms fee_transactions_dm · UpstreamSinkUnion 2 actors actor 32584
Epoch 11231927239573504 488ms
Materialize 7F4800000005 488ms
Union 7F4800000004 488ms
Merge 7F4800000001 488ms
LocalInput (actor 32586) 488ms
Merge 7F4800000003 488ms
LocalInput (actor 32588) 488ms
LocalInput (actor 32587) 488ms
UpstreamSinkUnion 7F480000271B 488ms
488ms teams_dm · UpstreamSinkUnion 2 actors actor 32593
Epoch 11231927239573504 488ms
Materialize 7F5100000005 488ms
Union 7F5100000004 488ms
Merge 7F5100000001 488ms
LocalInput (actor 32594) 488ms
Merge 7F5100000003 488ms
LocalInput (actor 32596) 488ms
LocalInput (actor 32595) 488ms
UpstreamSinkUnion 7F510000271B 488ms
488ms private_asset_valuations_ft · UpstreamSinkUnion 2 actors actor 32597
Epoch 11231927239573504 488ms
Materialize 7F5500000005 488ms
Union 7F5500000004 488ms
Merge 7F5500000001 488ms
LocalInput (actor 32650) 488ms
UpstreamSinkUnion 7F550000271B 488ms
Merge 7F5500000003 488ms
LocalInput (actor 32651) 488ms
LocalInput (actor 32652) 488ms
488ms private_holdings_dm · UpstreamSinkUnion 2 actors actor 32599
Epoch 11231927239573504 488ms
Materialize 7F5700000005 488ms
Union 7F5700000004 488ms
Merge 7F5700000001 488ms
LocalInput (actor 32601) 488ms
UpstreamSinkUnion 7F570000271B 488ms
Merge 7F5700000003 488ms
LocalInput (actor 32603) 488ms
LocalInput (actor 32602) 488ms
488ms clients_dm · UpstreamSinkUnion 2 actors actor 32604
Epoch 11231927239573504 488ms
Materialize 7F5C00000005 488ms
Union 7F5C00000004 488ms
Merge 7F5C00000001 488ms
LocalInput (actor 32606) 488ms
Merge 7F5C00000003 488ms
LocalInput (actor 32640) 488ms
LocalInput (actor 32641) 488ms
UpstreamSinkUnion 7F5C0000271B 488ms
488ms entity_to_teams_dm · UpstreamSinkUnion 2 actors actor 32622
Epoch 11231927239573504 488ms
Materialize 7F6E00000005 488ms
Union 7F6E00000004 488ms
Merge 7F6E00000001 488ms
LocalInput (actor 32623) 488ms
Merge 7F6E00000003 488ms
LocalInput (actor 32624) 488ms
LocalInput (actor 32625) 488ms
UpstreamSinkUnion 7F6E0000271B 488ms
488ms service_types_dm · UpstreamSinkUnion 2 actors actor 32630
Epoch 11231927239573504 488ms
Materialize 7F7600000005 488ms
Union 7F7600000004 488ms
UpstreamSinkUnion 7F760000271B 488ms
Merge 7F7600000003 488ms
LocalInput (actor 32634) 488ms
LocalInput (actor 32633) 488ms
Merge 7F7600000001 488ms
LocalInput (actor 32632) 488ms
488ms product_types_dm · UpstreamSinkUnion 2 actors actor 32670
Epoch 11231927239573504 488ms
Materialize 7F9E00000005 488ms
Union 7F9E00000004 488ms
Merge 7F9E00000001 488ms
LocalInput (actor 32672) 488ms
Merge 7F9E00000003 488ms
LocalInput (actor 32674) 488ms
LocalInput (actor 32673) 488ms
UpstreamSinkUnion 7F9E0000271B 488ms
488ms accounts_to_clients_dm · UpstreamSinkUnion 2 actors actor 32681
Epoch 11231927239573504 488ms
Materialize 7FA900000005 488ms
Union 7FA900000004 488ms
Merge 7FA900000001 488ms
LocalInput (actor 32682) 488ms
Merge 7FA900000003 488ms
LocalInput (actor 32684) 488ms
LocalInput (actor 32683) 488ms
UpstreamSinkUnion 7FA90000271B 488ms
488ms transactions_dm · UpstreamSinkUnion 2 actors actor 32694
Epoch 11231927239573504 488ms
Materialize 7FB600000005 488ms
Union 7FB600000004 488ms
Merge 7FB600000001 488ms
LocalInput (actor 32695) 488ms
UpstreamSinkUnion 7FB60000271B 488ms
Merge 7FB600000003 488ms
LocalInput (actor 32697) 488ms
LocalInput (actor 32696) 488ms
488ms fixed_deposit_accounts_ft · UpstreamSinkUnion 2 actors actor 32707
Epoch 11231927239573504 488ms
Materialize 7FC300000006 488ms
WatermarkFilter 7FC300000005 488ms
Union 7FC300000004 488ms
Merge 7FC300000001 488ms
LocalInput (actor 32708) 488ms
UpstreamSinkUnion 7FC30000271B 488ms
Merge 7FC300000003 488ms
LocalInput (actor 32628) 488ms
LocalInput (actor 32629) 488ms
488ms account_to_portfolios_sink · Sink 2 actors actor 32745
Epoch 11231927239573504 488ms
Sink 7FE900000004 488ms
consume_log (sink_id 18246) background loop alive 468211.9s
log_reader_next_item alive 488ms
Wait Next Item from Buffer alive 488ms
Wait For New Buffer Item alive 488ms
Merge 7FE900000003 488ms
LocalInput (actor 32736) 488ms
LocalInput (actor 32735) 488ms
488ms open_accounts_mv · StreamScan 2 actors actor 32747
Epoch 11231927239573504 488ms
Materialize 7FEB00000003 488ms
Project 7FEB00000002 488ms
Filter 7FEB00000001 488ms
StreamScan 7FEB0000273D 488ms
LocalInput (actor 32558) 488ms
LocalInput (actor 32557) 488ms
488ms benchmark_twrr_mv · hash_join_barrier_align 2 actors actor 32801
Epoch 11231927239573504 488ms
Materialize 802100000009 488ms
Project 802100000008 488ms
Filter 802100000007 488ms
OverWindow 802100000006 488ms
HashJoin 802100000005 488ms
hash_join_barrier_align 476ms
Merge 802100000004 488ms
LocalInput (actor 32927) 488ms
LocalInput (actor 32926) 488ms
Merge 802100000001 476ms
LocalInput (actor 32806) 476ms
LocalInput (actor 32805) 480ms
488ms benchmark_twrr_sink · StreamScan 2 actors actor 32803
Epoch 11231927239573504 488ms
Sink 802300000002 488ms
consume_log (sink_id 20052) background loop alive 468211.9s
log_reader_next_item alive 488ms
Wait Next Item from Buffer alive 488ms
Wait For New Buffer Item alive 488ms
Filter 802300000001 488ms
StreamScan 802300002732 488ms
Merge 802300000000 488ms
LocalInput (actor 32801) 488ms
488ms active_teams_memberships_mv · StreamScan 2 actors actor 32916
Epoch 11231927239573504 488ms
Materialize 809400000003 488ms
Project 809400000002 488ms
Filter 809400000001 488ms
StreamScan 809400002739 488ms
LocalInput (actor 32659) 488ms
LocalInput (actor 32658) 488ms
488ms settled_cost_basis_dedup_mv · StreamScan 2 actors actor 32957
Epoch 11231927239573504 488ms
Project 80BD00000002 484ms
Filter 80BD00000001 484ms
StreamScan 80BD0000277F 484ms
LocalInput (actor 32627) 484ms
LocalInput (actor 32626) 488ms
488ms active_parties_to_accounts_mv · Union 2 actors actor 33054
Epoch 11231927239573504 488ms
Union 811E00000010 488ms
Merge 811E0000000F 488ms
LocalInput (actor 33103) 488ms
LocalInput (actor 33104) 488ms
Merge 811E0000000C 488ms
LocalInput (actor 33105) 488ms
LocalInput (actor 33106) 488ms
488ms settled_cost_basis_carried_mv · HashAgg 2 actors actor 33109
Epoch 11231927239573504 488ms
Materialize 81550000000A 488ms
Project 815500000009 488ms
HashJoin 815500000008 488ms
hash_join_barrier_align 488ms
Merge 815500000005 488ms
LocalInput (actor 33107) 488ms
Project 815500000007 488ms
HashAgg 815500000006 488ms
Merge 8155FFFFFFFD 488ms
LocalInput (actor 33111) 488ms
488ms settled_cost_basis_carried_mv · StreamScan 2 actors actor 33153
Epoch 11231927239573504 488ms
Project 818100000001 488ms
StreamScan 8181000027B4 488ms
LocalInput (actor 32903) 488ms
LocalInput (actor 32904) 488ms
488ms party_to_account_groups_mv · HashAgg 2 actors actor 33498
Epoch 11231927239573504 488ms
HashJoin 82DA00000009 488ms
hash_join_barrier_align 488ms
Merge 82DA00000003 488ms
LocalInput (actor 33469) 488ms
LocalInput (actor 33470) 488ms
Project 82DA00000008 488ms
HashAgg 82DA00000007 488ms
Merge 82DA00000006 488ms
LocalInput (actor 33472) 488ms
LocalInput (actor 33471) 488ms
488ms asset_distributions_sink · StreamScan 2 actors actor 33576
Epoch 11231927239573504 488ms
Project 832800000001 488ms
StreamScan 83280000272A 488ms
LocalInput (actor 33234) 488ms
LocalInput (actor 33233) 488ms
488ms transaction_types_dm · CdcFilter 1 actor actor 32486
Epoch 11231927239573504 488ms
CdcFilter 7EE600002723 488ms
Merge 7EE600000000 488ms
LocalInput (actor 32495) 488ms
488ms account_to_portfolios_dm · CdcFilter 1 actor actor 32489
Epoch 11231927239573504 488ms
CdcFilter 7EE900002723 488ms
Merge 7EE900000000 488ms
LocalInput (actor 32495) 488ms
488ms service_types_dm · CdcFilter 1 actor actor 32490
Epoch 11231927239573504 488ms
CdcFilter 7EEA00002723 488ms
Merge 7EEA00000000 488ms
LocalInput (actor 32495) 488ms
488ms accounts_dm · CdcFilter 1 actor actor 32491
Epoch 11231927239573504 488ms
CdcFilter 7EEB00002723 488ms
Merge 7EEB00000000 488ms
LocalInput (actor 32495) 488ms
488ms transactions_intraday_dm · CdcFilter 1 actor actor 32492
Epoch 11231927239573504 488ms
CdcFilter 7EEC00002723 488ms
Merge 7EEC00000000 488ms
LocalInput (actor 32495) 488ms
488ms teams_memberships_dm · CdcFilter 1 actor actor 32496
Epoch 11231927239573504 488ms
CdcFilter 7EF000002723 488ms
Merge 7EF000000000 488ms
LocalInput (actor 32495) 488ms
488ms entity_to_teams_dm · CdcFilter 1 actor actor 32497
Epoch 11231927239573504 488ms
CdcFilter 7EF100002723 488ms
Merge 7EF100000000 488ms
LocalInput (actor 32495) 488ms
488ms product_types_dm · CdcFilter 1 actor actor 32499
Epoch 11231927239573504 488ms
CdcFilter 7EF300002723 488ms
Merge 7EF300000000 488ms
LocalInput (actor 32495) 488ms
488ms fee_transactions_dm · CdcFilter 1 actor actor 32500
Epoch 11231927239573504 488ms
CdcFilter 7EF400002723 488ms
Merge 7EF400000000 488ms
LocalInput (actor 32495) 488ms
488ms clients_portfolios_dm · CdcFilter 1 actor actor 32503
Epoch 11231927239573504 488ms
CdcFilter 7EF700002723 488ms
Merge 7EF700000000 488ms
LocalInput (actor 32495) 488ms
488ms private_holdings_dm · CdcFilter 1 actor actor 32504
Epoch 11231927239573504 488ms
CdcFilter 7EF800002723 488ms
Merge 7EF800000000 488ms
LocalInput (actor 32495) 488ms
488ms accounts_to_clients_dm · CdcFilter 1 actor actor 32505
Epoch 11231927239573504 488ms
CdcFilter 7EF900002723 488ms
Merge 7EF900000000 488ms
LocalInput (actor 32495) 488ms
488ms private_asset_valuations_ft · CdcFilter 1 actor actor 32506
Epoch 11231927239573504 488ms
CdcFilter 7EFA00002723 488ms
Merge 7EFA00000000 488ms
LocalInput (actor 32495) 488ms
488ms teams_dm · CdcFilter 1 actor actor 32508
Epoch 11231927239573504 488ms
CdcFilter 7EFC00002723 488ms
Merge 7EFC00000000 488ms
LocalInput (actor 32495) 488ms
488ms users_dm · CdcFilter 1 actor actor 32509
Epoch 11231927239573504 488ms
CdcFilter 7EFD00002723 488ms
Merge 7EFD00000000 488ms
LocalInput (actor 32495) 488ms
488ms portfolios_dm · CdcFilter 1 actor actor 32510
Epoch 11231927239573504 488ms
CdcFilter 7EFE00002723 488ms
Merge 7EFE00000000 488ms
LocalInput (actor 32495) 488ms
488ms portfolios_dm · StreamCdcScan 1 actor actor 32552
Epoch 11231927239573504 488ms
StreamCdcScan 7F2800002715 488ms
Merge 7F2800002724 488ms
LocalInput (actor 32510) 488ms
488ms account_to_portfolios_dm · StreamCdcScan 1 actor actor 32566
Epoch 11231927239573504 488ms
StreamCdcScan 7F3600002715 488ms
Merge 7F3600002724 488ms
LocalInput (actor 32489) 488ms
488ms clients_portfolios_dm · StreamCdcScan 1 actor actor 32571
Epoch 11231927239573504 488ms
StreamCdcScan 7F3B00002715 488ms
Merge 7F3B00002724 488ms
LocalInput (actor 32503) 488ms
488ms income_transactions_dm · StreamCdcScan 1 actor actor 32581
Epoch 11231927239573504 488ms
StreamCdcScan 7F4500002715 488ms
Merge 7F4500002724 488ms
LocalInput (actor 32502) 488ms
488ms fee_transactions_dm · StreamCdcScan 1 actor actor 32586
Epoch 11231927239573504 488ms
StreamCdcScan 7F4A00002715 488ms
Merge 7F4A00002724 488ms
LocalInput (actor 32500) 488ms
488ms transaction_types_dm · StreamCdcScan 1 actor actor 32589
Epoch 11231927239573504 488ms
StreamCdcScan 7F4D00002715 488ms
Merge 7F4D00002724 488ms
LocalInput (actor 32486) 488ms
488ms teams_dm · StreamCdcScan 1 actor actor 32594
Epoch 11231927239573504 488ms
StreamCdcScan 7F5200002715 488ms
Merge 7F5200002724 488ms
LocalInput (actor 32508) 488ms
488ms private_holdings_dm · StreamCdcScan 1 actor actor 32601
Epoch 11231927239573504 488ms
StreamCdcScan 7F5900002715 488ms
Merge 7F5900002724 488ms
LocalInput (actor 32504) 488ms
488ms clients_dm · StreamCdcScan 1 actor actor 32606
Epoch 11231927239573504 488ms
StreamCdcScan 7F5E00002715 488ms
Merge 7F5E00002724 488ms
LocalInput (actor 32488) 488ms
488ms transactions_intraday_dm · StreamCdcScan 1 actor actor 32616
Epoch 11231927239573504 488ms
StreamCdcScan 7F6800002715 488ms
Merge 7F6800002724 488ms
LocalInput (actor 32492) 488ms
488ms entity_to_teams_dm · StreamCdcScan 1 actor actor 32623
Epoch 11231927239573504 488ms
StreamCdcScan 7F6F00002715 488ms
Merge 7F6F00002724 488ms
LocalInput (actor 32497) 488ms
488ms users_dm · StreamCdcScan 1 actor actor 32637
Epoch 11231927239573504 488ms
StreamCdcScan 7F7D00002715 488ms
Merge 7F7D00002724 488ms
LocalInput (actor 32509) 488ms
488ms private_asset_valuations_ft · StreamCdcScan 1 actor actor 32650
Epoch 11231927239573504 488ms
StreamCdcScan 7F8A00002715 488ms
Merge 7F8A00002724 488ms
LocalInput (actor 32506) 488ms
488ms teams_memberships_dm · StreamCdcScan 1 actor actor 32660
Epoch 11231927239573504 488ms
StreamCdcScan 7F9400002715 488ms
Merge 7F9400002724 488ms
LocalInput (actor 32496) 488ms
488ms product_types_dm · StreamCdcScan 1 actor actor 32672
Epoch 11231927239573504 488ms
StreamCdcScan 7FA000002715 488ms
Merge 7FA000002724 488ms
LocalInput (actor 32499) 488ms
488ms accounts_to_clients_dm · StreamCdcScan 1 actor actor 32682
Epoch 11231927239573504 488ms
StreamCdcScan 7FAA00002715 488ms
Merge 7FAA00002724 488ms
LocalInput (actor 32505) 488ms
488ms transactions_dm · StreamCdcScan 1 actor actor 32695
Epoch 11231927239573504 488ms
StreamCdcScan 7FB700002715 488ms
Merge 7FB700002724 488ms
LocalInput (actor 32493) 488ms
488ms fixed_deposit_accounts_ft · StreamCdcScan 1 actor actor 32708
Epoch 11231927239573504 488ms
StreamCdcScan 7FC400002715 488ms
Merge 7FC400002726 488ms
LocalInput (actor 32507) 488ms
484ms user_account_membership_mv · hash_join_barrier_align 16 actors actor 33134
Epoch 11231927239573504 484ms
HashJoin 816E0000001F 484ms
hash_join_barrier_align 484ms
Merge 816E0000001E 484ms
LocalInput (actor 33149) 484ms
LocalInput (actor 33150) 484ms
Merge 816E0000001B 484ms
LocalInput (actor 33147) 484ms
LocalInput (actor 33148) 484ms
484ms account_to_account_groups_mv · StreamScan 16 actors actor 33443
Epoch 11231927239573504 484ms
Project 82A300000001 484ms
StreamScan 82A30000294C 484ms
LocalInput (actor 32748) 484ms
LocalInput (actor 32747) 484ms
484ms team_to_accounts_mv · StreamScan 12 actors actor 33327
Epoch 11231927239573504 484ms
Project 822F00000005 484ms
Filter 822F00000004 484ms
StreamScan 822F00002839 484ms
LocalInput (actor 32680) 484ms
LocalInput (actor 32681) 484ms
484ms client_account_via_portfolio_mv · hash_join_barrier_align 10 actors actor 32981
Epoch 11231927239573504 484ms
Project 80D500000007 484ms
Filter 80D500000006 484ms
HashJoin 80D500000005 484ms
hash_join_barrier_align 484ms
Merge 80D500000002 484ms
LocalInput (actor 32857) 484ms
LocalInput (actor 32858) 484ms
Merge 80D500000004 484ms
LocalInput (actor 33039) 484ms
LocalInput (actor 33040) 484ms
484ms portfolio_account_group_types_mv · Filter 6 actors actor 33000
Epoch 11231927239573504 484ms
Project 80E80000000D 484ms
Filter 80E80000000C 484ms
Merge 80E800000005 484ms
LocalInput (actor 32998) 484ms
484ms holding_values_journal_density_mv · StreamScan 6 actors actor 33294
Epoch 11231927239573504 484ms
Filter 820E00000004 480ms
StreamScan 820E00002865 480ms
LocalInput (actor 32562) 480ms
LocalInput (actor 32563) 484ms
484ms accounts_sink · StreamScan 4 actors actor 32749
Epoch 11231927239573504 484ms
Project 7FED00000002 484ms
Filter 7FED00000001 484ms
StreamScan 7FED0000275A 484ms
LocalInput (actor 32558) 484ms
LocalInput (actor 32557) 484ms
484ms active_parties_to_portfolios_mv · Filter 4 actors actor 33169
Epoch 11231927239573504 484ms
Project 81910000000E 484ms
Filter 81910000000D 484ms
Merge 819100000006 484ms
LocalInput (actor 33173) 484ms
484ms party_account_direct_mv · Project 4 actors actor 33261
Epoch 11231927239573504 484ms
Project 81ED0000000E 484ms
Merge 81ED0000000B 484ms
LocalInput (actor 33263) 484ms
484ms party_account_direct_mv · hash_join_barrier_align 4 actors actor 33263
Epoch 11231927239573504 484ms
HashJoin 81EF0000000A 484ms
hash_join_barrier_align 484ms
Merge 81EF00000006 484ms
LocalInput (actor 33267) 484ms
LocalInput (actor 33268) 484ms
Merge 81EF00000009 484ms
LocalInput (actor 33278) 484ms
LocalInput (actor 33277) 484ms
484ms active_account_to_portfolios_mv · StreamScan 2 actors actor 32698
Epoch 11231927239573504 484ms
Materialize 7FBA00000003 484ms
Project 7FBA00000002 484ms
Filter 7FBA00000001 484ms
StreamScan 7FBA0000273E 484ms
LocalInput (actor 32565) 484ms
LocalInput (actor 32564) 484ms
484ms account_to_portfolios_sink · StreamScan 2 actors actor 32735
Epoch 11231927239573504 484ms
Project 7FDF00000002 484ms
Filter 7FDF00000001 484ms
StreamScan 7FDF0000273A 484ms
LocalInput (actor 32565) 484ms
LocalInput (actor 32564) 484ms
484ms active_clients_portfolios_mv · StreamScan 2 actors actor 32770
Epoch 11231927239573504 484ms
Materialize 800200000006 484ms
Project 800200000005 484ms
DynamicFilter 800200000004 484ms
Project 800200000002 484ms
Filter 800200000001 484ms
StreamScan 800200002758 484ms
LocalInput (actor 32570) 484ms
LocalInput (actor 32569) 484ms
Merge 800200000003 484ms
LocalInput (actor 32769) 484ms
484ms portfolio_to_account_groups_mv · StreamScan 2 actors actor 32780
Epoch 11231927239573504 484ms
Project 800C00000002 484ms
Filter 800C00000001 484ms
StreamScan 800C000027C7 484ms
LocalInput (actor 32551) 484ms
LocalInput (actor 32550) 484ms
484ms portfolio_account_group_types_mv · hash_join_barrier_align 2 actors actor 32998
Epoch 11231927239573504 484ms
HashJoin 80E600000004 484ms
hash_join_barrier_align 484ms
Merge 80E600000002 484ms
LocalInput (actor 33086) 484ms
LocalInput (actor 33085) 484ms
Merge 80E600000003 484ms
LocalInput (actor 33092) 484ms
LocalInput (actor 33091) 484ms
484ms active_parties_to_accounts_mv · hash_join_barrier_align 2 actors actor 33049
Epoch 11231927239573504 484ms
Project 811900000016 484ms
HashJoin 811900000015 484ms
hash_join_barrier_align 484ms
Merge 811900000011 484ms
LocalInput (actor 33053) 484ms
LocalInput (actor 33054) 484ms
Merge 811900000014 484ms
LocalInput (actor 33113) 484ms
LocalInput (actor 33114) 484ms
484ms settled_cost_basis_carried_mv · OverWindow 2 actors actor 33107
Epoch 11231927239573504 484ms
Project 815300000004 484ms
OverWindow 815300000003 484ms
Merge 815300000002 484ms
LocalInput (actor 33154) 484ms
LocalInput (actor 33153) 484ms
484ms settled_cost_basis_carried_mv · NoOp 2 actors actor 33111
Epoch 11231927239573504 484ms
NoOp 8157FFFFFFFB 484ms
Merge 8157FFFFFFFC 484ms
LocalInput (actor 33107) 484ms
484ms active_parties_to_portfolios_mv · HashAgg 2 actors actor 33124
Epoch 11231927239573504 484ms
Materialize 816400000019 484ms
Project 816400000018 484ms
HashAgg 816400000017 484ms
Merge 816400000016 484ms
LocalInput (actor 33164) 484ms
LocalInput (actor 33163) 484ms
484ms active_parties_to_portfolios_mv · hash_join_barrier_align 2 actors actor 33164
Epoch 11231927239573504 484ms
HashJoin 818C00000015 484ms
hash_join_barrier_align 484ms
Merge 818C00000014 484ms
LocalInput (actor 33116) 484ms
LocalInput (actor 33115) 484ms
Merge 818C00000011 484ms
LocalInput (actor 33165) 484ms
LocalInput (actor 33166) 484ms
484ms active_parties_to_portfolios_mv · Union 2 actors actor 33165
Epoch 11231927239573504 484ms
Union 818D00000010 484ms
Merge 818D0000000F 484ms
LocalInput (actor 33170) 484ms
LocalInput (actor 33169) 484ms
Merge 818D0000000C 484ms
LocalInput (actor 33172) 484ms
LocalInput (actor 33171) 484ms
484ms settled_cost_basis_series_mv · StreamScan 2 actors actor 33191
Epoch 11231927239573504 484ms
Materialize 81A700000006 484ms
Project 81A700000005 484ms
OverWindow 81A700000004 484ms
Project 81A700000003 484ms
Filter 81A700000002 484ms
OverWindow 81A700000001 484ms
StreamScan 81A700002782 484ms
LocalInput (actor 33109) 484ms
LocalInput (actor 33110) 484ms
484ms settled_cost_basis_latest_mv · StreamScan 2 actors actor 33227
Epoch 11231927239573504 484ms
Project 81CB00000001 484ms
StreamScan 81CB00002761 484ms
LocalInput (actor 33109) 484ms
LocalInput (actor 33110) 484ms
484ms settled_cost_basis_latest_mv · GroupTopN 2 actors actor 33235
Epoch 11231927239573504 484ms
Materialize 81D300000005 484ms
Project 81D300000004 484ms
GroupTopN 81D300000003 484ms
Merge 81D300000002 484ms
LocalInput (actor 33227) 484ms
LocalInput (actor 33228) 484ms
480ms flow_values_mv · hash_join_barrier_align 16 actors actor 33747
Epoch 11231927239573504 480ms
Project 83D300000005 480ms
HashJoin 83D300000004 480ms
hash_join_barrier_align 480ms
Merge 83D300000003 480ms
LocalInput (actor 33764) 480ms
LocalInput (actor 33765) 480ms
Merge 83D300000001 480ms
LocalInput (actor 33665) 480ms
LocalInput (actor 33664) 480ms
480ms client_to_account_groups_mv · Project 8 actors actor 32836
Epoch 11231927239573504 480ms
Project 804400000006 480ms
Merge 804400000003 480ms
LocalInput (actor 32834) 480ms
480ms portfolio_to_account_groups_mv · Project 6 actors actor 32774
Epoch 11231927239573504 480ms
Project 800600000004 480ms
Merge 800600000003 480ms
LocalInput (actor 32780) 480ms
480ms transactions_sink · StreamScan 6 actors actor 32942
Epoch 11231927239573504 480ms
StreamScan 80AE00002757 480ms
LocalInput (actor 32556) 480ms
LocalInput (actor 32555) 480ms
480ms transactions_merged_mv · Project 6 actors actor 33004
Epoch 11231927239573504 480ms
Project 80EC00000008 480ms
Merge 80EC00000007 480ms
LocalInput (actor 33008) 480ms
480ms account_to_account_groups_mv · Filter 6 actors actor 33544
Epoch 11231927239573504 480ms
Project 830800000010 480ms
Filter 83080000000F 480ms
Merge 83080000000B 480ms
LocalInput (actor 33548) 480ms
480ms benchmark_values_by_currency_mv · hash_join_barrier_align 4 actors actor 32717
Epoch 11231927239573504 480ms
Materialize 7FCD0000000C 480ms
Project 7FCD0000000B 480ms
HashAgg 7FCD0000000A 480ms
HashJoin 7FCD00000009 480ms
hash_join_barrier_align 480ms
Merge 7FCD00000005 480ms
LocalInput (actor 32754) 480ms
LocalInput (actor 32753) 480ms
Merge 7FCD00000008 480ms
LocalInput (actor 32828) 480ms
LocalInput (actor 32827) 480ms
480ms private_asset_holdings_mv · hash_join_barrier_align 4 actors actor 32784
Epoch 11231927239573504 480ms
HashJoin 801000000007 480ms
hash_join_barrier_align 480ms
Merge 801000000003 480ms
LocalInput (actor 32765) 480ms
LocalInput (actor 32766) 480ms
Merge 801000000006 480ms
LocalInput (actor 32787) 480ms
LocalInput (actor 32786) 480ms
480ms benchmark_values_by_distribution_mv · hash_join_barrier_align 4 actors actor 33057
Epoch 11231927239573504 480ms
Project 812100000005 480ms
Filter 812100000004 480ms
HashJoin 812100000003 480ms
hash_join_barrier_align 476ms
Merge 812100000002 480ms
LocalInput (actor 33083) 480ms
LocalInput (actor 33084) 480ms
Merge 812100000001 476ms
LocalInput (actor 33082) 476ms
LocalInput (actor 33081) 476ms
480ms investment_account_purchasing_power_mv · hash_join_barrier_align 4 actors actor 33196
Epoch 11231927239573504 480ms
HashJoin 81AC00000004 480ms
hash_join_barrier_align 480ms
Merge 81AC00000003 480ms
LocalInput (actor 33210) 480ms
LocalInput (actor 33209) 480ms
Merge 81AC00000002 480ms
LocalInput (actor 33181) 480ms
LocalInput (actor 33182) 480ms
480ms private_asset_valuations_mv · hash_join_barrier_align 4 actors actor 33216
Epoch 11231927239573504 480ms
Project 81C000000008 480ms
Filter 81C000000007 480ms
HashJoin 81C000000006 480ms
hash_join_barrier_align 480ms
Merge 81C000000005 480ms
LocalInput (actor 33230) 480ms
LocalInput (actor 33229) 480ms
Merge 81C000000003 480ms
LocalInput (actor 33218) 480ms
LocalInput (actor 33217) 480ms
480ms holding_values_journal_density_mv · Project 4 actors actor 33295
Epoch 11231927239573504 480ms
Project 820F0000000F 476ms
Merge 820F00000005 476ms
LocalInput (actor 33293) 476ms
480ms cash_values_journal_density_mv · Project 4 actors actor 33303
Epoch 11231927239573504 480ms
Project 821700000006 480ms
Merge 821700000005 480ms
LocalInput (actor 33305) 480ms
480ms account_to_account_groups_mv · hash_join_barrier_align 4 actors actor 33548
Epoch 11231927239573504 480ms
HashJoin 830C0000000A 480ms
hash_join_barrier_align 480ms
Merge 830C00000008 480ms
LocalInput (actor 33449) 480ms
LocalInput (actor 33450) 480ms
Merge 830C00000009 480ms
LocalInput (actor 33452) 480ms
LocalInput (actor 33451) 480ms
480ms account_to_account_groups_txn_binned_mv · StreamScan 4 actors actor 33533
Epoch 11231927239573504 480ms
Project 82FD00000003 480ms
StreamScan 82FD0000277D 480ms
LocalInput (actor 32693) 480ms
LocalInput (actor 32694) 480ms
480ms active_parties_to_accounts_mv · HashAgg 2 actors actor 32656
Epoch 11231927239573504 480ms
Materialize 7F900000001A 480ms
Project 7F9000000019 480ms
HashAgg 7F9000000018 480ms
Merge 7F9000000017 480ms
LocalInput (actor 33050) 480ms
LocalInput (actor 33049) 480ms
480ms active_accounts_to_clients_mv · StreamScan 2 actors actor 32901
Epoch 11231927239573504 480ms
Materialize 808500000003 480ms
Project 808500000002 480ms
Filter 808500000001 480ms
StreamScan 80850000273E 480ms
LocalInput (actor 32680) 480ms
LocalInput (actor 32681) 480ms
480ms investment_accounts_ft_sink · StreamScan 2 actors actor 33075
Epoch 11231927239573504 480ms
Filter 813300000001 480ms
StreamScan 813300002737 480ms
Merge 813300000000 480ms
LocalInput (actor 33073) 480ms
480ms private_asset_valuations_sink · StreamScan 2 actors actor 33213
Epoch 11231927239573504 480ms
StreamScan 81BD00002725 480ms
Merge 81BD00000000 480ms
LocalInput (actor 33211) 480ms
480ms asset_price_with_lag_mv · OverWindow 2 actors actor 33312
Epoch 11231927239573504 480ms
Materialize 822000000008 480ms
OverWindow 822000000007 480ms
Merge 822000000006 480ms
LocalInput (actor 33313) 480ms
LocalInput (actor 33314) 480ms
480ms asset_price_with_lag_mv · hash_join_barrier_align 2 actors actor 33313
Epoch 11231927239573504 480ms
Project 822100000005 480ms
HashJoin 822100000004 480ms
hash_join_barrier_align 476ms
Merge 822100000003 480ms
LocalInput (actor 33281) 480ms
LocalInput (actor 33282) 480ms
Merge 822100000002 476ms
LocalInput (actor 33279) 476ms
LocalInput (actor 33280) 480ms
480ms holding_values_journal_density_mv · HashAgg 2 actors actor 33321
Epoch 11231927239573504 480ms
Project 822900000009 480ms
HashAgg 822900000008 480ms
Merge 822900000007 476ms
LocalInput (actor 33292) 476ms
LocalInput (actor 33291) 480ms
480ms asset_prices_snapshot_mv · GroupTopN 2 actors actor 33325
Epoch 11231927239573504 480ms
Materialize 822D00000005 480ms
Project 822D00000004 480ms
GroupTopN 822D00000003 480ms
Merge 822D00000002 476ms
LocalInput (actor 33332) 476ms
LocalInput (actor 33331) 476ms
480ms asset_prices_snapshot_mv · StreamScan 2 actors actor 33331
Epoch 11231927239573504 480ms
Filter 823300000001 476ms
StreamScan 82330000276A 476ms
LocalInput (actor 32562) 476ms
LocalInput (actor 32563) 480ms
480ms account_to_account_groups_txn_binned_mv · HashAgg 2 actors actor 33529
Epoch 11231927239573504 480ms
Project 82F900000006 480ms
HashAgg 82F900000005 480ms
Merge 82F900000004 480ms
LocalInput (actor 33534) 480ms
LocalInput (actor 33533) 480ms
480ms private_asset_valuations_sink · Sink 2 actors actor 33594
Epoch 11231927239573504 480ms
Sink 833A00000002 480ms
consume_log (sink_id 20868) background loop alive 468211.9s
log_reader_next_item alive 480ms
Wait Next Item from Buffer alive 480ms
Wait For New Buffer Item alive 480ms
Merge 833A00000001 480ms
LocalInput (actor 33213) 480ms
LocalInput (actor 33214) 480ms
480ms investment_accounts_ft_sink · Sink 2 actors actor 33639
Epoch 11231927239573504 480ms
Sink 836700000003 480ms
consume_log (sink_id 20865) background loop alive 468211.9s
log_reader_next_item alive 480ms
Wait Next Item from Buffer alive 480ms
Wait For New Buffer Item alive 480ms
Merge 836700000002 480ms
LocalInput (actor 33075) 480ms
LocalInput (actor 33076) 480ms
476ms client_account_via_portfolio_mv · Filter 6 actors actor 32976
Epoch 11231927239573504 476ms
Filter 80D00000000C 476ms
Merge 80D00000000B 476ms
LocalInput (actor 32978) 476ms
476ms portfolio_account_group_types_mv · HashAgg 6 actors actor 33087
Epoch 11231927239573504 476ms
Project 813F00000010 476ms
HashAgg 813F0000000F 476ms
Merge 813F0000000E 476ms
LocalInput (actor 33001) 476ms
LocalInput (actor 33000) 476ms
476ms client_account_direct_mv · Filter 6 actors actor 32989
Epoch 11231927239573504 476ms
Project 80DD0000000D 476ms
Filter 80DD0000000C 476ms
Merge 80DD00000005 476ms
LocalInput (actor 32993) 476ms
476ms transactions_merged_mv · hash_join_barrier_align 6 actors actor 33008
Epoch 11231927239573504 476ms
Project 80F000000006 476ms
HashJoin 80F000000005 476ms
hash_join_barrier_align 476ms
Merge 80F000000004 476ms
LocalInput (actor 32969) 476ms
Merge 80F000000003 476ms
LocalInput (actor 32961) 476ms
LocalInput (actor 32962) 476ms
476ms portfolio_to_account_groups_sink · StreamScan 4 actors actor 32955
Epoch 11231927239573504 476ms
StreamScan 80BB0000273D 476ms
LocalInput (actor 32983) 476ms
LocalInput (actor 32982) 476ms
476ms team_to_parties_mv · Filter 4 actors actor 33160
Epoch 11231927239573504 476ms
Project 81880000000B 476ms
DynamicFilter 81880000000A 476ms
Merge 818800000009 476ms
LocalInput (actor 33242) 476ms
Project 818800000008 476ms
Filter 818800000007 476ms
Merge 818800000006 476ms
LocalInput (actor 33156) 476ms
476ms party_account_via_portfolio_mv · Project 4 actors actor 33188
Epoch 11231927239573504 476ms
Project 81A40000001E 476ms
Merge 81A40000001D 476ms
LocalInput (actor 33186) 476ms
476ms cash_values_journal_density_mv · StreamScan 4 actors actor 33305
Epoch 11231927239573504 476ms
Filter 821900000004 476ms
StreamScan 821900002834 476ms
LocalInput (actor 32562) 476ms
LocalInput (actor 32563) 476ms
476ms benchmark_values_by_currency_sink · StreamScan 2 actors actor 32719
Epoch 11231927239573504 476ms
Sink 7FCF00000001 476ms
consume_log (sink_id 20852) background loop alive 468211.9s
log_reader_next_item alive 476ms
Wait Next Item from Buffer alive 476ms
Wait For New Buffer Item alive 476ms
StreamScan 7FCF00002724 476ms
Merge 7FCF00000000 476ms
LocalInput (actor 32717) 476ms
476ms clients_sink · StreamScan 2 actors actor 32733
Epoch 11231927239573504 476ms
Sink 7FDD00000003 476ms
consume_log (sink_id 18243) background loop alive 468211.6s
log_reader_next_item alive 476ms
Wait Next Item from Buffer alive 476ms
Wait For New Buffer Item alive 476ms
Project 7FDD00000002 476ms
Filter 7FDD00000001 476ms
StreamScan 7FDD00002733 476ms
LocalInput (actor 32605) 476ms
LocalInput (actor 32604) 476ms
476ms team_to_clients_mv · HashAgg 2 actors actor 32755
Epoch 11231927239573504 476ms
Materialize 7FF300000006 476ms
Project 7FF300000005 476ms
HashAgg 7FF300000004 476ms
Merge 7FF300000003 476ms
LocalInput (actor 32856) 476ms
LocalInput (actor 32855) 476ms
476ms private_asset_holdings_mv · Materialize 2 actors actor 32782
Epoch 11231927239573504 476ms
Materialize 800E0000000E 476ms
Merge 800E0000000D 476ms
LocalInput (actor 32763) 476ms
LocalInput (actor 32764) 476ms
476ms client_to_account_groups_mv · Union 2 actors actor 32830
Epoch 11231927239573504 476ms
Materialize 803E0000000D 476ms
Union 803E0000000C 476ms
Merge 803E00000009 476ms
LocalInput (actor 32840) 476ms
LocalInput (actor 32839) 476ms
Merge 803E0000000B 476ms
LocalInput (actor 32838) 476ms
LocalInput (actor 32837) 476ms
Merge 803E00000005 476ms
LocalInput (actor 32832) 476ms
LocalInput (actor 32831) 476ms
Merge 803E00000007 476ms
LocalInput (actor 32836) 476ms
LocalInput (actor 32835) 476ms
476ms client_to_account_groups_mv · StreamScan 2 actors actor 32833
Epoch 11231927239573504 476ms
Project 804100000002 476ms
Filter 804100000001 476ms
StreamScan 8041000027D8 476ms
LocalInput (actor 32605) 476ms
LocalInput (actor 32604) 476ms
476ms user_team_memberships_mv · hash_join_barrier_align 2 actors actor 32849
Epoch 11231927239573504 476ms
HashJoin 805100000007 476ms
hash_join_barrier_align 476ms
Merge 805100000003 476ms
LocalInput (actor 32946) 476ms
LocalInput (actor 32947) 476ms
Merge 805100000006 476ms
LocalInput (actor 32948) 476ms
LocalInput (actor 32949) 476ms
476ms benchmark_values_by_asset_class_sink · StreamScan 2 actors actor 32930
Epoch 11231927239573504 476ms
Sink 80A200000002 476ms
consume_log (sink_id 20060) background loop alive 468211.9s
log_reader_next_item alive 476ms
Wait Next Item from Buffer alive 476ms
Wait For New Buffer Item alive 476ms
Filter 80A200000001 476ms
StreamScan 80A200002733 476ms
Merge 80A200000000 476ms
LocalInput (actor 32934) 476ms
476ms benchmark_values_by_taxonomy_node_sink · StreamScan 2 actors actor 32932
Epoch 11231927239573504 476ms
Sink 80A400000001 476ms
consume_log (sink_id 20068) background loop alive 468211.9s
log_reader_next_item alive 476ms
Wait Next Item from Buffer alive 476ms
Wait For New Buffer Item alive 476ms
StreamScan 80A400002728 476ms
Merge 80A400000000 476ms
LocalInput (actor 32934) 476ms
476ms benchmark_values_by_sector_sink · StreamScan 2 actors actor 32936
Epoch 11231927239573504 476ms
Sink 80A800000002 476ms
consume_log (sink_id 20056) background loop alive 468211.9s
log_reader_next_item alive 476ms
Wait Next Item from Buffer alive 476ms
Wait For New Buffer Item alive 476ms
Filter 80A800000001 476ms
StreamScan 80A800002733 476ms
Merge 80A800000000 476ms
LocalInput (actor 32934) 476ms
476ms client_account_direct_mv · Union 2 actors actor 32986
Epoch 11231927239573504 476ms
Materialize 80DA00000010 476ms
Union 80DA0000000F 476ms
Merge 80DA00000008 476ms
LocalInput (actor 32994) 476ms
LocalInput (actor 32995) 476ms
Merge 80DA0000000E 476ms
LocalInput (actor 32988) 476ms
LocalInput (actor 32989) 476ms
Merge 80DA0000000B 476ms
LocalInput (actor 32990) 476ms
LocalInput (actor 32991) 476ms
476ms client_account_direct_mv · hash_join_barrier_align 2 actors actor 32992
Epoch 11231927239573504 476ms
HashJoin 80E000000004 476ms
hash_join_barrier_align 476ms
Merge 80E000000002 476ms
LocalInput (actor 33020) 476ms
LocalInput (actor 33021) 476ms
Merge 80E000000003 476ms
LocalInput (actor 33030) 476ms
LocalInput (actor 33031) 476ms
476ms cash_values_journal_density_mv · HashAgg 2 actors actor 33287
Epoch 11231927239573504 476ms
Project 820700000009 476ms
HashAgg 820700000008 476ms
Merge 820700000007 472ms
LocalInput (actor 33303) 472ms
LocalInput (actor 33304) 472ms
476ms asset_twrr_sink · StreamScan 2 actors actor 33357
Epoch 11231927239573504 476ms
Sink 824D00000002 476ms
consume_log (sink_id 22289) background loop alive 468211.9s
log_reader_next_item alive 476ms
Wait Next Item from Buffer alive 476ms
Wait For New Buffer Item alive 476ms
Filter 824D00000001 476ms
StreamScan 824D00002732 476ms
Merge 824D00000000 476ms
LocalInput (actor 33359) 476ms
476ms asset_twrr_mv · StreamScan 2 actors actor 33360
Epoch 11231927239573504 476ms
Materialize 825000000003 476ms
Project 825000000002 476ms
Filter 825000000001 476ms
StreamScan 825000002734 476ms
LocalInput (actor 33311) 476ms
LocalInput (actor 33312) 476ms
476ms asset_latest_price_mv · StreamScan 2 actors actor 33454
Epoch 11231927239573504 476ms
Materialize 82AE00000003 476ms
Project 82AE00000002 476ms
GroupTopN 82AE00000001 476ms
StreamScan 82AE00002754 476ms
LocalInput (actor 33311) 476ms
LocalInput (actor 33312) 476ms
476ms benchmark_twrr_by_currency_mv · HashAgg 2 actors actor 33479
Epoch 11231927239573504 476ms
Materialize 82C700000008 476ms
Project 82C700000007 476ms
HashAgg 82C700000006 476ms
Merge 82C700000005 476ms
LocalInput (actor 33661) 476ms
LocalInput (actor 33660) 476ms
476ms benchmark_twrr_by_asset_sink · StreamScan 2 actors actor 33586
Epoch 11231927239573504 476ms
Sink 833200000001 476ms
consume_log (sink_id 22299) background loop alive 468211.9s
log_reader_next_item alive 476ms
Wait Next Item from Buffer alive 476ms
Wait For New Buffer Item alive 476ms
StreamScan 833200002724 476ms
Merge 833200000000 476ms
LocalInput (actor 33588) 476ms
476ms benchmark_twrr_by_distribution_mv · HashAgg 2 actors actor 33646
Epoch 11231927239573504 476ms
Materialize 836E00000009 476ms
Project 836E00000008 476ms
HashAgg 836E00000007 476ms
Merge 836E00000006 476ms
LocalInput (actor 33653) 476ms
LocalInput (actor 33652) 476ms
476ms benchmark_twrr_by_distribution_mv · hash_join_barrier_align 2 actors actor 33653
Epoch 11231927239573504 476ms
Project 837500000005 476ms
Filter 837500000004 476ms
HashJoin 837500000003 476ms
hash_join_barrier_align 476ms
Merge 837500000001 476ms
LocalInput (actor 33655) 476ms
LocalInput (actor 33654) 476ms
Merge 837500000002 476ms
LocalInput (actor 33633) 476ms
LocalInput (actor 33632) 476ms
476ms benchmark_twrr_by_currency_mv · hash_join_barrier_align 2 actors actor 33661
Epoch 11231927239573504 476ms
HashJoin 837D00000004 476ms
hash_join_barrier_align 476ms
Merge 837D00000001 476ms
LocalInput (actor 33618) 476ms
LocalInput (actor 33619) 476ms
Merge 837D00000003 476ms
LocalInput (actor 33662) 476ms
LocalInput (actor 33663) 476ms
476ms benchmark_values_by_asset_sink · StreamScan 2 actors actor 33938
Epoch 11231927239573504 476ms
Sink 849200000001 476ms
consume_log (sink_id 20044) background loop alive 468211.9s
log_reader_next_item alive 476ms
Wait Next Item from Buffer alive 476ms
Wait For New Buffer Item alive 476ms
StreamScan 849200002724 476ms
Merge 849200000000 476ms
LocalInput (actor 33940) 476ms
476ms benchmark_values_by_asset_sink__rwm_shim · Materialize 2 actors actor 33940
Epoch 11231927239573504 476ms
Materialize 849400000007 476ms
Merge 849400000006 476ms
LocalInput (actor 33943) 476ms
LocalInput (actor 33942) 476ms
476ms benchmark_values_by_asset_sink__rwm_shim · hash_join_barrier_align 2 actors actor 33942
Epoch 11231927239573504 476ms
HashJoin 849600000005 476ms
hash_join_barrier_align 472ms
Merge 849600000004 476ms
LocalInput (actor 33270) 476ms
LocalInput (actor 33269) 476ms
Merge 849600000001 472ms
LocalInput (actor 33971) 472ms
LocalInput (actor 33970) 476ms
472ms account_groups_mv · hash_join_barrier_align 20 actors actor 33377
Epoch 11231927239573504 472ms
Project 826100000021 472ms
HashJoin 826100000020 472ms
hash_join_barrier_align 472ms
Merge 82610000001F 472ms
LocalInput (actor 33422) 472ms
LocalInput (actor 33421) 472ms
Merge 82610000001D 472ms
LocalInput (actor 33419) 472ms
LocalInput (actor 33420) 472ms
472ms client_to_account_groups_sink · StreamScan 4 actors actor 32967
Epoch 11231927239573504 472ms
StreamScan 80C700002758 472ms
LocalInput (actor 32830) 472ms
LocalInput (actor 32829) 472ms
472ms client_account_group_types_mv · StreamScan 4 actors actor 33177
Epoch 11231927239573504 472ms
Project 819900000003 472ms
StreamScan 819900002766 472ms
LocalInput (actor 32813) 472ms
LocalInput (actor 32812) 472ms
472ms party_account_group_types_mv · StreamScan 4 actors actor 33355
Epoch 11231927239573504 472ms
Project 824B00000001 472ms
StreamScan 824B00002761 472ms
LocalInput (actor 33175) 472ms
LocalInput (actor 33176) 472ms
472ms benchmark_twrr_by_asset_mv · hash_join_barrier_align 4 actors actor 33588
Epoch 11231927239573504 472ms
Materialize 83340000000B 472ms
Project 83340000000A 472ms
HashJoin 833400000009 472ms
hash_join_barrier_align 472ms
Merge 833400000008 472ms
LocalInput (actor 33592) 472ms
LocalInput (actor 33593) 472ms
Merge 833400000005 472ms
LocalInput (actor 33590) 472ms
LocalInput (actor 33591) 472ms
472ms flow_values_mv · Union 4 actors actor 33744
Epoch 11231927239573504 472ms
Union 83D00000001A 472ms
Merge 83D000000017 472ms
LocalInput (actor 33753) 472ms
LocalInput (actor 33752) 472ms
Merge 83D000000019 472ms
LocalInput (actor 33751) 472ms
LocalInput (actor 33750) 472ms
Merge 83D000000006 472ms
LocalInput (actor 33746) 472ms
LocalInput (actor 33747) 472ms
472ms flow_values_mv · Project 4 actors actor 33750
Epoch 11231927239573504 472ms
Project 83D600000018 472ms
Merge 83D600000015 472ms
LocalInput (actor 33748) 472ms
472ms portfolio_to_account_groups_mv · Union 2 actors actor 32772
Epoch 11231927239573504 472ms
Materialize 80040000000B 472ms
Union 80040000000A 472ms
Merge 800400000009 472ms
LocalInput (actor 32776) 472ms
LocalInput (actor 32777) 472ms
Merge 800400000007 472ms
LocalInput (actor 32778) 472ms
LocalInput (actor 32779) 472ms
Merge 800400000005 472ms
LocalInput (actor 32774) 472ms
LocalInput (actor 32775) 472ms
472ms client_account_via_portfolio_mv · Union 2 actors actor 32812
Epoch 11231927239573504 472ms
Materialize 802C00000025 472ms
Union 802C00000024 472ms
Merge 802C0000001B 472ms
LocalInput (actor 33037) 472ms
LocalInput (actor 33038) 472ms
Merge 802C00000023 472ms
LocalInput (actor 33046) 472ms
LocalInput (actor 33045) 472ms
Merge 802C00000013 472ms
LocalInput (actor 32814) 472ms
LocalInput (actor 32815) 472ms
472ms user_to_clients_mv · hash_join_barrier_align 2 actors actor 32842
Epoch 11231927239573504 472ms
HashJoin 804A00000007 472ms
hash_join_barrier_align 472ms
Merge 804A00000003 472ms
LocalInput (actor 32919) 472ms
LocalInput (actor 32918) 472ms
Merge 804A00000006 472ms
LocalInput (actor 32921) 472ms
LocalInput (actor 32920) 472ms
472ms user_to_portfolios_mv · hash_join_barrier_align 2 actors actor 32847
Epoch 11231927239573504 472ms
HashJoin 804F00000007 472ms
hash_join_barrier_align 472ms
Merge 804F00000003 472ms
LocalInput (actor 32938) 472ms
LocalInput (actor 32939) 472ms
Merge 804F00000006 472ms
LocalInput (actor 32941) 472ms
LocalInput (actor 32940) 472ms
472ms team_to_clients_mv · StreamScan 2 actors actor 32855
Epoch 11231927239573504 472ms
Project 805700000002 472ms
Filter 805700000001 472ms
StreamScan 805700002749 472ms
LocalInput (actor 32621) 472ms
LocalInput (actor 32622) 472ms
472ms settled_position_series_mv · TemporalJoin 2 actors actor 32878
Epoch 11231927239573504 472ms
Materialize 806E0000000B 472ms
Project 806E0000000A 472ms
OverWindow 806E00000009 472ms
Project 806E00000008 472ms
HashAgg 806E00000007 472ms
Project 806E00000006 472ms
Filter 806E00000005 472ms
TemporalJoin 806E00000004 472ms
Merge 806E00000003 472ms
LocalInput (actor 32880) 472ms
Merge 806E00000002 472ms
LocalInput (actor 32690) 472ms
LocalInput (actor 32689) 472ms
472ms abor_settlement_positions_mv · TemporalJoin 2 actors actor 32882
Epoch 11231927239573504 472ms
Project 807200000005 472ms
TemporalJoin 807200000004 472ms
Merge 807200000003 472ms
LocalInput (actor 32886) 472ms
Merge 807200000002 472ms
LocalInput (actor 33739) 472ms
LocalInput (actor 33738) 472ms
472ms private_asset_holdings_sink · Sink 2 actors actor 32896
Epoch 11231927239573504 472ms
Sink 808000000002 472ms
consume_log (sink_id 18266) background loop alive 468211.9s
log_reader_next_item alive 472ms
Wait Next Item from Buffer alive 472ms
Wait For New Buffer Item alive 472ms
Merge 808000000001 472ms
LocalInput (actor 32906) 472ms
LocalInput (actor 32905) 472ms
472ms transactions_merged_mv · Union 2 actors actor 32912
Epoch 11231927239573504 472ms
Materialize 809000000028 472ms
Union 809000000027 472ms
Merge 809000000026 472ms
LocalInput (actor 33016) 472ms
LocalInput (actor 33017) 472ms
Merge 809000000012 472ms
LocalInput (actor 33014) 472ms
LocalInput (actor 33015) 472ms
Merge 809000000009 472ms
LocalInput (actor 33005) 472ms
LocalInput (actor 33004) 472ms
472ms user_team_memberships_mv · Materialize 2 actors actor 32922
Epoch 11231927239573504 472ms
Materialize 809A00000009 472ms
Merge 809A00000008 472ms
LocalInput (actor 32850) 472ms
LocalInput (actor 32849) 472ms
472ms benchmark_values_by_region_sink · StreamScan 2 actors actor 32928
Epoch 11231927239573504 472ms
Sink 80A000000002 472ms
consume_log (sink_id 20064) background loop alive 468211.9s
log_reader_next_item alive 472ms
Wait Next Item from Buffer alive 472ms
Wait For New Buffer Item alive 472ms
Filter 80A000000001 472ms
StreamScan 80A000002733 472ms
Merge 80A000000000 472ms
LocalInput (actor 32934) 472ms
472ms portfolio_to_account_groups_sink · hash_join_barrier_align 2 actors actor 32944
Epoch 11231927239573504 472ms
Sink 80B000000004 472ms
consume_log (sink_id 18285) background loop alive 468211.6s
log_reader_next_item alive 472ms
Wait Next Item from Buffer alive 472ms
Wait For New Buffer Item alive 472ms
HashJoin 80B000000003 472ms
hash_join_barrier_align 472ms
Merge 80B000000002 472ms
LocalInput (actor 32956) 472ms
LocalInput (actor 32955) 472ms
Merge 80B000000001 472ms
LocalInput (actor 32953) 472ms
LocalInput (actor 32954) 472ms
472ms portfolio_account_group_types_mv · Union 2 actors actor 32982
Epoch 11231927239573504 472ms
Materialize 80D600000019 472ms
Union 80D600000018 472ms
Merge 80D60000000B 472ms
LocalInput (actor 32984) 472ms
LocalInput (actor 32985) 472ms
Merge 80D600000017 472ms
LocalInput (actor 33090) 472ms
LocalInput (actor 33089) 472ms
Merge 80D600000011 472ms
LocalInput (actor 33088) 472ms
LocalInput (actor 33087) 472ms
472ms transactions_merged_mv · HashAgg 2 actors actor 33017
Epoch 11231927239573504 472ms
Project 80F900000025 472ms
Filter 80F900000024 472ms
HashJoin 80F900000023 472ms
hash_join_barrier_align 472ms
Project 80F900000022 472ms
HashAgg 80F900000021 472ms
Merge 80F900000020 472ms
LocalInput (actor 33029) 472ms
LocalInput (actor 33028) 472ms
Merge 80F90000001E 472ms
LocalInput (actor 33019) 472ms
LocalInput (actor 33018) 472ms
472ms party_account_direct_mv · Union 2 actors actor 33175
Epoch 11231927239573504 472ms
Materialize 819700000011 472ms
Union 819700000010 472ms
Merge 81970000000D 472ms
LocalInput (actor 33266) 472ms
LocalInput (actor 33265) 472ms
Merge 81970000000F 472ms
LocalInput (actor 33262) 472ms
LocalInput (actor 33261) 472ms
472ms party_account_via_portfolio_mv · Union 2 actors actor 33179
Epoch 11231927239573504 472ms
Materialize 819B00000023 472ms
Union 819B00000022 472ms
Merge 819B00000021 472ms
LocalInput (actor 33189) 472ms
LocalInput (actor 33190) 472ms
Merge 819B0000001F 472ms
LocalInput (actor 33187) 472ms
LocalInput (actor 33188) 472ms
472ms active_party_memberships_mv · hash_join_barrier_align 2 actors actor 33203
Epoch 11231927239573504 472ms
Project 81B300000007 472ms
HashJoin 81B300000006 472ms
hash_join_barrier_align 472ms
Merge 81B300000004 472ms
LocalInput (actor 33205) 472ms
LocalInput (actor 33206) 472ms
Merge 81B300000005 472ms
LocalInput (actor 33208) 472ms
LocalInput (actor 33207) 472ms
472ms team_to_parties_mv · Union 2 actors actor 33240
Epoch 11231927239573504 472ms
Union 81D800000010 472ms
Merge 81D80000000F 472ms
LocalInput (actor 33157) 472ms
LocalInput (actor 33158) 472ms
Merge 81D80000000C 472ms
LocalInput (actor 33159) 472ms
LocalInput (actor 33160) 472ms
472ms benchmark_twrr_by_sector_sink · Sink 2 actors actor 33341
Epoch 11231927239573504 472ms
Sink 823D00000003 472ms
consume_log (sink_id 22307) background loop alive 468211.9s
log_reader_next_item alive 472ms
Wait Next Item from Buffer alive 472ms
Wait For New Buffer Item alive 472ms
Merge 823D00000002 472ms
LocalInput (actor 33649) 472ms
LocalInput (actor 33648) 472ms
472ms benchmark_twrr_by_currency_sink · StreamScan 2 actors actor 33481
Epoch 11231927239573504 472ms
Sink 82C900000001 472ms
consume_log (sink_id 22322) background loop alive 468211.9s
log_reader_next_item alive 472ms
Wait Next Item from Buffer alive 472ms
Wait For New Buffer Item alive 472ms
StreamScan 82C900002724 472ms
Merge 82C900000000 472ms
LocalInput (actor 33479) 472ms
472ms account_to_account_groups_mv · Union 2 actors actor 33540
Epoch 11231927239573504 472ms
Union 830400000019 472ms
Merge 830400000018 472ms
LocalInput (actor 33559) 472ms
LocalInput (actor 33560) 472ms
Merge 830400000006 472ms
LocalInput (actor 33447) 472ms
LocalInput (actor 33448) 472ms
Merge 830400000016 472ms
LocalInput (actor 33557) 472ms
LocalInput (actor 33558) 472ms
Merge 830400000004 472ms
LocalInput (actor 33446) 472ms
LocalInput (actor 33445) 472ms
Merge 830400000011 472ms
LocalInput (actor 33543) 472ms
LocalInput (actor 33544) 472ms
Merge 830400000014 472ms
LocalInput (actor 33541) 472ms
LocalInput (actor 33542) 472ms
Merge 83040000000E 472ms
LocalInput (actor 33545) 472ms
LocalInput (actor 33546) 472ms
Merge 830400000002 472ms
LocalInput (actor 33443) 472ms
LocalInput (actor 33444) 472ms
472ms benchmark_twrr_by_taxonomy_node_sink · Sink 2 actors actor 33628
Epoch 11231927239573504 472ms
Sink 835C00000002 472ms
consume_log (sink_id 22315) background loop alive 468211.9s
log_reader_next_item alive 472ms
Wait Next Item from Buffer alive 472ms
Wait For New Buffer Item alive 472ms
Merge 835C00000001 472ms
LocalInput (actor 33645) 472ms
LocalInput (actor 33644) 472ms
472ms benchmark_twrr_by_asset_class_sink · StreamScan 2 actors actor 33642
Epoch 11231927239573504 472ms
Filter 836A00000001 472ms
StreamScan 836A00002733 472ms
Merge 836A00000000 472ms
LocalInput (actor 33646) 472ms
472ms benchmark_twrr_by_taxonomy_node_sink · StreamScan 2 actors actor 33644
Epoch 11231927239573504 472ms
StreamScan 836C00002728 472ms
Merge 836C00000000 472ms
LocalInput (actor 33646) 472ms
472ms benchmark_twrr_by_sector_sink · StreamScan 2 actors actor 33648
Epoch 11231927239573504 472ms
Filter 837000000001 472ms
StreamScan 837000002733 472ms
Merge 837000000000 472ms
LocalInput (actor 33646) 472ms
472ms benchmark_twrr_by_region_sink · StreamScan 2 actors actor 33650
Epoch 11231927239573504 472ms
Filter 837200000001 472ms
StreamScan 837200002733 472ms
Merge 837200000000 472ms
LocalInput (actor 33646) 472ms
472ms benchmark_twrr_by_asset_type_mv · HashAgg 2 actors actor 33666
Epoch 11231927239573504 472ms
Materialize 838200000007 472ms
Project 838200000006 472ms
HashAgg 838200000005 472ms
Merge 838200000004 472ms
LocalInput (actor 33671) 472ms
LocalInput (actor 33670) 472ms
472ms benchmark_twrr_by_asset_type_sink · StreamScan 2 actors actor 33668
Epoch 11231927239573504 472ms
Sink 838400000001 472ms
consume_log (sink_id 22325) background loop alive 468211.9s
log_reader_next_item alive 472ms
Wait Next Item from Buffer alive 472ms
Wait For New Buffer Item alive 472ms
StreamScan 838400002724 472ms
Merge 838400000000 472ms
LocalInput (actor 33666) 472ms
472ms benchmark_twrr_by_asset_type_mv · hash_join_barrier_align 2 actors actor 33670
Epoch 11231927239573504 472ms
HashJoin 838600000003 472ms
hash_join_barrier_align 472ms
Merge 838600000002 472ms
LocalInput (actor 33673) 472ms
LocalInput (actor 33672) 472ms
Merge 838600000001 472ms
LocalInput (actor 33656) 472ms
LocalInput (actor 33657) 472ms
472ms benchmark_twrr_by_region_sink · Sink 2 actors actor 33862
Epoch 11231927239573504 472ms
Sink 844600000003 472ms
consume_log (sink_id 22311) background loop alive 468211.9s
log_reader_next_item alive 472ms
Wait Next Item from Buffer alive 472ms
Wait For New Buffer Item alive 472ms
Merge 844600000002 472ms
LocalInput (actor 33651) 472ms
LocalInput (actor 33650) 472ms
472ms benchmark_twrr_by_asset_class_sink · Sink 2 actors actor 33882
Epoch 11231927239573504 472ms
Sink 845A00000003 472ms
consume_log (sink_id 22319) background loop alive 468211.9s
log_reader_next_item alive 472ms
Wait Next Item from Buffer alive 472ms
Wait For New Buffer Item alive 472ms
Merge 845A00000002 472ms
LocalInput (actor 33643) 472ms
LocalInput (actor 33642) 472ms
468ms team_to_tasks_mv · hash_join_barrier_align 8 actors actor 33614
Epoch 11231927239573504 468ms
Project 834E0000001B 468ms
HashJoin 834E0000001A 468ms
hash_join_barrier_align 468ms
Merge 834E00000019 468ms
LocalInput (actor 33626) 468ms
LocalInput (actor 33627) 468ms
Merge 834E00000018 468ms
LocalInput (actor 33617) 468ms
LocalInput (actor 33616) 468ms
468ms holding_values_journal_density_mv · hash_join_barrier_align 6 actors actor 33316
Epoch 11231927239573504 468ms
Materialize 822400000018 468ms
Project 822400000017 468ms
HashJoin 822400000016 468ms
hash_join_barrier_align 468ms
Merge 822400000014 468ms
LocalInput (actor 33318) 468ms
LocalInput (actor 33317) 468ms
Merge 822400000015 468ms
LocalInput (actor 33297) 468ms
LocalInput (actor 33298) 468ms
468ms team_to_accounts_mv · hash_join_barrier_align 6 actors actor 33404
Epoch 11231927239573504 468ms
Project 827C00000008 468ms
HashJoin 827C00000007 468ms
hash_join_barrier_align 468ms
Merge 827C00000006 468ms
LocalInput (actor 33328) 468ms
LocalInput (actor 33327) 468ms
Merge 827C00000003 468ms
LocalInput (actor 33406) 468ms
LocalInput (actor 33405) 468ms
468ms party_to_account_groups_mv · hash_join_barrier_align 6 actors actor 33491
Epoch 11231927239573504 468ms
Project 82D300000015 468ms
HashJoin 82D300000014 468ms
hash_join_barrier_align 468ms
Merge 82D30000000A 468ms
LocalInput (actor 33497) 468ms
Merge 82D300000013 468ms
LocalInput (actor 33476) 468ms
LocalInput (actor 33475) 468ms
468ms accruals_agg_mv · hash_join_barrier_align 6 actors actor 33519
Epoch 11231927239573504 468ms
Filter 82EF0000000A 468ms
HashJoin 82EF00000009 468ms
hash_join_barrier_align 468ms
Merge 82EF00000008 468ms
LocalInput (actor 33507) 468ms
LocalInput (actor 33508) 468ms
Merge 82EF00000007 468ms
LocalInput (actor 33521) 468ms
LocalInput (actor 33522) 468ms
468ms settled_position_valuations_mv · hash_join_barrier_align 6 actors actor 33549
Epoch 11231927239573504 468ms
Materialize 830D00000013 468ms
Project 830D00000012 468ms
Project 830D00000011 468ms
HashJoin 830D00000010 468ms
hash_join_barrier_align 468ms
Merge 830D0000000D 468ms
LocalInput (actor 33553) 468ms
LocalInput (actor 33554) 468ms
Merge 830D0000000F 468ms
LocalInput (actor 33579) 468ms
LocalInput (actor 33578) 468ms
468ms transactions_sink · hash_join_barrier_align 4 actors actor 32844
Epoch 11231927239573504 468ms
Sink 804C00000007 468ms
consume_log (sink_id 18272) background loop alive 468211.7s
log_reader_next_item alive 468ms
Wait Next Item from Buffer alive 468ms
Wait For New Buffer Item alive 468ms
HashJoin 804C00000006 468ms
hash_join_barrier_align 468ms
Merge 804C00000004 468ms
LocalInput (actor 32924) 468ms
LocalInput (actor 32925) 468ms
Merge 804C00000005 468ms
LocalInput (actor 32950) 468ms
LocalInput (actor 32951) 468ms
468ms user_account_membership_mv · Union 4 actors actor 33100
Epoch 11231927239573504 468ms
Materialize 814C00000037 468ms
Union 814C00000036 468ms
Merge 814C00000032 468ms
LocalInput (actor 33064) 468ms
LocalInput (actor 33063) 468ms
Merge 814C0000002F 468ms
LocalInput (actor 33066) 468ms
LocalInput (actor 33065) 468ms
Merge 814C00000035 468ms
LocalInput (actor 33062) 468ms
LocalInput (actor 33061) 468ms
468ms cash_values_journal_density_mv · hash_join_barrier_align 4 actors actor 33285
Epoch 11231927239573504 468ms
Project 82050000000D 468ms
Filter 82050000000C 468ms
HashJoin 82050000000B 468ms
hash_join_barrier_align 468ms
Merge 820500000003 468ms
LocalInput (actor 33300) 468ms
LocalInput (actor 33299) 468ms
Merge 82050000000A 468ms
LocalInput (actor 33287) 468ms
LocalInput (actor 33288) 468ms
468ms team_to_portfolios_mv · hash_join_barrier_align 4 actors actor 33336
Epoch 11231927239573504 468ms
Project 823800000008 468ms
HashJoin 823800000007 468ms
hash_join_barrier_align 468ms
Merge 823800000006 468ms
LocalInput (actor 33345) 468ms
LocalInput (actor 33346) 468ms
Merge 823800000003 468ms
LocalInput (actor 33344) 468ms
LocalInput (actor 33343) 468ms
468ms account_groups_mv · Union 4 actors actor 33395
Epoch 11231927239573504 468ms
Union 827300000041 468ms
Merge 827300000040 468ms
LocalInput (actor 33439) 468ms
LocalInput (actor 33440) 468ms
Merge 82730000003E 468ms
LocalInput (actor 33438) 468ms
LocalInput (actor 33437) 468ms
468ms account_groups_mv · HashAgg 4 actors actor 33383
Epoch 11231927239573504 468ms
Project 82670000003B 468ms
HashAgg 82670000003A 468ms
Merge 826700000039 468ms
LocalInput (actor 33385) 468ms
LocalInput (actor 33386) 468ms
468ms account_to_account_groups_settlement_binned_mv · StreamScan 4 actors actor 33640
Epoch 11231927239573504 468ms
Project 836800000004 468ms
Filter 836800000003 468ms
StreamScan 83680000278C 468ms
LocalInput (actor 32913) 468ms
LocalInput (actor 32912) 468ms
468ms settled_cash_balances_sink · StreamScan 2 actors actor 32662
Epoch 11231927239573504 468ms
Sink 7F9600000001 468ms
consume_log (sink_id 20874) background loop alive 468211.9s
log_reader_next_item alive 468ms
Wait Next Item from Buffer alive 468ms
Wait For New Buffer Item alive 468ms
StreamScan 7F9600002724 468ms
Merge 7F9600000000 468ms
LocalInput (actor 32664) 468ms
468ms settled_cash_balances_mv · HashAgg 2 actors actor 32665
Epoch 11231927239573504 468ms
Project 7F9900000003 468ms
HashAgg 7F9900000002 468ms
Merge 7F9900000001 468ms
LocalInput (actor 33271) 468ms
LocalInput (actor 33272) 468ms
468ms user_to_clients_mv · HashAgg 2 actors actor 32790
Epoch 11231927239573504 468ms
Materialize 80160000000B 468ms
Project 80160000000A 468ms
HashAgg 801600000009 468ms
Merge 801600000008 468ms
LocalInput (actor 32841) 468ms
LocalInput (actor 32842) 468ms
468ms client_to_account_groups_sink · hash_join_barrier_align 2 actors actor 32797
Epoch 11231927239573504 468ms
Sink 801D00000006 468ms
consume_log (sink_id 18296) background loop alive 468211.6s
log_reader_next_item alive 468ms
Wait Next Item from Buffer alive 468ms
Wait For New Buffer Item alive 468ms
Project 801D00000005 468ms
Filter 801D00000004 468ms
HashJoin 801D00000003 468ms
hash_join_barrier_align 468ms
Merge 801D00000002 468ms
LocalInput (actor 32963) 468ms
LocalInput (actor 32964) 468ms
Merge 801D00000001 468ms
LocalInput (actor 32968) 468ms
LocalInput (actor 32967) 468ms
468ms portfolios_sink · hash_join_barrier_align 2 actors actor 32824
Epoch 11231927239573504 468ms
HashJoin 803800000005 468ms
hash_join_barrier_align 468ms
Merge 803800000003 468ms
LocalInput (actor 32825) 468ms
LocalInput (actor 32826) 468ms
Merge 803800000004 468ms
LocalInput (actor 32794) 468ms
LocalInput (actor 32795) 468ms
468ms user_to_portfolios_mv · HashAgg 2 actors actor 32845
Epoch 11231927239573504 468ms
Materialize 804D0000000B 468ms
Project 804D0000000A 468ms
HashAgg 804D00000009 468ms
Merge 804D00000008 468ms
LocalInput (actor 32848) 468ms
LocalInput (actor 32847) 468ms
468ms active_entity_to_teams_mv · StreamScan 2 actors actor 32864
Epoch 11231927239573504 468ms
Materialize 806000000006 468ms
Project 806000000005 468ms
DynamicFilter 806000000004 468ms
Merge 806000000003 468ms
LocalInput (actor 32863) 468ms
Project 806000000002 468ms
Filter 806000000001 468ms
StreamScan 806000002758 468ms
LocalInput (actor 32621) 468ms
LocalInput (actor 32622) 468ms
468ms settled_position_series_sink · StreamScan 2 actors actor 32889
Epoch 11231927239573504 468ms
Sink 807900000001 468ms
consume_log (sink_id 20849) background loop alive 468211.9s
log_reader_next_item alive 468ms
Wait Next Item from Buffer alive 468ms
Wait For New Buffer Item alive 468ms
StreamScan 807900002724 468ms
Merge 807900000000 468ms
LocalInput (actor 32879) 468ms
468ms settled_cash_series_mv · TemporalJoin 2 actors actor 32892
Epoch 11231927239573504 468ms
Materialize 807C00000009 468ms
Project 807C00000008 468ms
OverWindow 807C00000007 468ms
Project 807C00000006 468ms
HashAgg 807C00000005 468ms
TemporalJoin 807C00000004 468ms
Merge 807C00000003 468ms
LocalInput (actor 32876) 468ms
Merge 807C00000002 468ms
LocalInput (actor 32871) 468ms
LocalInput (actor 32870) 468ms
468ms private_asset_holdings_sink · StreamScan 2 actors actor 32905
Epoch 11231927239573504 468ms
StreamScan 808900002726 468ms
LocalInput (actor 32783) 468ms
LocalInput (actor 32782) 468ms
468ms user_account_membership_mv · HashAgg 2 actors actor 33068
Epoch 11231927239573504 468ms
Project 812C00000027 468ms
HashAgg 812C00000026 468ms
Merge 812C00000025 468ms
LocalInput (actor 33069) 468ms
LocalInput (actor 33070) 468ms
468ms active_portfolios_to_teams_mv · StreamScan 2 actors actor 33097
Epoch 11231927239573504 468ms
Materialize 814900000002 468ms
Filter 814900000001 468ms
StreamScan 814900002731 468ms
LocalInput (actor 32865) 468ms
LocalInput (actor 32864) 468ms
468ms active_party_memberships_mv · HashAgg 2 actors actor 33193
Epoch 11231927239573504 468ms
Materialize 81A90000000D 468ms
Project 81A90000000C 468ms
HashAgg 81A90000000B 468ms
Merge 81A90000000A 468ms
LocalInput (actor 33202) 468ms
LocalInput (actor 33201) 468ms
468ms active_party_memberships_mv · Union 2 actors actor 33201
Epoch 11231927239573504 468ms
Union 81B100000009 468ms
Merge 81B100000008 468ms
LocalInput (actor 33203) 468ms
LocalInput (actor 33204) 468ms
Merge 81B100000003 468ms
LocalInput (actor 32727) 468ms
LocalInput (actor 32726) 468ms
468ms client_account_group_types_mv · HashAgg 2 actors actor 33219
Epoch 11231927239573504 468ms
Materialize 81C300000009 468ms
Project 81C300000008 468ms
HashAgg 81C300000007 468ms
Merge 81C300000006 468ms
LocalInput (actor 33221) 468ms
LocalInput (actor 33222) 468ms
468ms client_account_group_types_mv · Union 2 actors actor 33221
Epoch 11231927239573504 468ms
Union 81C500000005 468ms
Merge 81C500000004 468ms
LocalInput (actor 33177) 468ms
LocalInput (actor 33178) 468ms
Merge 81C500000002 468ms
LocalInput (actor 33223) 468ms
LocalInput (actor 33224) 468ms
468ms user_to_account_groups_mv · HashAgg 2 actors actor 33225
Epoch 11231927239573504 468ms
Materialize 81C900000004 468ms
Project 81C900000003 468ms
HashAgg 81C900000002 468ms
Merge 81C900000001 468ms
LocalInput (actor 33117) 468ms
LocalInput (actor 33118) 468ms
468ms team_to_parties_mv · hash_join_barrier_align 2 actors actor 33237
Epoch 11231927239573504 468ms
Materialize 81D50000001C 468ms
Project 81D50000001B 468ms
HashAgg 81D50000001A 468ms
HashJoin 81D500000019 468ms
hash_join_barrier_align 468ms
Merge 81D500000018 468ms
LocalInput (actor 33247) 468ms
LocalInput (actor 33248) 468ms
HashJoin 81D500000015 468ms
hash_join_barrier_align 468ms
Merge 81D500000011 468ms
LocalInput (actor 33239) 468ms
LocalInput (actor 33240) 468ms
Merge 81D500000014 468ms
LocalInput (actor 33161) 468ms
LocalInput (actor 33162) 468ms
468ms settled_cash_balances_mv · StreamScan 2 actors actor 33271
Epoch 11231927239573504 468ms
StreamScan 81F700002762 468ms
LocalInput (actor 32892) 468ms
LocalInput (actor 32893) 468ms
468ms team_to_portfolios_mv · HashAgg 2 actors actor 33308
Epoch 11231927239573504 468ms
Materialize 821C00000016 468ms
Project 821C00000015 468ms
HashAgg 821C00000014 468ms
Merge 821C00000013 468ms
LocalInput (actor 33310) 468ms
LocalInput (actor 33309) 468ms
468ms team_to_portfolios_mv · Union 2 actors actor 33309
Epoch 11231927239573504 468ms
Union 821D00000012 468ms
Merge 821D00000009 468ms
LocalInput (actor 33335) 468ms
LocalInput (actor 33336) 468ms
Merge 821D00000011 468ms
LocalInput (actor 33350) 468ms
LocalInput (actor 33349) 468ms
Merge 821D0000000E 468ms
LocalInput (actor 33338) 468ms
LocalInput (actor 33337) 468ms
468ms holding_values_raw_mv · Union 2 actors actor 33324
Epoch 11231927239573504 468ms
Materialize 822C00000006 468ms
Union 822C00000005 468ms
Merge 822C00000002 468ms
LocalInput (actor 33477) 468ms
LocalInput (actor 33478) 468ms
Merge 822C00000004 468ms
LocalInput (actor 33468) 468ms
LocalInput (actor 33467) 468ms
468ms party_account_group_types_mv · HashAgg 2 actors actor 33333
Epoch 11231927239573504 468ms
Materialize 823500000009 468ms
Project 823500000008 468ms
HashAgg 823500000007 468ms
Merge 823500000006 468ms
LocalInput (actor 33354) 468ms
LocalInput (actor 33353) 468ms
468ms party_account_group_types_mv · Union 2 actors actor 33353
Epoch 11231927239573504 468ms
Union 824900000005 468ms
Merge 824900000004 468ms
LocalInput (actor 33363) 468ms
LocalInput (actor 33364) 468ms
Merge 824900000002 468ms
LocalInput (actor 33355) 468ms
LocalInput (actor 33356) 468ms
468ms team_to_accounts_mv · HashAgg 2 actors actor 33400
Epoch 11231927239573504 468ms
Materialize 82780000001A 468ms
Project 827800000019 468ms
HashAgg 827800000018 468ms
Merge 827800000017 468ms
LocalInput (actor 33402) 468ms
LocalInput (actor 33401) 468ms
468ms team_to_accounts_mv · Union 2 actors actor 33401
Epoch 11231927239573504 468ms
Union 827900000016 468ms
Merge 827900000015 468ms
LocalInput (actor 33485) 468ms
LocalInput (actor 33486) 468ms
Merge 827900000009 468ms
LocalInput (actor 33403) 468ms
LocalInput (actor 33404) 468ms
Merge 82790000000E 468ms
LocalInput (actor 33484) 468ms
LocalInput (actor 33483) 468ms
468ms account_to_account_groups_settlement_binned_mv · HashAgg 2 actors actor 33511
Epoch 11231927239573504 468ms
Project 82E700000007 468ms
HashAgg 82E700000006 468ms
Merge 82E700000005 468ms
LocalInput (actor 33641) 468ms
LocalInput (actor 33640) 468ms
468ms account_to_account_groups_mv · OverWindow 2 actors actor 33537
Epoch 11231927239573504 468ms
OverWindow 83010000001B 468ms
Merge 83010000001A 468ms
LocalInput (actor 33539) 468ms
LocalInput (actor 33540) 468ms
468ms team_to_tasks_mv · GroupTopN 2 actors actor 33581
Epoch 11231927239573504 468ms
Materialize 832D00000021 468ms
Project 832D00000020 468ms
GroupTopN 832D0000001F 468ms
Merge 832D0000001E 468ms
LocalInput (actor 33582) 468ms
LocalInput (actor 33583) 468ms
468ms account_groups_sink · Sink 2 actors actor 33998
Epoch 11231927239573504 468ms
Sink 84CE00000002 468ms
consume_log (sink_id 22285) background loop alive 468211.9s
log_reader_next_item alive 468ms
Wait Next Item from Buffer alive 468ms
Wait For New Buffer Item alive 468ms
Merge 84CE00000001 468ms
LocalInput (actor 33367) 468ms
LocalInput (actor 33368) 468ms
464ms flow_by_transaction_type_mv · hash_join_barrier_align 10 actors actor 33728
Epoch 11231927239573504 464ms
Project 83C00000001C 464ms
Filter 83C00000001B 464ms
HashJoin 83C00000001A 464ms
hash_join_barrier_align 464ms
Merge 83C000000019 464ms
LocalInput (actor 33860) 464ms
LocalInput (actor 33861) 464ms
Merge 83C000000017 464ms
LocalInput (actor 33841) 464ms
LocalInput (actor 33840) 464ms
464ms position_values_mv · hash_join_barrier_align 6 actors actor 33820
Epoch 11231927239573504 464ms
Materialize 841C00000011 464ms
Project 841C00000010 464ms
Project 841C0000000F 464ms
Filter 841C0000000E 464ms
HashJoin 841C0000000D 464ms
hash_join_barrier_align 464ms
Merge 841C0000000C 464ms
LocalInput (actor 33891) 464ms
LocalInput (actor 33890) 464ms
Merge 841C0000000B 464ms
LocalInput (actor 33822) 464ms
LocalInput (actor 33823) 464ms
464ms user_account_membership_mv · Filter 4 actors actor 33061
Epoch 11231927239573504 464ms
Project 812500000034 464ms
Filter 812500000033 464ms
Merge 81250000002D 464ms
LocalInput (actor 33059) 464ms
464ms holding_values_mv · StreamScan 4 actors actor 33463
Epoch 11231927239573504 464ms
Project 82B700000001 464ms
StreamScan 82B70000274D 464ms
LocalInput (actor 33674) 464ms
LocalInput (actor 33675) 464ms
464ms holding_values_raw_mv · StreamScan 4 actors actor 33467
Epoch 11231927239573504 464ms
Project 82BB00000003 464ms
StreamScan 82BB0000275C 464ms
LocalInput (actor 33284) 464ms
LocalInput (actor 33283) 464ms
464ms account_to_account_groups_membership_mv · StreamScan 4 actors actor 33607
Epoch 11231927239573504 464ms
Project 834700000001 464ms
StreamScan 834700002753 464ms
LocalInput (actor 33361) 464ms
LocalInput (actor 33362) 464ms
464ms orphan_accruals_mv · hash_join_barrier_align 4 actors actor 33634
Epoch 11231927239573504 464ms
Materialize 83620000000B 464ms
Project 83620000000A 464ms
Filter 836200000009 464ms
HashJoin 836200000008 464ms
hash_join_barrier_align 464ms
Merge 836200000007 464ms
LocalInput (actor 33687) 464ms
LocalInput (actor 33686) 464ms
Merge 836200000005 464ms
LocalInput (actor 33637) 464ms
LocalInput (actor 33636) 464ms
464ms holding_values_with_accruals_mv · hash_join_barrier_align 4 actors actor 33674
Epoch 11231927239573504 464ms
Materialize 838A0000000A 464ms
Project 838A00000009 464ms
Filter 838A00000008 464ms
HashJoin 838A00000007 464ms
hash_join_barrier_align 464ms
Merge 838A00000006 464ms
LocalInput (actor 33706) 464ms
LocalInput (actor 33707) 464ms
Merge 838A00000004 464ms
LocalInput (actor 33676) 464ms
LocalInput (actor 33677) 464ms
464ms flow_by_transaction_type_mv · HashAgg 4 actors actor 33726
Epoch 11231927239573504 464ms
Project 83BE0000001F 464ms
HashAgg 83BE0000001E 464ms
Merge 83BE0000001D 464ms
LocalInput (actor 33728) 464ms
LocalInput (actor 33729) 464ms
464ms position_snapshot_mv · hash_join_barrier_align 4 actors actor 33791
Epoch 11231927239573504 464ms
HashJoin 83FF00000005 464ms
hash_join_barrier_align 464ms
Merge 83FF00000001 464ms
LocalInput (actor 33792) 464ms
LocalInput (actor 33793) 464ms
Merge 83FF00000004 464ms
LocalInput (actor 33795) 464ms
LocalInput (actor 33794) 464ms
464ms position_by_asset_mv · hash_join_barrier_align 4 actors actor 33922
Epoch 11231927239573504 464ms
Filter 84820000000A 464ms
Project 848200000009 464ms
HashJoin 848200000008 464ms
hash_join_barrier_align 464ms
Merge 848200000007 464ms
LocalInput (actor 33929) 464ms
LocalInput (actor 33928) 464ms
Merge 848200000006 464ms
LocalInput (actor 33925) 464ms
LocalInput (actor 33924) 464ms
464ms twrr_by_currency_mv · StreamScan 4 actors actor 34042
Epoch 11231927239573504 464ms
Filter 84FA00000006 464ms
StreamScan 84FA000027AC 464ms
LocalInput (actor 33796) 464ms
LocalInput (actor 33797) 464ms
464ms position_by_currency_mv · StreamScan 4 actors actor 33980
Epoch 11231927239573504 464ms
Expand 84BC00000001 464ms
StreamScan 84BC00002797 464ms
LocalInput (actor 33821) 464ms
LocalInput (actor 33820) 464ms
464ms settled_cash_balances_mv · OverWindow 2 actors actor 32663
Epoch 11231927239573504 464ms
Materialize 7F9700000007 464ms
Project 7F9700000006 464ms
OverWindow 7F9700000005 464ms
Merge 7F9700000004 464ms
LocalInput (actor 32666) 464ms
LocalInput (actor 32665) 464ms
464ms accounts_sink · Sink 2 actors actor 32741
Epoch 11231927239573504 464ms
Sink 7FE500000007 464ms
consume_log (sink_id 18235) background loop alive 468211.9s
log_reader_next_item alive 464ms
Wait Next Item from Buffer alive 464ms
Wait For New Buffer Item alive 464ms
Merge 7FE500000006 464ms
LocalInput (actor 32744) 464ms
LocalInput (actor 32743) 464ms
464ms accounts_sink · hash_join_barrier_align 2 actors actor 32743
Epoch 11231927239573504 464ms
HashJoin 7FE700000005 464ms
hash_join_barrier_align 464ms
Merge 7FE700000003 464ms
LocalInput (actor 32750) 464ms
LocalInput (actor 32749) 464ms
Merge 7FE700000004 464ms
LocalInput (actor 32751) 464ms
LocalInput (actor 32752) 464ms
464ms portfolios_sink · Sink 2 actors actor 32821
Epoch 11231927239573504 464ms
Sink 803500000007 464ms
consume_log (sink_id 18252) background loop alive 468211.9s
log_reader_next_item alive 464ms
Wait Next Item from Buffer alive 464ms
Wait For New Buffer Item alive 464ms
Merge 803500000006 464ms
LocalInput (actor 32823) 464ms
LocalInput (actor 32824) 464ms
464ms user_account_membership_mv · Project 2 actors actor 33065
Epoch 11231927239573504 464ms
Project 81290000002E 464ms
Merge 81290000002D 464ms
LocalInput (actor 33059) 464ms
464ms active_clients_to_teams_mv · StreamScan 2 actors actor 33095
Epoch 11231927239573504 464ms
Materialize 814700000002 464ms
Filter 814700000001 464ms
StreamScan 814700002731 464ms
LocalInput (actor 32865) 464ms
LocalInput (actor 32864) 464ms
464ms user_to_account_groups_mv · StreamScan 2 actors actor 33117
Epoch 11231927239573504 464ms
StreamScan 815D0000273C 464ms
LocalInput (actor 33100) 464ms
LocalInput (actor 33099) 464ms
464ms account_groups_sink · StreamScan 2 actors actor 33367
Epoch 11231927239573504 464ms
StreamScan 825700002728 464ms
Merge 825700000000 464ms
LocalInput (actor 33365) 464ms
464ms party_to_account_groups_mv · Union 2 actors actor 33487
Epoch 11231927239573504 464ms
Materialize 82CF0000001D 464ms
Union 82CF0000001C 464ms
Merge 82CF0000001B 464ms
LocalInput (actor 33496) 464ms
LocalInput (actor 33495) 464ms
Merge 82CF00000011 464ms
LocalInput (actor 33493) 464ms
LocalInput (actor 33494) 464ms
Merge 82CF00000016 464ms
LocalInput (actor 33492) 464ms
LocalInput (actor 33491) 464ms
Merge 82CF0000000C 464ms
LocalInput (actor 33499) 464ms
LocalInput (actor 33500) 464ms
464ms party_to_account_groups_sink · StreamScan 2 actors actor 33489
Epoch 11231927239573504 464ms
StreamScan 82D100002728 464ms
Merge 82D100000000 464ms
LocalInput (actor 33487) 464ms
464ms account_to_account_groups_settlement_binned_mv · hash_join_barrier_align 2 actors actor 33509
Epoch 11231927239573504 464ms
Materialize 82E50000000C 464ms
Project 82E50000000B 464ms
Filter 82E50000000A 464ms
HashJoin 82E500000009 464ms
hash_join_barrier_align 464ms
Merge 82E500000008 464ms
LocalInput (actor 33511) 464ms
LocalInput (actor 33512) 464ms
Merge 82E500000002 464ms
LocalInput (actor 33514) 464ms
LocalInput (actor 33513) 464ms
464ms accruals_agg_mv · HashAgg 2 actors actor 33515
Epoch 11231927239573504 464ms
Materialize 82EB00000014 464ms
Project 82EB00000013 464ms
HashAgg 82EB00000012 464ms
Merge 82EB00000011 464ms
LocalInput (actor 33518) 464ms
LocalInput (actor 33517) 464ms
464ms account_to_account_groups_txn_binned_mv · hash_join_barrier_align 2 actors actor 33527
Epoch 11231927239573504 464ms
Materialize 82F70000000B 464ms
Project 82F70000000A 464ms
Filter 82F700000009 464ms
HashJoin 82F700000008 464ms
hash_join_barrier_align 464ms
Merge 82F700000007 464ms
LocalInput (actor 33530) 464ms
LocalInput (actor 33529) 464ms
Merge 82F700000002 464ms
LocalInput (actor 33531) 464ms
LocalInput (actor 33532) 464ms
464ms settled_position_valuations_sink · StreamScan 2 actors actor 33551
Epoch 11231927239573504 464ms
Sink 830F00000001 464ms
consume_log (sink_id 22296) background loop alive 468211.9s
log_reader_next_item alive 464ms
Wait Next Item from Buffer alive 464ms
Wait For New Buffer Item alive 464ms
StreamScan 830F00002725 464ms
Merge 830F00000000 464ms
LocalInput (actor 33549) 464ms
464ms team_to_tasks_mv · Union 2 actors actor 33582
Epoch 11231927239573504 464ms
Union 832E0000001D 464ms
Merge 832E0000000E 464ms
LocalInput (actor 33608) 464ms
LocalInput (actor 33609) 464ms
Merge 832E00000015 464ms
LocalInput (actor 33613) 464ms
LocalInput (actor 33612) 464ms
Merge 832E00000007 464ms
LocalInput (actor 33585) 464ms
LocalInput (actor 33584) 464ms
Merge 832E0000001C 464ms
LocalInput (actor 33614) 464ms
LocalInput (actor 33615) 464ms
464ms account_to_account_groups_sink · StreamScan 2 actors actor 33602
Epoch 11231927239573504 464ms
StreamScan 834200002728 464ms
Merge 834200000000 464ms
LocalInput (actor 33604) 464ms
464ms holding_values_latest_mv · GroupTopN 2 actors actor 33693
Epoch 11231927239573504 464ms
Materialize 839D00000004 464ms
Project 839D00000003 464ms
GroupTopN 839D00000002 464ms
Merge 839D00000001 464ms
LocalInput (actor 33694) 464ms
LocalInput (actor 33695) 464ms
464ms flow_by_transaction_type_sink · StreamScan 2 actors actor 33724
Epoch 11231927239573504 464ms
Sink 83BC00000002 464ms
consume_log (sink_id 22344) background loop alive 468211.9s
log_reader_next_item alive 464ms
Wait Next Item from Buffer alive 464ms
Wait For New Buffer Item alive 464ms
Project 83BC00000001 464ms
StreamScan 83BC0000272B 464ms
Merge 83BC00000000 464ms
LocalInput (actor 33722) 464ms
464ms abor_settlement_positions_mv · OverWindow 2 actors actor 33730
Epoch 11231927239573504 464ms
Materialize 83C200000013 464ms
Project 83C200000012 464ms
OverWindow 83C200000011 464ms
Merge 83C200000010 464ms
LocalInput (actor 33735) 464ms
LocalInput (actor 33734) 464ms
464ms abor_settlement_positions_mv · hash_join_barrier_align 2 actors actor 33736
Epoch 11231927239573504 464ms
Expand 83C80000000C 464ms
Project 83C80000000B 464ms
Filter 83C80000000A 464ms
HashJoin 83C800000009 464ms
hash_join_barrier_align 464ms
Merge 83C800000006 464ms
LocalInput (actor 32883) 464ms
LocalInput (actor 32882) 464ms
Merge 83C800000008 464ms
LocalInput (actor 33741) 464ms
LocalInput (actor 33740) 464ms
464ms flow_by_asset_type_mv · StreamScan 2 actors actor 33785
Epoch 11231927239573504 464ms
StreamScan 83F900002742 464ms
LocalInput (actor 33688) 464ms
LocalInput (actor 33689) 464ms
464ms flow_by_currency_mv · OverWindow 2 actors actor 33797
Epoch 11231927239573504 464ms
Materialize 840500000008 464ms
OverWindow 840500000007 464ms
Merge 840500000006 464ms
LocalInput (actor 33800) 464ms
LocalInput (actor 33801) 464ms
464ms flow_by_currency_mv · HashAgg 2 actors actor 33801
Epoch 11231927239573504 464ms
Project 840900000005 464ms
HashAgg 840900000004 464ms
Merge 840900000003 464ms
LocalInput (actor 33803) 464ms
LocalInput (actor 33802) 464ms
464ms flow_by_currency_mv · StreamScan 2 actors actor 33802
Epoch 11231927239573504 464ms
Filter 840A00000002 464ms
Expand 840A00000001 464ms
StreamScan 840A00002792 464ms
LocalInput (actor 33679) 464ms
LocalInput (actor 33678) 464ms
464ms account_to_account_groups_binned_mv · hash_join_barrier_align 2 actors actor 33805
Epoch 11231927239573504 464ms
Materialize 840D0000000B 464ms
Project 840D0000000A 464ms
Filter 840D00000009 464ms
HashJoin 840D00000008 464ms
hash_join_barrier_align 464ms
Merge 840D00000002 464ms
LocalInput (actor 33809) 464ms
LocalInput (actor 33808) 464ms
Merge 840D00000007 464ms
LocalInput (actor 33807) 464ms
LocalInput (actor 33806) 464ms
464ms holding_values_sink · Sink 2 actors actor 33898
Epoch 11231927239573504 464ms
Sink 846A00000003 464ms
consume_log (sink_id 22332) background loop alive 468211.9s
log_reader_next_item alive 464ms
Wait Next Item from Buffer alive 464ms
Wait For New Buffer Item alive 464ms
Merge 846A00000002 464ms
LocalInput (actor 33461) 464ms
LocalInput (actor 33462) 464ms
464ms asset_distributions_week_binned_mv · HashAgg 2 actors actor 33903
Epoch 11231927239573504 464ms
Project 846F00000006 464ms
HashAgg 846F00000005 464ms
Merge 846F00000004 464ms
LocalInput (actor 33958) 464ms
LocalInput (actor 33959) 464ms
464ms position_summary_sink · Sink 2 actors actor 33907
Epoch 11231927239573504 464ms
Sink 847300000003 464ms
consume_log (sink_id 22372) background loop alive 468211.9s
log_reader_next_item alive 464ms
Wait Next Item from Buffer alive 464ms
Wait For New Buffer Item alive 464ms
Merge 847300000002 464ms
LocalInput (actor 33915) 464ms
LocalInput (actor 33914) 464ms
464ms position_summary_mv · HashAgg 2 actors actor 33916
Epoch 11231927239573504 464ms
Materialize 847C00000004 464ms
Project 847C00000003 464ms
HashAgg 847C00000002 464ms
Merge 847C00000001 464ms
LocalInput (actor 33972) 464ms
LocalInput (actor 33973) 464ms
464ms party_to_account_groups_sink · Sink 2 actors actor 34076
Epoch 11231927239573504 464ms
Sink 851C00000002 464ms
consume_log (sink_id 22293) background loop alive 468211.9s
log_reader_next_item alive 464ms
Wait Next Item from Buffer alive 464ms
Wait For New Buffer Item alive 464ms
Merge 851C00000001 464ms
LocalInput (actor 33489) 464ms
LocalInput (actor 33490) 464ms
460ms position_by_distribution_mv · StreamScan 6 actors actor 34024
Epoch 11231927239573504 460ms
Project 84E800000001 460ms
StreamScan 84E8000027BE 460ms
LocalInput (actor 33944) 460ms
LocalInput (actor 33945) 460ms
460ms account_to_account_groups_binned_mv · StreamScan 4 actors actor 33808
Epoch 11231927239573504 460ms
Project 841000000001 460ms
StreamScan 841000002776 460ms
LocalInput (actor 33361) 460ms
LocalInput (actor 33362) 460ms
460ms pnl_summary_mv · StreamScan 4 actors actor 34028
Epoch 11231927239573504 460ms
Filter 84EC00000001 460ms
StreamScan 84EC0000275D 460ms
LocalInput (actor 33917) 460ms
LocalInput (actor 33916) 460ms
460ms pnl_by_currency_mv · StreamScan 4 actors actor 33986
Epoch 11231927239573504 460ms
StreamScan 84C200002762 460ms
LocalInput (actor 33796) 460ms
LocalInput (actor 33797) 460ms
460ms position_by_asset_type_mv · StreamScan 4 actors actor 33994
Epoch 11231927239573504 460ms
Expand 84CA00000002 460ms
Project 84CA00000001 460ms
StreamScan 84CA00002798 460ms
LocalInput (actor 33821) 460ms
LocalInput (actor 33820) 460ms
460ms twrr_mv · StreamScan 4 actors actor 34004
Epoch 11231927239573504 460ms
Filter 84D400000001 460ms
StreamScan 84D400002799 460ms
LocalInput (actor 33917) 460ms
LocalInput (actor 33916) 460ms
460ms position_by_distribution_mv · hash_join_barrier_align 4 actors actor 34014
Epoch 11231927239573504 460ms
Materialize 84DE0000000E 460ms
Project 84DE0000000D 460ms
HashJoin 84DE0000000C 460ms
hash_join_barrier_align 460ms
Merge 84DE0000000B 460ms
LocalInput (actor 33949) 460ms
LocalInput (actor 33948) 460ms
Merge 84DE0000000A 460ms
LocalInput (actor 34018) 460ms
LocalInput (actor 34019) 460ms
460ms twrr_by_distribution_mv · StreamScan 4 actors actor 34023
Epoch 11231927239573504 460ms
Filter 84E700000001 460ms
StreamScan 84E7000027A4 460ms
LocalInput (actor 34014) 460ms
LocalInput (actor 34015) 460ms
460ms pnl_by_asset_mv · StreamScan 4 actors actor 34079
Epoch 11231927239573504 460ms
StreamScan 851F00002762 460ms
LocalInput (actor 33831) 460ms
LocalInput (actor 33830) 460ms
460ms user_to_account_groups_sink · StreamScan 2 actors actor 33012
Epoch 11231927239573504 460ms
Sink 80F400000001 464ms
consume_log (sink_id 18304) background loop alive 468211.7s
log_reader_next_item alive 460ms
Wait Next Item from Buffer alive 460ms
Wait For New Buffer Item alive 460ms
StreamScan 80F400002725 460ms
LocalInput (actor 33225) 460ms
LocalInput (actor 33226) 460ms
460ms holding_values_mv · Union 2 actors actor 33459
Epoch 11231927239573504 460ms
Materialize 82B300000006 460ms
Union 82B300000005 460ms
Merge 82B300000002 460ms
LocalInput (actor 33464) 460ms
LocalInput (actor 33463) 460ms
Merge 82B300000004 460ms
LocalInput (actor 33465) 460ms
LocalInput (actor 33466) 460ms
460ms holding_values_sink · StreamScan 2 actors actor 33461
Epoch 11231927239573504 460ms
Project 82B500000001 460ms
StreamScan 82B50000272C 460ms
Merge 82B500000000 460ms
LocalInput (actor 33459) 460ms
460ms account_to_account_groups_sink · Sink 2 actors actor 33598
Epoch 11231927239573504 460ms
Sink 833E00000002 460ms
consume_log (sink_id 22303) background loop alive 468211.8s
log_reader_next_item alive 460ms
Wait Next Item from Buffer alive 460ms
Wait For New Buffer Item alive 460ms
Merge 833E00000001 460ms
LocalInput (actor 33603) 460ms
LocalInput (actor 33602) 460ms
460ms account_to_account_groups_membership_mv · Union 2 actors actor 33604
Epoch 11231927239573504 460ms
Materialize 834400000006 460ms
Union 834400000005 460ms
Merge 834400000002 460ms
LocalInput (actor 33606) 460ms
LocalInput (actor 33607) 460ms
Merge 834400000004 460ms
LocalInput (actor 33631) 460ms
LocalInput (actor 33630) 460ms
460ms flow_asset_values_mv · HashAgg 2 actors actor 33688
Epoch 11231927239573504 460ms
Materialize 839800000007 460ms
Project 839800000006 460ms
HashAgg 839800000005 460ms
Merge 839800000004 460ms
LocalInput (actor 33690) 460ms
LocalInput (actor 33691) 460ms
460ms flow_asset_values_mv · StreamScan 2 actors actor 33690
Epoch 11231927239573504 460ms
Filter 839A00000003 460ms
Expand 839A00000002 460ms
Project 839A00000001 460ms
StreamScan 839A00002777 460ms
LocalInput (actor 33679) 460ms
LocalInput (actor 33678) 460ms
460ms holding_values_latest_mv · StreamScan 2 actors actor 33694
Epoch 11231927239573504 460ms
StreamScan 839E00002756 460ms
LocalInput (actor 33459) 460ms
LocalInput (actor 33460) 460ms
460ms position_by_currency_sink · Sink 2 actors actor 33709
Epoch 11231927239573504 460ms
Sink 83AD00000003 460ms
consume_log (sink_id 22376) background loop alive 468211.9s
log_reader_next_item alive 460ms
Wait Next Item from Buffer alive 460ms
Wait For New Buffer Item alive 460ms
Merge 83AD00000002 460ms
LocalInput (actor 33974) 460ms
LocalInput (actor 33975) 460ms
460ms position_by_asset_type_sink · Sink 2 actors actor 33711
Epoch 11231927239573504 460ms
Sink 83AF00000003 460ms
consume_log (sink_id 22380) background loop alive 468211.9s
log_reader_next_item alive 460ms
Wait Next Item from Buffer alive 460ms
Wait For New Buffer Item alive 460ms
Merge 83AF00000002 460ms
LocalInput (actor 33990) 460ms
LocalInput (actor 33991) 460ms
460ms flow_by_transaction_type_mv · OverWindow 2 actors actor 33722
Epoch 11231927239573504 460ms
Materialize 83BA00000022 460ms
OverWindow 83BA00000021 460ms
Merge 83BA00000020 460ms
LocalInput (actor 33727) 460ms
LocalInput (actor 33726) 460ms
460ms abor_settlement_positions_sink · StreamScan 2 actors actor 33732
Epoch 11231927239573504 460ms
Sink 83C400000001 460ms
consume_log (sink_id 22328) background loop alive 468211.9s
log_reader_next_item alive 460ms
Wait Next Item from Buffer alive 460ms
Wait For New Buffer Item alive 460ms
StreamScan 83C400002725 460ms
Merge 83C400000000 460ms
LocalInput (actor 33730) 460ms
460ms abor_settlement_positions_mv · HashAgg 2 actors actor 33734
Epoch 11231927239573504 460ms
Project 83C60000000F 460ms
HashAgg 83C60000000E 460ms
Merge 83C60000000D 460ms
LocalInput (actor 33737) 460ms
LocalInput (actor 33736) 460ms
460ms position_snapshot_mv · HashAgg 2 actors actor 33786
Epoch 11231927239573504 460ms
Materialize 83FA00000010 460ms
Project 83FA0000000F 460ms
HashAgg 83FA0000000E 460ms
Merge 83FA0000000D 460ms
LocalInput (actor 33789) 460ms
LocalInput (actor 33788) 460ms
460ms flow_by_currency_sink · StreamScan 2 actors actor 33798
Epoch 11231927239573504 460ms
Sink 840600000002 460ms
consume_log (sink_id 22336) background loop alive 468211.9s
log_reader_next_item alive 460ms
Wait Next Item from Buffer alive 460ms
Wait For New Buffer Item alive 460ms
Project 840600000001 460ms
StreamScan 84060000272C 460ms
Merge 840600000000 460ms
LocalInput (actor 33796) 460ms
460ms account_to_account_groups_binned_mv · HashAgg 2 actors actor 33806
Epoch 11231927239573504 460ms
Project 840E00000006 460ms
HashAgg 840E00000005 460ms
Merge 840E00000004 460ms
LocalInput (actor 33810) 460ms
LocalInput (actor 33811) 460ms
460ms flow_summary_mv · OverWindow 2 actors actor 33814
Epoch 11231927239573504 460ms
Materialize 841600000006 460ms
OverWindow 841600000005 460ms
Merge 841600000004 460ms
LocalInput (actor 33816) 460ms
LocalInput (actor 33817) 460ms
460ms flow_summary_mv · StreamScan 2 actors actor 33819
Epoch 11231927239573504 460ms
StreamScan 841B00002742 460ms
LocalInput (actor 33688) 460ms
LocalInput (actor 33689) 460ms
460ms flow_by_asset_mv · hash_join_barrier_align 2 actors actor 33834
Epoch 11231927239573504 460ms
Filter 842A00000009 460ms
Expand 842A00000008 460ms
Project 842A00000007 460ms
Filter 842A00000006 460ms
HashJoin 842A00000005 460ms
hash_join_barrier_align 460ms
Merge 842A00000003 460ms
LocalInput (actor 33837) 460ms
LocalInput (actor 33836) 460ms
Merge 842A00000004 460ms
LocalInput (actor 33839) 460ms
LocalInput (actor 33838) 460ms
460ms flow_by_distribution_mv · hash_join_barrier_align 2 actors actor 33877
Epoch 11231927239573504 460ms
Project 845500000005 460ms
Filter 845500000004 460ms
HashJoin 845500000003 460ms
hash_join_barrier_align 460ms
Merge 845500000001 460ms
LocalInput (actor 33879) 460ms
LocalInput (actor 33878) 460ms
Merge 845500000002 460ms
LocalInput (actor 33880) 460ms
LocalInput (actor 33881) 460ms
460ms asset_distributions_week_binned_mv · hash_join_barrier_align 2 actors actor 33900
Epoch 11231927239573504 460ms
Materialize 846C0000000B 460ms
Project 846C0000000A 460ms
Filter 846C00000009 460ms
HashJoin 846C00000008 460ms
hash_join_barrier_align 460ms
Merge 846C00000002 460ms
LocalInput (actor 33905) 460ms
LocalInput (actor 33904) 460ms
Merge 846C00000007 460ms
LocalInput (actor 33902) 460ms
LocalInput (actor 33903) 460ms
460ms position_summary_sink · StreamScan 2 actors actor 33914
Epoch 11231927239573504 460ms
Project 847A00000001 460ms
StreamScan 847A0000272C 460ms
Merge 847A00000000 460ms
LocalInput (actor 33916) 460ms
460ms position_by_asset_mv · HashAgg 2 actors actor 33924
Epoch 11231927239573504 460ms
Project 848400000005 460ms
HashAgg 848400000004 460ms
Merge 848400000003 460ms
LocalInput (actor 33927) 460ms
LocalInput (actor 33926) 460ms
460ms twrr_by_asset_type_mv · hash_join_barrier_align 2 actors actor 33933
Epoch 11231927239573504 460ms
Materialize 848D0000000B 460ms
Project 848D0000000A 460ms
Project 848D00000009 460ms
HashJoin 848D00000008 460ms
hash_join_barrier_align 460ms
Merge 848D00000005 460ms
LocalInput (actor 33936) 460ms
LocalInput (actor 33937) 460ms
Merge 848D00000007 460ms
LocalInput (actor 34046) 460ms
LocalInput (actor 34047) 460ms
460ms position_asset_values_mv · HashAgg 2 actors actor 33944
Epoch 11231927239573504 460ms
Materialize 849800000006 460ms
Project 849800000005 460ms
HashAgg 849800000004 460ms
Merge 849800000003 460ms
LocalInput (actor 33946) 460ms
LocalInput (actor 33947) 460ms
460ms position_asset_values_mv · StreamScan 2 actors actor 33946
Epoch 11231927239573504 460ms
Expand 849A00000002 460ms
Project 849A00000001 460ms
StreamScan 849A00002764 460ms
LocalInput (actor 33821) 460ms
LocalInput (actor 33820) 460ms
460ms twrr_by_asset_mv · OverWindow 2 actors actor 33955
Epoch 11231927239573504 460ms
Filter 84A300000004 460ms
OverWindow 84A300000003 460ms
Merge 84A300000002 460ms
LocalInput (actor 34081) 460ms
LocalInput (actor 34080) 460ms
460ms position_summary_mv · StreamScan 2 actors actor 33972
Epoch 11231927239573504 460ms
StreamScan 84B40000273E 460ms
LocalInput (actor 33944) 460ms
LocalInput (actor 33945) 460ms
460ms position_by_currency_sink · StreamScan 2 actors actor 33975
Epoch 11231927239573504 460ms
Project 84B700000001 460ms
StreamScan 84B70000272C 460ms
Merge 84B700000000 460ms
LocalInput (actor 33977) 460ms
460ms position_by_currency_mv · HashAgg 2 actors actor 33978
Epoch 11231927239573504 460ms
Project 84BA00000004 460ms
HashAgg 84BA00000003 460ms
Merge 84BA00000002 460ms
LocalInput (actor 33980) 460ms
LocalInput (actor 33981) 460ms
460ms position_by_asset_type_mv · HashAgg 2 actors actor 33992
Epoch 11231927239573504 460ms
Project 84C800000005 460ms
HashAgg 84C800000004 460ms
Merge 84C800000003 460ms
LocalInput (actor 33995) 460ms
LocalInput (actor 33994) 460ms
460ms position_by_asset_sink · Sink 2 actors actor 34088
Epoch 11231927239573504 460ms
Sink 852800000003 460ms
consume_log (sink_id 22404) background loop alive 468211.9s
log_reader_next_item alive 460ms
Wait Next Item from Buffer alive 460ms
Wait For New Buffer Item alive 460ms
Merge 852800000002 460ms
LocalInput (actor 33920) 460ms
LocalInput (actor 33921) 460ms
456ms twrr_by_asset_mv · StreamScan 4 actors actor 33956
Epoch 11231927239573504 456ms
Filter 84A400000006 456ms
StreamScan 84A4000027AC 456ms
LocalInput (actor 33831) 456ms
LocalInput (actor 33830) 456ms
456ms twrr_by_asset_type_mv · StreamScan 4 actors actor 34044
Epoch 11231927239573504 456ms
Filter 84FC00000001 456ms
StreamScan 84FC000027A4 456ms
LocalInput (actor 33988) 456ms
LocalInput (actor 33989) 456ms
456ms pnl_by_asset_type_mv · StreamScan 4 actors actor 34054
Epoch 11231927239573504 456ms
Filter 850600000001 456ms
StreamScan 85060000275D 456ms
LocalInput (actor 33988) 456ms
LocalInput (actor 33989) 456ms
456ms pnl_by_distribution_mv · StreamScan 4 actors actor 34070
Epoch 11231927239573504 456ms
Filter 851600000001 456ms
StreamScan 85160000275E 456ms
LocalInput (actor 34014) 456ms
LocalInput (actor 34015) 456ms
456ms position_by_sector_sink · Sink 2 actors actor 32875
Epoch 11231927239573504 456ms
Sink 806B00000004 456ms
consume_log (sink_id 22400) background loop alive 468211.9s
Merge 806B00000003 456ms
LocalInput (actor 34008) 456ms
LocalInput (actor 34009) 456ms
456ms flow_summary_sink · Sink 2 actors actor 32915
Epoch 11231927239573504 456ms
Sink 809300000002 456ms
consume_log (sink_id 22348) background loop alive 468211.9s
log_reader_next_item alive 456ms
Wait Next Item from Buffer alive 456ms
Wait For New Buffer Item alive 456ms
Merge 809300000001 456ms
LocalInput (actor 33813) 456ms
LocalInput (actor 33812) 456ms
456ms pnl_by_asset_sink · Sink 2 actors actor 33702
Epoch 11231927239573504 456ms
Sink 83A600000003 456ms
consume_log (sink_id 22460) background loop alive 468211.9s
log_reader_next_item alive 456ms
Wait Next Item from Buffer alive 456ms
Wait For New Buffer Item alive 456ms
Merge 83A600000002 456ms
LocalInput (actor 34051) 456ms
LocalInput (actor 34050) 456ms
456ms flow_by_asset_type_mv · OverWindow 2 actors actor 33778
Epoch 11231927239573504 456ms
Materialize 83F200000006 456ms
OverWindow 83F200000005 456ms
Merge 83F200000004 456ms
LocalInput (actor 33782) 456ms
LocalInput (actor 33783) 456ms
456ms flow_by_asset_type_sink · StreamScan 2 actors actor 33780
Epoch 11231927239573504 456ms
Sink 83F400000002 456ms
consume_log (sink_id 22368) background loop alive 468211.9s
log_reader_next_item alive 456ms
Wait Next Item from Buffer alive 456ms
Wait For New Buffer Item alive 456ms
Project 83F400000001 456ms
StreamScan 83F40000272B 456ms
Merge 83F400000000 456ms
LocalInput (actor 33778) 456ms
456ms flow_by_asset_type_mv · HashAgg 2 actors actor 33782
Epoch 11231927239573504 456ms
Project 83F600000003 456ms
HashAgg 83F600000002 456ms
Merge 83F600000001 456ms
LocalInput (actor 33784) 456ms
LocalInput (actor 33785) 456ms
456ms flow_summary_sink · StreamScan 2 actors actor 33812
Epoch 11231927239573504 456ms
StreamScan 841400002727 456ms
Merge 841400000000 456ms
LocalInput (actor 33814) 456ms
456ms flow_summary_mv · HashAgg 2 actors actor 33816
Epoch 11231927239573504 456ms
Project 841800000003 456ms
HashAgg 841800000002 456ms
Merge 841800000001 456ms
LocalInput (actor 33818) 456ms
LocalInput (actor 33819) 456ms
456ms flow_by_asset_sink · StreamScan 2 actors actor 33828
Epoch 11231927239573504 456ms
Sink 842400000002 456ms
consume_log (sink_id 22340) background loop alive 468211.9s
log_reader_next_item alive 456ms
Wait Next Item from Buffer alive 456ms
Wait For New Buffer Item alive 456ms
Project 842400000001 456ms
StreamScan 84240000272C 456ms
Merge 842400000000 456ms
LocalInput (actor 33830) 456ms
456ms flow_by_asset_mv · OverWindow 2 actors actor 33830
Epoch 11231927239573504 456ms
Materialize 84260000000F 456ms
OverWindow 84260000000E 456ms
Merge 84260000000D 456ms
LocalInput (actor 33832) 456ms
LocalInput (actor 33833) 456ms
456ms flow_by_asset_mv · HashAgg 2 actors actor 33832
Epoch 11231927239573504 456ms
Project 84280000000C 456ms
HashAgg 84280000000B 456ms
Merge 84280000000A 456ms
LocalInput (actor 33835) 456ms
LocalInput (actor 33834) 456ms
456ms flow_by_sector_sink · StreamScan 2 actors actor 33864
Epoch 11231927239573504 456ms
Project 844800000002 456ms
Filter 844800000001 456ms
StreamScan 844800002737 456ms
Merge 844800000000 456ms
LocalInput (actor 33872) 456ms
456ms flow_by_asset_class_sink · StreamScan 2 actors actor 33866
Epoch 11231927239573504 456ms
Project 844A00000002 456ms
Filter 844A00000001 456ms
StreamScan 844A00002737 456ms
Merge 844A00000000 456ms
LocalInput (actor 33872) 456ms
456ms flow_by_taxonomy_node_sink · StreamScan 2 actors actor 33868
Epoch 11231927239573504 456ms
Project 844C00000001 456ms
StreamScan 844C0000272C 456ms
Merge 844C00000000 456ms
LocalInput (actor 33872) 456ms
456ms flow_by_region_sink · StreamScan 2 actors actor 33870
Epoch 11231927239573504 456ms
Project 844E00000002 456ms
Filter 844E00000001 456ms
StreamScan 844E00002737 456ms
Merge 844E00000000 456ms
LocalInput (actor 33872) 456ms
456ms flow_by_distribution_mv · OverWindow 2 actors actor 33872
Epoch 11231927239573504 456ms
Materialize 84500000000B 456ms
OverWindow 84500000000A 456ms
Merge 845000000009 456ms
LocalInput (actor 33875) 456ms
LocalInput (actor 33874) 456ms
456ms flow_by_distribution_mv · HashAgg 2 actors actor 33874
Epoch 11231927239573504 456ms
Project 845200000008 456ms
HashAgg 845200000007 456ms
Merge 845200000006 456ms
LocalInput (actor 33877) 456ms
LocalInput (actor 33876) 456ms
456ms pnl_by_currency_mv · hash_join_barrier_align 2 actors actor 33895
Epoch 11231927239573504 456ms
Materialize 846700000008 456ms
Project 846700000007 456ms
Project 846700000006 456ms
Project 846700000005 456ms
AsOfJoin 846700000004 456ms
hash_join_barrier_align 456ms
Merge 846700000002 456ms
LocalInput (actor 33984) 456ms
LocalInput (actor 33985) 456ms
Merge 846700000003 456ms
LocalInput (actor 33987) 456ms
LocalInput (actor 33986) 456ms
456ms pnl_by_currency_sink · StreamScan 2 actors actor 33897
Epoch 11231927239573504 456ms
StreamScan 846900002728 456ms
Merge 846900000000 456ms
LocalInput (actor 33895) 456ms
456ms pnl_summary_sink · StreamScan 2 actors actor 33911
Epoch 11231927239573504 456ms
StreamScan 847700002728 456ms
Merge 847700000000 456ms
LocalInput (actor 33909) 456ms
456ms position_by_asset_sink · StreamScan 2 actors actor 33920
Epoch 11231927239573504 456ms
Project 848000000001 456ms
StreamScan 84800000272C 456ms
Merge 848000000000 456ms
LocalInput (actor 33918) 456ms
456ms twrr_by_asset_type_sink · StreamScan 2 actors actor 33934
Epoch 11231927239573504 456ms
Sink 848E00000002 456ms
consume_log (sink_id 22420) background loop alive 468211.8s
log_reader_next_item alive 456ms
Wait Next Item from Buffer alive 456ms
Wait For New Buffer Item alive 456ms
Filter 848E00000001 456ms
StreamScan 848E00002733 456ms
Merge 848E00000000 456ms
LocalInput (actor 33932) 456ms
456ms twrr_by_asset_type_mv · OverWindow 2 actors actor 33936
Epoch 11231927239573504 456ms
Filter 849000000004 456ms
OverWindow 849000000003 456ms
Merge 849000000002 456ms
LocalInput (actor 34044) 456ms
LocalInput (actor 34045) 456ms
456ms twrr_by_asset_mv · hash_join_barrier_align 2 actors actor 33950
Epoch 11231927239573504 456ms
Materialize 849E0000000B 456ms
Project 849E0000000A 456ms
Project 849E00000009 456ms
HashJoin 849E00000008 456ms
hash_join_barrier_align 456ms
Merge 849E00000005 456ms
LocalInput (actor 33954) 456ms
LocalInput (actor 33955) 456ms
Merge 849E00000007 456ms
LocalInput (actor 33957) 456ms
LocalInput (actor 33956) 456ms
456ms twrr_by_asset_sink · StreamScan 2 actors actor 33952
Epoch 11231927239573504 456ms
Sink 84A000000002 456ms
consume_log (sink_id 22464) background loop alive 468211.9s
log_reader_next_item alive 456ms
Wait Next Item from Buffer alive 456ms
Wait For New Buffer Item alive 456ms
Filter 84A000000001 456ms
StreamScan 84A000002733 456ms
Merge 84A000000000 456ms
LocalInput (actor 33950) 456ms
456ms position_by_currency_mv · hash_join_barrier_align 2 actors actor 33976
Epoch 11231927239573504 456ms
Materialize 84B800000009 456ms
Project 84B800000008 456ms
HashJoin 84B800000007 456ms
hash_join_barrier_align 456ms
Merge 84B800000005 456ms
LocalInput (actor 33979) 456ms
LocalInput (actor 33978) 456ms
Merge 84B800000006 456ms
LocalInput (actor 33982) 456ms
LocalInput (actor 33983) 456ms
456ms position_by_asset_type_mv · hash_join_barrier_align 2 actors actor 33988
Epoch 11231927239573504 456ms
Materialize 84C40000000A 456ms
Project 84C400000009 456ms
HashJoin 84C400000008 456ms
hash_join_barrier_align 456ms
Merge 84C400000007 456ms
LocalInput (actor 33996) 456ms
LocalInput (actor 33997) 456ms
Merge 84C400000006 456ms
LocalInput (actor 33992) 456ms
LocalInput (actor 33993) 456ms
456ms position_by_asset_type_sink · StreamScan 2 actors actor 33990
Epoch 11231927239573504 456ms
Project 84C600000001 456ms
StreamScan 84C60000272C 456ms
Merge 84C600000000 456ms
LocalInput (actor 33988) 456ms
456ms twrr_mv · OverWindow 2 actors actor 34001
Epoch 11231927239573504 456ms
Materialize 84D100000009 456ms
Project 84D100000008 456ms
Project 84D100000007 456ms
HashJoin 84D100000006 456ms
hash_join_barrier_align 456ms
Filter 84D100000004 456ms
OverWindow 84D100000003 456ms
Merge 84D100000002 456ms
LocalInput (actor 34004) 456ms
LocalInput (actor 34005) 456ms
Merge 84D100000005 456ms
LocalInput (actor 34006) 456ms
LocalInput (actor 34007) 456ms
456ms position_by_sector_sink · StreamScan 2 actors actor 34008
Epoch 11231927239573504 456ms
Project 84D800000002 456ms
Filter 84D800000001 456ms
StreamScan 84D800002737 456ms
Merge 84D800000000 456ms
LocalInput (actor 34014) 456ms
456ms position_by_taxonomy_node_sink · StreamScan 2 actors actor 34011
Epoch 11231927239573504 456ms
Project 84DB00000001 456ms
StreamScan 84DB0000272C 456ms
Merge 84DB00000000 456ms
LocalInput (actor 34015) 456ms
456ms position_by_asset_class_sink · StreamScan 2 actors actor 34013
Epoch 11231927239573504 456ms
Project 84DD00000002 456ms
Filter 84DD00000001 456ms
StreamScan 84DD00002737 456ms
Merge 84DD00000000 456ms
LocalInput (actor 34015) 456ms
456ms position_by_region_sink · StreamScan 2 actors actor 34017
Epoch 11231927239573504 456ms
Project 84E100000002 456ms
Filter 84E100000001 456ms
StreamScan 84E100002737 456ms
Merge 84E100000000 456ms
LocalInput (actor 34015) 456ms
456ms position_by_distribution_mv · HashAgg 2 actors actor 34018
Epoch 11231927239573504 456ms
Project 84E200000009 456ms
HashAgg 84E200000008 456ms
Merge 84E200000007 456ms
LocalInput (actor 34021) 456ms
LocalInput (actor 34020) 456ms
456ms twrr_by_currency_mv · hash_join_barrier_align 2 actors actor 34036
Epoch 11231927239573504 456ms
Materialize 84F40000000B 456ms
Project 84F40000000A 456ms
Project 84F400000009 456ms
HashJoin 84F400000008 456ms
hash_join_barrier_align 456ms
Merge 84F400000005 456ms
LocalInput (actor 34041) 456ms
LocalInput (actor 34040) 456ms
Merge 84F400000007 456ms
LocalInput (actor 34042) 456ms
LocalInput (actor 34043) 456ms
456ms twrr_by_currency_mv · OverWindow 2 actors actor 34040
Epoch 11231927239573504 456ms
Filter 84F800000004 456ms
OverWindow 84F800000003 456ms
Merge 84F800000002 456ms
LocalInput (actor 33930) 456ms
LocalInput (actor 33931) 456ms
456ms pnl_by_asset_mv · hash_join_barrier_align 2 actors actor 34048
Epoch 11231927239573504 456ms
Materialize 850000000008 456ms
Project 850000000007 456ms
Project 850000000006 456ms
Project 850000000005 456ms
AsOfJoin 850000000004 456ms
hash_join_barrier_align 456ms
Merge 850000000002 456ms
LocalInput (actor 34052) 456ms
LocalInput (actor 34053) 456ms
Merge 850000000003 456ms
LocalInput (actor 34079) 456ms
LocalInput (actor 34078) 456ms
456ms pnl_by_asset_sink · StreamScan 2 actors actor 34050
Epoch 11231927239573504 456ms
Project 850200000001 456ms
StreamScan 85020000272C 456ms
Merge 850200000000 456ms
LocalInput (actor 34048) 456ms
456ms twrr_by_distribution_mv · OverWindow 2 actors actor 34069
Epoch 11231927239573504 456ms
Filter 851500000004 456ms
OverWindow 851500000003 456ms
Merge 851500000002 456ms
LocalInput (actor 34022) 456ms
LocalInput (actor 34023) 456ms
452ms position_by_taxonomy_node_sink · Sink 2 actors actor 33712
Epoch 11231927239573504 452ms
Sink 83B000000003 452ms
consume_log (sink_id 22388) background loop alive 468211.9s
log_reader_next_item alive 452ms
Wait Next Item from Buffer alive 452ms
Wait For New Buffer Item alive 452ms
Merge 83B000000002 452ms
LocalInput (actor 34010) 452ms
LocalInput (actor 34011) 452ms
452ms pnl_summary_mv · hash_join_barrier_align 2 actors actor 33908
Epoch 11231927239573504 452ms
Materialize 847400000008 452ms
Project 847400000007 452ms
Project 847400000006 452ms
Project 847400000005 452ms
AsOfJoin 847400000004 452ms
hash_join_barrier_align 452ms
Merge 847400000002 452ms
LocalInput (actor 34028) 452ms
LocalInput (actor 34029) 452ms
Merge 847400000003 452ms
LocalInput (actor 33913) 452ms
LocalInput (actor 33912) 452ms
452ms twrr_sink · StreamScan 2 actors actor 34002
Epoch 11231927239573504 452ms
Filter 84D200000001 452ms
StreamScan 84D200002733 452ms
Merge 84D200000000 452ms
LocalInput (actor 34000) 452ms
452ms pnl_by_asset_type_sink · StreamScan 2 actors actor 34030
Epoch 11231927239573504 452ms
StreamScan 84EE00002728 452ms
Merge 84EE00000000 452ms
LocalInput (actor 34032) 452ms
452ms pnl_by_asset_type_mv · hash_join_barrier_align 2 actors actor 34032
Epoch 11231927239573504 452ms
Materialize 84F000000008 452ms
Project 84F000000007 452ms
Project 84F000000006 452ms
Project 84F000000005 452ms
AsOfJoin 84F000000004 452ms
hash_join_barrier_align 452ms
Merge 84F000000003 452ms
LocalInput (actor 34057) 452ms
LocalInput (actor 34056) 452ms
Merge 84F000000002 452ms
LocalInput (actor 34055) 452ms
LocalInput (actor 34054) 452ms
452ms twrr_by_currency_sink · StreamScan 2 actors actor 34038
Epoch 11231927239573504 452ms
Sink 84F600000002 452ms
consume_log (sink_id 22412) background loop alive 468211.9s
log_reader_next_item alive 452ms
Wait Next Item from Buffer alive 452ms
Wait For New Buffer Item alive 452ms
Filter 84F600000001 452ms
StreamScan 84F600002733 452ms
Merge 84F600000000 452ms
LocalInput (actor 34036) 452ms
452ms twrr_sink · Sink 2 actors actor 34086
Epoch 11231927239573504 452ms
Sink 852600000003 452ms
consume_log (sink_id 22384) background loop alive 468211.9s
log_reader_next_item alive 452ms
Wait Next Item from Buffer alive 452ms
Wait For New Buffer Item alive 452ms
Merge 852600000002 452ms
LocalInput (actor 34003) 452ms
LocalInput (actor 34002) 452ms
452ms pnl_by_currency_sink · Sink 2 actors actor 34091
Epoch 11231927239573504 452ms
Sink 852B00000002 452ms
consume_log (sink_id 22416) background loop alive 468211.9s
log_reader_next_item alive 452ms
Wait Next Item from Buffer alive 452ms
Wait For New Buffer Item alive 452ms
Merge 852B00000001 452ms
LocalInput (actor 33896) 452ms
LocalInput (actor 33897) 452ms
452ms pnl_by_asset_type_sink · Sink 2 actors actor 34092
Epoch 11231927239573504 452ms
Sink 852C00000002 452ms
consume_log (sink_id 22424) background loop alive 468211.9s
log_reader_next_item alive 452ms
Wait Next Item from Buffer alive 452ms
Wait For New Buffer Item alive 452ms
Merge 852C00000001 452ms
LocalInput (actor 34030) 452ms
LocalInput (actor 34031) 452ms
452ms pnl_summary_sink · Sink 2 actors actor 34102
Epoch 11231927239573504 452ms
Sink 853600000002 452ms
consume_log (sink_id 22408) background loop alive 468211.9s
log_reader_next_item alive 452ms
Wait Next Item from Buffer alive 452ms
Wait For New Buffer Item alive 452ms
Merge 853600000001 452ms
LocalInput (actor 33910) 452ms
LocalInput (actor 33911) 452ms
448ms flow_by_sector_sink · Sink 2 actors actor 33892
Epoch 11231927239573504 448ms
Sink 846400000004 448ms
consume_log (sink_id 22352) background loop alive 468211.9s
Merge 846400000003 448ms
LocalInput (actor 33865) 448ms
LocalInput (actor 33864) 448ms
448ms pnl_by_sector_sink · StreamScan 2 actors actor 33960
Epoch 11231927239573504 448ms
Filter 84A800000001 448ms
StreamScan 84A800002733 448ms
Merge 84A800000000 448ms
LocalInput (actor 33966) 448ms
448ms pnl_by_taxonomy_sink · StreamScan 2 actors actor 33962
Epoch 11231927239573504 448ms
StreamScan 84AA00002728 448ms
Merge 84AA00000000 448ms
LocalInput (actor 33966) 448ms
448ms pnl_by_distribution_mv · hash_join_barrier_align 2 actors actor 33966
Epoch 11231927239573504 448ms
Materialize 84AE00000008 448ms
Project 84AE00000007 448ms
Project 84AE00000006 448ms
Project 84AE00000005 448ms
AsOfJoin 84AE00000004 448ms
hash_join_barrier_align 448ms
Merge 84AE00000003 448ms
LocalInput (actor 34073) 448ms
LocalInput (actor 34072) 448ms
Merge 84AE00000002 448ms
LocalInput (actor 34070) 448ms
LocalInput (actor 34071) 448ms
448ms pnl_by_asset_class_sink · StreamScan 2 actors actor 33968
Epoch 11231927239573504 448ms
Filter 84B000000001 448ms
StreamScan 84B000002733 448ms
Merge 84B000000000 448ms
LocalInput (actor 33966) 448ms
448ms twrr_by_distribution_mv · hash_join_barrier_align 2 actors actor 34058
Epoch 11231927239573504 448ms
Materialize 850A0000000B 448ms
Project 850A0000000A 448ms
Project 850A00000009 448ms
HashJoin 850A00000008 448ms
hash_join_barrier_align 448ms
Merge 850A00000007 448ms
LocalInput (actor 34074) 448ms
LocalInput (actor 34075) 448ms
Merge 850A00000005 448ms
LocalInput (actor 34068) 448ms
LocalInput (actor 34069) 448ms
448ms flow_by_asset_class_sink · Sink 2 actors actor 34082
Epoch 11231927239573504 448ms
Sink 852200000004 448ms
consume_log (sink_id 22356) background loop alive 468211.9s
Merge 852200000003 448ms
LocalInput (actor 33867) 448ms
LocalInput (actor 33866) 448ms
448ms flow_by_taxonomy_node_sink · Sink 2 actors actor 34084
Epoch 11231927239573504 448ms
Sink 852400000003 448ms
consume_log (sink_id 22360) background loop alive 468211.9s
log_reader_next_item alive 448ms
Wait Next Item from Buffer alive 448ms
Wait For New Buffer Item alive 448ms
Merge 852400000002 448ms
LocalInput (actor 33869) 448ms
LocalInput (actor 33868) 448ms
448ms pnl_by_taxonomy_sink · Sink 2 actors actor 34097
Epoch 11231927239573504 448ms
Sink 853100000002 448ms
consume_log (sink_id 22436) background loop alive 468211.9s
log_reader_next_item alive 448ms
Wait Next Item from Buffer alive 448ms
Wait For New Buffer Item alive 448ms
Merge 853100000001 448ms
LocalInput (actor 33963) 448ms
LocalInput (actor 33962) 448ms
448ms flow_by_region_sink · Sink 2 actors actor 34099
Epoch 11231927239573504 448ms
Sink 853300000004 448ms
consume_log (sink_id 22364) background loop alive 468211.8s
log_reader_next_item alive 448ms
Wait Next Item from Buffer alive 448ms
Wait For New Buffer Item alive 448ms
Merge 853300000003 448ms
LocalInput (actor 33871) 448ms
LocalInput (actor 33870) 448ms
444ms position_by_asset_class_sink · Sink 2 actors actor 33696
Epoch 11231927239573504 444ms
Sink 83A000000004 444ms
consume_log (sink_id 22392) background loop alive 468211.9s
Merge 83A000000003 444ms
LocalInput (actor 34012) 444ms
LocalInput (actor 34013) 444ms
444ms pnl_by_region_sink · StreamScan 2 actors actor 33964
Epoch 11231927239573504 444ms
Filter 84AC00000001 444ms
StreamScan 84AC00002733 444ms
Merge 84AC00000000 444ms
LocalInput (actor 33966) 444ms
444ms twrr_by_sector_sink · StreamScan 2 actors actor 34066
Epoch 11231927239573504 444ms
Filter 851200000001 444ms
StreamScan 851200002733 444ms
Merge 851200000000 444ms
LocalInput (actor 34058) 444ms
440ms twrr_by_sector_sink · Sink 2 actors actor 33716
Epoch 11231927239573504 440ms
Sink 83B400000003 440ms
consume_log (sink_id 22444) background loop alive 468211.9s
Merge 83B400000002 440ms
LocalInput (actor 34067) 440ms
LocalInput (actor 34066) 440ms
436ms position_by_region_sink · Sink 2 actors actor 32872
Epoch 11231927239573504 436ms
Sink 806800000004 436ms
consume_log (sink_id 22396) background loop alive 468211.9s
Merge 806800000003 436ms
LocalInput (actor 34016) 436ms
LocalInput (actor 34017) 436ms
436ms twrr_by_asset_class_sink · Sink 2 actors actor 33535
Epoch 11231927239573504 436ms
Sink 82FF00000003 436ms
consume_log (sink_id 22452) background loop alive 468211.9s
Merge 82FF00000002 436ms
LocalInput (actor 34061) 436ms
LocalInput (actor 34060) 436ms
436ms twrr_by_taxonomy_node_sink · Sink 2 actors actor 33698
Epoch 11231927239573504 436ms
Sink 83A200000003 440ms
consume_log (sink_id 22448) background loop alive 468211.9s
log_reader_next_item alive 436ms
Wait Next Item from Buffer alive 436ms
Wait For New Buffer Item alive 436ms
Merge 83A200000002 440ms
LocalInput (actor 34062) 440ms
LocalInput (actor 34063) 436ms
436ms twrr_by_region_sink · Sink 2 actors actor 33701
Epoch 11231927239573504 436ms
Sink 83A500000003 436ms
consume_log (sink_id 22456) background loop alive 468211.9s
Merge 83A500000002 436ms
LocalInput (actor 34065) 436ms
LocalInput (actor 34064) 436ms
436ms twrr_by_asset_class_sink · StreamScan 2 actors actor 34060
Epoch 11231927239573504 436ms
Filter 850C00000001 436ms
StreamScan 850C00002733 436ms
Merge 850C00000000 436ms
LocalInput (actor 34058) 436ms
436ms twrr_by_taxonomy_node_sink · StreamScan 2 actors actor 34062
Epoch 11231927239573504 436ms
Filter 850E00000001 436ms
StreamScan 850E00002733 436ms
Merge 850E00000000 436ms
LocalInput (actor 34058) 436ms
436ms twrr_by_region_sink · StreamScan 2 actors actor 34064
Epoch 11231927239573504 436ms
Filter 851000000001 436ms
StreamScan 851000002733 436ms
Merge 851000000000 436ms
LocalInput (actor 34058) 436ms
436ms pnl_by_sector_sink · Sink 2 actors actor 34101
Epoch 11231927239573504 436ms
Sink 853500000003 436ms
consume_log (sink_id 22432) background loop alive 468211.9s
log_reader_rewind alive 5.0s
Merge 853500000002 436ms
LocalInput (actor 33961) 436ms
LocalInput (actor 33960) 436ms
424ms pnl_by_asset_class_sink · Sink 2 actors actor 33714
Epoch 11231927239573504 424ms
Sink 83B200000003 428ms
consume_log (sink_id 22440) background loop alive 468211.9s
Merge 83B200000002 428ms
LocalInput (actor 33969) 428ms
LocalInput (actor 33968) 428ms
420ms pnl_by_region_sink · Sink 2 actors actor 34094
Epoch 11231927239573504 420ms
Sink 852E00000003 420ms
consume_log (sink_id 22428) background loop alive 468211.9s
Merge 852E00000002 420ms
LocalInput (actor 33965) 420ms
LocalInput (actor 33964) 420ms