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

digraph G { subgraph clusterstage_1736 { label="Stage 1736"; 18232 [labelType="html" label="SQLExecutionRDD [18232] run at <unknown>:0"]; 18240 [labelType="html" label="SQLExecutionRDD [18240] toJavaRDD at <unknown>:0"]; 18242 [labelType="html" label="PythonRDD [18242] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster40801 { label="MicroBatchScan"; 18228 [labelType="html" label="DataSourceRDD [18228] run at <unknown>:0"]; 18229 [labelType="html" label="MapPartitionsRDD [18229] run at <unknown>:0"]; } subgraph cluster40800 { label="Project"; 18230 [labelType="html" label="MapPartitionsRDD [18230] run at <unknown>:0"]; } subgraph cluster40796 { label="WholeStageCodegen (1)"; 18231 [labelType="html" label="MapPartitionsRDD [18231] run at <unknown>:0"]; } subgraph cluster40810 { label="WholeStageCodegen (1)"; 18233 [labelType="html" label="MapPartitionsRDD [18233] toJavaRDD at <unknown>:0"]; } subgraph cluster40809 { label="Filter"; 18234 [labelType="html" label="MapPartitionsRDD [18234] toJavaRDD at <unknown>:0"]; } subgraph cluster40808 { label="Project"; 18235 [labelType="html" label="MapPartitionsRDD [18235] toJavaRDD at <unknown>:0"]; } subgraph cluster40805 { label="WholeStageCodegen (2)"; 18236 [labelType="html" label="MapPartitionsRDD [18236] toJavaRDD at <unknown>:0"]; } subgraph cluster40804 { label="Project"; 18237 [labelType="html" label="MapPartitionsRDD [18237] toJavaRDD at <unknown>:0"]; } subgraph cluster40803 { label="DeserializeToObject"; 18238 [labelType="html" label="MapPartitionsRDD [18238] toJavaRDD at <unknown>:0"]; } subgraph cluster40802 { label="MapPartitions"; 18239 [labelType="html" label="MapPartitionsRDD [18239] toJavaRDD at <unknown>:0"]; } subgraph cluster40812 { label="mapPartitions"; 18241 [labelType="html" label="MapPartitionsRDD [18241] toJavaRDD at <unknown>:0"]; } } 18228->18229; 18229->18230; 18230->18231; 18231->18232; 18232->18233; 18233->18234; 18234->18235; 18235->18236; 18236->18237; 18237->18238; 18238->18239; 18239->18240; 18240->18241; 18241->18242; }

Event Timeline

Enable zooming