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

digraph G { subgraph clusterstage_1663 { label="Stage 1663"; 17477 [labelType="html" label="SQLExecutionRDD [17477] run at <unknown>:0"]; 17485 [labelType="html" label="SQLExecutionRDD [17485] toJavaRDD at <unknown>:0"]; 17487 [labelType="html" label="PythonRDD [17487] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster39105 { label="MicroBatchScan"; 17473 [labelType="html" label="DataSourceRDD [17473] run at <unknown>:0"]; 17474 [labelType="html" label="MapPartitionsRDD [17474] run at <unknown>:0"]; } subgraph cluster39104 { label="Project"; 17475 [labelType="html" label="MapPartitionsRDD [17475] run at <unknown>:0"]; } subgraph cluster39100 { label="WholeStageCodegen (1)"; 17476 [labelType="html" label="MapPartitionsRDD [17476] run at <unknown>:0"]; } subgraph cluster39114 { label="WholeStageCodegen (1)"; 17478 [labelType="html" label="MapPartitionsRDD [17478] toJavaRDD at <unknown>:0"]; } subgraph cluster39113 { label="Filter"; 17479 [labelType="html" label="MapPartitionsRDD [17479] toJavaRDD at <unknown>:0"]; } subgraph cluster39112 { label="Project"; 17480 [labelType="html" label="MapPartitionsRDD [17480] toJavaRDD at <unknown>:0"]; } subgraph cluster39109 { label="WholeStageCodegen (2)"; 17481 [labelType="html" label="MapPartitionsRDD [17481] toJavaRDD at <unknown>:0"]; } subgraph cluster39108 { label="Project"; 17482 [labelType="html" label="MapPartitionsRDD [17482] toJavaRDD at <unknown>:0"]; } subgraph cluster39107 { label="DeserializeToObject"; 17483 [labelType="html" label="MapPartitionsRDD [17483] toJavaRDD at <unknown>:0"]; } subgraph cluster39106 { label="MapPartitions"; 17484 [labelType="html" label="MapPartitionsRDD [17484] toJavaRDD at <unknown>:0"]; } subgraph cluster39116 { label="mapPartitions"; 17486 [labelType="html" label="MapPartitionsRDD [17486] toJavaRDD at <unknown>:0"]; } } 17473->17474; 17474->17475; 17475->17476; 17476->17477; 17477->17478; 17478->17479; 17479->17480; 17480->17481; 17481->17482; 17482->17483; 17483->17484; 17484->17485; 17485->17486; 17486->17487; }

Event Timeline

Enable zooming