diff --git a/dashboard/pages/fragment_graph.tsx b/dashboard/pages/fragment_graph.tsx index 23b4f04119c07..3ffbda24b232f 100644 --- a/dashboard/pages/fragment_graph.tsx +++ b/dashboard/pages/fragment_graph.tsx @@ -56,6 +56,7 @@ import { Dispatcher, MergeNode, StreamNode } from "../proto/gen/stream_plan" interface DispatcherNode { [actorId: number]: Dispatcher[] + fragment: TableFragments_Fragment } // Refresh interval (ms) for back pressure stats @@ -107,10 +108,14 @@ function buildPlanNodeDependency( dispatcherName = "noDispatcher" } - const dispatcherNode = fragment.actors.reduce((obj, actor) => { + let dispatcherNode = fragment.actors.reduce((obj, actor) => { obj[actor.actorId] = actor.dispatcher return obj }, {} as DispatcherNode) + dispatcherNode.fragment = { + ...fragment, + actors: [], + } return d3.hierarchy({ name: dispatcherName,