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

digraph G { subgraph clusterstage_1229 { label="Stage 1229"; 12920 [labelType="html" label="SQLExecutionRDD [12920] run at <unknown>:0"]; 12928 [labelType="html" label="SQLExecutionRDD [12928] toJavaRDD at <unknown>:0"]; 12930 [labelType="html" label="PythonRDD [12930] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster28906 { label="MicroBatchScan"; 12916 [labelType="html" label="DataSourceRDD [12916] run at <unknown>:0"]; 12917 [labelType="html" label="MapPartitionsRDD [12917] run at <unknown>:0"]; } subgraph cluster28905 { label="Project"; 12918 [labelType="html" label="MapPartitionsRDD [12918] run at <unknown>:0"]; } subgraph cluster28901 { label="WholeStageCodegen (1)"; 12919 [labelType="html" label="MapPartitionsRDD [12919] run at <unknown>:0"]; } subgraph cluster28915 { label="WholeStageCodegen (1)"; 12921 [labelType="html" label="MapPartitionsRDD [12921] toJavaRDD at <unknown>:0"]; } subgraph cluster28914 { label="Filter"; 12922 [labelType="html" label="MapPartitionsRDD [12922] toJavaRDD at <unknown>:0"]; } subgraph cluster28913 { label="Project"; 12923 [labelType="html" label="MapPartitionsRDD [12923] toJavaRDD at <unknown>:0"]; } subgraph cluster28910 { label="WholeStageCodegen (2)"; 12924 [labelType="html" label="MapPartitionsRDD [12924] toJavaRDD at <unknown>:0"]; } subgraph cluster28909 { label="Project"; 12925 [labelType="html" label="MapPartitionsRDD [12925] toJavaRDD at <unknown>:0"]; } subgraph cluster28908 { label="DeserializeToObject"; 12926 [labelType="html" label="MapPartitionsRDD [12926] toJavaRDD at <unknown>:0"]; } subgraph cluster28907 { label="MapPartitions"; 12927 [labelType="html" label="MapPartitionsRDD [12927] toJavaRDD at <unknown>:0"]; } subgraph cluster28917 { label="mapPartitions"; 12929 [labelType="html" label="MapPartitionsRDD [12929] toJavaRDD at <unknown>:0"]; } } 12916->12917; 12917->12918; 12918->12919; 12919->12920; 12920->12921; 12921->12922; 12922->12923; 12923->12924; 12924->12925; 12925->12926; 12926->12927; 12927->12928; 12928->12929; 12929->12930; }

Event Timeline

Enable zooming