processing-stream-kafka-raw-to-minio - Details for Stage 261 (Attempt 0)

Resource Profile Id: 0
Total Time Across All Tasks: 2 s
Locality Level Summary: Process local: 4
Input Size / Records: 0.0 B / 459
Associated Job Ids: 261

digraph G { subgraph clusterstage_261 { label="Stage 261"; 2734 [labelType="html" label="SQLExecutionRDD [2734] run at <unknown>:0"]; 2748 [labelType="html" label="SQLExecutionRDD [2748] toJavaRDD at <unknown>:0"]; 2750 [labelType="html" label="PythonRDD [2750] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster6115 { label="MicroBatchScan"; 2730 [labelType="html" label="DataSourceRDD [2730] run at <unknown>:0"]; 2731 [labelType="html" label="MapPartitionsRDD [2731] run at <unknown>:0"]; } subgraph cluster6114 { label="Project"; 2732 [labelType="html" label="MapPartitionsRDD [2732] run at <unknown>:0"]; } subgraph cluster6110 { label="WholeStageCodegen (1)"; 2733 [labelType="html" label="MapPartitionsRDD [2733] run at <unknown>:0"]; } subgraph cluster6132 { label="WholeStageCodegen (1)"; 2741 [labelType="html" label="MapPartitionsRDD [2741] toJavaRDD at <unknown>:0"]; } subgraph cluster6131 { label="Filter"; 2742 [labelType="html" label="MapPartitionsRDD [2742] toJavaRDD at <unknown>:0"]; } subgraph cluster6130 { label="Project"; 2743 [labelType="html" label="MapPartitionsRDD [2743] toJavaRDD at <unknown>:0"]; } subgraph cluster6127 { label="WholeStageCodegen (2)"; 2744 [labelType="html" label="MapPartitionsRDD [2744] toJavaRDD at <unknown>:0"]; } subgraph cluster6126 { label="Project"; 2745 [labelType="html" label="MapPartitionsRDD [2745] toJavaRDD at <unknown>:0"]; } subgraph cluster6125 { label="DeserializeToObject"; 2746 [labelType="html" label="MapPartitionsRDD [2746] toJavaRDD at <unknown>:0"]; } subgraph cluster6124 { label="MapPartitions"; 2747 [labelType="html" label="MapPartitionsRDD [2747] toJavaRDD at <unknown>:0"]; } subgraph cluster6134 { label="mapPartitions"; 2749 [labelType="html" label="MapPartitionsRDD [2749] toJavaRDD at <unknown>:0"]; } } 2730->2731; 2731->2732; 2732->2733; 2733->2734; 2734->2741; 2741->2742; 2742->2743; 2743->2744; 2744->2745; 2745->2746; 2746->2747; 2747->2748; 2748->2749; 2749->2750; }

Event Timeline

Enable zooming