Spark Jobs (?)

  • User: spark
  • Total Uptime: 2.9 h
  • Scheduling Mode: FAIR
  • Completed Jobs: 21602, only showing 902
Event Timeline

Completed Jobs (21602, only showing 902)

Job Id ▾ Description Submitted Duration Stages: Succeeded/Total Tasks (for all stages): Succeeded/Total
21601 jdbc at <unknown>:0 jdbc at <unknown>:0 2026/10/16 10:04:05 0.2 s 1/1 (2 skipped)
21/21 (1 skipped)
21600 count at <unknown>:0 count at <unknown>:0 2026/10/16 10:04:05 9 ms 1/1 (3 skipped)
1/1 (22 skipped)
21599 count at <unknown>:0 count at <unknown>:0 2026/10/16 10:04:05 88 ms 1/1 (2 skipped)
21/21 (1 skipped)
21598 collect at /opt/app/scheduler/jobs/dedup_job.py:386 collect at /opt/app/scheduler/jobs/dedup_job.py:386 2026/10/16 10:04:05 28 ms 1/1 (3 skipped)
1/1 (22 skipped)
21597 collect at /opt/app/scheduler/jobs/dedup_job.py:386 collect at /opt/app/scheduler/jobs/dedup_job.py:386 2026/10/16 10:04:05 0.1 s 1/1 (2 skipped)
21/21 (1 skipped)
21596 count at <unknown>:0 count at <unknown>:0 2026/10/16 10:04:05 7 ms 1/1 (3 skipped)
1/1 (22 skipped)
21595 count at <unknown>:0 count at <unknown>:0 2026/10/16 10:04:04 86 ms 1/1 (2 skipped)
21/21 (1 skipped)
21594 count at <unknown>:0 count at <unknown>:0 2026/10/16 10:04:04 0.1 s 1/1 (2 skipped)
21/21 (1 skipped)
21593 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 10:04:04 16 ms 1/1 (1 skipped)
1/1
21592 count at <unknown>:0 count at <unknown>:0 2026/10/16 10:04:04 0.3 s 1/1
1/1
21591 count at <unknown>:0 count at <unknown>:0 2026/10/16 10:04:04 0.3 s 1/1
1/1
21590 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 10:04:04 0.3 s 1/1
1/1
21589 count at <unknown>:0 count at <unknown>:0 2026/10/16 10:04:04 0.3 s 1/1
1/1
21588 count at <unknown>:0 count at <unknown>:0 2026/10/16 10:04:04 0.4 s 1/1
1/1
21587 count at <unknown>:0 count at <unknown>:0 2026/10/16 10:04:04 0.2 s 1/1
1/1
21586 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 10:04:04 0.1 s 1/1
1/1
21585 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 10:04:04 90 ms 1/1
1/1
21584 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 10:04:04 43 ms 1/1
1/1
21583 count at <unknown>:0 count at <unknown>:0 2026/10/16 10:04:03 6 ms 1/1 (1 skipped)
1/1 (1 skipped)
21582 count at <unknown>:0 count at <unknown>:0 2026/10/16 10:04:03 9 ms 1/1
1/1
21581 count at <unknown>:0 count at <unknown>:0 2026/10/16 10:04:03 7 ms 1/1 (1 skipped)
1/1 (1 skipped)
21580 count at <unknown>:0 count at <unknown>:0 2026/10/16 10:04:03 27 ms 1/1
1/1
21579 count at <unknown>:0 count at <unknown>:0 2026/10/16 10:04:03 86 ms 1/1
1/1
21578 count at <unknown>:0 count at <unknown>:0 2026/10/16 10:04:03 6 ms 1/1 (1 skipped)
1/1 (1 skipped)
21577 count at <unknown>:0 count at <unknown>:0 2026/10/16 10:04:03 7 ms 1/1
1/1
21576 count at <unknown>:0 count at <unknown>:0 2026/10/16 10:04:03 11 ms 1/1
1/1
21575 count at <unknown>:0 count at <unknown>:0 2026/10/16 10:04:03 7 ms 1/1 (1 skipped)
1/1 (1 skipped)
21574 count at <unknown>:0 count at <unknown>:0 2026/10/16 10:04:03 8 ms 1/1
1/1
21573 count at <unknown>:0 count at <unknown>:0 2026/10/16 10:04:03 0.4 s 1/1
1/1
21572 jdbc at <unknown>:0 jdbc at <unknown>:0 2026/10/16 09:53:42 0.2 s 1/1 (2 skipped)
21/21 (2 skipped)
21571 count at <unknown>:0 count at <unknown>:0 2026/10/16 09:53:41 8 ms 1/1 (3 skipped)
1/1 (23 skipped)
21570 count at <unknown>:0 count at <unknown>:0 2026/10/16 09:53:41 0.1 s 1/1 (2 skipped)
21/21 (2 skipped)
21569 collect at /opt/app/scheduler/jobs/dedup_job.py:386 collect at /opt/app/scheduler/jobs/dedup_job.py:386 2026/10/16 09:53:41 19 ms 1/1 (3 skipped)
1/1 (23 skipped)
21568 collect at /opt/app/scheduler/jobs/dedup_job.py:386 collect at /opt/app/scheduler/jobs/dedup_job.py:386 2026/10/16 09:53:41 0.4 s 1/1 (2 skipped)
21/21 (2 skipped)
21567 count at <unknown>:0 count at <unknown>:0 2026/10/16 09:53:40 90 ms 1/1 (3 skipped)
1/1 (23 skipped)
21566 count at <unknown>:0 count at <unknown>:0 2026/10/16 09:53:40 0.2 s 1/1 (2 skipped)
21/21 (2 skipped)
21565 count at <unknown>:0 count at <unknown>:0 2026/10/16 09:53:40 0.3 s 1/1 (2 skipped)
21/21 (2 skipped)
21564 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 09:53:40 31 ms 1/1 (1 skipped)
1/1 (1 skipped)
21563 count at <unknown>:0 count at <unknown>:0 2026/10/16 09:53:36 4 s 1/1
1/1
21562 count at <unknown>:0 count at <unknown>:0 2026/10/16 09:53:35 2 s 1/1
1/1
21561 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 09:53:35 13 ms 1/1 (1 skipped)
1/1 (1 skipped)
21560 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 09:53:35 62 ms 1/1 (1 skipped)
1/1 (1 skipped)
21559 count at <unknown>:0 count at <unknown>:0 2026/10/16 09:53:35 80 ms 1/1
1/1
21558 count at <unknown>:0 count at <unknown>:0 2026/10/16 09:53:35 0.4 s 1/1
1/1
21557 count at <unknown>:0 count at <unknown>:0 2026/10/16 09:53:35 0.4 s 1/1
1/1
21556 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 09:53:35 0.4 s 1/1
1/1
21555 count at <unknown>:0 count at <unknown>:0 2026/10/16 09:53:35 0.4 s 1/1
1/1
21554 count at <unknown>:0 count at <unknown>:0 2026/10/16 09:53:35 0.3 s 1/1
1/1
21553 count at <unknown>:0 count at <unknown>:0 2026/10/16 09:53:35 0.3 s 1/1
1/1
21552 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 09:53:35 0.1 s 1/1
1/1
21551 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 09:53:35 98 ms 1/1
1/1
21550 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 09:53:35 21 ms 1/1
1/1
21549 count at <unknown>:0 count at <unknown>:0 2026/10/16 09:53:34 7 ms 1/1 (1 skipped)
1/1 (1 skipped)
21548 count at <unknown>:0 count at <unknown>:0 2026/10/16 09:53:34 28 ms 1/1
1/1
21547 count at <unknown>:0 count at <unknown>:0 2026/10/16 09:53:34 8 ms 1/1 (1 skipped)
1/1 (1 skipped)
21546 count at <unknown>:0 count at <unknown>:0 2026/10/16 09:53:34 9 ms 1/1
1/1
21545 count at <unknown>:0 count at <unknown>:0 2026/10/16 09:53:34 0.1 s 1/1
1/1
21544 count at <unknown>:0 count at <unknown>:0 2026/10/16 09:53:34 7 ms 1/1 (1 skipped)
1/1 (1 skipped)
21543 count at <unknown>:0 count at <unknown>:0 2026/10/16 09:53:34 8 ms 1/1
1/1
21542 count at <unknown>:0 count at <unknown>:0 2026/10/16 09:53:34 27 ms 1/1
1/1
21541 count at <unknown>:0 count at <unknown>:0 2026/10/16 09:53:34 46 ms 1/1 (1 skipped)
1/1 (1 skipped)
21540 count at <unknown>:0 count at <unknown>:0 2026/10/16 09:53:34 16 ms 1/1
1/1
21539 count at <unknown>:0 count at <unknown>:0 2026/10/16 09:53:33 0.4 s 1/1
1/1
21538 collect at /opt/app/scheduler/jobs/memory_probe.py:76 collect at /opt/app/scheduler/jobs/memory_probe.py:76 2026/10/16 09:52:54 0.2 s 1/1
2/2
21537 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:52:52 0.9 s 1/1 (6 skipped)
1/1 (60 skipped)
21536 javaToPython at <unknown>:0 javaToPython at <unknown>:0 2026/10/16 09:52:52 0.7 s 1/5
22/38
21535 javaToPython at <unknown>:0 javaToPython at <unknown>:0 2026/10/16 09:52:52 0.4 s 1/1 (4 skipped)
22/22 (16 skipped)
21534 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 09:52:51 0.3 s 1/2
1/2
21533 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 09:52:51 0.3 s 1/1 (1 skipped)
2/2 (1 skipped)
21532 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 09:52:51 0.2 s 1/2
2/3
21531 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 09:52:51 0.2 s 1/2
1/2
21530 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 09:52:51 57 ms 1/1 (1 skipped)
1/1 (1 skipped)
21529 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:52:47 0.8 s 1/1 (4 skipped)
1/1 (16 skipped)
21528 javaToPython at <unknown>:0 javaToPython at <unknown>:0 2026/10/16 09:52:47 0.5 s 1/1 (4 skipped)
20/20 (16 skipped)
21527 javaToPython at <unknown>:0 javaToPython at <unknown>:0 2026/10/16 09:52:46 0.7 s 1/2 (1 skipped)
1/2 (3 skipped)
21526 javaToPython at <unknown>:0 javaToPython at <unknown>:0 2026/10/16 09:52:46 0.7 s 1/2
4/5
21525 javaToPython at <unknown>:0 javaToPython at <unknown>:0 2026/10/16 09:52:46 0.7 s 1/2
7/8
21524 javaToPython at <unknown>:0 javaToPython at <unknown>:0 2026/10/16 09:52:46 0.5 s 1/1 (1 skipped)
11/11 (1 skipped)
21523 javaToPython at <unknown>:0 javaToPython at <unknown>:0 2026/10/16 09:52:45 0.7 s 1/1 (1 skipped)
3/3 (1 skipped)
21522 javaToPython at <unknown>:0 javaToPython at <unknown>:0 2026/10/16 09:52:45 0.5 s 1/1 (1 skipped)
4/4 (1 skipped)
21521 javaToPython at <unknown>:0 javaToPython at <unknown>:0 2026/10/16 09:52:45 0.5 s 1/1 (1 skipped)
4/4 (1 skipped)
21520 javaToPython at <unknown>:0 javaToPython at <unknown>:0 2026/10/16 09:52:45 0.4 s 1/2
4/5
21519 javaToPython at <unknown>:0 javaToPython at <unknown>:0 2026/10/16 09:52:45 0.4 s 1/1 (1 skipped)
4/4 (1 skipped)
21518 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 09:52:45 0.4 s 1/2
1/2
21517 javaToPython at <unknown>:0 javaToPython at <unknown>:0 2026/10/16 09:52:45 0.3 s 1/1 (1 skipped)
3/3 (1 skipped)
21516 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 09:52:45 28 ms 1/1 (1 skipped)
1/1 (1 skipped)
21515 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:52:43 0.8 s 1/1 (1 skipped)
1/1 (1 skipped)
21514 javaToPython at <unknown>:0 javaToPython at <unknown>:0 2026/10/16 09:52:43 72 ms 1/1 (1 skipped)
1/1 (1 skipped)
21513 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 09:52:43 10 ms 1/1
1/1
21512 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:52:42 0.7 s 1/1 (1 skipped)
1/1 (1 skipped)
21511 javaToPython at <unknown>:0 javaToPython at <unknown>:0 2026/10/16 09:52:42 36 ms 1/1 (1 skipped)
2/2 (1 skipped)
21510 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 09:52:42 18 ms 1/1
1/1
21509 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:52:41 0.7 s 1/1 (1 skipped)
1/1 (1 skipped)
21508 javaToPython at <unknown>:0 javaToPython at <unknown>:0 2026/10/16 09:52:40 0.8 s 1/1 (1 skipped)
1/1 (1 skipped)
21507 foreachPartition at /opt/app/scheduler/jobs/memgraph_loader_job.py:2107 2026/10/16 09:52:40 0 ms 0/0
0/0
21506 javaToPython at <unknown>:0 javaToPython at <unknown>:0 2026/10/16 09:52:40 0.2 s 1/1 (1 skipped)
1/1 (1 skipped)
21505 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 09:52:40 24 ms 1/1
1/1
21504 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 09:52:40 15 ms 1/1
1/1
21503 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 09:52:40 12 ms 1/1 (1 skipped)
1/1 (1 skipped)
21502 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:52:39 0.7 s 1/1 (1 skipped)
1/1 (1 skipped)