Spark Jobs (?)

Event Timeline

Active Jobs (7)

Page:
Job Id ▾ Description Submitted Duration Stages: Succeeded/Total Tasks (for all stages): Succeeded/Total
14277 foreachPartition at /opt/app/scheduler/jobs/memgraph_loader_job.py:2107 (kill) foreachPartition at /opt/app/scheduler/jobs/memgraph_loader_job.py:2107 2026/10/16 08:58:27 0.3 s 0/2
0/6
14273 javaToPython at <unknown>:0 (kill) javaToPython at <unknown>:0 2026/10/16 08:58:26 1 s 0/2
1/6
14260 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 (kill) $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 08:58:10 18 s 0/1
0/1
14259 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 (kill) $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 08:58:10 18 s 0/1
0/1
14258 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 (kill) $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 08:58:10 18 s 0/2
1/6 (1 running)
14032 collect at PythonRDD.scala:195 (kill) collect at PythonRDD.scala:195 2026/10/16 08:55:45 2.7 min 0/2
0/6
14031 collect at PythonRDD.scala:195 (kill) collect at PythonRDD.scala:195 2026/10/16 08:55:45 2.7 min 0/2
4/6
Page:

Completed Jobs (14271, only showing 971)

Job Id Description Submitted Duration ▾ Stages: Succeeded/Total Tasks (for all stages): Succeeded/Total
11879 collect at PythonRDD.scala:195 collect at PythonRDD.scala:195 2026/10/16 08:35:51 16 min 1/1 (1 skipped)
5/5 (1 skipped)
12605 count at <unknown>:0 count at <unknown>:0 2026/10/16 08:43:36 8.4 min 1/1
1/1
13065 javaToPython at <unknown>:0 javaToPython at <unknown>:0 2026/10/16 08:48:40 2.8 min 1/1 (1 skipped)
5/5 (1 skipped)
13066 collect at PythonRDD.scala:195 collect at PythonRDD.scala:195 2026/10/16 08:48:40 2.6 min 1/1
1/1
13217 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 08:48:54 1.7 min 1/2
5/6
13218 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 08:48:54 1.7 min 1/2 (1 skipped)
1/2 (5 skipped)
13216 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 08:48:53 1.6 min 1/2
5/6
13215 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 08:48:53 1.6 min 1/2
5/6
13214 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 08:48:53 1.5 min 1/2
5/6
13230 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 08:49:05 1.5 min 1/1
1/1
13514 count at <unknown>:0 count at <unknown>:0 2026/10/16 08:52:01 1.5 min 1/1
1/1
13508 foreachPartition at /opt/app/scheduler/jobs/memgraph_loader_job.py:2107 foreachPartition at /opt/app/scheduler/jobs/memgraph_loader_job.py:2107 2026/10/16 08:52:01 1.5 min 1/1 (1 skipped)
5/5 (1 skipped)
13213 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 08:48:53 1.4 min 1/2
5/6
13212 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 08:48:53 1.3 min 1/2
5/6
13515 javaToPython at <unknown>:0 javaToPython at <unknown>:0 2026/10/16 08:52:01 1.3 min 1/1 (1 skipped)
5/5 (1 skipped)
13243 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 08:49:20 1.3 min 1/1
1/1
13211 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 08:48:53 1.2 min 1/2
5/6
13270 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 08:49:35 1.0 min 1/1
1/1
13273 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 08:49:38 58 s 1/1
1/1
14030 collect at PythonRDD.scala:195 collect at PythonRDD.scala:195 2026/10/16 08:55:44 55 s 1/1 (1 skipped)
5/5 (1 skipped)
13279 javaToPython at <unknown>:0 javaToPython at <unknown>:0 2026/10/16 08:49:43 54 s 1/1 (2 skipped)
1/1 (6 skipped)
13650 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 08:52:08 41 s 1/2
5/6
13651 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 08:52:08 41 s 1/2 (1 skipped)
1/2 (5 skipped)
13648 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 08:52:08 39 s 1/2
5/6
13649 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 08:52:08 39 s 1/2 (1 skipped)
1/2 (5 skipped)
13647 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 08:52:08 38 s 1/2
5/6
13645 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 08:52:08 36 s 1/2
5/6
13646 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 08:52:08 36 s 1/2 (1 skipped)
1/2 (5 skipped)
13644 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 08:52:08 34 s 1/2
5/6
13652 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 08:52:15 34 s 1/1
1/1
13643 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 08:52:08 33 s 1/2
5/6
13642 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 08:52:08 31 s 1/2
5/6
13322 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 08:50:06 30 s 1/1
1/1
13640 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 08:52:07 30 s 1/2
5/6
13641 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 08:52:07 30 s 1/2 (1 skipped)
1/2 (5 skipped)
13639 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 08:52:07 28 s 1/2
5/6
14105 collect at PythonRDD.scala:195 collect at PythonRDD.scala:195 2026/10/16 08:56:40 27 s 1/1 (1 skipped)
5/5 (1 skipped)
13653 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 08:52:23 27 s 1/1
1/1
13638 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 08:52:07 26 s 1/2
5/6
13654 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 08:52:24 25 s 1/1
1/1
14184 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 08:57:19 25 s 1/1
1/1
14183 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 08:57:19 25 s 1/1
1/1
13637 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 08:52:07 24 s 1/1 (1 skipped)
5/5 (1 skipped)
13636 javaToPython at <unknown>:0 javaToPython at <unknown>:0 2026/10/16 08:52:07 23 s 1/2
5/6
13328 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 08:50:14 23 s 1/1
1/1
13655 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 08:52:28 21 s 1/1
1/1
13635 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 08:52:07 21 s 1/2
5/6
14189 javaToPython at <unknown>:0 javaToPython at <unknown>:0 2026/10/16 08:57:24 20 s 1/6
32/84
13634 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 08:52:06 20 s 1/2
5/6
13656 javaToPython at <unknown>:0 javaToPython at <unknown>:0 2026/10/16 08:52:30 20 s 1/2 (1 skipped)
1/2 (5 skipped)
13375 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 08:50:37 19 s 1/1 (1 skipped)
10/10 (1 skipped)
13633 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 08:52:06 18 s 1/2
5/6
13420 javaToPython at <unknown>:0 javaToPython at <unknown>:0 2026/10/16 08:50:57 18 s 1/2
12/13
13419 javaToPython at <unknown>:0 javaToPython at <unknown>:0 2026/10/16 08:50:54 18 s 1/2
18/19
13710 count at <unknown>:0 count at <unknown>:0 2026/10/16 08:53:32 17 s 1/1
1/1
14029 collect at PythonRDD.scala:195 collect at PythonRDD.scala:195 2026/10/16 08:55:44 17 s 1/1 (1 skipped)
5/5 (1 skipped)
13374 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 08:50:36 17 s 1/1 (1 skipped)
10/10 (1 skipped)
13632 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 08:52:06 17 s 1/2
5/6
13418 javaToPython at <unknown>:0 javaToPython at <unknown>:0 2026/10/16 08:50:51 16 s 1/1 (1 skipped)
30/30 (1 skipped)
13667 javaToPython at <unknown>:0 javaToPython at <unknown>:0 2026/10/16 08:53:03 16 s 1/2
12/13
13666 javaToPython at <unknown>:0 javaToPython at <unknown>:0 2026/10/16 08:53:00 15 s 1/2
18/19
14210 javaToPython at <unknown>:0 javaToPython at <unknown>:0 2026/10/16 08:57:44 15 s 1/1 (1 skipped)
5/5 (1 skipped)
13371 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 08:50:36 15 s 1/2
10/11
13631 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 08:52:06 15 s 1/2
5/6
14256 javaToPython at <unknown>:0 javaToPython at <unknown>:0 2026/10/16 08:58:09 14 s 1/1 (1 skipped)
5/5 (1 skipped)
13487 foreachPartition at /opt/app/scheduler/jobs/memgraph_loader_job.py:2107 foreachPartition at /opt/app/scheduler/jobs/memgraph_loader_job.py:2107 2026/10/16 08:51:46 14 s 1/1 (1 skipped)
5/5 (1 skipped)
13630 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 08:52:05 13 s 1/2
5/6
13665 javaToPython at <unknown>:0 javaToPython at <unknown>:0 2026/10/16 08:52:57 13 s 1/1 (1 skipped)
30/30 (1 skipped)
13657 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 08:52:37 13 s 1/1
1/1
14106 javaToPython at <unknown>:0 javaToPython at <unknown>:0 2026/10/16 08:56:40 13 s 1/1 (1 skipped)
10/10 (1 skipped)
13658 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 08:52:39 12 s 1/1
1/1
13628 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 08:52:04 12 s 1/2
5/6
13629 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 08:52:05 12 s 1/2
5/6
13709 javaToPython at <unknown>:0 javaToPython at <unknown>:0 2026/10/16 08:53:32 11 s 1/1 (1 skipped)
5/5 (1 skipped)
13664 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 08:52:52 11 s 1/1 (1 skipped)
10/10 (1 skipped)
14239 collect at PythonRDD.scala:195 collect at PythonRDD.scala:195 2026/10/16 08:57:59 10 s 1/1 (1 skipped)
1/1 (1 skipped)
14238 collect at PythonRDD.scala:195 collect at PythonRDD.scala:195 2026/10/16 08:57:59 10 s 1/1 (1 skipped)
5/5 (1 skipped)
13627 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 08:52:04 10 s 1/2
5/6
14088 javaToPython at <unknown>:0 javaToPython at <unknown>:0 2026/10/16 08:56:28 10 s 1/1 (1 skipped)
5/5 (1 skipped)
13476 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 08:51:36 9 s 1/1 (1 skipped)
5/5 (1 skipped)
13477 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 08:51:36 9 s 1/1
1/1
13663 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 08:52:51 9 s 1/1 (1 skipped)
10/10 (1 skipped)
13475 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 08:51:36 9 s 1/1
1/1
14040 collect at PythonRDD.scala:195 collect at PythonRDD.scala:195 2026/10/16 08:56:01 9 s 1/1 (1 skipped)
5/5 (1 skipped)
14053 javaToPython at <unknown>:0 javaToPython at <unknown>:0 2026/10/16 08:56:10 8 s 1/1 (1 skipped)
5/5 (1 skipped)
13626 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 08:52:04 8 s 1/2
5/6
13481 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 08:51:37 8 s 1/2
5/6
13482 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 08:51:37 8 s 1/2 (1 skipped)
1/2 (5 skipped)
13662 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 08:52:50 7 s 1/2
10/11
14145 javaToPython at <unknown>:0 javaToPython at <unknown>:0 2026/10/16 08:57:09 7 s 1/1 (1 skipped)
5/5 (1 skipped)
14225 collect at PythonRDD.scala:195 collect at PythonRDD.scala:195 2026/10/16 08:57:52 7 s 1/1 (1 skipped)
5/5 (1 skipped)
13486 javaToPython at <unknown>:0 javaToPython at <unknown>:0 2026/10/16 08:51:45 7 s 1/1 (1 skipped)
5/5 (1 skipped)
13625 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 08:52:03 7 s 1/1 (1 skipped)
5/5 (1 skipped)
14033 foreachPartition at /opt/app/scheduler/jobs/memgraph_loader_job.py:2107 foreachPartition at /opt/app/scheduler/jobs/memgraph_loader_job.py:2107 2026/10/16 08:55:49 6 s 1/1 (1 skipped)
5/5 (1 skipped)
13814 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 08:54:04 6 s 1/2
5/6
13815 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 08:54:04 6 s 1/2 (1 skipped)
1/2 (5 skipped)
13440 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 08:51:16 6 s 1/1
2/2
13439 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 08:51:16 6 s 1/1 (1 skipped)
5/5 (1 skipped)
13480 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 08:51:36 6 s 1/2
5/6
14107 foreachPartition at /opt/app/scheduler/jobs/memgraph_loader_job.py:2107 foreachPartition at /opt/app/scheduler/jobs/memgraph_loader_job.py:2107 2026/10/16 08:56:40 6 s 1/1 (1 skipped)
5/5 (1 skipped)