Job is idle — throughput ~0; structure shown.
Fragment 25153 (Actor 121459,121460)
StreamMaterialize { columns: [party_id, customer_relationship_id, account_id, effective_start_date, effective_end_date, type, party_involvements_dm.id(hidden), party_involvements_dm.entity_id(hidden), party_involvements_dm.customer_relationship_id(hidden), $src(hidden)], stream_key: [party_involvements_dm.id, party_involvements_dm.entity_id, party_involvements_dm.customer_relationship_id, $src], pk_columns: [party_involvements_dm.id, party_involvements_dm.entity_id, party_involvements_dm.customer_relationship_id, $src], pk_conflict: NoCheck }
├── output: [ party_involvements_dm.party_id, party_involvements_dm.customer_relationship_id, party_involvements_dm.entity_id, party_involvements_dm.effective_from, party_involvements_dm.effective_to, 'all':Varchar, party_involvements_dm.id, party_involvements_dm.entity_id, party_involvements_dm.customer_relationship_id, $src ]
├── stream key: [ party_involvements_dm.id, party_involvements_dm.entity_id, party_involvements_dm.customer_relationship_id, $src ]
└── StreamUnion { all: true } { output: [ party_involvements_dm.party_id, party_involvements_dm.customer_relationship_id, party_involvements_dm.entity_id, party_involvements_dm.effective_from, party_involvements_dm.effective_to, 'all':Varchar, party_involvements_dm.id, party_involvements_dm.entity_id, party_involvements_dm.customer_relationship_id, $src ], stream key: [ party_involvements_dm.id, party_involvements_dm.entity_id, party_involvements_dm.customer_relationship_id, $src ] }
├── MergeExecutor { output: [ party_involvements_dm.party_id, party_involvements_dm.customer_relationship_id, party_involvements_dm.entity_id, party_involvements_dm.effective_from, party_involvements_dm.effective_to, 'all':Varchar, party_involvements_dm.id, party_involvements_dm.entity_id, party_involvements_dm.customer_relationship_id, 0:Int32 ], stream key: [ party_involvements_dm.id, party_involvements_dm.entity_id, party_involvements_dm.customer_relationship_id ] }
└── MergeExecutor { output: [ party_involvements_dm.party_id, party_involvements_dm.customer_relationship_id, party_involvements_dm.entity_id, party_involvements_dm.effective_from, party_involvements_dm.effective_to, $expr1, party_involvements_dm.id, party_involvements_dm.entity_id, party_involvements_dm.customer_relationship_id, 1:Int32 ], stream key: [ party_involvements_dm.id, party_involvements_dm.entity_id, party_involvements_dm.customer_relationship_id ] }
Fragment 25154 (Actor 121465,121466)
StreamProject { exprs: [party_involvements_dm.party_id, party_involvements_dm.customer_relationship_id, party_involvements_dm.entity_id, party_involvements_dm.effective_from, party_involvements_dm.effective_to, 'all':Varchar, party_involvements_dm.id, party_involvements_dm.entity_id, party_involvements_dm.customer_relationship_id, 0:Int32] }
├── output: [ party_involvements_dm.party_id, party_involvements_dm.customer_relationship_id, party_involvements_dm.entity_id, party_involvements_dm.effective_from, party_involvements_dm.effective_to, 'all':Varchar, party_involvements_dm.id, party_involvements_dm.entity_id, party_involvements_dm.customer_relationship_id, 0:Int32 ]
├── stream key: [ party_involvements_dm.id, party_involvements_dm.entity_id, party_involvements_dm.customer_relationship_id ]
└── MergeExecutor { output: [ party_involvements_dm.party_id, party_involvements_dm.customer_relationship_id, party_involvements_dm.entity_id, party_involvements_dm.effective_from, party_involvements_dm.effective_to, open_accounts_mv.is_restricted, party_involvements_dm.id, customer_relationships_next.id ], stream key: [ party_involvements_dm.id, party_involvements_dm.entity_id, party_involvements_dm.customer_relationship_id ] }
Fragment 25155 (Actor 121470,121469)
StreamSyncLogStore { output: [ party_involvements_dm.party_id, party_involvements_dm.customer_relationship_id, party_involvements_dm.entity_id, party_involvements_dm.effective_from, party_involvements_dm.effective_to, open_accounts_mv.is_restricted, party_involvements_dm.id, customer_relationships_next.id ], stream key: [ party_involvements_dm.id, party_involvements_dm.entity_id, party_involvements_dm.customer_relationship_id ] }
└── MergeExecutor { output: [ party_involvements_dm.party_id, party_involvements_dm.customer_relationship_id, party_involvements_dm.entity_id, party_involvements_dm.effective_from, party_involvements_dm.effective_to, open_accounts_mv.is_restricted, party_involvements_dm.id, customer_relationships_next.id ], stream key: [ party_involvements_dm.id, party_involvements_dm.entity_id, party_involvements_dm.customer_relationship_id ] }
Fragment 25156 (Actor 121463,121464)
StreamSyncLogStore { output: [ party_involvements_dm.party_id, party_involvements_dm.customer_relationship_id, party_involvements_dm.entity_id, party_involvements_dm.effective_from, party_involvements_dm.effective_to, open_accounts_mv.is_restricted, party_involvements_dm.id, customer_relationships_next.id ], stream key: [ party_involvements_dm.id, party_involvements_dm.entity_id, party_involvements_dm.customer_relationship_id ] }
└── StreamHashJoin { type: Inner, predicate: party_involvements_dm.customer_relationship_id = customer_relationships_next.id } { output: [ party_involvements_dm.party_id, party_involvements_dm.customer_relationship_id, party_involvements_dm.entity_id, party_involvements_dm.effective_from, party_involvements_dm.effective_to, open_accounts_mv.is_restricted, party_involvements_dm.id, customer_relationships_next.id ], stream key: [ party_involvements_dm.id, party_involvements_dm.entity_id, party_involvements_dm.customer_relationship_id ] }
├── MergeExecutor { output: [ party_involvements_dm.party_id, party_involvements_dm.customer_relationship_id, party_involvements_dm.entity_id, party_involvements_dm.effective_from, party_involvements_dm.effective_to, open_accounts_mv.is_restricted, party_involvements_dm.id, open_accounts_mv.account_id ], stream key: [ party_involvements_dm.id, party_involvements_dm.entity_id ] }
└── MergeExecutor { output: [ customer_relationships_next.id ], stream key: [ customer_relationships_next.id ] }
Fragment 25157 (Actor 121472,121471)
StreamSyncLogStore { output: [ party_involvements_dm.party_id, party_involvements_dm.customer_relationship_id, party_involvements_dm.entity_id, party_involvements_dm.effective_from, party_involvements_dm.effective_to, open_accounts_mv.is_restricted, party_involvements_dm.id, open_accounts_mv.account_id ], stream key: [ party_involvements_dm.id, party_involvements_dm.entity_id ] }
└── MergeExecutor { output: [ party_involvements_dm.party_id, party_involvements_dm.customer_relationship_id, party_involvements_dm.entity_id, party_involvements_dm.effective_from, party_involvements_dm.effective_to, open_accounts_mv.is_restricted, party_involvements_dm.id, open_accounts_mv.account_id ], stream key: [ party_involvements_dm.id, party_involvements_dm.entity_id ] }
Fragment 25158 (Actor 121474,121473)
StreamSyncLogStore { output: [ party_involvements_dm.party_id, party_involvements_dm.customer_relationship_id, party_involvements_dm.entity_id, party_involvements_dm.effective_from, party_involvements_dm.effective_to, open_accounts_mv.is_restricted, party_involvements_dm.id, open_accounts_mv.account_id ], stream key: [ party_involvements_dm.id, party_involvements_dm.entity_id ] }
└── StreamHashJoin { type: Inner, predicate: party_involvements_dm.entity_id = open_accounts_mv.account_id } { output: [ party_involvements_dm.party_id, party_involvements_dm.customer_relationship_id, party_involvements_dm.entity_id, party_involvements_dm.effective_from, party_involvements_dm.effective_to, open_accounts_mv.is_restricted, party_involvements_dm.id, open_accounts_mv.account_id ], stream key: [ party_involvements_dm.id, party_involvements_dm.entity_id ] }
├── MergeExecutor { output: [ party_involvements_dm.party_id, party_involvements_dm.customer_relationship_id, party_involvements_dm.entity_id, party_involvements_dm.effective_from, party_involvements_dm.effective_to, party_involvements_dm.id ], stream key: [ party_involvements_dm.id ] }
└── MergeExecutor { output: [ open_accounts_mv.account_id, open_accounts_mv.is_restricted ], stream key: [ open_accounts_mv.account_id ] }
Fragment 25159 (Actor 121476,121475)
StreamProject { exprs: [party_involvements_dm.party_id, party_involvements_dm.customer_relationship_id, party_involvements_dm.entity_id, party_involvements_dm.effective_from, party_involvements_dm.effective_to, party_involvements_dm.id] } { output: [ party_involvements_dm.party_id, party_involvements_dm.customer_relationship_id, party_involvements_dm.entity_id, party_involvements_dm.effective_from, party_involvements_dm.effective_to, party_involvements_dm.id ], stream key: [ party_involvements_dm.id ] }
└── StreamFilter { predicate: (party_involvements_dm.entity_type = 'ACCOUNT':Varchar) AND In(party_involvements_dm.involvement_type, 'ACCOUNT_HOLDER':Varchar, 'JOINT_ACCOUNT_HOLDER':Varchar) AND (party_involvements_dm.status = 'ACTIVE':Varchar) AND IsNull(party_involvements_dm.disabled_at) AND (IsNull(party_involvements_dm.effective_to) OR (party_involvements_dm.effective_to > party_involvements_dm.effective_from)) }
├── output: [ party_involvements_dm.party_id, party_involvements_dm.customer_relationship_id, party_involvements_dm.entity_id, party_involvements_dm.effective_from, party_involvements_dm.effective_to, party_involvements_dm.id, party_involvements_dm.involvement_type, party_involvements_dm.entity_type, party_involvements_dm.status, party_involvements_dm.disabled_at ]
├── stream key: [ party_involvements_dm.id ]
└── StreamTableScan { table: party_involvements_dm, columns: [party_id, customer_relationship_id, entity_id, effective_from, effective_to, id, involvement_type, entity_type, status, disabled_at] }
├── output: [ party_involvements_dm.party_id, party_involvements_dm.customer_relationship_id, party_involvements_dm.entity_id, party_involvements_dm.effective_from, party_involvements_dm.effective_to, party_involvements_dm.id, party_involvements_dm.involvement_type, party_involvements_dm.entity_type, party_involvements_dm.status, party_involvements_dm.disabled_at ]
├── stream key: [ party_involvements_dm.id ]
├── Upstream { output: [ party_id, customer_relationship_id, entity_id, effective_from, effective_to, id, involvement_type, entity_type, status, disabled_at ], stream key: [] }
└── BatchPlanNode { output: [ party_id, customer_relationship_id, entity_id, effective_from, effective_to, id, involvement_type, entity_type, status, disabled_at ], stream key: [] }
Fragment 25160 (Actor 121478,121477)
StreamTableScan { table: open_accounts_mv, columns: [account_id, is_restricted] } { output: [ open_accounts_mv.account_id, open_accounts_mv.is_restricted ], stream key: [ open_accounts_mv.account_id ] }
├── Upstream { output: [ account_id, is_restricted ], stream key: [] }
└── BatchPlanNode { output: [ account_id, is_restricted ], stream key: [] }
Fragment 25161 (Actor 121461,121462)
StreamProject { exprs: [customer_relationships_next.id] } { output: [ customer_relationships_next.id ], stream key: [ customer_relationships_next.id ] }
└── StreamFilter { predicate: (customer_relationships_next.type = 'CUSTOMER':Varchar) AND (customer_relationships_next.status = 'ACTIVE':Varchar) AND IsNull(customer_relationships_next.disabled_at) } { output: [ customer_relationships_next.id, customer_relationships_next.type, customer_relationships_next.status, customer_relationships_next.disabled_at ], stream key: [ customer_relationships_next.id ] }
└── StreamTableScan { table: customer_relationships_next, columns: [id, type, status, disabled_at] } { output: [ customer_relationships_next.id, customer_relationships_next.type, customer_relationships_next.status, customer_relationships_next.disabled_at ], stream key: [ customer_relationships_next.id ] }
├── Upstream { output: [ id, type, status, disabled_at ], stream key: [] }
└── BatchPlanNode { output: [ id, type, status, disabled_at ], stream key: [] }
Fragment 25162 (Actor 121468,121467)
StreamProject { exprs: [party_involvements_dm.party_id, party_involvements_dm.customer_relationship_id, party_involvements_dm.entity_id, party_involvements_dm.effective_from, party_involvements_dm.effective_to, Case(open_accounts_mv.is_restricted, 'restricted':Varchar, 'un_restricted':Varchar) as $expr1, party_involvements_dm.id, party_involvements_dm.entity_id, party_involvements_dm.customer_relationship_id, 1:Int32] }
├── output: [ party_involvements_dm.party_id, party_involvements_dm.customer_relationship_id, party_involvements_dm.entity_id, party_involvements_dm.effective_from, party_involvements_dm.effective_to, $expr1, party_involvements_dm.id, party_involvements_dm.entity_id, party_involvements_dm.customer_relationship_id, 1:Int32 ]
├── stream key: [ party_involvements_dm.id, party_involvements_dm.entity_id, party_involvements_dm.customer_relationship_id ]
└── MergeExecutor { output: [ party_involvements_dm.party_id, party_involvements_dm.customer_relationship_id, party_involvements_dm.entity_id, party_involvements_dm.effective_from, party_involvements_dm.effective_to, open_accounts_mv.is_restricted, party_involvements_dm.id, customer_relationships_next.id ], stream key: [ party_involvements_dm.id, party_involvements_dm.entity_id, party_involvements_dm.customer_relationship_id ] }