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

digraph G { subgraph clusterstage_1625 { label="Stage 1625"; 17078 [labelType="html" label="SQLExecutionRDD [17078] run at <unknown>:0"]; 17086 [labelType="html" label="SQLExecutionRDD [17086] toJavaRDD at <unknown>:0"]; 17088 [labelType="html" label="PythonRDD [17088] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster38212 { label="MicroBatchScan"; 17074 [labelType="html" label="DataSourceRDD [17074] run at <unknown>:0"]; 17075 [labelType="html" label="MapPartitionsRDD [17075] run at <unknown>:0"]; } subgraph cluster38211 { label="Project"; 17076 [labelType="html" label="MapPartitionsRDD [17076] run at <unknown>:0"]; } subgraph cluster38207 { label="WholeStageCodegen (1)"; 17077 [labelType="html" label="MapPartitionsRDD [17077] run at <unknown>:0"]; } subgraph cluster38221 { label="WholeStageCodegen (1)"; 17079 [labelType="html" label="MapPartitionsRDD [17079] toJavaRDD at <unknown>:0"]; } subgraph cluster38220 { label="Filter"; 17080 [labelType="html" label="MapPartitionsRDD [17080] toJavaRDD at <unknown>:0"]; } subgraph cluster38219 { label="Project"; 17081 [labelType="html" label="MapPartitionsRDD [17081] toJavaRDD at <unknown>:0"]; } subgraph cluster38216 { label="WholeStageCodegen (2)"; 17082 [labelType="html" label="MapPartitionsRDD [17082] toJavaRDD at <unknown>:0"]; } subgraph cluster38215 { label="Project"; 17083 [labelType="html" label="MapPartitionsRDD [17083] toJavaRDD at <unknown>:0"]; } subgraph cluster38214 { label="DeserializeToObject"; 17084 [labelType="html" label="MapPartitionsRDD [17084] toJavaRDD at <unknown>:0"]; } subgraph cluster38213 { label="MapPartitions"; 17085 [labelType="html" label="MapPartitionsRDD [17085] toJavaRDD at <unknown>:0"]; } subgraph cluster38223 { label="mapPartitions"; 17087 [labelType="html" label="MapPartitionsRDD [17087] toJavaRDD at <unknown>:0"]; } } 17074->17075; 17075->17076; 17076->17077; 17077->17078; 17078->17079; 17079->17080; 17080->17081; 17081->17082; 17082->17083; 17083->17084; 17084->17085; 17085->17086; 17086->17087; 17087->17088; }

Event Timeline

Enable zooming