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

digraph G { subgraph clusterstage_1806 { label="Stage 1806"; 18967 [labelType="html" label="SQLExecutionRDD [18967] run at <unknown>:0"]; 18975 [labelType="html" label="SQLExecutionRDD [18975] toJavaRDD at <unknown>:0"]; 18977 [labelType="html" label="PythonRDD [18977] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster42446 { label="MicroBatchScan"; 18963 [labelType="html" label="DataSourceRDD [18963] run at <unknown>:0"]; 18964 [labelType="html" label="MapPartitionsRDD [18964] run at <unknown>:0"]; } subgraph cluster42445 { label="Project"; 18965 [labelType="html" label="MapPartitionsRDD [18965] run at <unknown>:0"]; } subgraph cluster42441 { label="WholeStageCodegen (1)"; 18966 [labelType="html" label="MapPartitionsRDD [18966] run at <unknown>:0"]; } subgraph cluster42455 { label="WholeStageCodegen (1)"; 18968 [labelType="html" label="MapPartitionsRDD [18968] toJavaRDD at <unknown>:0"]; } subgraph cluster42454 { label="Filter"; 18969 [labelType="html" label="MapPartitionsRDD [18969] toJavaRDD at <unknown>:0"]; } subgraph cluster42453 { label="Project"; 18970 [labelType="html" label="MapPartitionsRDD [18970] toJavaRDD at <unknown>:0"]; } subgraph cluster42450 { label="WholeStageCodegen (2)"; 18971 [labelType="html" label="MapPartitionsRDD [18971] toJavaRDD at <unknown>:0"]; } subgraph cluster42449 { label="Project"; 18972 [labelType="html" label="MapPartitionsRDD [18972] toJavaRDD at <unknown>:0"]; } subgraph cluster42448 { label="DeserializeToObject"; 18973 [labelType="html" label="MapPartitionsRDD [18973] toJavaRDD at <unknown>:0"]; } subgraph cluster42447 { label="MapPartitions"; 18974 [labelType="html" label="MapPartitionsRDD [18974] toJavaRDD at <unknown>:0"]; } subgraph cluster42457 { label="mapPartitions"; 18976 [labelType="html" label="MapPartitionsRDD [18976] toJavaRDD at <unknown>:0"]; } } 18963->18964; 18964->18965; 18965->18966; 18966->18967; 18967->18968; 18968->18969; 18969->18970; 18970->18971; 18971->18972; 18972->18973; 18973->18974; 18974->18975; 18975->18976; 18976->18977; }

Event Timeline

Enable zooming