graphframes - Details for Job 12

Details for Job 12

Status: SUCCEEDED
Completed Stages: 6

Enable zooming

digraph G { subgraph clusterstage_30 { label="Stage 30"; 40 [labelType="html" label="SQLExecutionRDD [40] javaToPython at NativeMethodAccessorImpl.java:0"]; 43 [labelType="html" label="PythonRDD [43] RDD at PythonRDD.scala:53"]; 123 [labelType="html" label="SQLExecutionRDD [123] rdd at GraphFrame.scala:182"]; subgraph cluster69 { label="Scan csv "; 37 [labelType="html" label="FileScanRDD [37] javaToPython at NativeMethodAccessorImpl.java:0"]; 38 [labelType="html" label="MapPartitionsRDD [38] javaToPython at NativeMethodAccessorImpl.java:0"]; } subgraph cluster66 { label="WholeStageCodegen (1)"; 39 [labelType="html" label="MapPartitionsRDD [39] javaToPython at NativeMethodAccessorImpl.java:0"]; } subgraph cluster70 { label="map"; 41 [labelType="html" label="MapPartitionsRDD [41] javaToPython at NativeMethodAccessorImpl.java:0"]; } subgraph cluster71 { label="mapPartitions"; 42 [labelType="html" label="MapPartitionsRDD [42] javaToPython at NativeMethodAccessorImpl.java:0"]; } subgraph cluster72 { label="mapPartitions"; 44 [labelType="html" label="MapPartitionsRDD [44] mapPartitions at SerDeUtil.scala:184"]; } subgraph cluster73 { label="map"; 45 [labelType="html" label="MapPartitionsRDD [45] map at SerDeUtil.scala:137"]; } subgraph cluster74 { label="mapPartitions"; 46 [labelType="html" label="MapPartitionsRDD [46] applySchemaToPythonRDD at NativeMethodAccessorImpl.java:0"]; } subgraph cluster312 { label="WholeStageCodegen (1)"; 121 [labelType="html" label="MapPartitionsRDD [121] rdd at GraphFrame.scala:182"]; } subgraph cluster311 { label="DeserializeToObject"; 122 [labelType="html" label="MapPartitionsRDD [122] rdd at GraphFrame.scala:182"]; } subgraph cluster315 { label="mapPartitions"; 124 [labelType="html" label="MapPartitionsRDD [124] rdd at GraphFrame.scala:182"]; } subgraph cluster316 { label="map"; 125 [labelType="html" label="MapPartitionsRDD [125] map at GraphFrame.scala:183"]; } subgraph cluster317 { label="mapPartitionsWithIndex"; 126 [labelType="html" label="EdgeRDD, EdgeRDD [126] mapPartitionsWithIndex at EdgeRDD.scala:105"]; } subgraph cluster319 { label="mapPartitions"; 130 [labelType="html" label="VertexRDD.createRoutingTables - vid2pid (aggregation) [130] mapPartitions at VertexRDD.scala:356"]; } } 37->38; 38->39; 39->40; 40->41; 41->42; 42->43; 43->44; 44->45; 45->46; 46->121; 121->122; 122->123; 123->124; 124->125; 125->126; 126->130; }

