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

digraph G { subgraph clusterstage_1671 { label="Stage 1671"; 17561 [labelType="html" label="SQLExecutionRDD [17561] run at <unknown>:0"]; 17569 [labelType="html" label="SQLExecutionRDD [17569] toJavaRDD at <unknown>:0"]; 17571 [labelType="html" label="PythonRDD [17571] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster39293 { label="MicroBatchScan"; 17557 [labelType="html" label="DataSourceRDD [17557] run at <unknown>:0"]; 17558 [labelType="html" label="MapPartitionsRDD [17558] run at <unknown>:0"]; } subgraph cluster39292 { label="Project"; 17559 [labelType="html" label="MapPartitionsRDD [17559] run at <unknown>:0"]; } subgraph cluster39288 { label="WholeStageCodegen (1)"; 17560 [labelType="html" label="MapPartitionsRDD [17560] run at <unknown>:0"]; } subgraph cluster39302 { label="WholeStageCodegen (1)"; 17562 [labelType="html" label="MapPartitionsRDD [17562] toJavaRDD at <unknown>:0"]; } subgraph cluster39301 { label="Filter"; 17563 [labelType="html" label="MapPartitionsRDD [17563] toJavaRDD at <unknown>:0"]; } subgraph cluster39300 { label="Project"; 17564 [labelType="html" label="MapPartitionsRDD [17564] toJavaRDD at <unknown>:0"]; } subgraph cluster39297 { label="WholeStageCodegen (2)"; 17565 [labelType="html" label="MapPartitionsRDD [17565] toJavaRDD at <unknown>:0"]; } subgraph cluster39296 { label="Project"; 17566 [labelType="html" label="MapPartitionsRDD [17566] toJavaRDD at <unknown>:0"]; } subgraph cluster39295 { label="DeserializeToObject"; 17567 [labelType="html" label="MapPartitionsRDD [17567] toJavaRDD at <unknown>:0"]; } subgraph cluster39294 { label="MapPartitions"; 17568 [labelType="html" label="MapPartitionsRDD [17568] toJavaRDD at <unknown>:0"]; } subgraph cluster39304 { label="mapPartitions"; 17570 [labelType="html" label="MapPartitionsRDD [17570] toJavaRDD at <unknown>:0"]; } } 17557->17558; 17558->17559; 17559->17560; 17560->17561; 17561->17562; 17562->17563; 17563->17564; 17564->17565; 17565->17566; 17566->17567; 17567->17568; 17568->17569; 17569->17570; 17570->17571; }

Event Timeline

Enable zooming