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

digraph G { subgraph clusterstage_356 { label="Stage 356"; 3742 [labelType="html" label="SQLExecutionRDD [3742] run at <unknown>:0"]; 3750 [labelType="html" label="SQLExecutionRDD [3750] toJavaRDD at <unknown>:0"]; 3752 [labelType="html" label="PythonRDD [3752] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster8371 { label="MicroBatchScan"; 3738 [labelType="html" label="DataSourceRDD [3738] run at <unknown>:0"]; 3739 [labelType="html" label="MapPartitionsRDD [3739] run at <unknown>:0"]; } subgraph cluster8370 { label="Project"; 3740 [labelType="html" label="MapPartitionsRDD [3740] run at <unknown>:0"]; } subgraph cluster8366 { label="WholeStageCodegen (1)"; 3741 [labelType="html" label="MapPartitionsRDD [3741] run at <unknown>:0"]; } subgraph cluster8380 { label="WholeStageCodegen (1)"; 3743 [labelType="html" label="MapPartitionsRDD [3743] toJavaRDD at <unknown>:0"]; } subgraph cluster8379 { label="Filter"; 3744 [labelType="html" label="MapPartitionsRDD [3744] toJavaRDD at <unknown>:0"]; } subgraph cluster8378 { label="Project"; 3745 [labelType="html" label="MapPartitionsRDD [3745] toJavaRDD at <unknown>:0"]; } subgraph cluster8375 { label="WholeStageCodegen (2)"; 3746 [labelType="html" label="MapPartitionsRDD [3746] toJavaRDD at <unknown>:0"]; } subgraph cluster8374 { label="Project"; 3747 [labelType="html" label="MapPartitionsRDD [3747] toJavaRDD at <unknown>:0"]; } subgraph cluster8373 { label="DeserializeToObject"; 3748 [labelType="html" label="MapPartitionsRDD [3748] toJavaRDD at <unknown>:0"]; } subgraph cluster8372 { label="MapPartitions"; 3749 [labelType="html" label="MapPartitionsRDD [3749] toJavaRDD at <unknown>:0"]; } subgraph cluster8382 { label="mapPartitions"; 3751 [labelType="html" label="MapPartitionsRDD [3751] toJavaRDD at <unknown>:0"]; } } 3738->3739; 3739->3740; 3740->3741; 3741->3742; 3742->3743; 3743->3744; 3744->3745; 3745->3746; 3746->3747; 3747->3748; 3748->3749; 3749->3750; 3750->3751; 3751->3752; }

Event Timeline

Enable zooming