Spark Jobs (?)

  • User: spark
  • Total Uptime: 16.9 h
  • Scheduling Mode: FIFO
  • Completed Jobs: 2033, only showing 933
Event Timeline

Completed Jobs (2033, only showing 933)

Job Id (Job Group) ▾ Description Submitted Duration Stages: Succeeded/Total Tasks (for all stages): Succeeded/Total
2032 (dfea9fd6-ec85-4cdf-853d-dfa79705db20) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = dfea9fd6-ec85-4cdf-853d-dfa79705db20 batch = 14246 start at NativeMethodAccessorImpl.java:0 2026/06/27 14:16:32 4 s 1/1
3/3
2031 (da7db828-95a1-45a5-b0f8-6881440c4ddd) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = da7db828-95a1-45a5-b0f8-6881440c4ddd batch = 14245 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/27 14:16:32 2 s 1/1
3/3
2030 (dfea9fd6-ec85-4cdf-853d-dfa79705db20) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = dfea9fd6-ec85-4cdf-853d-dfa79705db20 batch = 14245 start at NativeMethodAccessorImpl.java:0 2026/06/27 14:15:32 5 s 1/1
3/3
2029 (da7db828-95a1-45a5-b0f8-6881440c4ddd) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = da7db828-95a1-45a5-b0f8-6881440c4ddd batch = 14244 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/27 14:15:31 2 s 1/1
3/3
2028 (dfea9fd6-ec85-4cdf-853d-dfa79705db20) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = dfea9fd6-ec85-4cdf-853d-dfa79705db20 batch = 14244 start at NativeMethodAccessorImpl.java:0 2026/06/27 14:14:32 5 s 1/1
3/3
2027 (da7db828-95a1-45a5-b0f8-6881440c4ddd) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = da7db828-95a1-45a5-b0f8-6881440c4ddd batch = 14243 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/27 14:14:32 2 s 1/1
3/3
2026 (dfea9fd6-ec85-4cdf-853d-dfa79705db20) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = dfea9fd6-ec85-4cdf-853d-dfa79705db20 batch = 14243 start at NativeMethodAccessorImpl.java:0 2026/06/27 14:13:32 5 s 1/1
3/3
2025 (da7db828-95a1-45a5-b0f8-6881440c4ddd) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = da7db828-95a1-45a5-b0f8-6881440c4ddd batch = 14242 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/27 14:13:32 2 s 1/1
3/3
2024 (da7db828-95a1-45a5-b0f8-6881440c4ddd) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = da7db828-95a1-45a5-b0f8-6881440c4ddd batch = 14241 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/27 14:12:32 5 s 1/1
3/3
2023 (dfea9fd6-ec85-4cdf-853d-dfa79705db20) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = dfea9fd6-ec85-4cdf-853d-dfa79705db20 batch = 14242 start at NativeMethodAccessorImpl.java:0 2026/06/27 14:12:32 4 s 1/1
3/3
2022 (dfea9fd6-ec85-4cdf-853d-dfa79705db20) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = dfea9fd6-ec85-4cdf-853d-dfa79705db20 batch = 14241 start at NativeMethodAccessorImpl.java:0 2026/06/27 14:11:32 5 s 1/1
3/3
2021 (da7db828-95a1-45a5-b0f8-6881440c4ddd) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = da7db828-95a1-45a5-b0f8-6881440c4ddd batch = 14240 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/27 14:11:31 2 s 1/1
3/3
2020 (da7db828-95a1-45a5-b0f8-6881440c4ddd) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = da7db828-95a1-45a5-b0f8-6881440c4ddd batch = 14239 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/27 14:10:32 5 s 1/1
3/3
2019 (dfea9fd6-ec85-4cdf-853d-dfa79705db20) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = dfea9fd6-ec85-4cdf-853d-dfa79705db20 batch = 14240 start at NativeMethodAccessorImpl.java:0 2026/06/27 14:10:32 3 s 1/1
3/3
2018 (da7db828-95a1-45a5-b0f8-6881440c4ddd) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = da7db828-95a1-45a5-b0f8-6881440c4ddd batch = 14238 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/27 14:09:32 5 s 1/1
3/3
2017 (dfea9fd6-ec85-4cdf-853d-dfa79705db20) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = dfea9fd6-ec85-4cdf-853d-dfa79705db20 batch = 14239 start at NativeMethodAccessorImpl.java:0 2026/06/27 14:09:32 3 s 1/1
3/3
2016 (dfea9fd6-ec85-4cdf-853d-dfa79705db20) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = dfea9fd6-ec85-4cdf-853d-dfa79705db20 batch = 14238 start at NativeMethodAccessorImpl.java:0 2026/06/27 14:08:32 5 s 1/1
3/3
2015 (da7db828-95a1-45a5-b0f8-6881440c4ddd) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = da7db828-95a1-45a5-b0f8-6881440c4ddd batch = 14237 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/27 14:08:32 2 s 1/1
3/3
2014 (dfea9fd6-ec85-4cdf-853d-dfa79705db20) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = dfea9fd6-ec85-4cdf-853d-dfa79705db20 batch = 14237 start at NativeMethodAccessorImpl.java:0 2026/06/27 14:07:32 5 s 1/1
3/3
2013 (da7db828-95a1-45a5-b0f8-6881440c4ddd) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = da7db828-95a1-45a5-b0f8-6881440c4ddd batch = 14236 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/27 14:07:31 2 s 1/1
3/3
2012 (dfea9fd6-ec85-4cdf-853d-dfa79705db20) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = dfea9fd6-ec85-4cdf-853d-dfa79705db20 batch = 14236 start at NativeMethodAccessorImpl.java:0 2026/06/27 14:06:32 5 s 1/1
3/3
2011 (da7db828-95a1-45a5-b0f8-6881440c4ddd) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = da7db828-95a1-45a5-b0f8-6881440c4ddd batch = 14235 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/27 14:06:32 2 s 1/1
3/3
2010 (da7db828-95a1-45a5-b0f8-6881440c4ddd) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = da7db828-95a1-45a5-b0f8-6881440c4ddd batch = 14234 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/27 14:05:32 6 s 1/1
3/3
2009 (dfea9fd6-ec85-4cdf-853d-dfa79705db20) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = dfea9fd6-ec85-4cdf-853d-dfa79705db20 batch = 14235 start at NativeMethodAccessorImpl.java:0 2026/06/27 14:05:31 4 s 1/1
3/3
2008 (dfea9fd6-ec85-4cdf-853d-dfa79705db20) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = dfea9fd6-ec85-4cdf-853d-dfa79705db20 batch = 14234 start at NativeMethodAccessorImpl.java:0 2026/06/27 14:04:32 4 s 1/1
3/3
2007 (da7db828-95a1-45a5-b0f8-6881440c4ddd) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = da7db828-95a1-45a5-b0f8-6881440c4ddd batch = 14233 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/27 14:04:32 2 s 1/1
3/3
2006 (dfea9fd6-ec85-4cdf-853d-dfa79705db20) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = dfea9fd6-ec85-4cdf-853d-dfa79705db20 batch = 14233 start at NativeMethodAccessorImpl.java:0 2026/06/27 14:03:32 5 s 1/1
3/3
2005 (da7db828-95a1-45a5-b0f8-6881440c4ddd) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = da7db828-95a1-45a5-b0f8-6881440c4ddd batch = 14232 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/27 14:03:31 2 s 1/1
3/3
2004 (dfea9fd6-ec85-4cdf-853d-dfa79705db20) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = dfea9fd6-ec85-4cdf-853d-dfa79705db20 batch = 14232 start at NativeMethodAccessorImpl.java:0 2026/06/27 14:02:32 5 s 1/1
3/3
2003 (da7db828-95a1-45a5-b0f8-6881440c4ddd) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = da7db828-95a1-45a5-b0f8-6881440c4ddd batch = 14231 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/27 14:02:31 2 s 1/1
3/3
2002 (dfea9fd6-ec85-4cdf-853d-dfa79705db20) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = dfea9fd6-ec85-4cdf-853d-dfa79705db20 batch = 14231 start at NativeMethodAccessorImpl.java:0 2026/06/27 14:01:32 5 s 1/1
3/3
2001 (da7db828-95a1-45a5-b0f8-6881440c4ddd) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = da7db828-95a1-45a5-b0f8-6881440c4ddd batch = 14230 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/27 14:01:32 2 s 1/1
3/3
2000 (da7db828-95a1-45a5-b0f8-6881440c4ddd) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = da7db828-95a1-45a5-b0f8-6881440c4ddd batch = 14229 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/27 14:00:32 5 s 1/1
3/3
1999 (dfea9fd6-ec85-4cdf-853d-dfa79705db20) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = dfea9fd6-ec85-4cdf-853d-dfa79705db20 batch = 14230 start at NativeMethodAccessorImpl.java:0 2026/06/27 14:00:32 3 s 1/1
3/3
1998 (dfea9fd6-ec85-4cdf-853d-dfa79705db20) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = dfea9fd6-ec85-4cdf-853d-dfa79705db20 batch = 14229 start at NativeMethodAccessorImpl.java:0 2026/06/27 13:59:32 5 s 1/1
3/3
1997 (da7db828-95a1-45a5-b0f8-6881440c4ddd) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = da7db828-95a1-45a5-b0f8-6881440c4ddd batch = 14228 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/27 13:59:31 2 s 1/1
3/3
1996 (da7db828-95a1-45a5-b0f8-6881440c4ddd) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = da7db828-95a1-45a5-b0f8-6881440c4ddd batch = 14227 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/27 13:58:32 5 s 1/1
3/3
1995 (dfea9fd6-ec85-4cdf-853d-dfa79705db20) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = dfea9fd6-ec85-4cdf-853d-dfa79705db20 batch = 14228 start at NativeMethodAccessorImpl.java:0 2026/06/27 13:58:32 3 s 1/1
3/3
1994 (dfea9fd6-ec85-4cdf-853d-dfa79705db20) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = dfea9fd6-ec85-4cdf-853d-dfa79705db20 batch = 14227 start at NativeMethodAccessorImpl.java:0 2026/06/27 13:57:32 5 s 1/1
3/3
1993 (da7db828-95a1-45a5-b0f8-6881440c4ddd) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = da7db828-95a1-45a5-b0f8-6881440c4ddd batch = 14226 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/27 13:57:32 2 s 1/1
3/3
1992 (dfea9fd6-ec85-4cdf-853d-dfa79705db20) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = dfea9fd6-ec85-4cdf-853d-dfa79705db20 batch = 14226 start at NativeMethodAccessorImpl.java:0 2026/06/27 13:56:32 5 s 1/1
3/3
1991 (da7db828-95a1-45a5-b0f8-6881440c4ddd) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = da7db828-95a1-45a5-b0f8-6881440c4ddd batch = 14225 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/27 13:56:32 2 s 1/1
3/3
1990 (dfea9fd6-ec85-4cdf-853d-dfa79705db20) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = dfea9fd6-ec85-4cdf-853d-dfa79705db20 batch = 14225 start at NativeMethodAccessorImpl.java:0 2026/06/27 13:55:32 5 s 1/1
3/3
1989 (da7db828-95a1-45a5-b0f8-6881440c4ddd) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = da7db828-95a1-45a5-b0f8-6881440c4ddd batch = 14224 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/27 13:55:32 2 s 1/1
3/3
1988 (dfea9fd6-ec85-4cdf-853d-dfa79705db20) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = dfea9fd6-ec85-4cdf-853d-dfa79705db20 batch = 14224 start at NativeMethodAccessorImpl.java:0 2026/06/27 13:54:32 5 s 1/1
3/3
1987 (da7db828-95a1-45a5-b0f8-6881440c4ddd) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = da7db828-95a1-45a5-b0f8-6881440c4ddd batch = 14223 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/27 13:54:32 2 s 1/1
3/3
1986 (dfea9fd6-ec85-4cdf-853d-dfa79705db20) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = dfea9fd6-ec85-4cdf-853d-dfa79705db20 batch = 14223 start at NativeMethodAccessorImpl.java:0 2026/06/27 13:53:33 5 s 1/1
3/3
1985 (da7db828-95a1-45a5-b0f8-6881440c4ddd) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = da7db828-95a1-45a5-b0f8-6881440c4ddd batch = 14222 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/27 13:53:32 2 s 1/1
3/3
1984 (dfea9fd6-ec85-4cdf-853d-dfa79705db20) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = dfea9fd6-ec85-4cdf-853d-dfa79705db20 batch = 14222 start at NativeMethodAccessorImpl.java:0 2026/06/27 13:52:32 5 s 1/1
3/3
1983 (da7db828-95a1-45a5-b0f8-6881440c4ddd) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = da7db828-95a1-45a5-b0f8-6881440c4ddd batch = 14221 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/27 13:52:31 2 s 1/1
3/3
1982 (dfea9fd6-ec85-4cdf-853d-dfa79705db20) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = dfea9fd6-ec85-4cdf-853d-dfa79705db20 batch = 14221 start at NativeMethodAccessorImpl.java:0 2026/06/27 13:51:32 5 s 1/1
3/3
1981 (da7db828-95a1-45a5-b0f8-6881440c4ddd) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = da7db828-95a1-45a5-b0f8-6881440c4ddd batch = 14220 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/27 13:51:32 2 s 1/1
3/3
1980 (dfea9fd6-ec85-4cdf-853d-dfa79705db20) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = dfea9fd6-ec85-4cdf-853d-dfa79705db20 batch = 14220 start at NativeMethodAccessorImpl.java:0 2026/06/27 13:50:32 5 s 1/1
3/3
1979 (da7db828-95a1-45a5-b0f8-6881440c4ddd) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = da7db828-95a1-45a5-b0f8-6881440c4ddd batch = 14219 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/27 13:50:31 2 s 1/1
3/3
1978 (da7db828-95a1-45a5-b0f8-6881440c4ddd) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = da7db828-95a1-45a5-b0f8-6881440c4ddd batch = 14218 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/27 13:49:32 5 s 1/1
3/3
1977 (dfea9fd6-ec85-4cdf-853d-dfa79705db20) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = dfea9fd6-ec85-4cdf-853d-dfa79705db20 batch = 14219 start at NativeMethodAccessorImpl.java:0 2026/06/27 13:49:32 4 s 1/1
3/3
1976 (dfea9fd6-ec85-4cdf-853d-dfa79705db20) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = dfea9fd6-ec85-4cdf-853d-dfa79705db20 batch = 14218 start at NativeMethodAccessorImpl.java:0 2026/06/27 13:48:32 4 s 1/1
3/3
1975 (da7db828-95a1-45a5-b0f8-6881440c4ddd) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = da7db828-95a1-45a5-b0f8-6881440c4ddd batch = 14217 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/27 13:48:32 2 s 1/1
3/3
1974 (dfea9fd6-ec85-4cdf-853d-dfa79705db20) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = dfea9fd6-ec85-4cdf-853d-dfa79705db20 batch = 14217 start at NativeMethodAccessorImpl.java:0 2026/06/27 13:47:32 4 s 1/1
3/3
1973 (da7db828-95a1-45a5-b0f8-6881440c4ddd) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = da7db828-95a1-45a5-b0f8-6881440c4ddd batch = 14216 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/27 13:47:31 2 s 1/1
3/3
1972 (dfea9fd6-ec85-4cdf-853d-dfa79705db20) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = dfea9fd6-ec85-4cdf-853d-dfa79705db20 batch = 14216 start at NativeMethodAccessorImpl.java:0 2026/06/27 13:46:32 5 s 1/1
3/3
1971 (da7db828-95a1-45a5-b0f8-6881440c4ddd) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = da7db828-95a1-45a5-b0f8-6881440c4ddd batch = 14215 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/27 13:46:32 2 s 1/1
3/3
1970 (dfea9fd6-ec85-4cdf-853d-dfa79705db20) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = dfea9fd6-ec85-4cdf-853d-dfa79705db20 batch = 14215 start at NativeMethodAccessorImpl.java:0 2026/06/27 13:45:32 5 s 1/1
3/3
1969 (da7db828-95a1-45a5-b0f8-6881440c4ddd) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = da7db828-95a1-45a5-b0f8-6881440c4ddd batch = 14214 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/27 13:45:32 2 s 1/1
3/3
1968 (dfea9fd6-ec85-4cdf-853d-dfa79705db20) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = dfea9fd6-ec85-4cdf-853d-dfa79705db20 batch = 14214 start at NativeMethodAccessorImpl.java:0 2026/06/27 13:44:32 5 s 1/1
3/3
1967 (da7db828-95a1-45a5-b0f8-6881440c4ddd) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = da7db828-95a1-45a5-b0f8-6881440c4ddd batch = 14213 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/27 13:44:32 2 s 1/1
3/3
1966 (dfea9fd6-ec85-4cdf-853d-dfa79705db20) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = dfea9fd6-ec85-4cdf-853d-dfa79705db20 batch = 14213 start at NativeMethodAccessorImpl.java:0 2026/06/27 13:43:32 4 s 1/1
3/3
1965 (da7db828-95a1-45a5-b0f8-6881440c4ddd) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = da7db828-95a1-45a5-b0f8-6881440c4ddd batch = 14212 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/27 13:43:32 2 s 1/1
3/3
1964 (dfea9fd6-ec85-4cdf-853d-dfa79705db20) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = dfea9fd6-ec85-4cdf-853d-dfa79705db20 batch = 14212 start at NativeMethodAccessorImpl.java:0 2026/06/27 13:42:32 5 s 1/1
3/3
1963 (da7db828-95a1-45a5-b0f8-6881440c4ddd) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = da7db828-95a1-45a5-b0f8-6881440c4ddd batch = 14211 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/27 13:42:32 2 s 1/1
3/3
1962 (dfea9fd6-ec85-4cdf-853d-dfa79705db20) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = dfea9fd6-ec85-4cdf-853d-dfa79705db20 batch = 14211 start at NativeMethodAccessorImpl.java:0 2026/06/27 13:41:32 5 s 1/1
3/3
1961 (da7db828-95a1-45a5-b0f8-6881440c4ddd) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = da7db828-95a1-45a5-b0f8-6881440c4ddd batch = 14210 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/27 13:41:31 2 s 1/1
3/3
1960 (dfea9fd6-ec85-4cdf-853d-dfa79705db20) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = dfea9fd6-ec85-4cdf-853d-dfa79705db20 batch = 14210 start at NativeMethodAccessorImpl.java:0 2026/06/27 13:40:32 5 s 1/1
3/3
1959 (da7db828-95a1-45a5-b0f8-6881440c4ddd) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = da7db828-95a1-45a5-b0f8-6881440c4ddd batch = 14209 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/27 13:40:32 2 s 1/1
3/3
1958 (dfea9fd6-ec85-4cdf-853d-dfa79705db20) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = dfea9fd6-ec85-4cdf-853d-dfa79705db20 batch = 14209 start at NativeMethodAccessorImpl.java:0 2026/06/27 13:39:32 5 s 1/1
3/3
1957 (da7db828-95a1-45a5-b0f8-6881440c4ddd) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = da7db828-95a1-45a5-b0f8-6881440c4ddd batch = 14208 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/27 13:39:32 2 s 1/1
3/3
1956 (da7db828-95a1-45a5-b0f8-6881440c4ddd) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = da7db828-95a1-45a5-b0f8-6881440c4ddd batch = 14207 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/27 13:38:32 5 s 1/1
3/3
1955 (dfea9fd6-ec85-4cdf-853d-dfa79705db20) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = dfea9fd6-ec85-4cdf-853d-dfa79705db20 batch = 14208 start at NativeMethodAccessorImpl.java:0 2026/06/27 13:38:32 4 s 1/1
3/3
1954 (dfea9fd6-ec85-4cdf-853d-dfa79705db20) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = dfea9fd6-ec85-4cdf-853d-dfa79705db20 batch = 14207 start at NativeMethodAccessorImpl.java:0 2026/06/27 13:37:32 5 s 1/1
3/3
1953 (da7db828-95a1-45a5-b0f8-6881440c4ddd) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = da7db828-95a1-45a5-b0f8-6881440c4ddd batch = 14206 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/27 13:37:32 2 s 1/1
3/3
1952 (dfea9fd6-ec85-4cdf-853d-dfa79705db20) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = dfea9fd6-ec85-4cdf-853d-dfa79705db20 batch = 14206 start at NativeMethodAccessorImpl.java:0 2026/06/27 13:36:32 5 s 1/1
3/3
1951 (da7db828-95a1-45a5-b0f8-6881440c4ddd) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = da7db828-95a1-45a5-b0f8-6881440c4ddd batch = 14205 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/27 13:36:32 2 s 1/1
3/3
1950 (da7db828-95a1-45a5-b0f8-6881440c4ddd) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = da7db828-95a1-45a5-b0f8-6881440c4ddd batch = 14204 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/27 13:35:32 6 s 1/1
3/3
1949 (dfea9fd6-ec85-4cdf-853d-dfa79705db20) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = dfea9fd6-ec85-4cdf-853d-dfa79705db20 batch = 14205 start at NativeMethodAccessorImpl.java:0 2026/06/27 13:35:32 4 s 1/1
3/3
1948 (dfea9fd6-ec85-4cdf-853d-dfa79705db20) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = dfea9fd6-ec85-4cdf-853d-dfa79705db20 batch = 14204 start at NativeMethodAccessorImpl.java:0 2026/06/27 13:34:32 5 s 1/1
3/3
1947 (da7db828-95a1-45a5-b0f8-6881440c4ddd) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = da7db828-95a1-45a5-b0f8-6881440c4ddd batch = 14203 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/27 13:34:32 2 s 1/1
3/3
1946 (dfea9fd6-ec85-4cdf-853d-dfa79705db20) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = dfea9fd6-ec85-4cdf-853d-dfa79705db20 batch = 14203 start at NativeMethodAccessorImpl.java:0 2026/06/27 13:33:32 5 s 1/1
3/3
1945 (da7db828-95a1-45a5-b0f8-6881440c4ddd) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = da7db828-95a1-45a5-b0f8-6881440c4ddd batch = 14202 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/27 13:33:32 2 s 1/1
3/3
1944 (dfea9fd6-ec85-4cdf-853d-dfa79705db20) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = dfea9fd6-ec85-4cdf-853d-dfa79705db20 batch = 14202 start at NativeMethodAccessorImpl.java:0 2026/06/27 13:32:32 4 s 1/1
3/3
1943 (da7db828-95a1-45a5-b0f8-6881440c4ddd) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = da7db828-95a1-45a5-b0f8-6881440c4ddd batch = 14201 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/27 13:32:32 2 s 1/1
3/3
1942 (da7db828-95a1-45a5-b0f8-6881440c4ddd) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = da7db828-95a1-45a5-b0f8-6881440c4ddd batch = 14200 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/27 13:31:32 5 s 1/1
3/3
1941 (dfea9fd6-ec85-4cdf-853d-dfa79705db20) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = dfea9fd6-ec85-4cdf-853d-dfa79705db20 batch = 14201 start at NativeMethodAccessorImpl.java:0 2026/06/27 13:31:32 3 s 1/1
3/3
1940 (da7db828-95a1-45a5-b0f8-6881440c4ddd) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = da7db828-95a1-45a5-b0f8-6881440c4ddd batch = 14199 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/27 13:30:32 5 s 1/1
3/3
1939 (dfea9fd6-ec85-4cdf-853d-dfa79705db20) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = dfea9fd6-ec85-4cdf-853d-dfa79705db20 batch = 14200 start at NativeMethodAccessorImpl.java:0 2026/06/27 13:30:32 3 s 1/1
3/3
1938 (dfea9fd6-ec85-4cdf-853d-dfa79705db20) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = dfea9fd6-ec85-4cdf-853d-dfa79705db20 batch = 14199 start at NativeMethodAccessorImpl.java:0 2026/06/27 13:29:32 5 s 1/1
3/3
1937 (da7db828-95a1-45a5-b0f8-6881440c4ddd) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = da7db828-95a1-45a5-b0f8-6881440c4ddd batch = 14198 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/27 13:29:32 2 s 1/1
3/3
1936 (dfea9fd6-ec85-4cdf-853d-dfa79705db20) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = dfea9fd6-ec85-4cdf-853d-dfa79705db20 batch = 14198 start at NativeMethodAccessorImpl.java:0 2026/06/27 13:28:32 5 s 1/1
3/3
1935 (da7db828-95a1-45a5-b0f8-6881440c4ddd) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = da7db828-95a1-45a5-b0f8-6881440c4ddd batch = 14197 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/27 13:28:32 2 s 1/1
3/3
1934 (dfea9fd6-ec85-4cdf-853d-dfa79705db20) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = dfea9fd6-ec85-4cdf-853d-dfa79705db20 batch = 14197 start at NativeMethodAccessorImpl.java:0 2026/06/27 13:27:32 5 s 1/1
3/3
1933 (da7db828-95a1-45a5-b0f8-6881440c4ddd) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = da7db828-95a1-45a5-b0f8-6881440c4ddd batch = 14196 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/27 13:27:32 2 s 1/1
3/3