processing-stream-kafka-raw-to-minio - Details for Stage 1003 (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 / 561
Associated Job Ids: 1004

digraph G { subgraph clusterstage_1003 { label="Stage 1003"; 10547 [labelType="html" label="SQLExecutionRDD [10547] run at <unknown>:0"]; 10555 [labelType="html" label="SQLExecutionRDD [10555] toJavaRDD at <unknown>:0"]; 10557 [labelType="html" label="PythonRDD [10557] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster23595 { label="MicroBatchScan"; 10543 [labelType="html" label="DataSourceRDD [10543] run at <unknown>:0"]; 10544 [labelType="html" label="MapPartitionsRDD [10544] run at <unknown>:0"]; } subgraph cluster23594 { label="Project"; 10545 [labelType="html" label="MapPartitionsRDD [10545] run at <unknown>:0"]; } subgraph cluster23590 { label="WholeStageCodegen (1)"; 10546 [labelType="html" label="MapPartitionsRDD [10546] run at <unknown>:0"]; } subgraph cluster23604 { label="WholeStageCodegen (1)"; 10548 [labelType="html" label="MapPartitionsRDD [10548] toJavaRDD at <unknown>:0"]; } subgraph cluster23603 { label="Filter"; 10549 [labelType="html" label="MapPartitionsRDD [10549] toJavaRDD at <unknown>:0"]; } subgraph cluster23602 { label="Project"; 10550 [labelType="html" label="MapPartitionsRDD [10550] toJavaRDD at <unknown>:0"]; } subgraph cluster23599 { label="WholeStageCodegen (2)"; 10551 [labelType="html" label="MapPartitionsRDD [10551] toJavaRDD at <unknown>:0"]; } subgraph cluster23598 { label="Project"; 10552 [labelType="html" label="MapPartitionsRDD [10552] toJavaRDD at <unknown>:0"]; } subgraph cluster23597 { label="DeserializeToObject"; 10553 [labelType="html" label="MapPartitionsRDD [10553] toJavaRDD at <unknown>:0"]; } subgraph cluster23596 { label="MapPartitions"; 10554 [labelType="html" label="MapPartitionsRDD [10554] toJavaRDD at <unknown>:0"]; } subgraph cluster23606 { label="mapPartitions"; 10556 [labelType="html" label="MapPartitionsRDD [10556] toJavaRDD at <unknown>:0"]; } } 10543->10544; 10544->10545; 10545->10546; 10546->10547; 10547->10548; 10548->10549; 10549->10550; 10550->10551; 10551->10552; 10552->10553; 10553->10554; 10554->10555; 10555->10556; 10556->10557; }

Event Timeline

Enable zooming