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

digraph G { subgraph clusterstage_1496 { label="Stage 1496"; 15712 [labelType="html" label="SQLExecutionRDD [15712] run at <unknown>:0"]; 15720 [labelType="html" label="SQLExecutionRDD [15720] toJavaRDD at <unknown>:0"]; 15722 [labelType="html" label="PythonRDD [15722] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster35161 { label="MicroBatchScan"; 15708 [labelType="html" label="DataSourceRDD [15708] run at <unknown>:0"]; 15709 [labelType="html" label="MapPartitionsRDD [15709] run at <unknown>:0"]; } subgraph cluster35160 { label="Project"; 15710 [labelType="html" label="MapPartitionsRDD [15710] run at <unknown>:0"]; } subgraph cluster35156 { label="WholeStageCodegen (1)"; 15711 [labelType="html" label="MapPartitionsRDD [15711] run at <unknown>:0"]; } subgraph cluster35170 { label="WholeStageCodegen (1)"; 15713 [labelType="html" label="MapPartitionsRDD [15713] toJavaRDD at <unknown>:0"]; } subgraph cluster35169 { label="Filter"; 15714 [labelType="html" label="MapPartitionsRDD [15714] toJavaRDD at <unknown>:0"]; } subgraph cluster35168 { label="Project"; 15715 [labelType="html" label="MapPartitionsRDD [15715] toJavaRDD at <unknown>:0"]; } subgraph cluster35165 { label="WholeStageCodegen (2)"; 15716 [labelType="html" label="MapPartitionsRDD [15716] toJavaRDD at <unknown>:0"]; } subgraph cluster35164 { label="Project"; 15717 [labelType="html" label="MapPartitionsRDD [15717] toJavaRDD at <unknown>:0"]; } subgraph cluster35163 { label="DeserializeToObject"; 15718 [labelType="html" label="MapPartitionsRDD [15718] toJavaRDD at <unknown>:0"]; } subgraph cluster35162 { label="MapPartitions"; 15719 [labelType="html" label="MapPartitionsRDD [15719] toJavaRDD at <unknown>:0"]; } subgraph cluster35172 { label="mapPartitions"; 15721 [labelType="html" label="MapPartitionsRDD [15721] toJavaRDD at <unknown>:0"]; } } 15708->15709; 15709->15710; 15710->15711; 15711->15712; 15712->15713; 15713->15714; 15714->15715; 15715->15716; 15716->15717; 15717->15718; 15718->15719; 15719->15720; 15720->15721; 15721->15722; }

Event Timeline

Enable zooming