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

digraph G { subgraph clusterstage_272 { label="Stage 272"; 2860 [labelType="html" label="SQLExecutionRDD [2860] run at <unknown>:0"]; 2868 [labelType="html" label="SQLExecutionRDD [2868] toJavaRDD at <unknown>:0"]; 2870 [labelType="html" label="PythonRDD [2870] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster6397 { label="MicroBatchScan"; 2856 [labelType="html" label="DataSourceRDD [2856] run at <unknown>:0"]; 2857 [labelType="html" label="MapPartitionsRDD [2857] run at <unknown>:0"]; } subgraph cluster6396 { label="Project"; 2858 [labelType="html" label="MapPartitionsRDD [2858] run at <unknown>:0"]; } subgraph cluster6392 { label="WholeStageCodegen (1)"; 2859 [labelType="html" label="MapPartitionsRDD [2859] run at <unknown>:0"]; } subgraph cluster6406 { label="WholeStageCodegen (1)"; 2861 [labelType="html" label="MapPartitionsRDD [2861] toJavaRDD at <unknown>:0"]; } subgraph cluster6405 { label="Filter"; 2862 [labelType="html" label="MapPartitionsRDD [2862] toJavaRDD at <unknown>:0"]; } subgraph cluster6404 { label="Project"; 2863 [labelType="html" label="MapPartitionsRDD [2863] toJavaRDD at <unknown>:0"]; } subgraph cluster6401 { label="WholeStageCodegen (2)"; 2864 [labelType="html" label="MapPartitionsRDD [2864] toJavaRDD at <unknown>:0"]; } subgraph cluster6400 { label="Project"; 2865 [labelType="html" label="MapPartitionsRDD [2865] toJavaRDD at <unknown>:0"]; } subgraph cluster6399 { label="DeserializeToObject"; 2866 [labelType="html" label="MapPartitionsRDD [2866] toJavaRDD at <unknown>:0"]; } subgraph cluster6398 { label="MapPartitions"; 2867 [labelType="html" label="MapPartitionsRDD [2867] toJavaRDD at <unknown>:0"]; } subgraph cluster6408 { label="mapPartitions"; 2869 [labelType="html" label="MapPartitionsRDD [2869] toJavaRDD at <unknown>:0"]; } } 2856->2857; 2857->2858; 2858->2859; 2859->2860; 2860->2861; 2861->2862; 2862->2863; 2863->2864; 2864->2865; 2865->2866; 2866->2867; 2867->2868; 2868->2869; 2869->2870; }

Event Timeline

Enable zooming