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

digraph G { subgraph clusterstage_1441 { label="Stage 1441"; 15146 [labelType="html" label="SQLExecutionRDD [15146] run at <unknown>:0"]; 15154 [labelType="html" label="SQLExecutionRDD [15154] toJavaRDD at <unknown>:0"]; 15156 [labelType="html" label="PythonRDD [15156] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster33888 { label="MicroBatchScan"; 15142 [labelType="html" label="DataSourceRDD [15142] run at <unknown>:0"]; 15143 [labelType="html" label="MapPartitionsRDD [15143] run at <unknown>:0"]; } subgraph cluster33887 { label="Project"; 15144 [labelType="html" label="MapPartitionsRDD [15144] run at <unknown>:0"]; } subgraph cluster33883 { label="WholeStageCodegen (1)"; 15145 [labelType="html" label="MapPartitionsRDD [15145] run at <unknown>:0"]; } subgraph cluster33897 { label="WholeStageCodegen (1)"; 15147 [labelType="html" label="MapPartitionsRDD [15147] toJavaRDD at <unknown>:0"]; } subgraph cluster33896 { label="Filter"; 15148 [labelType="html" label="MapPartitionsRDD [15148] toJavaRDD at <unknown>:0"]; } subgraph cluster33895 { label="Project"; 15149 [labelType="html" label="MapPartitionsRDD [15149] toJavaRDD at <unknown>:0"]; } subgraph cluster33892 { label="WholeStageCodegen (2)"; 15150 [labelType="html" label="MapPartitionsRDD [15150] toJavaRDD at <unknown>:0"]; } subgraph cluster33891 { label="Project"; 15151 [labelType="html" label="MapPartitionsRDD [15151] toJavaRDD at <unknown>:0"]; } subgraph cluster33890 { label="DeserializeToObject"; 15152 [labelType="html" label="MapPartitionsRDD [15152] toJavaRDD at <unknown>:0"]; } subgraph cluster33889 { label="MapPartitions"; 15153 [labelType="html" label="MapPartitionsRDD [15153] toJavaRDD at <unknown>:0"]; } subgraph cluster33899 { label="mapPartitions"; 15155 [labelType="html" label="MapPartitionsRDD [15155] toJavaRDD at <unknown>:0"]; } } 15142->15143; 15143->15144; 15144->15145; 15145->15146; 15146->15147; 15147->15148; 15148->15149; 15149->15150; 15150->15151; 15151->15152; 15152->15153; 15153->15154; 15154->15155; 15155->15156; }

Event Timeline

Enable zooming