digraph G { subgraph clusterstage_31 { label="Stage 31"; 30 [labelType="html" label="SQLExecutionRDD [30] javaToPython at NativeMethodAccessorImpl.java:0"]; 33 [labelType="html" label="PythonRDD [33] RDD at PythonRDD.scala:53"]; 118 [labelType="html" label="SQLExecutionRDD [118] rdd at GraphFrame.scala:180"]; subgraph cluster60 { label="Scan csv "; 27 [labelType="html" label="FileScanRDD [27] javaToPython at NativeMethodAccessorImpl.java:0"]; 28 [labelType="html" label="MapPartitionsRDD [28] javaToPython at NativeMethodAccessorImpl.java:0"]; } subgraph cluster57 { label="WholeStageCodegen (1)"; 29 [labelType="html" label="MapPartitionsRDD [29] javaToPython at NativeMethodAccessorImpl.java:0"]; } subgraph cluster61 { label="map"; 31 [labelType="html" label="MapPartitionsRDD [31] javaToPython at NativeMethodAccessorImpl.java:0"]; } subgraph cluster62 { label="mapPartitions"; 32 [labelType="html" label="MapPartitionsRDD [32] javaToPython at NativeMethodAccessorImpl.java:0"]; } subgraph cluster63 { label="mapPartitions"; 34 [labelType="html" label="MapPartitionsRDD [34] mapPartitions at SerDeUtil.scala:184"]; } subgraph cluster64 { label="map"; 35 [labelType="html" label="MapPartitionsRDD [35] map at SerDeUtil.scala:137"]; } subgraph cluster65 { label="mapPartitions"; 36 [labelType="html" label="MapPartitionsRDD [36] applySchemaToPythonRDD at NativeMethodAccessorImpl.java:0"]; } subgraph cluster306 { label="WholeStageCodegen (1)"; 116 [labelType="html" label="MapPartitionsRDD [116] rdd at GraphFrame.scala:180"]; } subgraph cluster305 { label="DeserializeToObject"; 117 [labelType="html" label="MapPartitionsRDD [117] rdd at GraphFrame.scala:180"]; } subgraph cluster309 { label="mapPartitions"; 119 [labelType="html" label="MapPartitionsRDD [119] rdd at GraphFrame.scala:180"]; } subgraph cluster310 { label="map"; 120 [labelType="html" label="MapPartitionsRDD [120] map at GraphFrame.scala:181"]; } } 27->28; 28->29; 29->30; 30->31; 31->32; 32->33; 33->34; 34->35; 35->36; 36->116; 116->117; 117->118; 118->119; 119->120; }

digraph G { subgraph clusterstage_32 { label="Stage 32"; subgraph cluster318 { label="partitionBy"; 129 [labelType="html" label="ShuffledRDD [129] partitionBy at VertexRDD.scala:319"]; } subgraph cluster320 { label="partitionBy"; 131 [labelType="html" label="ShuffledRDD [131] partitionBy at VertexRDD.scala:361"]; } subgraph cluster321 { label="mapPartitions"; 132 [labelType="html" label="MapPartitionsRDD [132] mapPartitions at VertexRDD.scala:361"]; } subgraph cluster322 { label="zipPartitions"; 133 [labelType="html" label="VertexRDD, VertexRDD [133] [Cached] zipPartitions at VertexRDD.scala:322"]; } subgraph cluster324 { label="mapPartitions"; 138 [labelType="html" label="VertexRDD [138] [Cached] mapPartitions at VertexRDDImpl.scala:96"]; } subgraph cluster327 { label="mapPartitions"; 144 [labelType="html" label="VertexRDD [144] [Cached] mapPartitions at VertexRDDImpl.scala:96"]; } subgraph cluster329 { label="mapPartitions"; 148 [labelType="html" label="VertexRDD [148] [Cached] mapPartitions at VertexRDDImpl.scala:96"]; } subgraph cluster334 { label="mapPartitions"; 156 [labelType="html" label="ReplicatedVertexView.upgrade(true, true) - shippedVerts true true (broadcast) [156] mapPartitions at VertexRDDImpl.scala:247"]; } } 131->132; 129->133; 132->133; 133->138; 138->144; 144->148; 148->156; }

120,129

130,131

133

138

144

148

