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

digraph G { subgraph clusterstage_1578 { label="Stage 1578"; 16580 [labelType="html" label="SQLExecutionRDD [16580] run at <unknown>:0"]; 16588 [labelType="html" label="SQLExecutionRDD [16588] toJavaRDD at <unknown>:0"]; 16590 [labelType="html" label="PythonRDD [16590] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster37092 { label="MicroBatchScan"; 16571 [labelType="html" label="DataSourceRDD [16571] run at <unknown>:0"]; 16577 [labelType="html" label="MapPartitionsRDD [16577] run at <unknown>:0"]; } subgraph cluster37091 { label="Project"; 16578 [labelType="html" label="MapPartitionsRDD [16578] run at <unknown>:0"]; } subgraph cluster37085 { label="WholeStageCodegen (1)"; 16579 [labelType="html" label="MapPartitionsRDD [16579] run at <unknown>:0"]; } subgraph cluster37101 { label="WholeStageCodegen (1)"; 16581 [labelType="html" label="MapPartitionsRDD [16581] toJavaRDD at <unknown>:0"]; } subgraph cluster37100 { label="Filter"; 16582 [labelType="html" label="MapPartitionsRDD [16582] toJavaRDD at <unknown>:0"]; } subgraph cluster37099 { label="Project"; 16583 [labelType="html" label="MapPartitionsRDD [16583] toJavaRDD at <unknown>:0"]; } subgraph cluster37096 { label="WholeStageCodegen (2)"; 16584 [labelType="html" label="MapPartitionsRDD [16584] toJavaRDD at <unknown>:0"]; } subgraph cluster37095 { label="Project"; 16585 [labelType="html" label="MapPartitionsRDD [16585] toJavaRDD at <unknown>:0"]; } subgraph cluster37094 { label="DeserializeToObject"; 16586 [labelType="html" label="MapPartitionsRDD [16586] toJavaRDD at <unknown>:0"]; } subgraph cluster37093 { label="MapPartitions"; 16587 [labelType="html" label="MapPartitionsRDD [16587] toJavaRDD at <unknown>:0"]; } subgraph cluster37103 { label="mapPartitions"; 16589 [labelType="html" label="MapPartitionsRDD [16589] toJavaRDD at <unknown>:0"]; } } 16571->16577; 16577->16578; 16578->16579; 16579->16580; 16580->16581; 16581->16582; 16582->16583; 16583->16584; 16584->16585; 16585->16586; 16586->16587; 16587->16588; 16588->16589; 16589->16590; }

Event Timeline

Enable zooming