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

digraph G { subgraph clusterstage_1657 { label="Stage 1657"; 17414 [labelType="html" label="SQLExecutionRDD [17414] run at <unknown>:0"]; 17422 [labelType="html" label="SQLExecutionRDD [17422] toJavaRDD at <unknown>:0"]; 17424 [labelType="html" label="PythonRDD [17424] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster38964 { label="MicroBatchScan"; 17410 [labelType="html" label="DataSourceRDD [17410] run at <unknown>:0"]; 17411 [labelType="html" label="MapPartitionsRDD [17411] run at <unknown>:0"]; } subgraph cluster38963 { label="Project"; 17412 [labelType="html" label="MapPartitionsRDD [17412] run at <unknown>:0"]; } subgraph cluster38959 { label="WholeStageCodegen (1)"; 17413 [labelType="html" label="MapPartitionsRDD [17413] run at <unknown>:0"]; } subgraph cluster38973 { label="WholeStageCodegen (1)"; 17415 [labelType="html" label="MapPartitionsRDD [17415] toJavaRDD at <unknown>:0"]; } subgraph cluster38972 { label="Filter"; 17416 [labelType="html" label="MapPartitionsRDD [17416] toJavaRDD at <unknown>:0"]; } subgraph cluster38971 { label="Project"; 17417 [labelType="html" label="MapPartitionsRDD [17417] toJavaRDD at <unknown>:0"]; } subgraph cluster38968 { label="WholeStageCodegen (2)"; 17418 [labelType="html" label="MapPartitionsRDD [17418] toJavaRDD at <unknown>:0"]; } subgraph cluster38967 { label="Project"; 17419 [labelType="html" label="MapPartitionsRDD [17419] toJavaRDD at <unknown>:0"]; } subgraph cluster38966 { label="DeserializeToObject"; 17420 [labelType="html" label="MapPartitionsRDD [17420] toJavaRDD at <unknown>:0"]; } subgraph cluster38965 { label="MapPartitions"; 17421 [labelType="html" label="MapPartitionsRDD [17421] toJavaRDD at <unknown>:0"]; } subgraph cluster38975 { label="mapPartitions"; 17423 [labelType="html" label="MapPartitionsRDD [17423] toJavaRDD at <unknown>:0"]; } } 17410->17411; 17411->17412; 17412->17413; 17413->17414; 17414->17415; 17415->17416; 17416->17417; 17417->17418; 17418->17419; 17419->17420; 17420->17421; 17421->17422; 17422->17423; 17423->17424; }

Event Timeline

Enable zooming