DataHubScheduler - Details for Job 25166

Status: SUCCEEDED
Submitted: 2026/10/16 12:49:02
Duration: 14 ms
Completed Stages: 1

Enable zooming

digraph G { subgraph clusterstage_39757 { label="Stage 39757"; 170270 [labelType="html" label="JDBCRDD [170270] cache at <unknown>:0"]; subgraph cluster405790 { label="WholeStageCodegen (1)"; 170316 [labelType="html" label="MapPartitionsRDD [170316] javaToPython at <unknown>:0"]; } subgraph cluster405789 { label="AdaptiveSparkPlan"; 170317 [labelType="html" label="MapPartitionsRDD [170317] javaToPython at <unknown>:0"]; 170318 [labelType="html" label="*(1) Scan JDBCRelation((\nSELECT ms.supplier_id, ms.supplier_uid, ms.supplier_name, ms.country, ms.state, ms.city,\n ms.is_nominated,\n CONVERT(VARCHAR(10), ms.association_accepted_date, 23) AS master_first_created_date\nFROM vw_Master_Supplier ms\nWHERE ms.brand_context_id = '6aacf5861a41b434b2a90520' AND ms.supplier_status = 'Active'\n) AS t) [numPartitions=1] [supplier_id#20377295] PushedFilters: [], ReadSchema: struct<supplier_id:string>\n [170318] [Cached] javaToPython at <unknown>:0"]; } subgraph cluster405800 { label="InMemoryTableScan"; 170322 [labelType="html" label="MapPartitionsRDD [170322] $anonfun$withThreadLocalCaptured$1 at <unknown>:0"]; 170323 [labelType="html" label="MapPartitionsRDD [170323] $anonfun$withThreadLocalCaptured$1 at <unknown>:0"]; 170324 [labelType="html" label="MapPartitionsRDD [170324] $anonfun$withThreadLocalCaptured$1 at <unknown>:0"]; } subgraph cluster405795 { label="WholeStageCodegen (1)"; 170325 [labelType="html" label="MapPartitionsRDD [170325] $anonfun$withThreadLocalCaptured$1 at <unknown>:0"]; } subgraph cluster405794 { label="BroadcastExchange"; 170326 [labelType="html" label="MapPartitionsRDD [170326] $anonfun$withThreadLocalCaptured$1 at <unknown>:0"]; } } 170270->170316; 170316->170317; 170317->170318; 170318->170322; 170322->170323; 170323->170324; 170324->170325; 170325->170326; }

170318

Completed Stages (1)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Input	Output	Shuffle Read	Shuffle Write
39757	MemgraphDeclaredBatch-6aacf5861a41b434b2a90520_2	$anonfun$withThreadLocalCaptured$1 at <unknown>:0 +details org.apache.spark.sql.execution.SQLExecution$.$anonfun$withThreadLocalCaptured$1(SQLExecution.scala:219) java.base/java.util.concurrent.FutureTask.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source)	2026/10/16 12:49:02	12 ms	1/1	408.0 B

Stage Id ▾

Pool Name

Description

Submitted

Duration

Tasks: Succeeded/Total

Input

Output

Shuffle Read

Shuffle Write

39757

MemgraphDeclaredBatch-6aacf5861a41b434b2a90520_2

$anonfun$withThreadLocalCaptured$1 at <unknown>:0 +details

org.apache.spark.sql.execution.SQLExecution$.$anonfun$withThreadLocalCaptured$1(SQLExecution.scala:219)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)

2026/10/16 12:49:02

12 ms

1/1

408.0 B

Page: