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

digraph G { subgraph clusterstage_724 { label="Stage 724"; 7606 [labelType="html" label="SQLExecutionRDD [7606] run at <unknown>:0"]; 7614 [labelType="html" label="SQLExecutionRDD [7614] toJavaRDD at <unknown>:0"]; 7616 [labelType="html" label="PythonRDD [7616] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster17019 { label="MicroBatchScan"; 7602 [labelType="html" label="DataSourceRDD [7602] run at <unknown>:0"]; 7603 [labelType="html" label="MapPartitionsRDD [7603] run at <unknown>:0"]; } subgraph cluster17018 { label="Project"; 7604 [labelType="html" label="MapPartitionsRDD [7604] run at <unknown>:0"]; } subgraph cluster17014 { label="WholeStageCodegen (1)"; 7605 [labelType="html" label="MapPartitionsRDD [7605] run at <unknown>:0"]; } subgraph cluster17028 { label="WholeStageCodegen (1)"; 7607 [labelType="html" label="MapPartitionsRDD [7607] toJavaRDD at <unknown>:0"]; } subgraph cluster17027 { label="Filter"; 7608 [labelType="html" label="MapPartitionsRDD [7608] toJavaRDD at <unknown>:0"]; } subgraph cluster17026 { label="Project"; 7609 [labelType="html" label="MapPartitionsRDD [7609] toJavaRDD at <unknown>:0"]; } subgraph cluster17023 { label="WholeStageCodegen (2)"; 7610 [labelType="html" label="MapPartitionsRDD [7610] toJavaRDD at <unknown>:0"]; } subgraph cluster17022 { label="Project"; 7611 [labelType="html" label="MapPartitionsRDD [7611] toJavaRDD at <unknown>:0"]; } subgraph cluster17021 { label="DeserializeToObject"; 7612 [labelType="html" label="MapPartitionsRDD [7612] toJavaRDD at <unknown>:0"]; } subgraph cluster17020 { label="MapPartitions"; 7613 [labelType="html" label="MapPartitionsRDD [7613] toJavaRDD at <unknown>:0"]; } subgraph cluster17030 { label="mapPartitions"; 7615 [labelType="html" label="MapPartitionsRDD [7615] toJavaRDD at <unknown>:0"]; } } 7602->7603; 7603->7604; 7604->7605; 7605->7606; 7606->7607; 7607->7608; 7608->7609; 7609->7610; 7610->7611; 7611->7612; 7612->7613; 7613->7614; 7614->7615; 7615->7616; }

Event Timeline

Enable zooming