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

digraph G { subgraph clusterstage_954 { label="Stage 954"; 10021 [labelType="html" label="SQLExecutionRDD [10021] run at <unknown>:0"]; 10029 [labelType="html" label="SQLExecutionRDD [10029] toJavaRDD at <unknown>:0"]; 10031 [labelType="html" label="PythonRDD [10031] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster22424 { label="MicroBatchScan"; 10017 [labelType="html" label="DataSourceRDD [10017] run at <unknown>:0"]; 10018 [labelType="html" label="MapPartitionsRDD [10018] run at <unknown>:0"]; } subgraph cluster22423 { label="Project"; 10019 [labelType="html" label="MapPartitionsRDD [10019] run at <unknown>:0"]; } subgraph cluster22419 { label="WholeStageCodegen (1)"; 10020 [labelType="html" label="MapPartitionsRDD [10020] run at <unknown>:0"]; } subgraph cluster22433 { label="WholeStageCodegen (1)"; 10022 [labelType="html" label="MapPartitionsRDD [10022] toJavaRDD at <unknown>:0"]; } subgraph cluster22432 { label="Filter"; 10023 [labelType="html" label="MapPartitionsRDD [10023] toJavaRDD at <unknown>:0"]; } subgraph cluster22431 { label="Project"; 10024 [labelType="html" label="MapPartitionsRDD [10024] toJavaRDD at <unknown>:0"]; } subgraph cluster22428 { label="WholeStageCodegen (2)"; 10025 [labelType="html" label="MapPartitionsRDD [10025] toJavaRDD at <unknown>:0"]; } subgraph cluster22427 { label="Project"; 10026 [labelType="html" label="MapPartitionsRDD [10026] toJavaRDD at <unknown>:0"]; } subgraph cluster22426 { label="DeserializeToObject"; 10027 [labelType="html" label="MapPartitionsRDD [10027] toJavaRDD at <unknown>:0"]; } subgraph cluster22425 { label="MapPartitions"; 10028 [labelType="html" label="MapPartitionsRDD [10028] toJavaRDD at <unknown>:0"]; } subgraph cluster22435 { label="mapPartitions"; 10030 [labelType="html" label="MapPartitionsRDD [10030] toJavaRDD at <unknown>:0"]; } } 10017->10018; 10018->10019; 10019->10020; 10020->10021; 10021->10022; 10022->10023; 10023->10024; 10024->10025; 10025->10026; 10026->10027; 10027->10028; 10028->10029; 10029->10030; 10030->10031; }

Event Timeline

Enable zooming