Job is idle — throughput ~0; structure shown.
Fragment 12287 (Actor 33487,33488)
StreamMaterialize { columns: [party_id, account_group_id, type, parties.id(hidden), null:Varchar(hidden), $src(hidden)], stream_key: [parties.id, null:Varchar, $src], pk_columns: [parties.id, null:Varchar, $src], pk_conflict: NoCheck }
├── output: [ parties.id, $expr1, 'none':Varchar, parties.id, null:Varchar, $src ]
├── stream key: [ parties.id, null:Varchar, $src ]
└── StreamUnion { all: true } { output: [ parties.id, $expr1, 'none':Varchar, parties.id, null:Varchar, $src ], stream key: [ parties.id, null:Varchar, $src ] }
├── MergeExecutor { output: [ parties.id, $expr1, 'none':Varchar, parties.id, null:Varchar, 0:Int32 ], stream key: [ parties.id ] }
├── MergeExecutor { output: [ parties.id, $expr2, 'all':Varchar, parties.id, party_account_group_types_mv_next.type, 1:Int32 ], stream key: [ parties.id, party_account_group_types_mv_next.type ] }
├── MergeExecutor { output: [ parties.id, $expr3, 'restricted':Varchar, parties.id, party_account_group_types_mv_next.type, 2:Int32 ], stream key: [ parties.id, party_account_group_types_mv_next.type ] }
└── MergeExecutor { output: [ parties.id, $expr4, 'un_restricted':Varchar, parties.id, party_account_group_types_mv_next.type, 3:Int32 ], stream key: [ parties.id, party_account_group_types_mv_next.type ] }
Fragment 12288 (Actor 33499,33500)
StreamProject { exprs: [parties.id, ConcatOp('account_group_':Varchar, Md5(ConcatOp(parties.id, 'none':Varchar)::Bytea)) as $expr1, 'none':Varchar, parties.id, null:Varchar, 0:Int32] }
├── output: [ parties.id, $expr1, 'none':Varchar, parties.id, null:Varchar, 0:Int32 ]
├── stream key: [ parties.id ]
└── MergeExecutor { output: [ parties.id, customer_relationships.party_id ], stream key: [ parties.id ] }
Fragment 12289 (Actor 33498,33497)
StreamHashJoin { type: Inner, predicate: parties.id = customer_relationships.party_id } { output: [ parties.id, customer_relationships.party_id ], stream key: [ parties.id ] }
├── MergeExecutor { output: [ parties.id ], stream key: [ parties.id ] }
└── StreamProject { exprs: [customer_relationships.party_id] } { output: [ customer_relationships.party_id ], stream key: [ customer_relationships.party_id ] }
└── StreamHashAgg { group_key: [customer_relationships.party_id], aggs: [count] } { output: [ customer_relationships.party_id, count ], stream key: [ customer_relationships.party_id ] }
└── MergeExecutor { output: [ customer_relationships.party_id, customer_relationships.id ], stream key: [ customer_relationships.id ] }
Fragment 12290 (Actor 33470,33469)
StreamProject { exprs: [parties.id] } { output: [ parties.id ], stream key: [ parties.id ] }
└── StreamFilter { predicate: IsNull(parties.disabled_at) } { output: [ parties.id, parties.disabled_at ], stream key: [ parties.id ] }
└── StreamTableScan { table: parties, columns: [id, disabled_at] } { output: [ parties.id, parties.disabled_at ], stream key: [ parties.id ] }
├── Upstream { output: [ id, disabled_at ], stream key: [] }
└── BatchPlanNode { output: [ id, disabled_at ], stream key: [] }
Fragment 12291 (Actor 33472,33471)
StreamProject { exprs: [customer_relationships.party_id, customer_relationships.id] } { output: [ customer_relationships.party_id, customer_relationships.id ], stream key: [ customer_relationships.id ] }
└── StreamFilter { predicate: (customer_relationships.type = 'CUSTOMER':Varchar) AND (customer_relationships.status = 'ACTIVE':Varchar) AND IsNull(customer_relationships.disabled_at) }
├── output: [ customer_relationships.party_id, customer_relationships.id, customer_relationships.type, customer_relationships.status, customer_relationships.disabled_at ]
├── stream key: [ customer_relationships.id ]
└── StreamTableScan { table: customer_relationships, columns: [party_id, id, type, status, disabled_at] }
├── output: [ customer_relationships.party_id, customer_relationships.id, customer_relationships.type, customer_relationships.status, customer_relationships.disabled_at ]
├── stream key: [ customer_relationships.id ]
├── Upstream { output: [ party_id, id, type, status, disabled_at ], stream key: [] }
└── BatchPlanNode { output: [ party_id, id, type, status, disabled_at ], stream key: [] }
Fragment 12292 (Actor 33493,33494)
StreamProject { exprs: [parties.id, ConcatOp('account_group_':Varchar, Md5(ConcatOp(parties.id, 'all':Varchar)::Bytea)) as $expr2, 'all':Varchar, parties.id, party_account_group_types_mv_next.type, 1:Int32] }
├── output: [ parties.id, $expr2, 'all':Varchar, parties.id, party_account_group_types_mv_next.type, 1:Int32 ]
├── stream key: [ parties.id, party_account_group_types_mv_next.type ]
└── StreamHashJoin { type: Inner, predicate: parties.id = party_account_group_types_mv_next.party_id }
├── output: [ parties.id, party_account_group_types_mv_next.party_id, party_account_group_types_mv_next.type ]
├── stream key: [ parties.id, party_account_group_types_mv_next.type ]
├── MergeExecutor { output: [ parties.id, customer_relationships.party_id ], stream key: [ parties.id ] }
└── MergeExecutor { output: [ party_account_group_types_mv_next.party_id, party_account_group_types_mv_next.type ], stream key: [ party_account_group_types_mv_next.party_id, party_account_group_types_mv_next.type ] }
Fragment 12293 (Actor 33473,33474)
StreamFilter { predicate: (party_account_group_types_mv_next.type = 'all':Varchar) }
├── output: [ party_account_group_types_mv_next.party_id, party_account_group_types_mv_next.type ]
├── stream key: [ party_account_group_types_mv_next.party_id, party_account_group_types_mv_next.type ]
└── StreamTableScan { table: party_account_group_types_mv_next, columns: [party_id, type] }
├── output: [ party_account_group_types_mv_next.party_id, party_account_group_types_mv_next.type ]
├── stream key: [ party_account_group_types_mv_next.party_id, party_account_group_types_mv_next.type ]
├── Upstream { output: [ party_id, type ], stream key: [] }
└── BatchPlanNode { output: [ party_id, type ], stream key: [] }
Fragment 12294 (Actor 33492,33491)
StreamProject { exprs: [parties.id, ConcatOp('account_group_':Varchar, Md5(ConcatOp(parties.id, 'restricted':Varchar)::Bytea)) as $expr3, 'restricted':Varchar, parties.id, party_account_group_types_mv_next.type, 2:Int32] }
├── output: [ parties.id, $expr3, 'restricted':Varchar, parties.id, party_account_group_types_mv_next.type, 2:Int32 ]
├── stream key: [ parties.id, party_account_group_types_mv_next.type ]
└── StreamHashJoin { type: Inner, predicate: parties.id = party_account_group_types_mv_next.party_id }
├── output: [ parties.id, party_account_group_types_mv_next.party_id, party_account_group_types_mv_next.type ]
├── stream key: [ parties.id, party_account_group_types_mv_next.type ]
├── MergeExecutor { output: [ parties.id, customer_relationships.party_id ], stream key: [ parties.id ] }
└── MergeExecutor { output: [ party_account_group_types_mv_next.party_id, party_account_group_types_mv_next.type ], stream key: [ party_account_group_types_mv_next.party_id, party_account_group_types_mv_next.type ] }
Fragment 12295 (Actor 33475,33476)
StreamFilter { predicate: (party_account_group_types_mv_next.type = 'restricted':Varchar) }
├── output: [ party_account_group_types_mv_next.party_id, party_account_group_types_mv_next.type ]
├── stream key: [ party_account_group_types_mv_next.party_id, party_account_group_types_mv_next.type ]
└── StreamTableScan { table: party_account_group_types_mv_next, columns: [party_id, type] }
├── output: [ party_account_group_types_mv_next.party_id, party_account_group_types_mv_next.type ]
├── stream key: [ party_account_group_types_mv_next.party_id, party_account_group_types_mv_next.type ]
├── Upstream { output: [ party_id, type ], stream key: [] }
└── BatchPlanNode { output: [ party_id, type ], stream key: [] }
Fragment 12296 (Actor 33496,33495)
StreamProject { exprs: [parties.id, ConcatOp('account_group_':Varchar, Md5(ConcatOp(parties.id, 'un_restricted':Varchar)::Bytea)) as $expr4, 'un_restricted':Varchar, parties.id, party_account_group_types_mv_next.type, 3:Int32] }
├── output: [ parties.id, $expr4, 'un_restricted':Varchar, parties.id, party_account_group_types_mv_next.type, 3:Int32 ]
├── stream key: [ parties.id, party_account_group_types_mv_next.type ]
└── StreamHashJoin { type: Inner, predicate: parties.id = party_account_group_types_mv_next.party_id }
├── output: [ parties.id, party_account_group_types_mv_next.party_id, party_account_group_types_mv_next.type ]
├── stream key: [ parties.id, party_account_group_types_mv_next.type ]
├── MergeExecutor { output: [ parties.id, customer_relationships.party_id ], stream key: [ parties.id ] }
└── MergeExecutor { output: [ party_account_group_types_mv_next.party_id, party_account_group_types_mv_next.type ], stream key: [ party_account_group_types_mv_next.party_id, party_account_group_types_mv_next.type ] }
Fragment 12297 (Actor 33525,33526)
StreamFilter { predicate: (party_account_group_types_mv_next.type = 'un_restricted':Varchar) }
├── output: [ party_account_group_types_mv_next.party_id, party_account_group_types_mv_next.type ]
├── stream key: [ party_account_group_types_mv_next.party_id, party_account_group_types_mv_next.type ]
└── StreamTableScan { table: party_account_group_types_mv_next, columns: [party_id, type] }
├── output: [ party_account_group_types_mv_next.party_id, party_account_group_types_mv_next.type ]
├── stream key: [ party_account_group_types_mv_next.party_id, party_account_group_types_mv_next.type ]
├── Upstream { output: [ party_id, type ], stream key: [] }
└── BatchPlanNode { output: [ party_id, type ], stream key: [] }