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

digraph G { subgraph clusterstage_1615 { label="Stage 1615"; 16973 [labelType="html" label="SQLExecutionRDD [16973] run at <unknown>:0"]; 16981 [labelType="html" label="SQLExecutionRDD [16981] toJavaRDD at <unknown>:0"]; 16983 [labelType="html" label="PythonRDD [16983] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster37977 { label="MicroBatchScan"; 16969 [labelType="html" label="DataSourceRDD [16969] run at <unknown>:0"]; 16970 [labelType="html" label="MapPartitionsRDD [16970] run at <unknown>:0"]; } subgraph cluster37976 { label="Project"; 16971 [labelType="html" label="MapPartitionsRDD [16971] run at <unknown>:0"]; } subgraph cluster37972 { label="WholeStageCodegen (1)"; 16972 [labelType="html" label="MapPartitionsRDD [16972] run at <unknown>:0"]; } subgraph cluster37986 { label="WholeStageCodegen (1)"; 16974 [labelType="html" label="MapPartitionsRDD [16974] toJavaRDD at <unknown>:0"]; } subgraph cluster37985 { label="Filter"; 16975 [labelType="html" label="MapPartitionsRDD [16975] toJavaRDD at <unknown>:0"]; } subgraph cluster37984 { label="Project"; 16976 [labelType="html" label="MapPartitionsRDD [16976] toJavaRDD at <unknown>:0"]; } subgraph cluster37981 { label="WholeStageCodegen (2)"; 16977 [labelType="html" label="MapPartitionsRDD [16977] toJavaRDD at <unknown>:0"]; } subgraph cluster37980 { label="Project"; 16978 [labelType="html" label="MapPartitionsRDD [16978] toJavaRDD at <unknown>:0"]; } subgraph cluster37979 { label="DeserializeToObject"; 16979 [labelType="html" label="MapPartitionsRDD [16979] toJavaRDD at <unknown>:0"]; } subgraph cluster37978 { label="MapPartitions"; 16980 [labelType="html" label="MapPartitionsRDD [16980] toJavaRDD at <unknown>:0"]; } subgraph cluster37988 { label="mapPartitions"; 16982 [labelType="html" label="MapPartitionsRDD [16982] toJavaRDD at <unknown>:0"]; } } 16969->16970; 16970->16971; 16971->16972; 16972->16973; 16973->16974; 16974->16975; 16975->16976; 16976->16977; 16977->16978; 16978->16979; 16979->16980; 16980->16981; 16981->16982; 16982->16983; }

Event Timeline

Enable zooming