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

digraph G { subgraph clusterstage_1233 { label="Stage 1233"; 12962 [labelType="html" label="SQLExecutionRDD [12962] run at <unknown>:0"]; 12970 [labelType="html" label="SQLExecutionRDD [12970] toJavaRDD at <unknown>:0"]; 12972 [labelType="html" label="PythonRDD [12972] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster29000 { label="MicroBatchScan"; 12958 [labelType="html" label="DataSourceRDD [12958] run at <unknown>:0"]; 12959 [labelType="html" label="MapPartitionsRDD [12959] run at <unknown>:0"]; } subgraph cluster28999 { label="Project"; 12960 [labelType="html" label="MapPartitionsRDD [12960] run at <unknown>:0"]; } subgraph cluster28995 { label="WholeStageCodegen (1)"; 12961 [labelType="html" label="MapPartitionsRDD [12961] run at <unknown>:0"]; } subgraph cluster29009 { label="WholeStageCodegen (1)"; 12963 [labelType="html" label="MapPartitionsRDD [12963] toJavaRDD at <unknown>:0"]; } subgraph cluster29008 { label="Filter"; 12964 [labelType="html" label="MapPartitionsRDD [12964] toJavaRDD at <unknown>:0"]; } subgraph cluster29007 { label="Project"; 12965 [labelType="html" label="MapPartitionsRDD [12965] toJavaRDD at <unknown>:0"]; } subgraph cluster29004 { label="WholeStageCodegen (2)"; 12966 [labelType="html" label="MapPartitionsRDD [12966] toJavaRDD at <unknown>:0"]; } subgraph cluster29003 { label="Project"; 12967 [labelType="html" label="MapPartitionsRDD [12967] toJavaRDD at <unknown>:0"]; } subgraph cluster29002 { label="DeserializeToObject"; 12968 [labelType="html" label="MapPartitionsRDD [12968] toJavaRDD at <unknown>:0"]; } subgraph cluster29001 { label="MapPartitions"; 12969 [labelType="html" label="MapPartitionsRDD [12969] toJavaRDD at <unknown>:0"]; } subgraph cluster29011 { label="mapPartitions"; 12971 [labelType="html" label="MapPartitionsRDD [12971] toJavaRDD at <unknown>:0"]; } } 12958->12959; 12959->12960; 12960->12961; 12961->12962; 12962->12963; 12963->12964; 12964->12965; 12965->12966; 12966->12967; 12967->12968; 12968->12969; 12969->12970; 12970->12971; 12971->12972; }

Event Timeline

Enable zooming