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

digraph G { subgraph clusterstage_1684 { label="Stage 1684"; 17693 [labelType="html" label="SQLExecutionRDD [17693] run at <unknown>:0"]; 17701 [labelType="html" label="SQLExecutionRDD [17701] toJavaRDD at <unknown>:0"]; 17703 [labelType="html" label="PythonRDD [17703] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster39583 { label="MicroBatchScan"; 17689 [labelType="html" label="DataSourceRDD [17689] run at <unknown>:0"]; 17690 [labelType="html" label="MapPartitionsRDD [17690] run at <unknown>:0"]; } subgraph cluster39582 { label="Project"; 17691 [labelType="html" label="MapPartitionsRDD [17691] run at <unknown>:0"]; } subgraph cluster39576 { label="WholeStageCodegen (1)"; 17692 [labelType="html" label="MapPartitionsRDD [17692] run at <unknown>:0"]; } subgraph cluster39592 { label="WholeStageCodegen (1)"; 17694 [labelType="html" label="MapPartitionsRDD [17694] toJavaRDD at <unknown>:0"]; } subgraph cluster39591 { label="Filter"; 17695 [labelType="html" label="MapPartitionsRDD [17695] toJavaRDD at <unknown>:0"]; } subgraph cluster39590 { label="Project"; 17696 [labelType="html" label="MapPartitionsRDD [17696] toJavaRDD at <unknown>:0"]; } subgraph cluster39587 { label="WholeStageCodegen (2)"; 17697 [labelType="html" label="MapPartitionsRDD [17697] toJavaRDD at <unknown>:0"]; } subgraph cluster39586 { label="Project"; 17698 [labelType="html" label="MapPartitionsRDD [17698] toJavaRDD at <unknown>:0"]; } subgraph cluster39585 { label="DeserializeToObject"; 17699 [labelType="html" label="MapPartitionsRDD [17699] toJavaRDD at <unknown>:0"]; } subgraph cluster39584 { label="MapPartitions"; 17700 [labelType="html" label="MapPartitionsRDD [17700] toJavaRDD at <unknown>:0"]; } subgraph cluster39594 { label="mapPartitions"; 17702 [labelType="html" label="MapPartitionsRDD [17702] toJavaRDD at <unknown>:0"]; } } 17689->17690; 17690->17691; 17691->17692; 17692->17693; 17693->17694; 17694->17695; 17695->17696; 17696->17697; 17697->17698; 17698->17699; 17699->17700; 17700->17701; 17701->17702; 17702->17703; }

Event Timeline

Enable zooming