digraph G { subgraph clusterstage_33 { label="Stage 33"; subgraph cluster318 { label="partitionBy"; 129 [labelType="html" label="ShuffledRDD [129] partitionBy at VertexRDD.scala:319"]; } subgraph cluster320 { label="partitionBy"; 131 [labelType="html" label="ShuffledRDD [131] partitionBy at VertexRDD.scala:361"]; } subgraph cluster321 { label="mapPartitions"; 132 [labelType="html" label="MapPartitionsRDD [132] mapPartitions at VertexRDD.scala:361"]; } subgraph cluster322 { label="zipPartitions"; 133 [labelType="html" label="VertexRDD, VertexRDD [133] [Cached] zipPartitions at VertexRDD.scala:322"]; } subgraph cluster324 { label="mapPartitions"; 138 [labelType="html" label="VertexRDD [138] [Cached] mapPartitions at VertexRDDImpl.scala:96"]; } subgraph cluster327 { label="mapPartitions"; 144 [labelType="html" label="VertexRDD [144] [Cached] mapPartitions at VertexRDDImpl.scala:96"]; } subgraph cluster329 { label="mapPartitions"; 148 [labelType="html" label="VertexRDD [148] [Cached] mapPartitions at VertexRDDImpl.scala:96"]; } subgraph cluster330 { label="zipPartitions"; 150 [labelType="html" label="VertexRDD [150] zipPartitions at VertexRDDImpl.scala:144"]; } subgraph cluster331 { label="mapPartitions"; 152 [labelType="html" label="ReplicatedVertexView.updateVertices - shippedVerts false false (broadcast) [152] mapPartitions at VertexRDDImpl.scala:247"]; } } 131->132; 129->133; 132->133; 133->138; 138->144; 144->148; 144->150; 148->150; 150->152; }

120,129

130,131

133

138

144

148

digraph G { subgraph clusterstage_34 { label="Stage 34"; 40 [labelType="html" label="SQLExecutionRDD [40] javaToPython at NativeMethodAccessorImpl.java:0"]; 43 [labelType="html" label="PythonRDD [43] RDD at PythonRDD.scala:53"]; 123 [labelType="html" label="SQLExecutionRDD [123] rdd at GraphFrame.scala:182"]; subgraph cluster69 { label="Scan csv "; 37 [labelType="html" label="FileScanRDD [37] javaToPython at NativeMethodAccessorImpl.java:0"]; 38 [labelType="html" label="MapPartitionsRDD [38] javaToPython at NativeMethodAccessorImpl.java:0"]; } subgraph cluster66 { label="WholeStageCodegen (1)"; 39 [labelType="html" label="MapPartitionsRDD [39] javaToPython at NativeMethodAccessorImpl.java:0"]; } subgraph cluster70 { label="map"; 41 [labelType="html" label="MapPartitionsRDD [41] javaToPython at NativeMethodAccessorImpl.java:0"]; } subgraph cluster71 { label="mapPartitions"; 42 [labelType="html" label="MapPartitionsRDD [42] javaToPython at NativeMethodAccessorImpl.java:0"]; } subgraph cluster72 { label="mapPartitions"; 44 [labelType="html" label="MapPartitionsRDD [44] mapPartitions at SerDeUtil.scala:184"]; } subgraph cluster73 { label="map"; 45 [labelType="html" label="MapPartitionsRDD [45] map at SerDeUtil.scala:137"]; } subgraph cluster74 { label="mapPartitions"; 46 [labelType="html" label="MapPartitionsRDD [46] applySchemaToPythonRDD at NativeMethodAccessorImpl.java:0"]; } subgraph cluster312 { label="WholeStageCodegen (1)"; 121 [labelType="html" label="MapPartitionsRDD [121] rdd at GraphFrame.scala:182"]; } subgraph cluster311 { label="DeserializeToObject"; 122 [labelType="html" label="MapPartitionsRDD [122] rdd at GraphFrame.scala:182"]; } subgraph cluster315 { label="mapPartitions"; 124 [labelType="html" label="MapPartitionsRDD [124] rdd at GraphFrame.scala:182"]; } subgraph cluster316 { label="map"; 125 [labelType="html" label="MapPartitionsRDD [125] map at GraphFrame.scala:183"]; } subgraph cluster317 { label="mapPartitionsWithIndex"; 126 [labelType="html" label="EdgeRDD, EdgeRDD [126] mapPartitionsWithIndex at EdgeRDD.scala:105"]; } subgraph cluster323 { label="mapPartitions"; 136 [labelType="html" label="EdgeRDD [136] [Cached] mapPartitions at EdgeRDDImpl.scala:119"]; } subgraph cluster325 { label="mapPartitions"; 140 [labelType="html" label="EdgeRDD [140] [Cached] mapPartitions at EdgeRDDImpl.scala:119"]; } subgraph cluster326 { label="mapPartitions"; 142 [labelType="html" label="EdgeRDD [142] mapPartitions at EdgeRDDImpl.scala:119"]; } subgraph cluster328 { label="mapPartitions"; 146 [labelType="html" label="EdgeRDD [146] [Cached] mapPartitions at EdgeRDDImpl.scala:119"]; } subgraph cluster332 { label="partitionBy"; 153 [labelType="html" label="ShuffledRDD [153] partitionBy at ReplicatedVertexView.scala:110"]; } subgraph cluster333 { label="zipPartitions"; 154 [labelType="html" label="EdgeRDD [154] [Cached] zipPartitions at ReplicatedVertexView.scala:112"]; } subgraph cluster335 { label="partitionBy"; 157 [labelType="html" label="ShuffledRDD [157] partitionBy at ReplicatedVertexView.scala:69"]; } subgraph cluster336 { label="zipPartitions"; 158 [labelType="html" label="EdgeRDD [158] zipPartitions at ReplicatedVertexView.scala:70"]; } subgraph cluster337 { label="mapPartitions"; 160 [labelType="html" label="GraphImpl.aggregateMessages - preAgg [160] mapPartitions at GraphImpl.scala:208"]; } } 37->38; 38->39; 39->40; 40->41; 41->42; 42->43; 43->44; 44->45; 45->46; 46->121; 121->122; 122->123; 123->124; 124->125; 125->126; 126->136; 136->140; 140->142; 142->146; 146->154; 153->154; 154->158; 157->158; 158->160; }

