Skip to content

Commit 85a644b

Browse files
author
Andrew Or
committed
[HOT FIX] For DAG visualization #5954
1 parent 76e8344 commit 85a644b

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

core/src/main/resources/org/apache/spark/ui/static/spark-dag-viz.js

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -333,10 +333,10 @@ function drawCrossStageEdges(edges, svgContainer) {
333333
connectRDDs(fromRDDId, toRDDId, edgesContainer, svgContainer);
334334
}
335335
// Now draw the arrows by borrowing the arrow marker generated by dagre-d3
336-
var dagreD3Marker = svgContainer.select("g.edgePaths marker").node();
336+
var dagreD3Marker = svgContainer.select("g.edgePaths marker");
337337
if (!dagreD3Marker.empty()) {
338338
svgContainer
339-
.append(function() { return dagreD3Marker.cloneNode(true); })
339+
.append(function() { return dagreD3Marker.node().cloneNode(true); })
340340
.attr("id", "marker-arrow")
341341
svgContainer.selectAll("g > path").attr("marker-end", "url(#marker-arrow)");
342342
svgContainer.selectAll("g.edgePaths def").remove(); // We no longer need these

0 commit comments

Comments
 (0)