Spark Jobs (?)

Event Timeline

Active Jobs (4)

Page:
Job Id ▾ Description Submitted Duration Stages: Succeeded/Total Tasks (for all stages): Succeeded/Total
9719 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 (kill) $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 08:23:17 0.4 s 0/1
0/1
9718 javaToPython at <unknown>:0 (kill) javaToPython at <unknown>:0 2026/10/16 08:23:17 0.4 s 0/1
0/1
9717 javaToPython at <unknown>:0 (kill) javaToPython at <unknown>:0 2026/10/16 08:23:17 0.4 s 0/1
0/1
9716 javaToPython at <unknown>:0 (kill) javaToPython at <unknown>:0 2026/10/16 08:23:17 0.4 s 0/1
0/1 (1 running)
Page:

Completed Jobs (9716, only showing 916)

Job Id ▴ Description Submitted Duration Stages: Succeeded/Total Tasks (for all stages): Succeeded/Total
8800 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 08:19:51 2 s 1/1 (1 skipped)
1/1 (1 skipped)
8801 first at /opt/app/scheduler/jobs/batch_table_copy_job.py:169 2026/10/16 08:19:51 2 s 1/1
1/1
8802 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 08:19:52 0.6 s 1/1
1/1
8803 count at <unknown>:0 2026/10/16 08:19:52 0.6 s 1/1 (1 skipped)
1/1 (1 skipped)
8804 count at <unknown>:0 2026/10/16 08:19:52 0.6 s 1/1 (1 skipped)
1/1 (1 skipped)
8805 first at /opt/app/scheduler/jobs/batch_table_copy_job.py:169 2026/10/16 08:19:53 0.6 s 1/1
1/1
8806 first at /opt/app/scheduler/jobs/batch_table_copy_job.py:169 2026/10/16 08:19:53 0.5 s 1/1
1/1
8807 count at <unknown>:0 2026/10/16 08:19:53 3 s 1/1
1/1
8808 count at <unknown>:0 count at <unknown>:0 2026/10/16 08:19:53 5 s 1/1
1/1
8809 first at /opt/app/scheduler/jobs/batch_table_copy_job.py:169 first at /opt/app/scheduler/jobs/batch_table_copy_job.py:169 2026/10/16 08:19:53 5 s 1/1
1/1
8810 javaToPython at <unknown>:0 javaToPython at <unknown>:0 2026/10/16 08:19:53 5 s 1/1
1/1
8811 jdbc at <unknown>:0 jdbc at <unknown>:0 2026/10/16 08:19:53 6 s 1/1
1/1
8812 jdbc at <unknown>:0 jdbc at <unknown>:0 2026/10/16 08:19:53 7 s 1/1
1/1
8813 first at /opt/app/scheduler/jobs/batch_table_copy_job.py:169 first at /opt/app/scheduler/jobs/batch_table_copy_job.py:169 2026/10/16 08:19:53 7 s 1/1 (1 skipped)
1/1 (1 skipped)
8814 first at /opt/app/scheduler/jobs/batch_table_copy_job.py:169 first at /opt/app/scheduler/jobs/batch_table_copy_job.py:169 2026/10/16 08:19:53 7 s 1/1
1/1
8815 first at /opt/app/scheduler/jobs/batch_table_copy_job.py:169 first at /opt/app/scheduler/jobs/batch_table_copy_job.py:169 2026/10/16 08:19:58 2 s 1/1 (1 skipped)
1/1 (1 skipped)
8816 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 08:19:58 2 s 1/1 (1 skipped)
1/1 (1 skipped)
8817 collect at PythonRDD.scala:195 collect at PythonRDD.scala:195 2026/10/16 08:19:58 3 s 1/1
1/1
8818 count at <unknown>:0 count at <unknown>:0 2026/10/16 08:19:59 2 s 1/1
1/1
8819 first at /opt/app/scheduler/jobs/batch_table_copy_job.py:169 first at /opt/app/scheduler/jobs/batch_table_copy_job.py:169 2026/10/16 08:20:00 2 s 1/1
1/1
8820 count at <unknown>:0 count at <unknown>:0 2026/10/16 08:20:00 2 s 1/1
1/1
8821 first at /opt/app/scheduler/jobs/batch_table_copy_job.py:169 first at /opt/app/scheduler/jobs/batch_table_copy_job.py:169 2026/10/16 08:20:00 2 s 1/1
1/1
8822 first at /opt/app/scheduler/jobs/batch_table_copy_job.py:169 first at /opt/app/scheduler/jobs/batch_table_copy_job.py:169 2026/10/16 08:20:00 2 s 1/1
1/1
8823 count at <unknown>:0 count at <unknown>:0 2026/10/16 08:20:00 3 s 1/1 (2 skipped)
21/21 (2 skipped)
8824 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 08:20:01 2 s 1/1
1/1
8825 count at <unknown>:0 count at <unknown>:0 2026/10/16 08:20:02 2 s 1/1
1/1
8826 first at /opt/app/scheduler/jobs/batch_table_copy_job.py:169 first at /opt/app/scheduler/jobs/batch_table_copy_job.py:169 2026/10/16 08:20:02 1 s 1/1
1/1
8827 count at <unknown>:0 count at <unknown>:0 2026/10/16 08:20:02 1 s 1/1
1/1
8828 first at /opt/app/scheduler/jobs/batch_table_copy_job.py:169 first at /opt/app/scheduler/jobs/batch_table_copy_job.py:169 2026/10/16 08:20:02 1.0 s 1/1
1/1
8829 first at /opt/app/scheduler/jobs/batch_table_copy_job.py:169 first at /opt/app/scheduler/jobs/batch_table_copy_job.py:169 2026/10/16 08:20:03 0.7 s 1/1
1/1
8830 collect at PythonRDD.scala:195 collect at PythonRDD.scala:195 2026/10/16 08:20:03 0.8 s 1/1
2/2
8831 count at <unknown>:0 count at <unknown>:0 2026/10/16 08:20:03 0.9 s 1/1 (2 skipped)
21/21 (2 skipped)
8832 javaToPython at <unknown>:0 javaToPython at <unknown>:0 2026/10/16 08:20:03 0.9 s 1/1
1/1
8833 count at <unknown>:0 count at <unknown>:0 2026/10/16 08:20:03 0.9 s 1/1 (1 skipped)
1/1 (1 skipped)
8834 count at <unknown>:0 count at <unknown>:0 2026/10/16 08:20:03 0.8 s 1/1 (1 skipped)
1/1 (1 skipped)
8835 first at /opt/app/scheduler/jobs/batch_table_copy_job.py:169 first at /opt/app/scheduler/jobs/batch_table_copy_job.py:169 2026/10/16 08:20:03 0.8 s 1/1
1/1
8836 first at /opt/app/scheduler/jobs/batch_table_copy_job.py:169 first at /opt/app/scheduler/jobs/batch_table_copy_job.py:169 2026/10/16 08:20:03 0.8 s 1/1
1/1
8837 first at /opt/app/scheduler/jobs/batch_table_copy_job.py:169 first at /opt/app/scheduler/jobs/batch_table_copy_job.py:169 2026/10/16 08:20:03 0.9 s 1/1
1/1
8838 count at <unknown>:0 count at <unknown>:0 2026/10/16 08:20:04 0.3 s 1/1 (3 skipped)
1/1 (23 skipped)
8839 collect at PythonRDD.scala:195 collect at PythonRDD.scala:195 2026/10/16 08:20:04 1 s 1/1
1/1
8840 jdbc at <unknown>:0 jdbc at <unknown>:0 2026/10/16 08:20:04 2 s 1/1
1/1
8841 jdbc at <unknown>:0 jdbc at <unknown>:0 2026/10/16 08:20:04 2 s 1/1
1/1
8842 first at /opt/app/scheduler/jobs/batch_table_copy_job.py:169 first at /opt/app/scheduler/jobs/batch_table_copy_job.py:169 2026/10/16 08:20:04 2 s 1/1
1/1
8843 first at /opt/app/scheduler/jobs/batch_table_copy_job.py:169 first at /opt/app/scheduler/jobs/batch_table_copy_job.py:169 2026/10/16 08:20:04 2 s 1/1
1/1
8844 first at /opt/app/scheduler/jobs/batch_table_copy_job.py:169 first at /opt/app/scheduler/jobs/batch_table_copy_job.py:169 2026/10/16 08:20:04 2 s 1/1
1/1
8845 collectToPython at <unknown>:0 collectToPython at <unknown>:0 2026/10/16 08:20:04 3 s 1/1 (2 skipped)
21/21 (2 skipped)
8846 count at <unknown>:0 count at <unknown>:0 2026/10/16 08:20:06 1 s 1/1
1/1
8847 javaToPython at <unknown>:0 javaToPython at <unknown>:0 2026/10/16 08:20:06 2 s 1/1
1/1
8848 javaToPython at <unknown>:0 javaToPython at <unknown>:0 2026/10/16 08:20:06 2 s 1/1
1/1
8849 count at <unknown>:0 count at <unknown>:0 2026/10/16 08:20:06 1 s 1/1
1/1
8850 first at /opt/app/scheduler/jobs/batch_table_copy_job.py:169 first at /opt/app/scheduler/jobs/batch_table_copy_job.py:169 2026/10/16 08:20:06 2 s 1/1
1/1
8851 first at /opt/app/scheduler/jobs/batch_table_copy_job.py:169 first at /opt/app/scheduler/jobs/batch_table_copy_job.py:169 2026/10/16 08:20:06 2 s 1/1
1/1
8852 first at /opt/app/scheduler/jobs/batch_table_copy_job.py:169 first at /opt/app/scheduler/jobs/batch_table_copy_job.py:169 2026/10/16 08:20:07 1 s 1/1
1/1
8853 collectToPython at <unknown>:0 collectToPython at <unknown>:0 2026/10/16 08:20:07 1.0 s 1/1 (3 skipped)
1/1 (23 skipped)
8854 count at <unknown>:0 count at <unknown>:0 2026/10/16 08:20:07 0.8 s 1/1
1/1
8855 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 $anonfun$withThreadLocalCaptured$1 at <unknown>:0 2026/10/16 08:20:07 0.7 s 1/1 (1 skipped)
1/1 (1 skipped)
8856 count at <unknown>:0 count at <unknown>:0 2026/10/16 08:20:08 0.5 s 1/1
1/1
8857 first at /opt/app/scheduler/jobs/batch_table_copy_job.py:169 first at /opt/app/scheduler/jobs/batch_table_copy_job.py:169 2026/10/16 08:20:08 0.3 s 1/1
1/1
8858 first at /opt/app/scheduler/jobs/batch_table_copy_job.py:169 first at /opt/app/scheduler/jobs/batch_table_copy_job.py:169 2026/10/16 08:20:08 0.2 s 1/1 (1 skipped)
1/1 (1 skipped)
8859 first at /opt/app/scheduler/jobs/batch_table_copy_job.py:169 first at /opt/app/scheduler/jobs/batch_table_copy_job.py:169 2026/10/16 08:20:08 0.2 s 1/1 (1 skipped)
1/1 (1 skipped)
8860 count at <unknown>:0 count at <unknown>:0 2026/10/16 08:20:08 0.2 s 1/1 (1 skipped)
1/1 (1 skipped)
8861 count at <unknown>:0 count at <unknown>:0 2026/10/16 08:20:08 0.6 s 1/1 (2 skipped)
21/21 (2 skipped)
8862 javaToPython at <unknown>:0 javaToPython at <unknown>:0 2026/10/16 08:20:08 0.6 s 1/1
1/1
8863 count at <unknown>:0 count at <unknown>:0 2026/10/16 08:20:08 0.6 s 1/1 (1 skipped)
1/1 (1 skipped)
8864 first at /opt/app/scheduler/jobs/batch_table_copy_job.py:169 first at /opt/app/scheduler/jobs/batch_table_copy_job.py:169 2026/10/16 08:20:08 0.6 s 1/1 (1 skipped)
1/1 (1 skipped)
8865 first at /opt/app/scheduler/jobs/batch_table_copy_job.py:169 first at /opt/app/scheduler/jobs/batch_table_copy_job.py:169 2026/10/16 08:20:08 0.8 s 1/1
1/1
8866 first at /opt/app/scheduler/jobs/batch_table_copy_job.py:169 first at /opt/app/scheduler/jobs/batch_table_copy_job.py:169 2026/10/16 08:20:08 1.0 s 1/1
1/1
8867 jdbc at <unknown>:0 jdbc at <unknown>:0 2026/10/16 08:20:08 2 s 1/1
1/1
8868 count at <unknown>:0 count at <unknown>:0 2026/10/16 08:20:09 1 s 1/1 (3 skipped)
1/1 (23 skipped)
8869 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:20:09 2 s 1/1
1/1
8870 jdbc at <unknown>:0 jdbc at <unknown>:0 2026/10/16 08:20:09 3 s 1/1
1/1
8871 first at /opt/app/scheduler/jobs/batch_table_copy_job.py:169 first at /opt/app/scheduler/jobs/batch_table_copy_job.py:169 2026/10/16 08:20:09 3 s 1/1
1/1
8872 first at /opt/app/scheduler/jobs/batch_table_copy_job.py:169 first at /opt/app/scheduler/jobs/batch_table_copy_job.py:169 2026/10/16 08:20:09 3 s 1/1
1/1
8873 first at /opt/app/scheduler/jobs/batch_table_copy_job.py:169 first at /opt/app/scheduler/jobs/batch_table_copy_job.py:169 2026/10/16 08:20:10 3 s 1/1
1/1
8874 count at <unknown>:0 count at <unknown>:0 2026/10/16 08:20:10 2 s 1/1
1/1
8875 jdbc at <unknown>:0 jdbc at <unknown>:0 2026/10/16 08:20:10 3 s 1/1 (2 skipped)
21/21 (2 skipped)
8876 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:20:11 2 s 1/1
1/1
8877 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:20:11 2 s 1/1
1/1
8878 count at <unknown>:0 count at <unknown>:0 2026/10/16 08:20:12 2 s 1/1
1/1
8879 first at /opt/app/scheduler/jobs/batch_table_copy_job.py:169 first at /opt/app/scheduler/jobs/batch_table_copy_job.py:169 2026/10/16 08:20:12 2 s 1/1
1/1
8880 first at /opt/app/scheduler/jobs/batch_table_copy_job.py:169 first at /opt/app/scheduler/jobs/batch_table_copy_job.py:169 2026/10/16 08:20:12 2 s 1/1
1/1
8881 count at <unknown>:0 count at <unknown>:0 2026/10/16 08:20:12 1 s 1/1
1/1
8882 first at /opt/app/scheduler/jobs/batch_table_copy_job.py:169 first at /opt/app/scheduler/jobs/batch_table_copy_job.py:169 2026/10/16 08:20:13 1 s 1/1
1/1
8883 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:20:13 1 s 1/1
1/1
8884 count at <unknown>:0 count at <unknown>:0 2026/10/16 08:20:14 0.9 s 1/1
1/1
8885 first at /opt/app/scheduler/jobs/batch_table_copy_job.py:169 first at /opt/app/scheduler/jobs/batch_table_copy_job.py:169 2026/10/16 08:20:14 0.7 s 1/1 (1 skipped)
1/1 (1 skipped)
8886 count at <unknown>:0 count at <unknown>:0 2026/10/16 08:20:14 0.8 s 1/1 (1 skipped)
1/1 (1 skipped)
8887 first at /opt/app/scheduler/jobs/batch_table_copy_job.py:182 first at /opt/app/scheduler/jobs/batch_table_copy_job.py:182 2026/10/16 08:20:14 0.9 s 1/1
1/1
8888 first at /opt/app/scheduler/jobs/batch_table_copy_job.py:169 first at /opt/app/scheduler/jobs/batch_table_copy_job.py:169 2026/10/16 08:20:14 0.6 s 1/1
1/1
8889 count at <unknown>:0 count at <unknown>:0 2026/10/16 08:20:14 0.2 s 1/1 (1 skipped)
1/1 (1 skipped)
8890 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:20:14 0.9 s 1/1
1/1
8891 first at /opt/app/scheduler/jobs/batch_table_copy_job.py:169 first at /opt/app/scheduler/jobs/batch_table_copy_job.py:169 2026/10/16 08:20:14 1 s 1/1
1/1
8892 jdbc at <unknown>:0 jdbc at <unknown>:0 2026/10/16 08:20:14 2 s 1/1
1/1
8893 first at /opt/app/scheduler/jobs/batch_table_copy_job.py:169 first at /opt/app/scheduler/jobs/batch_table_copy_job.py:169 2026/10/16 08:20:15 2 s 1/1 (1 skipped)
1/1 (1 skipped)
8894 first at /opt/app/scheduler/jobs/batch_table_copy_job.py:182 first at /opt/app/scheduler/jobs/batch_table_copy_job.py:182 2026/10/16 08:20:15 2 s 1/1
1/1
8895 jdbc at <unknown>:0 jdbc at <unknown>:0 2026/10/16 08:20:15 3 s 1/1
1/1
8896 javaToPython at <unknown>:0 javaToPython at <unknown>:0 2026/10/16 08:20:15 3 s 1/1
1/1
8897 first at /opt/app/scheduler/jobs/batch_table_copy_job.py:169 first at /opt/app/scheduler/jobs/batch_table_copy_job.py:169 2026/10/16 08:20:16 2 s 1/1
1/1
8898 first at /opt/app/scheduler/jobs/batch_table_copy_job.py:182 first at /opt/app/scheduler/jobs/batch_table_copy_job.py:182 2026/10/16 08:20:17 2 s 1/1
1/1
8899 count at <unknown>:0 count at <unknown>:0 2026/10/16 08:20:17 2 s 1/1
1/1