152,153

156,157

136

140

146

154

digraph G { subgraph clusterstage_35 { label="Stage 35"; subgraph cluster318 { label="partitionBy"; 129 [labelType="html" label="ShuffledRDD [129] partitionBy at VertexRDD.scala:319"]; } subgraph cluster320 { label="partitionBy"; 131 [labelType="html" label="ShuffledRDD [131] partitionBy at VertexRDD.scala:361"]; } subgraph cluster321 { label="mapPartitions"; 132 [labelType="html" label="MapPartitionsRDD [132] mapPartitions at VertexRDD.scala:361"]; } subgraph cluster322 { label="zipPartitions"; 133 [labelType="html" label="VertexRDD, VertexRDD [133] [Cached] zipPartitions at VertexRDD.scala:322"]; } subgraph cluster324 { label="mapPartitions"; 138 [labelType="html" label="VertexRDD [138] [Cached] mapPartitions at VertexRDDImpl.scala:96"]; } subgraph cluster327 { label="mapPartitions"; 144 [labelType="html" label="VertexRDD [144] [Cached] mapPartitions at VertexRDDImpl.scala:96"]; } subgraph cluster329 { label="mapPartitions"; 148 [labelType="html" label="VertexRDD [148] [Cached] mapPartitions at VertexRDDImpl.scala:96"]; } subgraph cluster338 { label="partitionBy"; 161 [labelType="html" label="ShuffledRDD [161] partitionBy at VertexRDDImpl.scala:214"]; } subgraph cluster339 { label="zipPartitions"; 162 [labelType="html" label="VertexRDD [162] [Cached] zipPartitions at VertexRDDImpl.scala:215"]; } subgraph cluster340 { label="map"; 164 [labelType="html" label="MapPartitionsRDD [164] map at VertexRDDImpl.scala:90"]; } } 131->132; 129->133; 132->133; 133->138; 138->144; 144->148; 148->162; 161->162; 162->164; }

120,129

130,131

160,161

133

138

144

148

162

Completed Stages (6)

Page:

