processing-stream-kafka-raw-to-minio - Details for Stage 1418 (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: 1419

digraph G { subgraph clusterstage_1418 { label="Stage 1418"; 14894 [labelType="html" label="SQLExecutionRDD [14894] run at <unknown>:0"]; 14908 [labelType="html" label="SQLExecutionRDD [14908] toJavaRDD at <unknown>:0"]; 14910 [labelType="html" label="PythonRDD [14910] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster33324 { label="MicroBatchScan"; 14890 [labelType="html" label="DataSourceRDD [14890] run at <unknown>:0"]; 14891 [labelType="html" label="MapPartitionsRDD [14891] run at <unknown>:0"]; } subgraph cluster33323 { label="Project"; 14892 [labelType="html" label="MapPartitionsRDD [14892] run at <unknown>:0"]; } subgraph cluster33319 { label="WholeStageCodegen (1)"; 14893 [labelType="html" label="MapPartitionsRDD [14893] run at <unknown>:0"]; } subgraph cluster33341 { label="WholeStageCodegen (1)"; 14901 [labelType="html" label="MapPartitionsRDD [14901] toJavaRDD at <unknown>:0"]; } subgraph cluster33340 { label="Filter"; 14902 [labelType="html" label="MapPartitionsRDD [14902] toJavaRDD at <unknown>:0"]; } subgraph cluster33339 { label="Project"; 14903 [labelType="html" label="MapPartitionsRDD [14903] toJavaRDD at <unknown>:0"]; } subgraph cluster33336 { label="WholeStageCodegen (2)"; 14904 [labelType="html" label="MapPartitionsRDD [14904] toJavaRDD at <unknown>:0"]; } subgraph cluster33335 { label="Project"; 14905 [labelType="html" label="MapPartitionsRDD [14905] toJavaRDD at <unknown>:0"]; } subgraph cluster33334 { label="DeserializeToObject"; 14906 [labelType="html" label="MapPartitionsRDD [14906] toJavaRDD at <unknown>:0"]; } subgraph cluster33333 { label="MapPartitions"; 14907 [labelType="html" label="MapPartitionsRDD [14907] toJavaRDD at <unknown>:0"]; } subgraph cluster33343 { label="mapPartitions"; 14909 [labelType="html" label="MapPartitionsRDD [14909] toJavaRDD at <unknown>:0"]; } } 14890->14891; 14891->14892; 14892->14893; 14893->14894; 14894->14901; 14901->14902; 14902->14903; 14903->14904; 14904->14905; 14905->14906; 14906->14907; 14907->14908; 14908->14909; 14909->14910; }

Event Timeline

Enable zooming