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

digraph G { subgraph clusterstage_1117 { label="Stage 1117"; 11744 [labelType="html" label="SQLExecutionRDD [11744] run at <unknown>:0"]; 11752 [labelType="html" label="SQLExecutionRDD [11752] toJavaRDD at <unknown>:0"]; 11754 [labelType="html" label="PythonRDD [11754] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster26274 { label="MicroBatchScan"; 11740 [labelType="html" label="DataSourceRDD [11740] run at <unknown>:0"]; 11741 [labelType="html" label="MapPartitionsRDD [11741] run at <unknown>:0"]; } subgraph cluster26273 { label="Project"; 11742 [labelType="html" label="MapPartitionsRDD [11742] run at <unknown>:0"]; } subgraph cluster26269 { label="WholeStageCodegen (1)"; 11743 [labelType="html" label="MapPartitionsRDD [11743] run at <unknown>:0"]; } subgraph cluster26283 { label="WholeStageCodegen (1)"; 11745 [labelType="html" label="MapPartitionsRDD [11745] toJavaRDD at <unknown>:0"]; } subgraph cluster26282 { label="Filter"; 11746 [labelType="html" label="MapPartitionsRDD [11746] toJavaRDD at <unknown>:0"]; } subgraph cluster26281 { label="Project"; 11747 [labelType="html" label="MapPartitionsRDD [11747] toJavaRDD at <unknown>:0"]; } subgraph cluster26278 { label="WholeStageCodegen (2)"; 11748 [labelType="html" label="MapPartitionsRDD [11748] toJavaRDD at <unknown>:0"]; } subgraph cluster26277 { label="Project"; 11749 [labelType="html" label="MapPartitionsRDD [11749] toJavaRDD at <unknown>:0"]; } subgraph cluster26276 { label="DeserializeToObject"; 11750 [labelType="html" label="MapPartitionsRDD [11750] toJavaRDD at <unknown>:0"]; } subgraph cluster26275 { label="MapPartitions"; 11751 [labelType="html" label="MapPartitionsRDD [11751] toJavaRDD at <unknown>:0"]; } subgraph cluster26285 { label="mapPartitions"; 11753 [labelType="html" label="MapPartitionsRDD [11753] toJavaRDD at <unknown>:0"]; } } 11740->11741; 11741->11742; 11742->11743; 11743->11744; 11744->11745; 11745->11746; 11746->11747; 11747->11748; 11748->11749; 11749->11750; 11750->11751; 11751->11752; 11752->11753; 11753->11754; }

Event Timeline

Enable zooming