Stage Id ▾	Description	Submitted	Duration	Tasks: Succeeded/Total	Input	Shuffle Read	Shuffle Write
35	fold at VertexRDDImpl.scala:90 +details org.apache.spark.rdd.RDD.fold(RDD.scala:1151) org.apache.spark.graphx.impl.VertexRDDImpl.count(VertexRDDImpl.scala:90) org.apache.spark.graphx.Pregel$.apply(Pregel.scala:140) org.apache.spark.graphx.lib.ShortestPaths$.run(ShortestPaths.scala:75) org.graphframes.lib.ShortestPaths$.org$graphframes$lib$ShortestPaths$$run(ShortestPaths.scala:70) org.graphframes.lib.ShortestPaths.run(ShortestPaths.scala:61) sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) java.lang.reflect.Method.invoke(Method.java:498) py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244) py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:357) py4j.Gateway.invoke(Gateway.java:282) py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132) py4j.commands.CallCommand.execute(CallCommand.java:79) py4j.GatewayConnection.run(GatewayConnection.java:238) java.lang.Thread.run(Thread.java:750)	2024/12/04 20:24:05	18 ms	1/1	43.4 KiB	1611.0 B
34	mapPartitions at GraphImpl.scala:208 +details org.apache.spark.rdd.RDD.mapPartitions(RDD.scala:833) org.apache.spark.graphx.impl.GraphImpl.aggregateMessagesWithActiveSet(GraphImpl.scala:208) org.apache.spark.graphx.GraphXUtils$.mapReduceTriplets(GraphXUtils.scala:69) org.apache.spark.graphx.Pregel$.apply(Pregel.scala:136) org.apache.spark.graphx.lib.ShortestPaths$.run(ShortestPaths.scala:75) org.graphframes.lib.ShortestPaths$.org$graphframes$lib$ShortestPaths$$run(ShortestPaths.scala:70) org.graphframes.lib.ShortestPaths.run(ShortestPaths.scala:61) sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) java.lang.reflect.Method.invoke(Method.java:498) py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244) py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:357) py4j.Gateway.invoke(Gateway.java:282) py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132) py4j.commands.CallCommand.execute(CallCommand.java:79) py4j.GatewayConnection.run(GatewayConnection.java:238) java.lang.Thread.run(Thread.java:750)	2024/12/04 20:24:02	3 s	3/3	46.9 MiB	5.9 KiB	1611.0 B
33	mapPartitions at VertexRDDImpl.scala:247 +details org.apache.spark.rdd.RDD.mapPartitions(RDD.scala:833) org.apache.spark.graphx.impl.VertexRDDImpl.shipVertexAttributes(VertexRDDImpl.scala:247) org.apache.spark.graphx.impl.ReplicatedVertexView.updateVertices(ReplicatedVertexView.scala:107) org.apache.spark.graphx.impl.GraphImpl.mapVertices(GraphImpl.scala:133) org.apache.spark.graphx.Pregel$.apply(Pregel.scala:130) org.apache.spark.graphx.lib.ShortestPaths$.run(ShortestPaths.scala:75) org.graphframes.lib.ShortestPaths$.org$graphframes$lib$ShortestPaths$$run(ShortestPaths.scala:70) org.graphframes.lib.ShortestPaths.run(ShortestPaths.scala:61) sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) java.lang.reflect.Method.invoke(Method.java:498) py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244) py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:357) py4j.Gateway.invoke(Gateway.java:282) py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132) py4j.commands.CallCommand.execute(CallCommand.java:79) py4j.GatewayConnection.run(GatewayConnection.java:238) java.lang.Thread.run(Thread.java:750)	2024/12/04 20:24:02	0.1 s	1/1	12.9 KiB	10.4 KiB	860.0 B
32	mapPartitions at VertexRDDImpl.scala:247 +details org.apache.spark.rdd.RDD.mapPartitions(RDD.scala:833) org.apache.spark.graphx.impl.VertexRDDImpl.shipVertexAttributes(VertexRDDImpl.scala:247) org.apache.spark.graphx.impl.ReplicatedVertexView.upgrade(ReplicatedVertexView.scala:66) org.apache.spark.graphx.impl.GraphImpl.aggregateMessagesWithActiveSet(GraphImpl.scala:198) org.apache.spark.graphx.GraphXUtils$.mapReduceTriplets(GraphXUtils.scala:69) org.apache.spark.graphx.Pregel$.apply(Pregel.scala:136) org.apache.spark.graphx.lib.ShortestPaths$.run(ShortestPaths.scala:75) org.graphframes.lib.ShortestPaths$.org$graphframes$lib$ShortestPaths$$run(ShortestPaths.scala:70) org.graphframes.lib.ShortestPaths.run(ShortestPaths.scala:61) sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) java.lang.reflect.Method.invoke(Method.java:498) py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244) py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:357) py4j.Gateway.invoke(Gateway.java:282) py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132) py4j.commands.CallCommand.execute(CallCommand.java:79) py4j.GatewayConnection.run(GatewayConnection.java:238) java.lang.Thread.run(Thread.java:750)	2024/12/04 20:24:02	12 ms	1/1	43.4 KiB		5.1 KiB
31	map at GraphFrame.scala:181 +details org.apache.spark.rdd.RDD.map(RDD.scala:395) org.graphframes.GraphFrame.toGraphX(GraphFrame.scala:181) org.graphframes.GraphFrame.cachedGraphX$lzycompute(GraphFrame.scala:598) org.graphframes.GraphFrame.cachedGraphX(GraphFrame.scala:598) org.graphframes.GraphFrame.cachedTopologyGraphX$lzycompute(GraphFrame.scala:592) org.graphframes.GraphFrame.cachedTopologyGraphX(GraphFrame.scala:591) org.graphframes.lib.ShortestPaths$.org$graphframes$lib$ShortestPaths$$run(ShortestPaths.scala:71) org.graphframes.lib.ShortestPaths.run(ShortestPaths.scala:61) sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) java.lang.reflect.Method.invoke(Method.java:498) py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244) py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:357) py4j.Gateway.invoke(Gateway.java:282) py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132) py4j.commands.CallCommand.execute(CallCommand.java:79) py4j.GatewayConnection.run(GatewayConnection.java:238) java.lang.Thread.run(Thread.java:750)	2024/12/04 20:24:00	70 ms	1/1	7.4 KiB		7.1 KiB
30	mapPartitions at VertexRDD.scala:356 +details org.apache.spark.rdd.RDD.mapPartitions(RDD.scala:833) org.apache.spark.graphx.VertexRDD$.createRoutingTables(VertexRDD.scala:356) org.apache.spark.graphx.VertexRDD$.apply(VertexRDD.scala:321) org.apache.spark.graphx.VertexRDD$.apply(VertexRDD.scala:299) org.apache.spark.graphx.impl.GraphImpl$.apply(GraphImpl.scala:315) org.apache.spark.graphx.Graph$.apply(Graph.scala:531) org.graphframes.GraphFrame.toGraphX(GraphFrame.scala:184) org.graphframes.GraphFrame.cachedGraphX$lzycompute(GraphFrame.scala:598) org.graphframes.GraphFrame.cachedGraphX(GraphFrame.scala:598) org.graphframes.GraphFrame.cachedTopologyGraphX$lzycompute(GraphFrame.scala:592) org.graphframes.GraphFrame.cachedTopologyGraphX(GraphFrame.scala:591) org.graphframes.lib.ShortestPaths$.org$graphframes$lib$ShortestPaths$$run(ShortestPaths.scala:71) org.graphframes.lib.ShortestPaths.run(ShortestPaths.scala:61) sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) java.lang.reflect.Method.invoke(Method.java:498) py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244) py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:357) py4j.Gateway.invoke(Gateway.java:282)	2024/12/04 20:24:00	2 s	3/3	46.9 MiB		3.3 KiB

Page: