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

digraph G { subgraph clusterstage_1112 { label="Stage 1112"; 11681 [labelType="html" label="SQLExecutionRDD [11681] run at <unknown>:0"]; 11695 [labelType="html" label="SQLExecutionRDD [11695] toJavaRDD at <unknown>:0"]; 11697 [labelType="html" label="PythonRDD [11697] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster26133 { label="MicroBatchScan"; 11677 [labelType="html" label="DataSourceRDD [11677] run at <unknown>:0"]; 11678 [labelType="html" label="MapPartitionsRDD [11678] run at <unknown>:0"]; } subgraph cluster26132 { label="Project"; 11679 [labelType="html" label="MapPartitionsRDD [11679] run at <unknown>:0"]; } subgraph cluster26128 { label="WholeStageCodegen (1)"; 11680 [labelType="html" label="MapPartitionsRDD [11680] run at <unknown>:0"]; } subgraph cluster26150 { label="WholeStageCodegen (1)"; 11688 [labelType="html" label="MapPartitionsRDD [11688] toJavaRDD at <unknown>:0"]; } subgraph cluster26149 { label="Filter"; 11689 [labelType="html" label="MapPartitionsRDD [11689] toJavaRDD at <unknown>:0"]; } subgraph cluster26148 { label="Project"; 11690 [labelType="html" label="MapPartitionsRDD [11690] toJavaRDD at <unknown>:0"]; } subgraph cluster26145 { label="WholeStageCodegen (2)"; 11691 [labelType="html" label="MapPartitionsRDD [11691] toJavaRDD at <unknown>:0"]; } subgraph cluster26144 { label="Project"; 11692 [labelType="html" label="MapPartitionsRDD [11692] toJavaRDD at <unknown>:0"]; } subgraph cluster26143 { label="DeserializeToObject"; 11693 [labelType="html" label="MapPartitionsRDD [11693] toJavaRDD at <unknown>:0"]; } subgraph cluster26142 { label="MapPartitions"; 11694 [labelType="html" label="MapPartitionsRDD [11694] toJavaRDD at <unknown>:0"]; } subgraph cluster26152 { label="mapPartitions"; 11696 [labelType="html" label="MapPartitionsRDD [11696] toJavaRDD at <unknown>:0"]; } } 11677->11678; 11678->11679; 11679->11680; 11680->11681; 11681->11688; 11688->11689; 11689->11690; 11690->11691; 11691->11692; 11692->11693; 11693->11694; 11694->11695; 11695->11696; 11696->11697; }

Event Timeline

Enable zooming