Spark Jobs (?)

Event Timeline

Active Jobs (10)

Page:
Job Id ▾ Description Submitted Duration Stages: Succeeded/Total Tasks (for all stages): Succeeded/Total
19861 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:41:58 4 s 0/8
2/112 (2 running)
19860 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 (kill) $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 09:41:57 5 s 0/2
0/6
19859 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 (kill) $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 09:41:56 6 s 0/2
0/6
19858 javaToPython at <unknown>:0 (kill) javaToPython at <unknown>:0 2026/10/16 09:41:56 6 s 0/2
0/6
19857 javaToPython at <unknown>:0 (kill) javaToPython at <unknown>:0 2026/10/16 09:41:56 6 s 0/2
0/6
19856 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 (kill) $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 09:41:56 6 s 0/2
0/11
19855 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 (kill) $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 09:41:56 6 s 0/2
4/11
19850 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 (kill) $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 09:41:55 7 s 0/1
0/1
19849 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 (kill) $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 09:41:55 7 s 0/1
0/1
19482 collect at PythonRDD.scala:195 (kill) collect at PythonRDD.scala:195 2026/10/16 09:38:12 3.8 min 0/2
0/6
Page:

Completed Jobs (19852, only showing 952)

Job Id ▾ Description Submitted Duration Stages: Succeeded/Total Tasks (for all stages): Succeeded/Total
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)
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
19847 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
8/9
19846 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.0 s 1/1 (1 skipped)
4/4 (1 skipped)
19845 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 0.8 s 1/1 (1 skipped)
4/4 (1 skipped)
19844 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 0.7 s 1/1 (1 skipped)
8/8 (1 skipped)
19843 collect at PythonRDD.scala:195 collect at PythonRDD.scala:195 2026/10/16 09:41:52 2 s 1/1 (1 skipped)
1/1 (1 skipped)
19842 javaToPython at <unknown>:0 javaToPython at <unknown>:0 2026/10/16 09:41:52 0.6 s 1/1 (1 skipped)
5/5 (1 skipped)
19841 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 09:41:50 1 s 1/1
1/1
19840 collect at PythonRDD.scala:195 collect at PythonRDD.scala:195 2026/10/16 09:41:48 2 s 1/1 (1 skipped)
1/1 (1 skipped)
19839 collect at PythonRDD.scala:195 collect at PythonRDD.scala:195 2026/10/16 09:41:47 0.7 s 1/1 (4 skipped)
1/1 (40 skipped)
19838 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:47 0.7 s 1/1 (5 skipped)
1/1 (44 skipped)
19837 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:46 0.3 s 1/1 (5 skipped)
30/30 (44 skipped)
19836 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:46 0.3 s 1/2 (1 skipped)
1/2 (6 skipped)
19835 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:46 0.3 s 1/2
10/11
19834 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:46 0.3 s 1/2
16/17
19833 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:46 0.3 s 1/1 (1 skipped)
26/26 (1 skipped)
19832 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:46 0.3 s 1/1 (1 skipped)
6/6 (1 skipped)
19831 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:46 0.3 s 1/1 (1 skipped)
10/10 (1 skipped)
19830 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:46 0.3 s 1/1 (1 skipped)
10/10 (1 skipped)
19829 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:46 0.2 s 1/2
10/11
19828 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:46 0.2 s 1/1 (1 skipped)
10/10 (1 skipped)
19827 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:46 11 ms 1/1 (2 skipped)
1/1 (5 skipped)
19826 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:45 0.4 s 1/2
4/5
19825 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:45 0.3 s 1/1 (1 skipped)
6/6 (1 skipped)
19824 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:45 75 ms 1/1 (1 skipped)
4/4 (1 skipped)
19823 collect at PythonRDD.scala:195 collect at PythonRDD.scala:195 2026/10/16 09:41:45 9 s 1/1 (1 skipped)
5/5 (1 skipped)
19822 javaToPython at <unknown>:0 javaToPython at <unknown>:0 2026/10/16 09:41:44 4 s 1/1 (1 skipped)
10/10 (1 skipped)
19821 javaToPython at <unknown>:0 javaToPython at <unknown>:0 2026/10/16 09:41:44 3 s 1/1 (4 skipped)
20/20 (40 skipped)
19820 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:43 0.7 s 1/1 (1 skipped)
1/1 (1 skipped)
19819 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:43 21 ms 1/1 (1 skipped)
4/4 (1 skipped)
19818 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:43 8 ms 1/1
1/1
19817 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:42 0.7 s 1/1 (1 skipped)
1/1 (1 skipped)
19816 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:42 54 ms 1/1 (1 skipped)
8/8 (1 skipped)
19815 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:42 16 ms 1/1
1/1
19814 javaToPython at <unknown>:0 javaToPython at <unknown>:0 2026/10/16 09:41:42 2 s 1/2 (1 skipped)
1/2 (7 skipped)
19813 javaToPython at <unknown>:0 javaToPython at <unknown>:0 2026/10/16 09:41:42 2 s 1/2
12/13
19812 javaToPython at <unknown>:0 javaToPython at <unknown>:0 2026/10/16 09:41:42 2 s 1/2
19/20
19811 javaToPython at <unknown>:0 javaToPython at <unknown>:0 2026/10/16 09:41:42 2 s 1/1 (1 skipped)
31/31 (1 skipped)
19810 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:41 0.7 s 1/1 (1 skipped)
1/1 (1 skipped)
19809 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:38 3 s 1/1 (1 skipped)
4/4 (1 skipped)
19808 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:38 0.7 s 1/1 (1 skipped)
1/1 (1 skipped)
19807 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:37 1 s 1/1 (1 skipped)
4/4 (1 skipped)
19806 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:36 29 ms 1/1 (1 skipped)
4/4 (1 skipped)
19805 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:36 15 ms 1/1
1/1
19804 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:36 8 ms 1/1
1/1
19803 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:36 0.7 s 1/1 (1 skipped)
1/1 (1 skipped)
19802 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 09:41:35 10 s 1/1
1/1
19801 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:34 1 s 1/1 (1 skipped)
4/4 (1 skipped)
19800 javaToPython at <unknown>:0 javaToPython at <unknown>:0 2026/10/16 09:41:34 8 s 1/1 (1 skipped)
7/7 (1 skipped)
19799 javaToPython at <unknown>:0 javaToPython at <unknown>:0 2026/10/16 09:41:34 8 s 1/1 (1 skipped)
12/12 (1 skipped)
19798 javaToPython at <unknown>:0 javaToPython at <unknown>:0 2026/10/16 09:41:34 8 s 1/1 (1 skipped)
12/12 (1 skipped)
19797 javaToPython at <unknown>:0 javaToPython at <unknown>:0 2026/10/16 09:41:34 8 s 1/2
12/13
19796 javaToPython at <unknown>:0 javaToPython at <unknown>:0 2026/10/16 09:41:34 4 s 1/1 (1 skipped)
12/12 (1 skipped)
19795 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:34 0.7 s 1/1
1/1
19794 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:34 0.7 s 1/1
1/1
19793 collect at PythonRDD.scala:195 collect at PythonRDD.scala:195 2026/10/16 09:41:33 1 s 1/1 (1 skipped)
1/1 (1 skipped)
19792 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 09:41:32 1 s 1/1 (2 skipped)
1/1 (6 skipped)
19791 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:32 1 s 1/1 (1 skipped)
1/1 (1 skipped)
19790 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:31 1 s 1/1 (1 skipped)
4/4 (1 skipped)
19789 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:31 21 ms 1/1
1/1
19788 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:31 16 ms 1/1
1/1
19787 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:27 4 s 1/1 (1 skipped)
4/4 (1 skipped)
19786 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:23 4 s 1/1 (1 skipped)
4/4 (1 skipped)
19785 javaToPython at <unknown>:0 javaToPython at <unknown>:0 2026/10/16 09:41:23 10 s 1/2
5/6
19784 javaToPython at <unknown>:0 javaToPython at <unknown>:0 2026/10/16 09:41:23 4 s 1/1 (1 skipped)
7/7 (1 skipped)
19783 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:22 11 ms 1/1 (2 skipped)
1/1 (5 skipped)
19782 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 09:41:22 0.3 s 1/1 (1 skipped)
5/5 (1 skipped)
19781 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:22 0.9 s 1/1 (1 skipped)
4/4 (1 skipped)
19780 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:21 0.4 s 1/1 (1 skipped)
4/4 (1 skipped)
19779 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:20 0.7 s 1/1
1/1
19778 collect at PythonRDD.scala:195 collect at PythonRDD.scala:195 2026/10/16 09:41:15 6 s 1/1 (1 skipped)
1/1 (1 skipped)
19777 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:15 5 s 1/1 (6 skipped)
5/5 (84 skipped)
19776 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:14 1 s 1/2 (1 skipped)
1/2 (5 skipped)
19775 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:14 1 s 1/2 (1 skipped)
1/2 (5 skipped)
19774 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:14 1 s 1/5
22/62
19773 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:14 1 s 1/2 (3 skipped)
22/23 (39 skipped)
19772 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:13 0.8 s 1/1 (1 skipped)
5/5 (1 skipped)
19771 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:13 0.7 s 1/1 (1 skipped)
5/5 (1 skipped)
19770 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:13 0.7 s 1/1 (1 skipped)
5/5 (1 skipped)
19769 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:13 0.6 s 1/1 (1 skipped)
10/10 (1 skipped)
19768 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:13 0.5 s 1/1 (1 skipped)
10/10 (1 skipped)
19767 javaToPython at <unknown>:0 javaToPython at <unknown>:0 2026/10/16 09:41:12 3 s 1/1 (1 skipped)
5/5 (1 skipped)
19766 javaToPython at <unknown>:0 javaToPython at <unknown>:0 2026/10/16 09:41:12 21 s 1/1 (1 skipped)
5/5 (1 skipped)
19765 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 09:41:12 0.7 s 1/1
1/1
19764 collect at PythonRDD.scala:195 collect at PythonRDD.scala:195 2026/10/16 09:41:11 1 s 1/1 (1 skipped)
1/1 (1 skipped)
19763 collect at PythonRDD.scala:195 collect at PythonRDD.scala:195 2026/10/16 09:41:10 1 s 1/1 (1 skipped)
1/1 (1 skipped)
19762 javaToPython at <unknown>:0 javaToPython at <unknown>:0 2026/10/16 09:41:10 0.2 s 1/1 (1 skipped)
10/10 (1 skipped)
19761 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 09:41:10 0.5 s 1/1
1/1
19760 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:09 1 s 1/1 (4 skipped)
1/1 (40 skipped)
19759 collect at PythonRDD.scala:195 collect at PythonRDD.scala:195 2026/10/16 09:41:09 0.8 s 1/1 (1 skipped)
1/1 (1 skipped)
19758 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:08 1 s 1/1 (4 skipped)
20/20 (40 skipped)
19757 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:07 1.0 s 1/2 (1 skipped)
1/2 (7 skipped)
19756 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:07 1 s 1/2
12/13
19755 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:07 0.9 s 1/2
19/20
19754 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:06 0.5 s 1/1 (1 skipped)
31/31 (1 skipped)
19753 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:05 1 s 1/1 (1 skipped)
7/7 (1 skipped)