ODIn/spark-instrumented-optimizer
1
0
Fork 0
Code Issues Pull requests Projects Releases Wiki Activity

[HOT FIX] For DAG visualization #5954

Browse source
This commit is contained in:
Andrew Or 2015-05-06 18:02:08 -07:00
parent 8fa6829f5e
commit 71a452b61c
1 changed files with 2 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

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

@ -333,10 +333,10 @@ function drawCrossStageEdges(edges, svgContainer) {
connectRDDs(fromRDDId, toRDDId, edgesContainer, svgContainer);
}
// Now draw the arrows by borrowing the arrow marker generated by dagre-d3
var dagreD3Marker = svgContainer.select("g.edgePaths marker").node();
var dagreD3Marker = svgContainer.select("g.edgePaths marker");
if (!dagreD3Marker.empty()) {
svgContainer
.append(function() { return dagreD3Marker.cloneNode(true); })
.append(function() { return dagreD3Marker.node().cloneNode(true); })
.attr("id", "marker-arrow")
svgContainer.selectAll("g > path").attr("marker-end", "url(#marker-arrow)");
svgContainer.selectAll("g.edgePaths def").remove(); // We no longer need these