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

digraph G { subgraph clusterstage_1043 { label="Stage 1043"; 10967 [labelType="html" label="SQLExecutionRDD [10967] run at <unknown>:0"]; 10975 [labelType="html" label="SQLExecutionRDD [10975] toJavaRDD at <unknown>:0"]; 10977 [labelType="html" label="PythonRDD [10977] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster24535 { label="MicroBatchScan"; 10963 [labelType="html" label="DataSourceRDD [10963] run at <unknown>:0"]; 10964 [labelType="html" label="MapPartitionsRDD [10964] run at <unknown>:0"]; } subgraph cluster24534 { label="Project"; 10965 [labelType="html" label="MapPartitionsRDD [10965] run at <unknown>:0"]; } subgraph cluster24530 { label="WholeStageCodegen (1)"; 10966 [labelType="html" label="MapPartitionsRDD [10966] run at <unknown>:0"]; } subgraph cluster24544 { label="WholeStageCodegen (1)"; 10968 [labelType="html" label="MapPartitionsRDD [10968] toJavaRDD at <unknown>:0"]; } subgraph cluster24543 { label="Filter"; 10969 [labelType="html" label="MapPartitionsRDD [10969] toJavaRDD at <unknown>:0"]; } subgraph cluster24542 { label="Project"; 10970 [labelType="html" label="MapPartitionsRDD [10970] toJavaRDD at <unknown>:0"]; } subgraph cluster24539 { label="WholeStageCodegen (2)"; 10971 [labelType="html" label="MapPartitionsRDD [10971] toJavaRDD at <unknown>:0"]; } subgraph cluster24538 { label="Project"; 10972 [labelType="html" label="MapPartitionsRDD [10972] toJavaRDD at <unknown>:0"]; } subgraph cluster24537 { label="DeserializeToObject"; 10973 [labelType="html" label="MapPartitionsRDD [10973] toJavaRDD at <unknown>:0"]; } subgraph cluster24536 { label="MapPartitions"; 10974 [labelType="html" label="MapPartitionsRDD [10974] toJavaRDD at <unknown>:0"]; } subgraph cluster24546 { label="mapPartitions"; 10976 [labelType="html" label="MapPartitionsRDD [10976] toJavaRDD at <unknown>:0"]; } } 10963->10964; 10964->10965; 10965->10966; 10966->10967; 10967->10968; 10968->10969; 10969->10970; 10970->10971; 10971->10972; 10972->10973; 10973->10974; 10974->10975; 10975->10976; 10976->10977; }

Event Timeline

Enable zooming