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 2 s 0/2
0/6 (2 running)
19709 javaToPython at <unknown>:0 (kill) javaToPython at <unknown>:0 2026/10/16 09:40:33 8 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 18 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 (19707, only showing 907)

Job Id Description Submitted ▴ Duration Stages: Succeeded/Total Tasks (for all stages): Succeeded/Total
18800 javaToPython at <unknown>:0 javaToPython at <unknown>:0 2026/10/16 09:33:47 0.2 s 1/1 (1 skipped)
4/4 (1 skipped)
18801 javaToPython at <unknown>:0 javaToPython at <unknown>:0 2026/10/16 09:33:47 0.2 s 1/1 (1 skipped)
3/3 (1 skipped)
18802 javaToPython at <unknown>:0 javaToPython at <unknown>:0 2026/10/16 09:33:47 0.1 s 1/1 (1 skipped)
11/11 (1 skipped)
18803 javaToPython at <unknown>:0 javaToPython at <unknown>:0 2026/10/16 09:33:47 0.2 s 1/2
7/8
18804 javaToPython at <unknown>:0 javaToPython at <unknown>:0 2026/10/16 09:33:47 0.2 s 1/2
4/5
18805 javaToPython at <unknown>:0 javaToPython at <unknown>:0 2026/10/16 09:33:47 0.2 s 1/2 (1 skipped)
1/2 (3 skipped)
18806 javaToPython at <unknown>:0 javaToPython at <unknown>:0 2026/10/16 09:33:47 0.1 s 1/1 (4 skipped)
20/20 (16 skipped)
18807 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:33:48 0.7 s 1/1 (4 skipped)
1/1 (16 skipped)
18808 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 09:33:51 38 ms 1/1 (1 skipped)
2/2 (1 skipped)
18809 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 09:33:51 53 ms 1/2
2/3
18810 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 09:33:51 62 ms 1/2
1/2
18811 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 09:33:51 90 ms 1/1 (1 skipped)
1/1 (1 skipped)
18812 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 09:33:51 0.1 s 1/2
1/2
18813 javaToPython at <unknown>:0 javaToPython at <unknown>:0 2026/10/16 09:33:51 0.4 s 1/1 (4 skipped)
22/22 (16 skipped)
18814 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:33:51 1 s 1/5
1/17
18815 first at /opt/app/scheduler/jobs/memgraph_declared_loader_job.py:521 first at /opt/app/scheduler/jobs/memgraph_declared_loader_job.py:521 2026/10/16 09:33:53 83 ms 1/1
1/1
18816 count at <unknown>:0 count at <unknown>:0 2026/10/16 09:33:53 0.1 s 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)
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)
18819 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:33:54 1 s 1/1 (1 skipped)
1/1 (1 skipped)
18820 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:33:55 1 s 1/1 (1 skipped)
1/1 (1 skipped)
18821 javaToPython at <unknown>:0 javaToPython at <unknown>:0 2026/10/16 09:33:56 49 ms 1/1
1/1
18822 javaToPython at <unknown>:0 javaToPython at <unknown>:0 2026/10/16 09:33:56 0.1 s 1/1
1/1
18823 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 09:33:56 72 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
18825 javaToPython at <unknown>:0 javaToPython at <unknown>:0 2026/10/16 09:33:56 0.4 s 1/1 (1 skipped)
1/1 (1 skipped)
18826 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:33:56 0.6 s 1/1 (1 skipped)
1/1 (1 skipped)
18827 javaToPython at <unknown>:0 javaToPython at <unknown>:0 2026/10/16 09:33:57 0.2 s 1/1
1/1
18828 javaToPython at <unknown>:0 javaToPython at <unknown>:0 2026/10/16 09:33:57 0.2 s 1/1
1/1
18829 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 09:33:57 80 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
18831 javaToPython at <unknown>:0 javaToPython at <unknown>:0 2026/10/16 09:33:57 0.4 s 1/1 (1 skipped)
1/1 (1 skipped)
18832 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:33:58 0.7 s 1/1 (1 skipped)
1/1 (1 skipped)
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
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
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)
18836 javaToPython at <unknown>:0 javaToPython at <unknown>:0 2026/10/16 09:33:59 0.2 s 1/1 (1 skipped)
1/1 (1 skipped)
18837 foreachPartition at /opt/app/scheduler/jobs/memgraph_loader_job.py:2107 2026/10/16 09:33:59 0 ms 0/0
0/0
18838 javaToPython at <unknown>:0 javaToPython at <unknown>:0 2026/10/16 09:33:59 0.8 s 1/1 (1 skipped)
1/1 (1 skipped)
18839 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:00 0.7 s 1/1 (1 skipped)
1/1 (1 skipped)
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
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)
18842 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:01 0.7 s 1/1 (1 skipped)
1/1 (1 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
18844 javaToPython at <unknown>:0 javaToPython at <unknown>:0 2026/10/16 09:34:01 30 ms 1/1 (1 skipped)
1/1 (1 skipped)
18845 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:01 0.7 s 1/1 (1 skipped)
1/1 (1 skipped)
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)
18847 javaToPython at <unknown>:0 javaToPython at <unknown>:0 2026/10/16 09:34:03 0.2 s 1/1 (1 skipped)
3/3 (1 skipped)
18848 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 09:34:03 0.2 s 1/2
1/2
18849 javaToPython at <unknown>:0 javaToPython at <unknown>:0 2026/10/16 09:34:03 0.2 s 1/1 (1 skipped)
4/4 (1 skipped)
18850 javaToPython at <unknown>:0 javaToPython at <unknown>:0 2026/10/16 09:34:03 0.2 s 1/2
4/5
18851 javaToPython at <unknown>:0 javaToPython at <unknown>:0 2026/10/16 09:34:03 0.2 s 1/2
4/5
18852 javaToPython at <unknown>:0 javaToPython at <unknown>:0 2026/10/16 09:34:03 0.2 s 1/1 (1 skipped)
4/4 (1 skipped)
18853 javaToPython at <unknown>:0 javaToPython at <unknown>:0 2026/10/16 09:34:03 0.2 s 1/1 (1 skipped)
3/3 (1 skipped)
18854 javaToPython at <unknown>:0 javaToPython at <unknown>:0 2026/10/16 09:34:03 0.1 s 1/1 (1 skipped)
11/11 (1 skipped)
18855 javaToPython at <unknown>:0 javaToPython at <unknown>:0 2026/10/16 09:34:03 0.2 s 1/2
7/8
18856 javaToPython at <unknown>:0 javaToPython at <unknown>:0 2026/10/16 09:34:03 0.2 s 1/2
4/5
18857 javaToPython at <unknown>:0 javaToPython at <unknown>:0 2026/10/16 09:34:03 0.2 s 1/2 (1 skipped)
1/2 (3 skipped)
18858 javaToPython at <unknown>:0 javaToPython at <unknown>:0 2026/10/16 09:34:04 0.3 s 1/1 (4 skipped)
20/20 (16 skipped)
18859 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:04 0.8 s 1/1 (4 skipped)
1/1 (16 skipped)
18860 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 09:34:07 43 ms 1/1 (1 skipped)
2/2 (1 skipped)
18861 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 09:34:07 63 ms 1/2
2/3
18862 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 09:34:07 0.2 s 1/1 (1 skipped)
1/1 (1 skipped)
18863 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 09:34:07 0.2 s 1/2
1/2
18864 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 09:34:07 0.2 s 1/2
1/2
18865 javaToPython at <unknown>:0 javaToPython at <unknown>:0 2026/10/16 09:34:07 0.5 s 1/1 (4 skipped)
22/22 (16 skipped)
18866 javaToPython at <unknown>:0 javaToPython at <unknown>:0 2026/10/16 09:34:07 0.7 s 1/5
22/38
18867 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:08 1 s 1/5
1/17
18868 first at /opt/app/scheduler/jobs/memgraph_declared_loader_job.py:521 first at /opt/app/scheduler/jobs/memgraph_declared_loader_job.py:521 2026/10/16 09:34:10 0.1 s 1/1
1/1
18870 count at <unknown>:0 count at <unknown>:0 2026/10/16 09:34:10 0.1 s 1/1
1/1
18869 count at <unknown>:0 count at <unknown>:0 2026/10/16 09:34:10 0.6 s 1/1
1/1
18871 count at <unknown>:0 count at <unknown>:0 2026/10/16 09:34:10 0.5 s 1/1 (1 skipped)
2/2 (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)
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)
18874 count at <unknown>:0 count at <unknown>:0 2026/10/16 09:34:11 27 ms 1/1 (1 skipped)
2/2 (1 skipped)
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)
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)
18877 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:12 3 s 1/1 (1 skipped)
4/4 (1 skipped)
18878 collect at PythonRDD.scala:195 collect at PythonRDD.scala:195 2026/10/16 09:34:12 8 s 1/1 (1 skipped)
2/2 (1 skipped)
18879 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:15 4 s 1/1 (1 skipped)
4/4 (1 skipped)
18880 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:19 0.7 s 1/1
1/1
18881 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:19 0.8 s 1/1
1/1
18882 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 3 s 1/1 (1 skipped)
2/2 (1 skipped)
18883 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 74 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
18885 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 2 s 1/1 (1 skipped)
4/4 (1 skipped)
18886 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:22 1 s 1/1 (1 skipped)
1/1 (1 skipped)
18888 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:23 0.7 s 1/1
1/1
18887 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:23 0.7 s 1/1
1/1
18889 javaToPython at <unknown>:0 javaToPython at <unknown>:0 2026/10/16 09:34:23 0.1 s 1/1
1/1
18890 javaToPython at <unknown>:0 javaToPython at <unknown>:0 2026/10/16 09:34:23 0.2 s 1/1
1/1
18891 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:23 0.8 s 1/1 (1 skipped)
2/2 (1 skipped)
18892 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 09:34:24 43 ms 1/1
1/1
18893 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 09:34:24 0.4 s 1/1
1/1
18894 javaToPython at <unknown>:0 javaToPython at <unknown>:0 2026/10/16 09:34:24 1 s 1/1 (1 skipped)
4/4 (1 skipped)
18895 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:24 2 s 1/1 (1 skipped)
1/1 (1 skipped)
18896 collect at PythonRDD.scala:195 collect at PythonRDD.scala:195 2026/10/16 09:34:25 1 s 1/1 (1 skipped)
1/1 (1 skipped)
18897 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:26 0.7 s 1/1
1/1
18898 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:26 0.7 s 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