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

digraph G { subgraph clusterstage_1904 { label="Stage 1904"; 19996 [labelType="html" label="SQLExecutionRDD [19996] run at <unknown>:0"]; 20004 [labelType="html" label="SQLExecutionRDD [20004] toJavaRDD at <unknown>:0"]; 20006 [labelType="html" label="PythonRDD [20006] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster44749 { label="MicroBatchScan"; 19992 [labelType="html" label="DataSourceRDD [19992] run at <unknown>:0"]; 19993 [labelType="html" label="MapPartitionsRDD [19993] run at <unknown>:0"]; } subgraph cluster44748 { label="Project"; 19994 [labelType="html" label="MapPartitionsRDD [19994] run at <unknown>:0"]; } subgraph cluster44744 { label="WholeStageCodegen (1)"; 19995 [labelType="html" label="MapPartitionsRDD [19995] run at <unknown>:0"]; } subgraph cluster44758 { label="WholeStageCodegen (1)"; 19997 [labelType="html" label="MapPartitionsRDD [19997] toJavaRDD at <unknown>:0"]; } subgraph cluster44757 { label="Filter"; 19998 [labelType="html" label="MapPartitionsRDD [19998] toJavaRDD at <unknown>:0"]; } subgraph cluster44756 { label="Project"; 19999 [labelType="html" label="MapPartitionsRDD [19999] toJavaRDD at <unknown>:0"]; } subgraph cluster44753 { label="WholeStageCodegen (2)"; 20000 [labelType="html" label="MapPartitionsRDD [20000] toJavaRDD at <unknown>:0"]; } subgraph cluster44752 { label="Project"; 20001 [labelType="html" label="MapPartitionsRDD [20001] toJavaRDD at <unknown>:0"]; } subgraph cluster44751 { label="DeserializeToObject"; 20002 [labelType="html" label="MapPartitionsRDD [20002] toJavaRDD at <unknown>:0"]; } subgraph cluster44750 { label="MapPartitions"; 20003 [labelType="html" label="MapPartitionsRDD [20003] toJavaRDD at <unknown>:0"]; } subgraph cluster44760 { label="mapPartitions"; 20005 [labelType="html" label="MapPartitionsRDD [20005] toJavaRDD at <unknown>:0"]; } } 19992->19993; 19993->19994; 19994->19995; 19995->19996; 19996->19997; 19997->19998; 19998->19999; 19999->20000; 20000->20001; 20001->20002; 20002->20003; 20003->20004; 20004->20005; 20005->20006; }

Event Timeline

Enable zooming