aboutsummaryrefslogtreecommitdiff
path: root/core
diff options
context:
space:
mode:
authorAndrew Or <andrew@databricks.com>2015-05-12 12:06:30 -0700
committerAndrew Or <andrew@databricks.com>2015-05-12 12:06:30 -0700
commitb9b01f44f687f35460db9e0ab0b426897747596a (patch)
tree685f2bb98f7d33ae49405c08d0ac1a0c65278481 /core
parent4e290522c2a6310636317c54589dc35c91d95486 (diff)
downloadspark-b9b01f44f687f35460db9e0ab0b426897747596a.tar.gz
spark-b9b01f44f687f35460db9e0ab0b426897747596a.tar.bz2
spark-b9b01f44f687f35460db9e0ab0b426897747596a.zip
[HOT FIX #6076] DAG visualization: curve the edges
Diffstat (limited to 'core')
-rw-r--r--core/src/main/resources/org/apache/spark/ui/static/spark-dag-viz.js3
1 files changed, 2 insertions, 1 deletions
diff --git a/core/src/main/resources/org/apache/spark/ui/static/spark-dag-viz.js b/core/src/main/resources/org/apache/spark/ui/static/spark-dag-viz.js
index 8b7b1f6050..f7d0d3c614 100644
--- a/core/src/main/resources/org/apache/spark/ui/static/spark-dag-viz.js
+++ b/core/src/main/resources/org/apache/spark/ui/static/spark-dag-viz.js
@@ -272,7 +272,8 @@ function preprocessGraphLayout(g, forJob) {
// Curve the edges
var edges = g.edges();
for (var j = 0; j < edges.length; j++) {
- edges[j].lineInterpolate = "basis";
+ var edge = g.edge(edges[j]);
+ edge.lineInterpolate = "basis";
}
// Adjust vertical separation between nodes
if (forJob) {