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

digraph G { subgraph clusterstage_1593 { label="Stage 1593"; 16742 [labelType="html" label="SQLExecutionRDD [16742] run at <unknown>:0"]; 16750 [labelType="html" label="SQLExecutionRDD [16750] toJavaRDD at <unknown>:0"]; 16752 [labelType="html" label="PythonRDD [16752] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster37460 { label="MicroBatchScan"; 16738 [labelType="html" label="DataSourceRDD [16738] run at <unknown>:0"]; 16739 [labelType="html" label="MapPartitionsRDD [16739] run at <unknown>:0"]; } subgraph cluster37459 { label="Project"; 16740 [labelType="html" label="MapPartitionsRDD [16740] run at <unknown>:0"]; } subgraph cluster37455 { label="WholeStageCodegen (1)"; 16741 [labelType="html" label="MapPartitionsRDD [16741] run at <unknown>:0"]; } subgraph cluster37469 { label="WholeStageCodegen (1)"; 16743 [labelType="html" label="MapPartitionsRDD [16743] toJavaRDD at <unknown>:0"]; } subgraph cluster37468 { label="Filter"; 16744 [labelType="html" label="MapPartitionsRDD [16744] toJavaRDD at <unknown>:0"]; } subgraph cluster37467 { label="Project"; 16745 [labelType="html" label="MapPartitionsRDD [16745] toJavaRDD at <unknown>:0"]; } subgraph cluster37464 { label="WholeStageCodegen (2)"; 16746 [labelType="html" label="MapPartitionsRDD [16746] toJavaRDD at <unknown>:0"]; } subgraph cluster37463 { label="Project"; 16747 [labelType="html" label="MapPartitionsRDD [16747] toJavaRDD at <unknown>:0"]; } subgraph cluster37462 { label="DeserializeToObject"; 16748 [labelType="html" label="MapPartitionsRDD [16748] toJavaRDD at <unknown>:0"]; } subgraph cluster37461 { label="MapPartitions"; 16749 [labelType="html" label="MapPartitionsRDD [16749] toJavaRDD at <unknown>:0"]; } subgraph cluster37471 { label="mapPartitions"; 16751 [labelType="html" label="MapPartitionsRDD [16751] toJavaRDD at <unknown>:0"]; } } 16738->16739; 16739->16740; 16740->16741; 16741->16742; 16742->16743; 16743->16744; 16744->16745; 16745->16746; 16746->16747; 16747->16748; 16748->16749; 16749->16750; 16750->16751; 16751->16752; }

Event Timeline

Enable zooming