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

digraph G { subgraph clusterstage_1902 { label="Stage 1902"; 19975 [labelType="html" label="SQLExecutionRDD [19975] run at <unknown>:0"]; 19983 [labelType="html" label="SQLExecutionRDD [19983] toJavaRDD at <unknown>:0"]; 19985 [labelType="html" label="PythonRDD [19985] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster44702 { label="MicroBatchScan"; 19971 [labelType="html" label="DataSourceRDD [19971] run at <unknown>:0"]; 19972 [labelType="html" label="MapPartitionsRDD [19972] run at <unknown>:0"]; } subgraph cluster44701 { label="Project"; 19973 [labelType="html" label="MapPartitionsRDD [19973] run at <unknown>:0"]; } subgraph cluster44697 { label="WholeStageCodegen (1)"; 19974 [labelType="html" label="MapPartitionsRDD [19974] run at <unknown>:0"]; } subgraph cluster44711 { label="WholeStageCodegen (1)"; 19976 [labelType="html" label="MapPartitionsRDD [19976] toJavaRDD at <unknown>:0"]; } subgraph cluster44710 { label="Filter"; 19977 [labelType="html" label="MapPartitionsRDD [19977] toJavaRDD at <unknown>:0"]; } subgraph cluster44709 { label="Project"; 19978 [labelType="html" label="MapPartitionsRDD [19978] toJavaRDD at <unknown>:0"]; } subgraph cluster44706 { label="WholeStageCodegen (2)"; 19979 [labelType="html" label="MapPartitionsRDD [19979] toJavaRDD at <unknown>:0"]; } subgraph cluster44705 { label="Project"; 19980 [labelType="html" label="MapPartitionsRDD [19980] toJavaRDD at <unknown>:0"]; } subgraph cluster44704 { label="DeserializeToObject"; 19981 [labelType="html" label="MapPartitionsRDD [19981] toJavaRDD at <unknown>:0"]; } subgraph cluster44703 { label="MapPartitions"; 19982 [labelType="html" label="MapPartitionsRDD [19982] toJavaRDD at <unknown>:0"]; } subgraph cluster44713 { label="mapPartitions"; 19984 [labelType="html" label="MapPartitionsRDD [19984] toJavaRDD at <unknown>:0"]; } } 19971->19972; 19972->19973; 19973->19974; 19974->19975; 19975->19976; 19976->19977; 19977->19978; 19978->19979; 19979->19980; 19980->19981; 19981->19982; 19982->19983; 19983->19984; 19984->19985; }

Event Timeline

Enable zooming