Spark Jobs (?)

Event Timeline

Active Jobs (5)

Page:
Job Id ▾ Description Submitted Duration Stages: Succeeded/Total Tasks (for all stages): Succeeded/Total
14419 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 08:59:38 5 s 0/2
2/6 (2 running)
14417 collect at PythonRDD.scala:195 (kill) collect at PythonRDD.scala:195 2026/10/16 08:59:32 11 s 0/2
0/2
14416 collect at PythonRDD.scala:195 (kill) collect at PythonRDD.scala:195 2026/10/16 08:59:32 11 s 0/8
1/121
14389 collect at PythonRDD.scala:195 (kill) collect at PythonRDD.scala:195 2026/10/16 08:59:21 22 s 0/2
4/6
14032 collect at PythonRDD.scala:195 (kill) collect at PythonRDD.scala:195 2026/10/16 08:55:45 4.0 min 0/2
0/6
Page:

Completed Jobs (14415, only showing 915)

Job Id ▾ Description Submitted Duration Stages: Succeeded/Total Tasks (for all stages): Succeeded/Total
14418 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 08:59:32 6 s 1/1 (1 skipped)
5/5 (1 skipped)
14415 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 08:59:32 18 ms 1/1 (2 skipped)
1/1 (6 skipped)
14414 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 08:59:31 31 ms 1/1 (1 skipped)
5/5 (1 skipped)
14413 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 08:59:31 66 ms 1/1 (1 skipped)
5/5 (1 skipped)
14412 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 08:59:31 0.1 s 1/1
1/1
14411 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 08:59:27 4 s 1/1 (7 skipped)
5/5 (116 skipped)
14410 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 08:59:26 0.8 s 1/2 (1 skipped)
1/2 (5 skipped)
14409 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 08:59:26 0.9 s 1/2 (1 skipped)
1/2 (5 skipped)
14408 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 08:59:26 0.9 s 1/6
32/84
14407 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 08:59:26 0.6 s 1/1 (5 skipped)
32/32 (52 skipped)
14406 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 08:59:26 0.4 s 1/1 (1 skipped)
5/5 (1 skipped)
14405 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 08:59:26 0.3 s 1/1 (1 skipped)
5/5 (1 skipped)
14404 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 08:59:26 0.3 s 1/1 (1 skipped)
10/10 (1 skipped)
14403 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 08:59:26 0.1 s 1/2
10/11
14402 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 08:59:26 0.1 s 1/1 (1 skipped)
5/5 (1 skipped)
14401 javaToPython at <unknown>:0 javaToPython at <unknown>:0 2026/10/16 08:59:26 6 s 1/6
32/84
14400 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 08:59:26 6 s 1/2 (1 skipped)
1/2 (5 skipped)
14399 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 08:59:26 6 s 1/2 (1 skipped)
1/2 (5 skipped)
14398 javaToPython at <unknown>:0 javaToPython at <unknown>:0 2026/10/16 08:59:25 6 s 1/1 (5 skipped)
32/32 (52 skipped)
14397 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 08:59:25 0.6 s 1/1 (1 skipped)
10/10 (1 skipped)
14396 javaToPython at <unknown>:0 javaToPython at <unknown>:0 2026/10/16 08:59:25 0.6 s 1/1 (1 skipped)
5/5 (1 skipped)
14395 javaToPython at <unknown>:0 javaToPython at <unknown>:0 2026/10/16 08:59:25 0.6 s 1/1 (1 skipped)
5/5 (1 skipped)
14394 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 08:59:25 0.5 s 1/2
5/6
14393 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 08:59:25 0.5 s 1/1 (1 skipped)
10/10 (1 skipped)
14392 javaToPython at <unknown>:0 javaToPython at <unknown>:0 2026/10/16 08:59:24 8 s 1/1 (1 skipped)
5/5 (1 skipped)
14391 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 08:59:23 1 s 1/1
1/1
14390 collect at PythonRDD.scala:195 collect at PythonRDD.scala:195 2026/10/16 08:59:21 2 s 1/1 (1 skipped)
1/1 (1 skipped)
14388 javaToPython at <unknown>:0 javaToPython at <unknown>:0 2026/10/16 08:59:20 1 s 1/1 (1 skipped)
10/10 (1 skipped)
14387 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 08:59:18 1 s 1/1 (5 skipped)
1/1 (52 skipped)
14386 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 08:59:18 1 s 1/1
1/1
14385 collect at PythonRDD.scala:195 collect at PythonRDD.scala:195 2026/10/16 08:59:17 2 s 1/1 (5 skipped)
1/1 (52 skipped)
14384 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 08:59:17 1.0 s 1/1 (5 skipped)
30/30 (52 skipped)
14383 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 08:59:17 0.4 s 1/2 (1 skipped)
1/2 (7 skipped)
14382 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 08:59:17 0.4 s 1/2
12/13
14381 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 08:59:17 0.4 s 1/2
19/20
14380 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 08:59:17 0.3 s 1/1 (1 skipped)
31/31 (1 skipped)
14379 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 08:59:16 0.4 s 1/1 (1 skipped)
7/7 (1 skipped)
14378 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 08:59:16 0.3 s 1/1 (1 skipped)
12/12 (1 skipped)
14377 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 08:59:16 0.3 s 1/1 (1 skipped)
12/12 (1 skipped)
14376 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 08:59:16 0.3 s 1/2
12/13
14375 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 08:59:16 0.2 s 1/1 (1 skipped)
12/12 (1 skipped)
14374 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 08:59:16 16 ms 1/1 (2 skipped)
1/1 (6 skipped)
14373 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 08:59:16 0.2 s 1/2
5/6
14372 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 08:59:16 0.2 s 1/1 (1 skipped)
7/7 (1 skipped)
14371 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 08:59:16 24 ms 1/1 (1 skipped)
5/5 (1 skipped)
14370 collect at PythonRDD.scala:195 collect at PythonRDD.scala:195 2026/10/16 08:59:16 2 s 1/1 (1 skipped)
1/1 (1 skipped)
14369 javaToPython at <unknown>:0 javaToPython at <unknown>:0 2026/10/16 08:59:15 2 s 1/1 (5 skipped)
30/30 (52 skipped)
14368 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 08:59:14 0.7 s 1/1 (1 skipped)
1/1 (1 skipped)
14367 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 08:59:14 43 ms 1/1 (1 skipped)
5/5 (1 skipped)
14366 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 08:59:14 20 ms 1/1
1/1
14365 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 08:59:13 0.7 s 1/1 (1 skipped)
1/1 (1 skipped)
14364 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 08:59:13 61 ms 1/1 (1 skipped)
10/10 (1 skipped)
14363 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 08:59:13 15 ms 1/1
1/1
14362 javaToPython at <unknown>:0 javaToPython at <unknown>:0 2026/10/16 08:59:13 2 s 1/2 (1 skipped)
1/2 (7 skipped)
14361 javaToPython at <unknown>:0 javaToPython at <unknown>:0 2026/10/16 08:59:13 2 s 1/2
12/13
14360 javaToPython at <unknown>:0 javaToPython at <unknown>:0 2026/10/16 08:59:12 3 s 1/2
19/20
14359 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 08:59:12 0.7 s 1/1 (1 skipped)
1/1 (1 skipped)
14358 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 08:59:09 3 s 1/1 (1 skipped)
5/5 (1 skipped)
14357 foreachPartition at /opt/app/scheduler/jobs/memgraph_loader_job.py:2107 2026/10/16 08:59:09 0 ms 0/0
0/0
14356 javaToPython at <unknown>:0 javaToPython at <unknown>:0 2026/10/16 08:59:08 6 s 1/1 (1 skipped)
31/31 (1 skipped)
14355 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 08:59:08 1 s 1/1 (1 skipped)
5/5 (1 skipped)
14354 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 08:59:08 31 ms 1/1
1/1
14353 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 08:59:08 26 ms 1/1 (1 skipped)
5/5 (1 skipped)
14352 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 08:59:08 8 ms 1/1
1/1
14351 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 08:59:07 0.7 s 1/1 (1 skipped)
1/1 (1 skipped)
14350 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 08:59:06 1 s 1/1 (1 skipped)
5/5 (1 skipped)
14349 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 08:59:06 66 ms 1/1
1/1
14348 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 08:59:06 61 ms 1/1
1/1
14347 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 08:59:05 0.7 s 1/1 (1 skipped)
1/1 (1 skipped)
14346 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 08:59:03 2 s 1/1 (1 skipped)
5/5 (1 skipped)
14345 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 08:59:03 21 ms 1/1
1/1
14344 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 08:59:03 13 ms 1/1
1/1
14343 javaToPython at <unknown>:0 javaToPython at <unknown>:0 2026/10/16 08:58:59 14 s 1/1 (1 skipped)
7/7 (1 skipped)
14342 javaToPython at <unknown>:0 javaToPython at <unknown>:0 2026/10/16 08:58:59 14 s 1/1 (1 skipped)
12/12 (1 skipped)
14341 javaToPython at <unknown>:0 javaToPython at <unknown>:0 2026/10/16 08:58:59 13 s 1/1 (1 skipped)
12/12 (1 skipped)
14340 javaToPython at <unknown>:0 javaToPython at <unknown>:0 2026/10/16 08:58:59 9 s 1/2
12/13
14339 javaToPython at <unknown>:0 javaToPython at <unknown>:0 2026/10/16 08:58:59 7 s 1/1 (1 skipped)
12/12 (1 skipped)
14338 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 08:58:59 4 s 1/1 (1 skipped)
5/5 (1 skipped)
14337 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 08:58:54 5 s 1/1 (1 skipped)
5/5 (1 skipped)
14336 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 08:58:54 5 s 1/1 (2 skipped)
1/1 (6 skipped)
14335 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 08:58:53 91 ms 1/1 (2 skipped)
1/1 (6 skipped)
14334 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 08:58:53 30 ms 1/1 (1 skipped)
5/5 (1 skipped)
14333 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 08:58:53 38 ms 1/1 (1 skipped)
5/5 (1 skipped)
14332 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 08:58:53 0.7 s 1/1
1/1
14331 javaToPython at <unknown>:0 javaToPython at <unknown>:0 2026/10/16 08:58:53 1 s 1/2
5/6
14330 javaToPython at <unknown>:0 javaToPython at <unknown>:0 2026/10/16 08:58:53 1 s 1/1 (1 skipped)
7/7 (1 skipped)
14329 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 08:58:48 4 s 1/1 (7 skipped)
5/5 (116 skipped)
14328 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 08:58:48 4 s 1/1 (1 skipped)
5/5 (1 skipped)
14327 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 08:58:47 1 s 1/2 (1 skipped)
1/2 (5 skipped)
14326 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 08:58:47 1 s 1/2 (1 skipped)
1/2 (5 skipped)
14325 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 08:58:47 1 s 1/6
32/84
14324 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 08:58:47 0.9 s 1/2 (4 skipped)
32/33 (51 skipped)
14323 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 08:58:46 1 s 1/1 (1 skipped)
5/5 (1 skipped)
14322 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 08:58:46 1 s 1/1 (1 skipped)
5/5 (1 skipped)
14321 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 08:58:46 0.9 s 1/1 (1 skipped)
5/5 (1 skipped)
14320 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 08:58:46 0.8 s 1/1 (1 skipped)
10/10 (1 skipped)
14319 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 08:58:46 0.7 s 1/1 (1 skipped)
10/10 (1 skipped)
14318 javaToPython at <unknown>:0 javaToPython at <unknown>:0 2026/10/16 08:58:46 30 s 1/1 (1 skipped)
5/5 (1 skipped)
14317 collect at PythonRDD.scala:195 collect at PythonRDD.scala:195 2026/10/16 08:58:45 1 s 1/1 (1 skipped)
1/1 (1 skipped)
14316 collect at PythonRDD.scala:195 collect at PythonRDD.scala:195 2026/10/16 08:58:45 0.7 s 1/1 (1 skipped)
1/1 (1 skipped)