Spark Jobs (?)

Event Timeline

Active Jobs (5)

Page:
Job Id ▾ Description Submitted Duration Stages: Succeeded/Total Tasks (for all stages): Succeeded/Total
19711 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 09:40:39 5 s 0/2
4/6 (1 running)
19709 javaToPython at <unknown>:0 (kill) javaToPython at <unknown>:0 2026/10/16 09:40:33 11 s 0/2
2/6
19697 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 (kill) $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 09:40:23 21 s 0/2
3/6
19482 collect at PythonRDD.scala:195 (kill) collect at PythonRDD.scala:195 2026/10/16 09:38:12 2.5 min 0/2
0/6
19481 collect at PythonRDD.scala:195 (kill) collect at PythonRDD.scala:195 2026/10/16 09:38:12 2.5 min 0/2
3/6
Page:

Completed Jobs (19708, only showing 907)

Job Id Description Submitted Duration ▴ Stages: Succeeded/Total Tasks (for all stages): Succeeded/Total
19657 foreachPartition at /opt/app/scheduler/jobs/memgraph_loader_job.py:2107 2026/10/16 09:40:03 0 ms 0/0
0/0
19576 foreachPartition at /opt/app/scheduler/jobs/memgraph_loader_job.py:2107 2026/10/16 09:39:25 0 ms 0/0
0/0
19537 collect at PythonRDD.scala:195 2026/10/16 09:38:53 0 ms 0/0
0/0
19427 javaToPython at <unknown>:0 2026/10/16 09:37:57 0 ms 0/0
0/0
19416 javaToPython at <unknown>:0 2026/10/16 09:37:55 0 ms 0/0
0/0
19414 foreachPartition at /opt/app/scheduler/jobs/memgraph_loader_job.py:2107 2026/10/16 09:37:55 0 ms 0/0
0/0
19411 collect at PythonRDD.scala:195 2026/10/16 09:37:54 0 ms 0/0
0/0
19403 foreachPartition at /opt/app/scheduler/jobs/memgraph_loader_job.py:2107 2026/10/16 09:37:53 0 ms 0/0
0/0
19401 foreachPartition at /opt/app/scheduler/jobs/memgraph_loader_job.py:2107 2026/10/16 09:37:52 0 ms 0/0
0/0
19399 foreachPartition at /opt/app/scheduler/jobs/memgraph_loader_job.py:2107 2026/10/16 09:37:51 0 ms 0/0
0/0
19396 foreachPartition at /opt/app/scheduler/jobs/memgraph_loader_job.py:2107 2026/10/16 09:37:51 0 ms 0/0
0/0
19391 foreachPartition at /opt/app/scheduler/jobs/memgraph_loader_job.py:2107 2026/10/16 09:37:49 0 ms 0/0
0/0
19387 foreachPartition at /opt/app/scheduler/jobs/memgraph_loader_job.py:2107 2026/10/16 09:37:49 0 ms 0/0
0/0
19294 collect at PythonRDD.scala:195 2026/10/16 09:37:21 0 ms 0/0
0/0
19290 foreachPartition at /opt/app/scheduler/jobs/memgraph_loader_job.py:2107 2026/10/16 09:37:20 0 ms 0/0
0/0
19195 foreachPartition at /opt/app/scheduler/jobs/memgraph_loader_job.py:2107 2026/10/16 09:36:45 0 ms 0/0
0/0
19173 foreachPartition at /opt/app/scheduler/jobs/memgraph_loader_job.py:2107 2026/10/16 09:36:35 0 ms 0/0
0/0
19107 foreachPartition at /opt/app/scheduler/jobs/memgraph_loader_job.py:2107 2026/10/16 09:35:55 0 ms 0/0
0/0
19021 foreachPartition at /opt/app/scheduler/jobs/memgraph_loader_job.py:2107 2026/10/16 09:35:16 0 ms 0/0
0/0
19019 foreachPartition at /opt/app/scheduler/jobs/memgraph_loader_job.py:2107 2026/10/16 09:35:15 0 ms 0/0
0/0
18914 foreachPartition at /opt/app/scheduler/jobs/memgraph_loader_job.py:2107 2026/10/16 09:34:33 0 ms 0/0
0/0
18904 foreachPartition at /opt/app/scheduler/jobs/memgraph_loader_job.py:2107 2026/10/16 09:34:28 0 ms 0/0
0/0
18837 foreachPartition at /opt/app/scheduler/jobs/memgraph_loader_job.py:2107 2026/10/16 09:33:59 0 ms 0/0
0/0
19383 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 09:37:48 7 ms 1/1
1/1
19372 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 09:37:46 7 ms 1/1
1/1
19277 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 09:37:18 7 ms 1/1
1/1
18830 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 09:33:57 7 ms 1/1
1/1
19412 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 09:37:55 8 ms 1/1
1/1
19384 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 09:37:48 8 ms 1/1
1/1
19301 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 09:37:24 8 ms 1/1
1/1
18876 count at <unknown>:0 count at <unknown>:0 2026/10/16 09:34:11 8 ms 1/1 (2 skipped)
1/1 (3 skipped)
18843 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 09:34:01 8 ms 1/1
1/1
18833 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 09:33:58 8 ms 1/1
1/1
19407 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 09:37:54 9 ms 1/1
1/1
19360 count at <unknown>:0 count at <unknown>:0 2026/10/16 09:37:38 9 ms 1/1 (2 skipped)
1/1 (4 skipped)
19209 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 09:36:51 9 ms 1/1
1/1
19178 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 09:36:40 9 ms 1/1
1/1
19113 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 09:35:59 9 ms 1/1
1/1
19100 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 09:35:52 9 ms 1/1
1/1
19088 count at <unknown>:0 count at <unknown>:0 2026/10/16 09:35:41 9 ms 1/1 (2 skipped)
1/1 (5 skipped)
18984 count at <unknown>:0 count at <unknown>:0 2026/10/16 09:34:56 9 ms 1/1 (2 skipped)
1/1 (6 skipped)
18924 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 09:34:37 9 ms 1/1
1/1
18900 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 09:34:27 9 ms 1/1
1/1
18817 count at <unknown>:0 count at <unknown>:0 2026/10/16 09:33:53 9 ms 1/1 (1 skipped)
1/1 (1 skipped)
19475 count at <unknown>:0 count at <unknown>:0 2026/10/16 09:38:10 10 ms 1/1 (2 skipped)
1/1 (6 skipped)
19466 count at <unknown>:0 count at <unknown>:0 2026/10/16 09:38:09 10 ms 1/1 (2 skipped)
1/1 (6 skipped)
19426 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 09:37:57 10 ms 1/1 (1 skipped)
1/1 (1 skipped)
19382 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 09:37:48 10 ms 1/1
1/1
19149 count at <unknown>:0 count at <unknown>:0 2026/10/16 09:36:13 10 ms 1/1 (2 skipped)
1/1 (5 skipped)
19034 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 09:35:24 10 ms 1/1
1/1
19029 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 09:35:22 10 ms 1/1
1/1
18899 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 09:34:27 10 ms 1/1
1/1
18875 count at <unknown>:0 count at <unknown>:0 2026/10/16 09:34:11 10 ms 1/1 (2 skipped)
1/1 (5 skipped)
19371 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 09:37:46 11 ms 1/1
1/1
18884 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 09:34:20 11 ms 1/1
1/1
19649 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 09:39:59 12 ms 1/1
1/1
18846 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 09:34:03 12 ms 1/1 (1 skipped)
1/1 (1 skipped)
18834 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 09:33:58 12 ms 1/1
1/1
18824 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 09:33:56 12 ms 1/1
1/1
19358 count at <unknown>:0 count at <unknown>:0 2026/10/16 09:37:38 13 ms 1/1 (1 skipped)
1/1 (1 skipped)
19254 count at <unknown>:0 count at <unknown>:0 2026/10/16 09:37:10 13 ms 1/1 (1 skipped)
1/1 (1 skipped)
19179 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 09:36:40 13 ms 1/1
1/1
18818 count at <unknown>:0 count at <unknown>:0 2026/10/16 09:33:53 13 ms 1/1 (1 skipped)
1/1 (1 skipped)
19599 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 09:39:35 14 ms 1/1 (2 skipped)
1/1 (6 skipped)
19156 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 09:36:24 14 ms 1/1
1/1
18994 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 09:35:07 14 ms 1/1
1/1
18840 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 09:34:00 14 ms 1/1
1/1
19642 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 09:39:47 15 ms 1/1 (2 skipped)
1/1 (6 skipped)
19266 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 09:37:15 15 ms 1/1
1/1
19707 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 09:40:33 16 ms 1/1
1/1
19256 count at <unknown>:0 count at <unknown>:0 2026/10/16 09:37:10 16 ms 1/1 (1 skipped)
1/1 (1 skipped)
19255 count at <unknown>:0 count at <unknown>:0 2026/10/16 09:37:10 16 ms 1/1 (1 skipped)
1/1 (1 skipped)
18995 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 09:35:07 16 ms 1/1
1/1
19653 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 09:40:01 17 ms 1/1
1/1
19650 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 09:39:59 17 ms 1/1
1/1
19524 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 09:38:50 17 ms 1/1 (2 skipped)
1/1 (6 skipped)
19413 javaToPython at <unknown>:0 javaToPython at <unknown>:0 2026/10/16 09:37:55 17 ms 1/1 (1 skipped)
1/1 (1 skipped)
19357 count at <unknown>:0 count at <unknown>:0 2026/10/16 09:37:38 18 ms 1/1 (1 skipped)
3/3 (1 skipped)
19228 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 09:36:59 18 ms 1/1 (2 skipped)
1/1 (5 skipped)
19119 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 09:36:02 18 ms 1/1 (2 skipped)
1/1 (5 skipped)
19110 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 09:35:59 18 ms 1/1
1/1
19094 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 09:35:49 18 ms 1/1
1/1
19467 count at <unknown>:0 count at <unknown>:0 2026/10/16 09:38:09 19 ms 1/1 (1 skipped)
5/5 (1 skipped)
19359 count at <unknown>:0 count at <unknown>:0 2026/10/16 09:37:38 19 ms 1/1 (1 skipped)
3/3 (1 skipped)
19086 count at <unknown>:0 count at <unknown>:0 2026/10/16 09:35:41 20 ms 1/1 (1 skipped)
4/4 (1 skipped)
19005 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 09:35:11 21 ms 1/1
1/1
18983 count at <unknown>:0 count at <unknown>:0 2026/10/16 09:34:56 21 ms 1/1 (1 skipped)
1/1 (1 skipped)
19559 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 09:39:15 22 ms 1/1
1/1
19103 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 09:35:54 22 ms 1/1 (1 skipped)
4/4 (1 skipped)
19087 count at <unknown>:0 count at <unknown>:0 2026/10/16 09:35:41 22 ms 1/1 (1 skipped)
4/4 (1 skipped)
18930 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 09:34:38 22 ms 1/1 (2 skipped)
1/1 (5 skipped)
18873 count at <unknown>:0 count at <unknown>:0 2026/10/16 09:34:11 22 ms 1/1 (1 skipped)
4/4 (1 skipped)
18872 count at <unknown>:0 count at <unknown>:0 2026/10/16 09:34:11 22 ms 1/1 (1 skipped)
4/4 (1 skipped)
18835 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 09:33:58 22 ms 1/1 (1 skipped)
1/1 (1 skipped)
19116 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 09:36:01 23 ms 1/1 (1 skipped)
4/4 (1 skipped)
19392 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 09:37:49 24 ms 1/1
1/1
19641 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 09:39:47 25 ms 1/1 (1 skipped)
5/5 (1 skipped)
18841 javaToPython at <unknown>:0 javaToPython at <unknown>:0 2026/10/16 09:34:01 25 ms 1/1 (1 skipped)
2/2 (1 skipped)
19500 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 09:38:34 26 ms 1/1
1/1
19428 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 09:37:57 26 ms 1/1 (1 skipped)
1/1 (1 skipped)