Spark Jobs (?)

Event Timeline

Active Jobs (2)

Page:
Job Id ▾ Description Submitted Duration Stages: Succeeded/Total Tasks (for all stages): Succeeded/Total
19949 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:42:49 1 s 0/7
0/89 (1 running)
19939 javaToPython at <unknown>:0 (kill) javaToPython at <unknown>:0 2026/10/16 09:42:47 4 s 0/2
2/6
Page:

Completed Jobs (19948, only showing 948)

Job Id ▾ Description Submitted Duration Stages: Succeeded/Total Tasks (for all stages): Succeeded/Total
19948 javaToPython at <unknown>:0 javaToPython at <unknown>:0 2026/10/16 09:42:48 2 s 1/5
22/62
19947 javaToPython at <unknown>:0 javaToPython at <unknown>:0 2026/10/16 09:42:48 0.7 s 1/2 (3 skipped)
22/23 (39 skipped)
19946 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 09:42:48 0.2 s 1/1 (2 skipped)
1/1 (6 skipped)
19945 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 09:42:48 0.2 s 1/2 (1 skipped)
1/2 (5 skipped)
19944 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 09:42:47 0.7 s 1/1 (1 skipped)
10/10 (1 skipped)
19943 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 09:42:47 0.7 s 1/2
10/11
19942 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 09:42:47 0.6 s 1/1 (1 skipped)
5/5 (1 skipped)
19941 javaToPython at <unknown>:0 javaToPython at <unknown>:0 2026/10/16 09:42:47 0.6 s 1/1 (1 skipped)
5/5 (1 skipped)
19940 javaToPython at <unknown>:0 javaToPython at <unknown>:0 2026/10/16 09:42:47 0.6 s 1/1 (1 skipped)
5/5 (1 skipped)
19938 foreachPartition at /opt/app/scheduler/jobs/memgraph_loader_job.py:2107 2026/10/16 09:42:47 0 ms 0/0
0/0
19937 javaToPython at <unknown>:0 javaToPython at <unknown>:0 2026/10/16 09:42:45 1 s 1/1 (1 skipped)
5/5 (1 skipped)
19936 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 09:42:45 0.1 s 1/1 (1 skipped)
5/5 (1 skipped)
19935 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 09:42:45 13 ms 1/1
1/1
19934 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 09:42:45 9 ms 1/1
1/1
19933 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:42:45 0.7 s 1/1 (1 skipped)
1/1 (1 skipped)
19932 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:42:43 1 s 1/1 (4 skipped)
1/1 (40 skipped)
19931 javaToPython at <unknown>:0 javaToPython at <unknown>:0 2026/10/16 09:42:42 0.5 s 1/1 (4 skipped)
20/20 (40 skipped)
19930 javaToPython at <unknown>:0 javaToPython at <unknown>:0 2026/10/16 09:42:42 0.5 s 1/2 (1 skipped)
1/2 (7 skipped)
19929 javaToPython at <unknown>:0 javaToPython at <unknown>:0 2026/10/16 09:42:42 0.5 s 1/2
12/13
19928 javaToPython at <unknown>:0 javaToPython at <unknown>:0 2026/10/16 09:42:42 0.5 s 1/2
19/20
19927 javaToPython at <unknown>:0 javaToPython at <unknown>:0 2026/10/16 09:42:42 0.3 s 1/1 (1 skipped)
31/31 (1 skipped)
19926 javaToPython at <unknown>:0 javaToPython at <unknown>:0 2026/10/16 09:42:41 0.7 s 1/1 (1 skipped)
7/7 (1 skipped)
19925 javaToPython at <unknown>:0 javaToPython at <unknown>:0 2026/10/16 09:42:41 0.7 s 1/1 (1 skipped)
12/12 (1 skipped)
19924 javaToPython at <unknown>:0 javaToPython at <unknown>:0 2026/10/16 09:42:41 0.6 s 1/1 (1 skipped)
12/12 (1 skipped)
19923 javaToPython at <unknown>:0 javaToPython at <unknown>:0 2026/10/16 09:42:41 0.6 s 1/2
12/13
19922 javaToPython at <unknown>:0 javaToPython at <unknown>:0 2026/10/16 09:42:41 0.6 s 1/1 (1 skipped)
12/12 (1 skipped)
19921 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 09:42:41 0.4 s 1/1 (2 skipped)
1/1 (6 skipped)
19920 javaToPython at <unknown>:0 javaToPython at <unknown>:0 2026/10/16 09:42:40 4 s 1/1 (1 skipped)
5/5 (1 skipped)
19919 javaToPython at <unknown>:0 javaToPython at <unknown>:0 2026/10/16 09:42:40 0.4 s 1/2
5/6
19918 javaToPython at <unknown>:0 javaToPython at <unknown>:0 2026/10/16 09:42:40 0.3 s 1/1 (1 skipped)
7/7 (1 skipped)
19917 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 09:42:40 19 ms 1/1
1/1
19916 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 09:42:40 16 ms 1/1
1/1
19915 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 09:42:40 0.3 s 1/1 (1 skipped)
5/5 (1 skipped)
19914 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:42:40 0.7 s 1/1 (1 skipped)
1/1 (1 skipped)
19913 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:42:38 1 s 1/1 (1 skipped)
1/1 (1 skipped)
19912 javaToPython at <unknown>:0 javaToPython at <unknown>:0 2026/10/16 09:42:38 0.2 s 1/1 (1 skipped)
5/5 (1 skipped)
19911 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 09:42:37 0.4 s 1/1
1/1
19910 javaToPython at <unknown>:0 javaToPython at <unknown>:0 2026/10/16 09:42:37 3 s 1/1 (1 skipped)
5/5 (1 skipped)
19909 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:42:37 0.7 s 1/1 (1 skipped)
1/1 (1 skipped)
19908 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 09:42:36 54 ms 1/1
1/1
19907 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 09:42:36 50 ms 1/1
1/1
19906 javaToPython at <unknown>:0 javaToPython at <unknown>:0 2026/10/16 09:42:35 1 s 1/1 (1 skipped)
10/10 (1 skipped)
19905 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 09:42:35 0.9 s 1/1
1/1
19904 collect at PythonRDD.scala:195 collect at PythonRDD.scala:195 2026/10/16 09:42:33 2 s 1/1 (1 skipped)
1/1 (1 skipped)
19903 javaToPython at <unknown>:0 javaToPython at <unknown>:0 2026/10/16 09:42:28 4 s 1/1 (1 skipped)
5/5 (1 skipped)
19902 collect at PythonRDD.scala:195 2026/10/16 09:42:28 0 ms 0/0
0/0
19901 javaToPython at <unknown>:0 javaToPython at <unknown>:0 2026/10/16 09:42:26 2 s 1/1 (1 skipped)
5/5 (1 skipped)
19900 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:42:26 10 s 1/1 (1 skipped)
5/5 (1 skipped)
19899 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 09:42:25 1 s 1/1
1/1
19898 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 09:42:25 1 s 1/1
1/1
19897 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 09:42:25 1 s 1/1 (1 skipped)
5/5 (1 skipped)
19896 collect at PythonRDD.scala:195 collect at PythonRDD.scala:195 2026/10/16 09:42:23 2 s 1/1 (1 skipped)
1/1 (1 skipped)
19895 collect at PythonRDD.scala:195 collect at PythonRDD.scala:195 2026/10/16 09:42:17 5 s 1/1 (7 skipped)
5/5 (116 skipped)
19894 javaToPython at <unknown>:0 javaToPython at <unknown>:0 2026/10/16 09:42:17 6 s 1/1 (1 skipped)
5/5 (1 skipped)
19893 javaToPython at <unknown>:0 javaToPython at <unknown>:0 2026/10/16 09:42:16 0.8 s 1/6
32/84
19892 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 09:42:16 0.5 s 1/2 (1 skipped)
1/2 (5 skipped)
19891 javaToPython at <unknown>:0 javaToPython at <unknown>:0 2026/10/16 09:42:16 0.6 s 1/1 (5 skipped)
32/32 (52 skipped)
19890 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 09:42:16 0.4 s 1/2 (1 skipped)
1/2 (5 skipped)
19889 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 09:42:15 1 s 1/1
1/1
19888 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 09:42:15 1 s 1/1
1/1
19887 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 09:42:15 0.6 s 1/1 (1 skipped)
10/10 (1 skipped)
19886 javaToPython at <unknown>:0 javaToPython at <unknown>:0 2026/10/16 09:42:15 0.6 s 1/2
5/6
19885 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 09:42:15 0.5 s 1/1 (1 skipped)
5/5 (1 skipped)
19884 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 09:42:15 0.4 s 1/1 (1 skipped)
10/10 (1 skipped)
19883 javaToPython at <unknown>:0 javaToPython at <unknown>:0 2026/10/16 09:42:15 0.3 s 1/1 (1 skipped)
5/5 (1 skipped)
19882 collect at PythonRDD.scala:195 collect at PythonRDD.scala:195 2026/10/16 09:42:13 2 s 1/1 (1 skipped)
1/1 (1 skipped)
19881 collect at PythonRDD.scala:195 collect at PythonRDD.scala:195 2026/10/16 09:42:11 1 s 1/1 (5 skipped)
1/1 (52 skipped)
19880 javaToPython at <unknown>:0 javaToPython at <unknown>:0 2026/10/16 09:42:10 1 s 1/1 (5 skipped)
30/30 (52 skipped)
19879 javaToPython at <unknown>:0 javaToPython at <unknown>:0 2026/10/16 09:42:09 0.8 s 1/2 (1 skipped)
1/2 (7 skipped)
19878 javaToPython at <unknown>:0 javaToPython at <unknown>:0 2026/10/16 09:42:09 0.8 s 1/2
12/13
19877 javaToPython at <unknown>:0 javaToPython at <unknown>:0 2026/10/16 09:42:09 0.6 s 1/2
19/20
19876 javaToPython at <unknown>:0 javaToPython at <unknown>:0 2026/10/16 09:42:09 0.4 s 1/1 (1 skipped)
31/31 (1 skipped)
19875 javaToPython at <unknown>:0 javaToPython at <unknown>:0 2026/10/16 09:42:08 0.8 s 1/1 (1 skipped)
7/7 (1 skipped)
19874 javaToPython at <unknown>:0 javaToPython at <unknown>:0 2026/10/16 09:42:08 0.7 s 1/1 (1 skipped)
12/12 (1 skipped)
19873 javaToPython at <unknown>:0 javaToPython at <unknown>:0 2026/10/16 09:42:08 0.7 s 1/1 (1 skipped)
12/12 (1 skipped)
19872 javaToPython at <unknown>:0 javaToPython at <unknown>:0 2026/10/16 09:42:08 0.6 s 1/2
12/13
19871 javaToPython at <unknown>:0 javaToPython at <unknown>:0 2026/10/16 09:42:08 0.6 s 1/1 (1 skipped)
12/12 (1 skipped)
19870 javaToPython at <unknown>:0 javaToPython at <unknown>:0 2026/10/16 09:42:07 6 s 1/1 (1 skipped)
5/5 (1 skipped)
19869 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 09:42:07 1 s 1/1 (2 skipped)
1/1 (6 skipped)
19868 javaToPython at <unknown>:0 javaToPython at <unknown>:0 2026/10/16 09:42:03 4 s 1/2
5/6
19867 collect at PythonRDD.scala:195 collect at PythonRDD.scala:195 2026/10/16 09:42:03 4 s 1/1 (6 skipped)
5/5 (84 skipped)
19866 javaToPython at <unknown>:0 javaToPython at <unknown>:0 2026/10/16 09:42:03 4 s 1/1 (1 skipped)
7/7 (1 skipped)
19865 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 09:42:03 0.7 s 1/2 (1 skipped)
1/2 (5 skipped)
19864 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 09:42:02 0.8 s 1/2 (1 skipped)
1/2 (5 skipped)
19863 javaToPython at <unknown>:0 javaToPython at <unknown>:0 2026/10/16 09:42:02 0.8 s 1/5
22/62
19862 javaToPython at <unknown>:0 javaToPython at <unknown>:0 2026/10/16 09:42:02 0.6 s 1/2 (3 skipped)
22/23 (39 skipped)
19861 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:41:58 4 s 1/1 (7 skipped)
4/4 (108 skipped)
19860 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 09:41:57 6 s 1/1 (1 skipped)
5/5 (1 skipped)
19859 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 09:41:56 6 s 1/1 (1 skipped)
5/5 (1 skipped)
19858 javaToPython at <unknown>:0 javaToPython at <unknown>:0 2026/10/16 09:41:56 6 s 1/1 (1 skipped)
5/5 (1 skipped)
19857 javaToPython at <unknown>:0 javaToPython at <unknown>:0 2026/10/16 09:41:56 6 s 1/2
5/6
19856 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 09:41:56 6 s 1/1 (1 skipped)
10/10 (1 skipped)
19855 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 09:41:56 6 s 1/1 (1 skipped)
10/10 (1 skipped)
19854 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:41:56 3 s 1/2 (1 skipped)
1/2 (4 skipped)
19853 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:41:55 3 s 1/6
32/76
19852 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:41:55 2 s 1/2 (1 skipped)
1/2 (4 skipped)
19851 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:41:55 2 s 1/1 (5 skipped)
32/32 (44 skipped)
19850 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 09:41:55 12 s 1/1
1/1
19849 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 09:41:55 9 s 1/1
1/1
19848 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:41:54 1 s 1/2
4/5