Spark Jobs (?)

Event Timeline

Active Jobs (5)

Page:
Job Id ▾ Description Submitted Duration Stages: Succeeded/Total Tasks (for all stages): Succeeded/Total
19716 collect at PythonRDD.scala:195 (kill) collect at PythonRDD.scala:195 2026/10/16 09:40:47 0.2 s 0/2
0/2
19715 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:46 0.6 s 0/2
0/2 (1 running)
19697 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 (kill) $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 09:40:23 24 s 0/2
3/6
19482 collect at PythonRDD.scala:195 (kill) collect at PythonRDD.scala:195 2026/10/16 09:38:12 2.6 min 0/2
0/6
19481 collect at PythonRDD.scala:195 (kill) collect at PythonRDD.scala:195 2026/10/16 09:38:12 2.6 min 0/2
3/6
Page:

Completed Jobs (19712, only showing 912)

Job Id ▾ Description Submitted Duration Stages: Succeeded/Total Tasks (for all stages): Succeeded/Total
19714 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:44 2 s 1/1 (1 skipped)
5/5 (1 skipped)
19713 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:44 0.2 s 1/1
1/1
19712 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:44 0.2 s 1/1
1/1
19711 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:39 5 s 1/1 (1 skipped)
5/5 (1 skipped)
19710 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:34 5 s 1/1 (1 skipped)
5/5 (1 skipped)
19709 javaToPython at <unknown>:0 javaToPython at <unknown>:0 2026/10/16 09:40:33 14 s 1/1 (1 skipped)
5/5 (1 skipped)
19708 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 09:40:33 27 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
19706 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:32 1 s 1/1 (2 skipped)
1/1 (6 skipped)
19705 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:31 1 s 1/1 (1 skipped)
5/5 (1 skipped)
19704 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:30 1 s 1/1 (1 skipped)
5/5 (1 skipped)
19703 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:29 1.0 s 1/1
1/1
19702 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:24 5 s 1/1 (6 skipped)
5/5 (84 skipped)
19701 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:23 0.6 s 1/5
22/62
19700 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:23 0.4 s 1/1 (4 skipped)
22/22 (40 skipped)
19699 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:23 0.1 s 1/2 (1 skipped)
1/2 (5 skipped)
19698 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:23 0.2 s 1/2 (1 skipped)
1/2 (5 skipped)
19696 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 09:40:23 10 s 1/1
1/1
19695 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 09:40:23 10 s 1/1
1/1
19694 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:23 0.4 s 1/1 (1 skipped)
10/10 (1 skipped)
19693 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:23 0.3 s 1/1 (1 skipped)
10/10 (1 skipped)
19692 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:23 0.3 s 1/2
5/6
19691 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:23 0.2 s 1/1 (1 skipped)
5/5 (1 skipped)
19690 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:23 0.2 s 1/1 (1 skipped)
5/5 (1 skipped)
19689 collect at PythonRDD.scala:195 collect at PythonRDD.scala:195 2026/10/16 09:40:22 11 s 1/1 (1 skipped)
5/5 (1 skipped)
19688 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:18 2 s 1/1 (4 skipped)
1/1 (40 skipped)
19687 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:17 1 s 1/1 (4 skipped)
20/20 (40 skipped)
19686 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:16 0.4 s 1/2 (1 skipped)
1/2 (7 skipped)
19685 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:16 0.5 s 1/2
12/13
19684 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:16 0.4 s 1/2
19/20
19683 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:16 0.4 s 1/1 (1 skipped)
31/31 (1 skipped)
19682 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:15 1 s 1/1 (1 skipped)
7/7 (1 skipped)
19681 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:15 1 s 1/1 (1 skipped)
12/12 (1 skipped)
19680 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:15 1 s 1/1 (1 skipped)
12/12 (1 skipped)
19679 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:15 1 s 1/2
12/13
19678 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:15 1 s 1/1 (1 skipped)
12/12 (1 skipped)
19677 collect at PythonRDD.scala:195 collect at PythonRDD.scala:195 2026/10/16 09:40:15 8 s 1/1 (1 skipped)
1/1 (1 skipped)
19676 collect at PythonRDD.scala:195 collect at PythonRDD.scala:195 2026/10/16 09:40:14 8 s 1/1 (1 skipped)
5/5 (1 skipped)
19675 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:14 0.4 s 1/1 (2 skipped)
1/1 (6 skipped)
19674 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:14 0.5 s 1/2
5/6
19673 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:14 0.5 s 1/1 (1 skipped)
7/7 (1 skipped)
19672 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:14 83 ms 1/1 (1 skipped)
5/5 (1 skipped)
19671 count at <unknown>:0 count at <unknown>:0 2026/10/16 09:40:13 0.4 s 1/1 (2 skipped)
1/1 (6 skipped)
19670 count at <unknown>:0 count at <unknown>:0 2026/10/16 09:40:13 0.2 s 1/1 (1 skipped)
5/5 (1 skipped)
19669 count at <unknown>:0 count at <unknown>:0 2026/10/16 09:40:13 0.4 s 1/1 (1 skipped)
5/5 (1 skipped)
19668 count at <unknown>:0 count at <unknown>:0 2026/10/16 09:40:11 1 s 1/1
1/1
19667 javaToPython at <unknown>:0 javaToPython at <unknown>:0 2026/10/16 09:40:11 4 s 1/1 (1 skipped)
5/5 (1 skipped)
19666 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:11 1 s 1/1 (1 skipped)
1/1 (1 skipped)
19665 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:10 0.7 s 1/1 (1 skipped)
5/5 (1 skipped)
19664 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:10 0.7 s 1/1
1/1
19663 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:08 1 s 1/1 (1 skipped)
1/1 (1 skipped)
19662 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:07 0.7 s 1/1 (1 skipped)
10/10 (1 skipped)
19661 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:07 0.6 s 1/1
1/1
19660 collect at PythonRDD.scala:195 collect at PythonRDD.scala:195 2026/10/16 09:40:06 5 s 1/1 (6 skipped)
5/5 (84 skipped)
19659 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:06 0.8 s 1/1 (1 skipped)
1/1 (1 skipped)
19658 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:03 3 s 1/1 (1 skipped)
5/5 (1 skipped)
19657 foreachPartition at /opt/app/scheduler/jobs/memgraph_loader_job.py:2107 2026/10/16 09:40:03 0 ms 0/0
0/0
19656 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 1 s 1/1 (1 skipped)
5/5 (1 skipped)
19655 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 36 ms 1/1
1/1
19654 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 34 ms 1/1 (1 skipped)
5/5 (1 skipped)
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
19652 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 0.7 s 1/1 (1 skipped)
1/1 (1 skipped)
19651 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 2 s 1/1 (1 skipped)
5/5 (1 skipped)
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
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
19648 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:58 0.7 s 1/1 (1 skipped)
1/1 (1 skipped)
19647 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:57 2 s 1/1 (1 skipped)
5/5 (1 skipped)
19646 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:57 78 ms 1/1
1/1
19645 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:57 67 ms 1/1
1/1
19644 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:53 4 s 1/1 (1 skipped)
5/5 (1 skipped)
19643 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:48 5 s 1/1 (1 skipped)
5/5 (1 skipped)
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)
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)
19640 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 29 ms 1/1 (1 skipped)
5/5 (1 skipped)
19639 javaToPython at <unknown>:0 javaToPython at <unknown>:0 2026/10/16 09:39:47 19 s 1/5
22/62
19638 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 0.2 s 1/1
1/1
19637 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 09:39:47 5 s 1/2 (1 skipped)
1/2 (5 skipped)
19636 javaToPython at <unknown>:0 javaToPython at <unknown>:0 2026/10/16 09:39:47 1.0 s 1/1 (4 skipped)
22/22 (40 skipped)
19635 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 09:39:47 0.2 s 1/2 (1 skipped)
1/2 (5 skipped)
19634 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 09:39:44 3 s 1/1 (1 skipped)
10/10 (1 skipped)
19633 javaToPython at <unknown>:0 javaToPython at <unknown>:0 2026/10/16 09:39:44 3 s 1/2
5/6
19632 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 09:39:44 3 s 1/1 (1 skipped)
5/5 (1 skipped)
19631 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 09:39:44 3 s 1/1 (1 skipped)
10/10 (1 skipped)
19630 javaToPython at <unknown>:0 javaToPython at <unknown>:0 2026/10/16 09:39:44 3 s 1/1 (1 skipped)
5/5 (1 skipped)
19629 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 09:39:43 28 s 1/1
1/1
19628 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 09:39:43 28 s 1/1
1/1
19627 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:43 4 s 1/1 (6 skipped)
5/5 (84 skipped)
19626 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:42 0.8 s 1/2 (1 skipped)
1/2 (5 skipped)
19625 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:42 0.9 s 1/5
22/62
19624 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:41 0.7 s 1/1 (4 skipped)
22/22 (40 skipped)
19623 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:41 0.4 s 1/2 (1 skipped)
1/2 (5 skipped)
19622 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:41 0.8 s 1/1 (1 skipped)
5/5 (1 skipped)
19621 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:41 0.7 s 1/2
10/11
19620 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:41 0.6 s 1/1 (1 skipped)
5/5 (1 skipped)
19619 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:41 0.5 s 1/1 (1 skipped)
10/10 (1 skipped)
19618 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:41 0.4 s 1/1 (1 skipped)
5/5 (1 skipped)
19617 collect at PythonRDD.scala:195 collect at PythonRDD.scala:195 2026/10/16 09:39:40 3 s 1/1 (1 skipped)
1/1 (1 skipped)
19616 collect at PythonRDD.scala:195 collect at PythonRDD.scala:195 2026/10/16 09:39:39 0.9 s 1/1 (4 skipped)
1/1 (40 skipped)
19615 javaToPython at <unknown>:0 javaToPython at <unknown>:0 2026/10/16 09:39:38 0.8 s 1/1 (4 skipped)
20/20 (40 skipped)
19614 javaToPython at <unknown>:0 javaToPython at <unknown>:0 2026/10/16 09:39:37 0.7 s 1/2 (1 skipped)
1/2 (7 skipped)