processing-stream-kafka-raw-to-minio - Details for Stage 13 (Attempt 0)

Resource Profile Id: 0
Total Time Across All Tasks: 2 s
Locality Level Summary: Process local: 3
Input Size / Records: 0.0 B / 417
Associated Job Ids: 13

digraph G { subgraph clusterstage_13 { label="Stage 13"; 130 [labelType="html" label="SQLExecutionRDD [130] run at <unknown>:0"]; 144 [labelType="html" label="SQLExecutionRDD [144] toJavaRDD at NativeMethodAccessorImpl.java:0"]; 146 [labelType="html" label="PythonRDD [146] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster293 { label="MicroBatchScan"; 126 [labelType="html" label="DataSourceRDD [126] run at <unknown>:0"]; 127 [labelType="html" label="MapPartitionsRDD [127] run at <unknown>:0"]; } subgraph cluster292 { label="Project"; 128 [labelType="html" label="MapPartitionsRDD [128] run at <unknown>:0"]; } subgraph cluster282 { label="WholeStageCodegen (1)"; 129 [labelType="html" label="MapPartitionsRDD [129] run at <unknown>:0"]; } subgraph cluster304 { label="WholeStageCodegen (1)"; 137 [labelType="html" label="MapPartitionsRDD [137] toJavaRDD at NativeMethodAccessorImpl.java:0"]; } subgraph cluster303 { label="Filter"; 138 [labelType="html" label="MapPartitionsRDD [138] toJavaRDD at NativeMethodAccessorImpl.java:0"]; } subgraph cluster302 { label="Project"; 139 [labelType="html" label="MapPartitionsRDD [139] toJavaRDD at NativeMethodAccessorImpl.java:0"]; } subgraph cluster299 { label="WholeStageCodegen (2)"; 140 [labelType="html" label="MapPartitionsRDD [140] toJavaRDD at NativeMethodAccessorImpl.java:0"]; } subgraph cluster298 { label="Project"; 141 [labelType="html" label="MapPartitionsRDD [141] toJavaRDD at NativeMethodAccessorImpl.java:0"]; } subgraph cluster297 { label="DeserializeToObject"; 142 [labelType="html" label="MapPartitionsRDD [142] toJavaRDD at NativeMethodAccessorImpl.java:0"]; } subgraph cluster296 { label="MapPartitions"; 143 [labelType="html" label="MapPartitionsRDD [143] toJavaRDD at NativeMethodAccessorImpl.java:0"]; } subgraph cluster306 { label="mapPartitions"; 145 [labelType="html" label="MapPartitionsRDD [145] toJavaRDD at NativeMethodAccessorImpl.java:0"]; } } 126->127; 127->128; 128->129; 129->130; 130->137; 137->138; 138->139; 139->140; 140->141; 141->142; 142->143; 143->144; 144->145; 145->146; }

Event Timeline

Enable zooming