Skip to content

Commit

Permalink
fix(dashboard): actor not show multiple dispatchers (#5666)
Browse files Browse the repository at this point in the history
Fix

Co-authored-by: jon-chuang <jon-chuang@users.noreply.github.com>
Co-authored-by: mergify[bot] <37929162+mergify[bot]@users.noreply.github.com>
  • Loading branch information
3 people authored Sep 30, 2022
1 parent 726ea34 commit e6a0ac7
Showing 1 changed file with 3 additions and 3 deletions.
6 changes: 3 additions & 3 deletions src/meta/src/dashboard/index.html
Original file line number Diff line number Diff line change
Expand Up @@ -446,7 +446,7 @@ <h1 class="flex-auto leading-6 font-semibold text-sky-500 dark:text-sky-400">
const selectedActors = actors.actors.filter(actor => fragmentIdOf(actor) == fragmentId)
const actorIds = selectedActors.map(actor => actor.actorId)
if (d.data.operatorId == "dispatcher") {
const nodes = selectedActors.map(actor => ({ dispatcher: dispatcherNode(actor.dispatcher), downstreamActorId: actor.downstreamActorId }))
const nodes = selectedActors.map(actor => ({ dispatcher: actor.dispatcher, downstreamActorId: actor.downstreamActorId }))
showInfo(actorIds, selectedActors, nodes)
} else {
findInfo(actorIds, selectedActors.map(actor => actor.nodes), d.data.operatorId, (actorIds, nodes) => showInfo(actorIds, selectedActors, nodes))
Expand Down Expand Up @@ -559,13 +559,13 @@ <h1 class="flex-auto leading-6 font-semibold text-sky-500 dark:text-sky-400">
if (actor.dispatcher) {
return ({
...actor,
dispatcher: actor.dispatcher[0],
dispatcher: actor.dispatcher,
downstreamActorId: eraseDownstreamIfChain(actor.dispatcher[0])
})
} else {
return ({
...actor,
dispatcher: { type: "BROADCAST", dispatcherId: "0", downstreamActorId: [] },
dispatcher: [{ type: "BROADCAST", dispatcherId: "0", downstreamActorId: [] }],
downstreamActorId: []
})
}
Expand Down

0 comments on commit e6a0ac7

Please sign in to comment.