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

digraph G { subgraph clusterstage_1050 { label="Stage 1050"; 11029 [labelType="html" label="SQLExecutionRDD [11029] run at <unknown>:0"]; 11037 [labelType="html" label="SQLExecutionRDD [11037] toJavaRDD at <unknown>:0"]; 11039 [labelType="html" label="PythonRDD [11039] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster24680 { label="MicroBatchScan"; 11025 [labelType="html" label="DataSourceRDD [11025] run at <unknown>:0"]; 11026 [labelType="html" label="MapPartitionsRDD [11026] run at <unknown>:0"]; } subgraph cluster24679 { label="Project"; 11027 [labelType="html" label="MapPartitionsRDD [11027] run at <unknown>:0"]; } subgraph cluster24675 { label="WholeStageCodegen (1)"; 11028 [labelType="html" label="MapPartitionsRDD [11028] run at <unknown>:0"]; } subgraph cluster24689 { label="WholeStageCodegen (1)"; 11030 [labelType="html" label="MapPartitionsRDD [11030] toJavaRDD at <unknown>:0"]; } subgraph cluster24688 { label="Filter"; 11031 [labelType="html" label="MapPartitionsRDD [11031] toJavaRDD at <unknown>:0"]; } subgraph cluster24687 { label="Project"; 11032 [labelType="html" label="MapPartitionsRDD [11032] toJavaRDD at <unknown>:0"]; } subgraph cluster24684 { label="WholeStageCodegen (2)"; 11033 [labelType="html" label="MapPartitionsRDD [11033] toJavaRDD at <unknown>:0"]; } subgraph cluster24683 { label="Project"; 11034 [labelType="html" label="MapPartitionsRDD [11034] toJavaRDD at <unknown>:0"]; } subgraph cluster24682 { label="DeserializeToObject"; 11035 [labelType="html" label="MapPartitionsRDD [11035] toJavaRDD at <unknown>:0"]; } subgraph cluster24681 { label="MapPartitions"; 11036 [labelType="html" label="MapPartitionsRDD [11036] toJavaRDD at <unknown>:0"]; } subgraph cluster24691 { label="mapPartitions"; 11038 [labelType="html" label="MapPartitionsRDD [11038] toJavaRDD at <unknown>:0"]; } } 11025->11026; 11026->11027; 11027->11028; 11028->11029; 11029->11030; 11030->11031; 11031->11032; 11032->11033; 11033->11034; 11034->11035; 11035->11036; 11036->11037; 11037->11038; 11038->11039; }

Event Timeline

Enable zooming