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

digraph G { subgraph clusterstage_1516 { label="Stage 1516"; 15922 [labelType="html" label="SQLExecutionRDD [15922] run at <unknown>:0"]; 15930 [labelType="html" label="SQLExecutionRDD [15930] toJavaRDD at <unknown>:0"]; 15932 [labelType="html" label="PythonRDD [15932] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster35631 { label="MicroBatchScan"; 15918 [labelType="html" label="DataSourceRDD [15918] run at <unknown>:0"]; 15919 [labelType="html" label="MapPartitionsRDD [15919] run at <unknown>:0"]; } subgraph cluster35630 { label="Project"; 15920 [labelType="html" label="MapPartitionsRDD [15920] run at <unknown>:0"]; } subgraph cluster35626 { label="WholeStageCodegen (1)"; 15921 [labelType="html" label="MapPartitionsRDD [15921] run at <unknown>:0"]; } subgraph cluster35640 { label="WholeStageCodegen (1)"; 15923 [labelType="html" label="MapPartitionsRDD [15923] toJavaRDD at <unknown>:0"]; } subgraph cluster35639 { label="Filter"; 15924 [labelType="html" label="MapPartitionsRDD [15924] toJavaRDD at <unknown>:0"]; } subgraph cluster35638 { label="Project"; 15925 [labelType="html" label="MapPartitionsRDD [15925] toJavaRDD at <unknown>:0"]; } subgraph cluster35635 { label="WholeStageCodegen (2)"; 15926 [labelType="html" label="MapPartitionsRDD [15926] toJavaRDD at <unknown>:0"]; } subgraph cluster35634 { label="Project"; 15927 [labelType="html" label="MapPartitionsRDD [15927] toJavaRDD at <unknown>:0"]; } subgraph cluster35633 { label="DeserializeToObject"; 15928 [labelType="html" label="MapPartitionsRDD [15928] toJavaRDD at <unknown>:0"]; } subgraph cluster35632 { label="MapPartitions"; 15929 [labelType="html" label="MapPartitionsRDD [15929] toJavaRDD at <unknown>:0"]; } subgraph cluster35642 { label="mapPartitions"; 15931 [labelType="html" label="MapPartitionsRDD [15931] toJavaRDD at <unknown>:0"]; } } 15918->15919; 15919->15920; 15920->15921; 15921->15922; 15922->15923; 15923->15924; 15924->15925; 15925->15926; 15926->15927; 15927->15928; 15928->15929; 15929->15930; 15930->15931; 15931->15932; }

Event Timeline

Enable zooming