processing-stream-kafka-raw-to-minio - Details for Stage 1439 (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 / 450
Associated Job Ids: 1440

digraph G { subgraph clusterstage_1439 { label="Stage 1439"; 15125 [labelType="html" label="SQLExecutionRDD [15125] run at <unknown>:0"]; 15133 [labelType="html" label="SQLExecutionRDD [15133] toJavaRDD at <unknown>:0"]; 15136 [labelType="html" label="PythonRDD [15136] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster33841 { label="MicroBatchScan"; 15121 [labelType="html" label="DataSourceRDD [15121] run at <unknown>:0"]; 15122 [labelType="html" label="MapPartitionsRDD [15122] run at <unknown>:0"]; } subgraph cluster33840 { label="Project"; 15123 [labelType="html" label="MapPartitionsRDD [15123] run at <unknown>:0"]; } subgraph cluster33836 { label="WholeStageCodegen (1)"; 15124 [labelType="html" label="MapPartitionsRDD [15124] run at <unknown>:0"]; } subgraph cluster33850 { label="WholeStageCodegen (1)"; 15126 [labelType="html" label="MapPartitionsRDD [15126] toJavaRDD at <unknown>:0"]; } subgraph cluster33849 { label="Filter"; 15127 [labelType="html" label="MapPartitionsRDD [15127] toJavaRDD at <unknown>:0"]; } subgraph cluster33848 { label="Project"; 15128 [labelType="html" label="MapPartitionsRDD [15128] toJavaRDD at <unknown>:0"]; } subgraph cluster33845 { label="WholeStageCodegen (2)"; 15129 [labelType="html" label="MapPartitionsRDD [15129] toJavaRDD at <unknown>:0"]; } subgraph cluster33844 { label="Project"; 15130 [labelType="html" label="MapPartitionsRDD [15130] toJavaRDD at <unknown>:0"]; } subgraph cluster33843 { label="DeserializeToObject"; 15131 [labelType="html" label="MapPartitionsRDD [15131] toJavaRDD at <unknown>:0"]; } subgraph cluster33842 { label="MapPartitions"; 15132 [labelType="html" label="MapPartitionsRDD [15132] toJavaRDD at <unknown>:0"]; } subgraph cluster33852 { label="mapPartitions"; 15134 [labelType="html" label="MapPartitionsRDD [15134] toJavaRDD at <unknown>:0"]; } } 15121->15122; 15122->15123; 15123->15124; 15124->15125; 15125->15126; 15126->15127; 15127->15128; 15128->15129; 15129->15130; 15130->15131; 15131->15132; 15132->15133; 15133->15134; 15134->15136; }

Event Timeline

Enable zooming