processing-stream-kafka-raw-to-minio - Details for Stage 1673 (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 / 458
Associated Job Ids: 1674

digraph G { subgraph clusterstage_1673 { label="Stage 1673"; 17582 [labelType="html" label="SQLExecutionRDD [17582] run at <unknown>:0"]; 17590 [labelType="html" label="SQLExecutionRDD [17590] toJavaRDD at <unknown>:0"]; 17592 [labelType="html" label="PythonRDD [17592] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster39340 { label="MicroBatchScan"; 17578 [labelType="html" label="DataSourceRDD [17578] run at <unknown>:0"]; 17579 [labelType="html" label="MapPartitionsRDD [17579] run at <unknown>:0"]; } subgraph cluster39339 { label="Project"; 17580 [labelType="html" label="MapPartitionsRDD [17580] run at <unknown>:0"]; } subgraph cluster39335 { label="WholeStageCodegen (1)"; 17581 [labelType="html" label="MapPartitionsRDD [17581] run at <unknown>:0"]; } subgraph cluster39349 { label="WholeStageCodegen (1)"; 17583 [labelType="html" label="MapPartitionsRDD [17583] toJavaRDD at <unknown>:0"]; } subgraph cluster39348 { label="Filter"; 17584 [labelType="html" label="MapPartitionsRDD [17584] toJavaRDD at <unknown>:0"]; } subgraph cluster39347 { label="Project"; 17585 [labelType="html" label="MapPartitionsRDD [17585] toJavaRDD at <unknown>:0"]; } subgraph cluster39344 { label="WholeStageCodegen (2)"; 17586 [labelType="html" label="MapPartitionsRDD [17586] toJavaRDD at <unknown>:0"]; } subgraph cluster39343 { label="Project"; 17587 [labelType="html" label="MapPartitionsRDD [17587] toJavaRDD at <unknown>:0"]; } subgraph cluster39342 { label="DeserializeToObject"; 17588 [labelType="html" label="MapPartitionsRDD [17588] toJavaRDD at <unknown>:0"]; } subgraph cluster39341 { label="MapPartitions"; 17589 [labelType="html" label="MapPartitionsRDD [17589] toJavaRDD at <unknown>:0"]; } subgraph cluster39351 { label="mapPartitions"; 17591 [labelType="html" label="MapPartitionsRDD [17591] toJavaRDD at <unknown>:0"]; } } 17578->17579; 17579->17580; 17580->17581; 17581->17582; 17582->17583; 17583->17584; 17584->17585; 17585->17586; 17586->17587; 17587->17588; 17588->17589; 17589->17590; 17590->17591; 17591->17592; }

Event Timeline

Enable zooming