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

digraph G { subgraph clusterstage_1888 { label="Stage 1888"; 19828 [labelType="html" label="SQLExecutionRDD [19828] run at <unknown>:0"]; 19836 [labelType="html" label="SQLExecutionRDD [19836] toJavaRDD at <unknown>:0"]; 19838 [labelType="html" label="PythonRDD [19838] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster44373 { label="MicroBatchScan"; 19824 [labelType="html" label="DataSourceRDD [19824] run at <unknown>:0"]; 19825 [labelType="html" label="MapPartitionsRDD [19825] run at <unknown>:0"]; } subgraph cluster44372 { label="Project"; 19826 [labelType="html" label="MapPartitionsRDD [19826] run at <unknown>:0"]; } subgraph cluster44368 { label="WholeStageCodegen (1)"; 19827 [labelType="html" label="MapPartitionsRDD [19827] run at <unknown>:0"]; } subgraph cluster44382 { label="WholeStageCodegen (1)"; 19829 [labelType="html" label="MapPartitionsRDD [19829] toJavaRDD at <unknown>:0"]; } subgraph cluster44381 { label="Filter"; 19830 [labelType="html" label="MapPartitionsRDD [19830] toJavaRDD at <unknown>:0"]; } subgraph cluster44380 { label="Project"; 19831 [labelType="html" label="MapPartitionsRDD [19831] toJavaRDD at <unknown>:0"]; } subgraph cluster44377 { label="WholeStageCodegen (2)"; 19832 [labelType="html" label="MapPartitionsRDD [19832] toJavaRDD at <unknown>:0"]; } subgraph cluster44376 { label="Project"; 19833 [labelType="html" label="MapPartitionsRDD [19833] toJavaRDD at <unknown>:0"]; } subgraph cluster44375 { label="DeserializeToObject"; 19834 [labelType="html" label="MapPartitionsRDD [19834] toJavaRDD at <unknown>:0"]; } subgraph cluster44374 { label="MapPartitions"; 19835 [labelType="html" label="MapPartitionsRDD [19835] toJavaRDD at <unknown>:0"]; } subgraph cluster44384 { label="mapPartitions"; 19837 [labelType="html" label="MapPartitionsRDD [19837] toJavaRDD at <unknown>:0"]; } } 19824->19825; 19825->19826; 19826->19827; 19827->19828; 19828->19829; 19829->19830; 19830->19831; 19831->19832; 19832->19833; 19833->19834; 19834->19835; 19835->19836; 19836->19837; 19837->19838; }

Event Timeline

Enable zooming