DataHubScheduler - Details for Job 24280

Status: SUCCEEDED
Submitted: 2026/10/18 10:50:21
Duration: 89 ms
Completed Stages: 1

Enable zooming

digraph G { subgraph clusterstage_34026 { label="Stage 34026"; 149621 [labelType="html" label="JDBCRDD [149621] cache at <unknown>:0"]; subgraph cluster361646 { label="WholeStageCodegen (1)"; 149703 [labelType="html" label="MapPartitionsRDD [149703] javaToPython at <unknown>:0"]; } subgraph cluster361645 { label="AdaptiveSparkPlan"; 149704 [labelType="html" label="MapPartitionsRDD [149704] javaToPython at <unknown>:0"]; 149705 [labelType="html" label="*(1) Scan JDBCRelation((\nSELECT\n mf.entity_id AS facility_id, mf.facility_uid, mf.facility_name,\n ms.supplier_id AS owner_supplier_id,\n mf.country, mf.state, mf.city, mf.value_process, mf.materials,\n CONVERT(VARCHAR(10), mf.facility_create_date, 23) AS master_first_created_date\nFROM vw_Master_Facility mf\nLEFT JOIN vw_Master_Supplier ms\n ON ms.supplier_uid = mf.supplier_uid\n AND ms.brand_context_id = mf.brand_context_id\n AND ms.supplier_status = 'Active'\nWHERE mf.brand_context_id = '6ad063ee7c692062b1d40711' AND mf.FACILITY_STATUS = 'Active'\n) AS t) [numPartitions=1] [facility_id#14299789] PushedFilters: [], ReadSchema: struct<facility_id:string>\n [149705] [Cached] javaToPython at <unknown>:0"]; } subgraph cluster361656 { label="InMemoryTableScan"; 149709 [labelType="html" label="MapPartitionsRDD [149709] $anonfun$withThreadLocalCaptured$1 at <unknown>:0"]; 149710 [labelType="html" label="MapPartitionsRDD [149710] $anonfun$withThreadLocalCaptured$1 at <unknown>:0"]; 149711 [labelType="html" label="MapPartitionsRDD [149711] $anonfun$withThreadLocalCaptured$1 at <unknown>:0"]; } subgraph cluster361651 { label="WholeStageCodegen (1)"; 149712 [labelType="html" label="MapPartitionsRDD [149712] $anonfun$withThreadLocalCaptured$1 at <unknown>:0"]; } subgraph cluster361650 { label="BroadcastExchange"; 149713 [labelType="html" label="MapPartitionsRDD [149713] $anonfun$withThreadLocalCaptured$1 at <unknown>:0"]; } } 149621->149703; 149703->149704; 149704->149705; 149705->149709; 149709->149710; 149710->149711; 149711->149712; 149712->149713; }

149705

Completed Stages (1)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Input	Output	Shuffle Read	Shuffle Write
34026	MemgraphDeclaredBatch-6ad063ee7c692062b1d40711_0	$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/18 10:50:21	14 ms	1/1	1360.0 B

Stage Id ▾

Pool Name

Description

Submitted

Duration

Tasks: Succeeded/Total

Input

Output

Shuffle Read

Shuffle Write

34026

MemgraphDeclaredBatch-6ad063ee7c692062b1d40711_0

$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/18 10:50:21

14 ms

1/1

1360.0 B

Page: