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

digraph G { subgraph clusterstage_1054 { label="Stage 1054"; 11072 [labelType="html" label="SQLExecutionRDD [11072] run at <unknown>:0"]; 11086 [labelType="html" label="SQLExecutionRDD [11086] toJavaRDD at <unknown>:0"]; 11088 [labelType="html" label="PythonRDD [11088] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster24770 { label="MicroBatchScan"; 11068 [labelType="html" label="DataSourceRDD [11068] run at <unknown>:0"]; 11069 [labelType="html" label="MapPartitionsRDD [11069] run at <unknown>:0"]; } subgraph cluster24769 { label="Project"; 11070 [labelType="html" label="MapPartitionsRDD [11070] run at <unknown>:0"]; } subgraph cluster24765 { label="WholeStageCodegen (1)"; 11071 [labelType="html" label="MapPartitionsRDD [11071] run at <unknown>:0"]; } subgraph cluster24787 { label="WholeStageCodegen (1)"; 11079 [labelType="html" label="MapPartitionsRDD [11079] toJavaRDD at <unknown>:0"]; } subgraph cluster24786 { label="Filter"; 11080 [labelType="html" label="MapPartitionsRDD [11080] toJavaRDD at <unknown>:0"]; } subgraph cluster24785 { label="Project"; 11081 [labelType="html" label="MapPartitionsRDD [11081] toJavaRDD at <unknown>:0"]; } subgraph cluster24782 { label="WholeStageCodegen (2)"; 11082 [labelType="html" label="MapPartitionsRDD [11082] toJavaRDD at <unknown>:0"]; } subgraph cluster24781 { label="Project"; 11083 [labelType="html" label="MapPartitionsRDD [11083] toJavaRDD at <unknown>:0"]; } subgraph cluster24780 { label="DeserializeToObject"; 11084 [labelType="html" label="MapPartitionsRDD [11084] toJavaRDD at <unknown>:0"]; } subgraph cluster24779 { label="MapPartitions"; 11085 [labelType="html" label="MapPartitionsRDD [11085] toJavaRDD at <unknown>:0"]; } subgraph cluster24789 { label="mapPartitions"; 11087 [labelType="html" label="MapPartitionsRDD [11087] toJavaRDD at <unknown>:0"]; } } 11068->11069; 11069->11070; 11070->11071; 11071->11072; 11072->11079; 11079->11080; 11080->11081; 11081->11082; 11082->11083; 11083->11084; 11084->11085; 11085->11086; 11086->11087; 11087->11088; }

Event Timeline

Enable zooming