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

digraph G { subgraph clusterstage_1097 { label="Stage 1097"; 11534 [labelType="html" label="SQLExecutionRDD [11534] run at <unknown>:0"]; 11542 [labelType="html" label="SQLExecutionRDD [11542] toJavaRDD at <unknown>:0"]; 11544 [labelType="html" label="PythonRDD [11544] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster25804 { label="MicroBatchScan"; 11530 [labelType="html" label="DataSourceRDD [11530] run at <unknown>:0"]; 11531 [labelType="html" label="MapPartitionsRDD [11531] run at <unknown>:0"]; } subgraph cluster25803 { label="Project"; 11532 [labelType="html" label="MapPartitionsRDD [11532] run at <unknown>:0"]; } subgraph cluster25799 { label="WholeStageCodegen (1)"; 11533 [labelType="html" label="MapPartitionsRDD [11533] run at <unknown>:0"]; } subgraph cluster25813 { label="WholeStageCodegen (1)"; 11535 [labelType="html" label="MapPartitionsRDD [11535] toJavaRDD at <unknown>:0"]; } subgraph cluster25812 { label="Filter"; 11536 [labelType="html" label="MapPartitionsRDD [11536] toJavaRDD at <unknown>:0"]; } subgraph cluster25811 { label="Project"; 11537 [labelType="html" label="MapPartitionsRDD [11537] toJavaRDD at <unknown>:0"]; } subgraph cluster25808 { label="WholeStageCodegen (2)"; 11538 [labelType="html" label="MapPartitionsRDD [11538] toJavaRDD at <unknown>:0"]; } subgraph cluster25807 { label="Project"; 11539 [labelType="html" label="MapPartitionsRDD [11539] toJavaRDD at <unknown>:0"]; } subgraph cluster25806 { label="DeserializeToObject"; 11540 [labelType="html" label="MapPartitionsRDD [11540] toJavaRDD at <unknown>:0"]; } subgraph cluster25805 { label="MapPartitions"; 11541 [labelType="html" label="MapPartitionsRDD [11541] toJavaRDD at <unknown>:0"]; } subgraph cluster25815 { label="mapPartitions"; 11543 [labelType="html" label="MapPartitionsRDD [11543] toJavaRDD at <unknown>:0"]; } } 11530->11531; 11531->11532; 11532->11533; 11533->11534; 11534->11535; 11535->11536; 11536->11537; 11537->11538; 11538->11539; 11539->11540; 11540->11541; 11541->11542; 11542->11543; 11543->11544; }

Event Timeline

Enable zooming