| Job Id (Job Group) ▾ | Description | Submitted | Duration | Stages: Succeeded/Total | Tasks (for all stages): Succeeded/Total |
|---|---|---|---|---|---|
| 2346 (834b49b1-8901-4af8-83eb-bf0f54cf1839) | kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 834b49b1-8901-4af8-83eb-bf0f54cf1839 batch = 16890 start at NativeMethodAccessorImpl.java:0 | 2026/06/29 10:20:32 | 5 s | 1/1 |
3/3
|
| 2345 (ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412) | kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412 batch = 16888 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 | 2026/06/29 10:20:32 | 2 s | 1/1 |
3/3
|
| 2344 (834b49b1-8901-4af8-83eb-bf0f54cf1839) | kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 834b49b1-8901-4af8-83eb-bf0f54cf1839 batch = 16889 start at NativeMethodAccessorImpl.java:0 | 2026/06/29 10:19:32 | 5 s | 1/1 |
3/3
|
| 2343 (ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412) | kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412 batch = 16887 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 | 2026/06/29 10:19:32 | 2 s | 1/1 |
3/3
|
| 2342 (ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412) | kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412 batch = 16886 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 | 2026/06/29 10:18:32 | 5 s | 1/1 |
3/3
|
| 2341 (834b49b1-8901-4af8-83eb-bf0f54cf1839) | kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 834b49b1-8901-4af8-83eb-bf0f54cf1839 batch = 16888 start at NativeMethodAccessorImpl.java:0 | 2026/06/29 10:18:32 | 3 s | 1/1 |
3/3
|
| 2340 (834b49b1-8901-4af8-83eb-bf0f54cf1839) | kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 834b49b1-8901-4af8-83eb-bf0f54cf1839 batch = 16887 start at NativeMethodAccessorImpl.java:0 | 2026/06/29 10:17:32 | 5 s | 1/1 |
3/3
|
| 2339 (ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412) | kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412 batch = 16885 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 | 2026/06/29 10:17:32 | 2 s | 1/1 |
3/3
|
| 2338 (ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412) | kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412 batch = 16884 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 | 2026/06/29 10:16:32 | 4 s | 1/1 |
3/3
|
| 2337 (834b49b1-8901-4af8-83eb-bf0f54cf1839) | kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 834b49b1-8901-4af8-83eb-bf0f54cf1839 batch = 16886 start at NativeMethodAccessorImpl.java:0 | 2026/06/29 10:16:32 | 3 s | 1/1 |
3/3
|
| 2336 (834b49b1-8901-4af8-83eb-bf0f54cf1839) | kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 834b49b1-8901-4af8-83eb-bf0f54cf1839 batch = 16885 start at NativeMethodAccessorImpl.java:0 | 2026/06/29 10:15:33 | 5 s | 1/1 |
3/3
|
| 2335 (ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412) | kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412 batch = 16883 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 | 2026/06/29 10:15:32 | 2 s | 1/1 |
3/3
|
| 2334 (834b49b1-8901-4af8-83eb-bf0f54cf1839) | kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 834b49b1-8901-4af8-83eb-bf0f54cf1839 batch = 16884 start at NativeMethodAccessorImpl.java:0 | 2026/06/29 10:14:32 | 5 s | 1/1 |
3/3
|
| 2333 (ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412) | kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412 batch = 16882 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 | 2026/06/29 10:14:32 | 2 s | 1/1 |
3/3
|
| 2332 (834b49b1-8901-4af8-83eb-bf0f54cf1839) | kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 834b49b1-8901-4af8-83eb-bf0f54cf1839 batch = 16883 start at NativeMethodAccessorImpl.java:0 | 2026/06/29 10:13:32 | 5 s | 1/1 |
3/3
|
| 2331 (ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412) | kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412 batch = 16881 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 | 2026/06/29 10:13:32 | 2 s | 1/1 |
3/3
|
| 2330 (834b49b1-8901-4af8-83eb-bf0f54cf1839) | kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 834b49b1-8901-4af8-83eb-bf0f54cf1839 batch = 16882 start at NativeMethodAccessorImpl.java:0 | 2026/06/29 10:12:33 | 5 s | 1/1 |
3/3
|
| 2329 (ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412) | kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412 batch = 16880 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 | 2026/06/29 10:12:32 | 2 s | 1/1 |
3/3
|
| 2328 (834b49b1-8901-4af8-83eb-bf0f54cf1839) | kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 834b49b1-8901-4af8-83eb-bf0f54cf1839 batch = 16881 start at NativeMethodAccessorImpl.java:0 | 2026/06/29 10:11:32 | 4 s | 1/1 |
3/3
|
| 2327 (ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412) | kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412 batch = 16879 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 | 2026/06/29 10:11:31 | 2 s | 1/1 |
3/3
|
| 2326 (ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412) | kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412 batch = 16878 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 | 2026/06/29 10:10:32 | 5 s | 1/1 |
3/3
|
| 2325 (834b49b1-8901-4af8-83eb-bf0f54cf1839) | kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 834b49b1-8901-4af8-83eb-bf0f54cf1839 batch = 16880 start at NativeMethodAccessorImpl.java:0 | 2026/06/29 10:10:31 | 3 s | 1/1 |
3/3
|
| 2324 (834b49b1-8901-4af8-83eb-bf0f54cf1839) | kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 834b49b1-8901-4af8-83eb-bf0f54cf1839 batch = 16879 start at NativeMethodAccessorImpl.java:0 | 2026/06/29 10:09:32 | 5 s | 1/1 |
3/3
|
| 2323 (ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412) | kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412 batch = 16877 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 | 2026/06/29 10:09:32 | 2 s | 1/1 |
3/3
|
| 2322 (834b49b1-8901-4af8-83eb-bf0f54cf1839) | kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 834b49b1-8901-4af8-83eb-bf0f54cf1839 batch = 16878 start at NativeMethodAccessorImpl.java:0 | 2026/06/29 10:08:32 | 6 s | 1/1 |
3/3
|
| 2321 (ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412) | kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412 batch = 16876 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 | 2026/06/29 10:08:32 | 2 s | 1/1 |
3/3
|
| 2320 (834b49b1-8901-4af8-83eb-bf0f54cf1839) | kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 834b49b1-8901-4af8-83eb-bf0f54cf1839 batch = 16877 start at NativeMethodAccessorImpl.java:0 | 2026/06/29 10:07:32 | 4 s | 1/1 |
3/3
|
| 2319 (ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412) | kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412 batch = 16875 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 | 2026/06/29 10:07:31 | 2 s | 1/1 |
3/3
|
| 2318 (834b49b1-8901-4af8-83eb-bf0f54cf1839) | kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 834b49b1-8901-4af8-83eb-bf0f54cf1839 batch = 16876 start at NativeMethodAccessorImpl.java:0 | 2026/06/29 10:06:32 | 5 s | 1/1 |
3/3
|
| 2317 (ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412) | kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412 batch = 16874 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 | 2026/06/29 10:06:32 | 2 s | 1/1 |
3/3
|
| 2316 (ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412) | kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412 batch = 16873 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 | 2026/06/29 10:05:32 | 4 s | 1/1 |
3/3
|
| 2315 (834b49b1-8901-4af8-83eb-bf0f54cf1839) | kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 834b49b1-8901-4af8-83eb-bf0f54cf1839 batch = 16875 start at NativeMethodAccessorImpl.java:0 | 2026/06/29 10:05:32 | 3 s | 1/1 |
3/3
|
| 2314 (834b49b1-8901-4af8-83eb-bf0f54cf1839) | kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 834b49b1-8901-4af8-83eb-bf0f54cf1839 batch = 16874 start at NativeMethodAccessorImpl.java:0 | 2026/06/29 10:04:32 | 5 s | 1/1 |
3/3
|
| 2313 (ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412) | kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412 batch = 16872 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 | 2026/06/29 10:04:32 | 2 s | 1/1 |
3/3
|
| 2312 (834b49b1-8901-4af8-83eb-bf0f54cf1839) | kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 834b49b1-8901-4af8-83eb-bf0f54cf1839 batch = 16873 start at NativeMethodAccessorImpl.java:0 | 2026/06/29 10:03:32 | 5 s | 1/1 |
3/3
|
| 2311 (ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412) | kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412 batch = 16871 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 | 2026/06/29 10:03:32 | 2 s | 1/1 |
3/3
|
| 2310 (834b49b1-8901-4af8-83eb-bf0f54cf1839) | kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 834b49b1-8901-4af8-83eb-bf0f54cf1839 batch = 16872 start at NativeMethodAccessorImpl.java:0 | 2026/06/29 10:02:32 | 5 s | 1/1 |
3/3
|
| 2309 (ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412) | kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412 batch = 16870 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 | 2026/06/29 10:02:32 | 2 s | 1/1 |
3/3
|
| 2308 (834b49b1-8901-4af8-83eb-bf0f54cf1839) | kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 834b49b1-8901-4af8-83eb-bf0f54cf1839 batch = 16871 start at NativeMethodAccessorImpl.java:0 | 2026/06/29 10:01:32 | 5 s | 1/1 |
3/3
|
| 2307 (ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412) | kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412 batch = 16869 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 | 2026/06/29 10:01:31 | 2 s | 1/1 |
3/3
|
| 2306 (ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412) | kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412 batch = 16868 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 | 2026/06/29 10:00:32 | 5 s | 1/1 |
3/3
|
| 2305 (834b49b1-8901-4af8-83eb-bf0f54cf1839) | kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 834b49b1-8901-4af8-83eb-bf0f54cf1839 batch = 16870 start at NativeMethodAccessorImpl.java:0 | 2026/06/29 10:00:32 | 3 s | 1/1 |
3/3
|
| 2304 (834b49b1-8901-4af8-83eb-bf0f54cf1839) | kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 834b49b1-8901-4af8-83eb-bf0f54cf1839 batch = 16869 start at NativeMethodAccessorImpl.java:0 | 2026/06/29 09:59:32 | 5 s | 1/1 |
3/3
|
| 2303 (ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412) | kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412 batch = 16867 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 | 2026/06/29 09:59:32 | 2 s | 1/1 |
3/3
|
| 2302 (ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412) | kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412 batch = 16866 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 | 2026/06/29 09:58:32 | 5 s | 1/1 |
3/3
|
| 2301 (834b49b1-8901-4af8-83eb-bf0f54cf1839) | kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 834b49b1-8901-4af8-83eb-bf0f54cf1839 batch = 16868 start at NativeMethodAccessorImpl.java:0 | 2026/06/29 09:58:32 | 3 s | 1/1 |
3/3
|
| 2300 (834b49b1-8901-4af8-83eb-bf0f54cf1839) | kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 834b49b1-8901-4af8-83eb-bf0f54cf1839 batch = 16867 start at NativeMethodAccessorImpl.java:0 | 2026/06/29 09:57:32 | 5 s | 1/1 |
3/3
|
| 2299 (ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412) | kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412 batch = 16865 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 | 2026/06/29 09:57:32 | 2 s | 1/1 |
3/3
|
| 2298 (ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412) | kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412 batch = 16864 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 | 2026/06/29 09:56:32 | 5 s | 1/1 |
3/3
|
| 2297 (834b49b1-8901-4af8-83eb-bf0f54cf1839) | kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 834b49b1-8901-4af8-83eb-bf0f54cf1839 batch = 16866 start at NativeMethodAccessorImpl.java:0 | 2026/06/29 09:56:32 | 3 s | 1/1 |
3/3
|
| 2296 (834b49b1-8901-4af8-83eb-bf0f54cf1839) | kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 834b49b1-8901-4af8-83eb-bf0f54cf1839 batch = 16865 start at NativeMethodAccessorImpl.java:0 | 2026/06/29 09:55:32 | 5 s | 1/1 |
3/3
|
| 2295 (ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412) | kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412 batch = 16863 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 | 2026/06/29 09:55:32 | 2 s | 1/1 |
3/3
|
| 2294 (834b49b1-8901-4af8-83eb-bf0f54cf1839) | kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 834b49b1-8901-4af8-83eb-bf0f54cf1839 batch = 16864 start at NativeMethodAccessorImpl.java:0 | 2026/06/29 09:54:32 | 4 s | 1/1 |
3/3
|
| 2293 (ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412) | kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412 batch = 16862 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 | 2026/06/29 09:54:31 | 2 s | 1/1 |
3/3
|
| 2292 (834b49b1-8901-4af8-83eb-bf0f54cf1839) | kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 834b49b1-8901-4af8-83eb-bf0f54cf1839 batch = 16863 start at NativeMethodAccessorImpl.java:0 | 2026/06/29 09:53:32 | 5 s | 1/1 |
3/3
|
| 2291 (ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412) | kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412 batch = 16861 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 | 2026/06/29 09:53:32 | 2 s | 1/1 |
3/3
|
| 2290 (834b49b1-8901-4af8-83eb-bf0f54cf1839) | kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 834b49b1-8901-4af8-83eb-bf0f54cf1839 batch = 16862 start at NativeMethodAccessorImpl.java:0 | 2026/06/29 09:52:32 | 5 s | 1/1 |
3/3
|
| 2289 (ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412) | kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412 batch = 16860 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 | 2026/06/29 09:52:32 | 2 s | 1/1 |
3/3
|
| 2288 (834b49b1-8901-4af8-83eb-bf0f54cf1839) | kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 834b49b1-8901-4af8-83eb-bf0f54cf1839 batch = 16861 start at NativeMethodAccessorImpl.java:0 | 2026/06/29 09:51:32 | 5 s | 1/1 |
3/3
|
| 2287 (ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412) | kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412 batch = 16859 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 | 2026/06/29 09:51:31 | 2 s | 1/1 |
3/3
|
| 2286 (834b49b1-8901-4af8-83eb-bf0f54cf1839) | kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 834b49b1-8901-4af8-83eb-bf0f54cf1839 batch = 16860 start at NativeMethodAccessorImpl.java:0 | 2026/06/29 09:50:32 | 5 s | 1/1 |
3/3
|
| 2285 (ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412) | kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412 batch = 16858 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 | 2026/06/29 09:50:32 | 2 s | 1/1 |
3/3
|
| 2284 (ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412) | kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412 batch = 16857 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 | 2026/06/29 09:49:33 | 5 s | 1/1 |
3/3
|
| 2283 (834b49b1-8901-4af8-83eb-bf0f54cf1839) | kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 834b49b1-8901-4af8-83eb-bf0f54cf1839 batch = 16859 start at NativeMethodAccessorImpl.java:0 | 2026/06/29 09:49:32 | 4 s | 1/1 |
3/3
|
| 2282 (834b49b1-8901-4af8-83eb-bf0f54cf1839) | kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 834b49b1-8901-4af8-83eb-bf0f54cf1839 batch = 16858 start at NativeMethodAccessorImpl.java:0 | 2026/06/29 09:48:32 | 5 s | 1/1 |
3/3
|
| 2281 (ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412) | kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412 batch = 16856 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 | 2026/06/29 09:48:32 | 2 s | 1/1 |
3/3
|
| 2280 (834b49b1-8901-4af8-83eb-bf0f54cf1839) | kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 834b49b1-8901-4af8-83eb-bf0f54cf1839 batch = 16857 start at NativeMethodAccessorImpl.java:0 | 2026/06/29 09:47:32 | 5 s | 1/1 |
3/3
|
| 2279 (ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412) | kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412 batch = 16855 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 | 2026/06/29 09:47:32 | 2 s | 1/1 |
3/3
|
| 2278 (ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412) | kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412 batch = 16854 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 | 2026/06/29 09:46:32 | 5 s | 1/1 |
3/3
|
| 2277 (834b49b1-8901-4af8-83eb-bf0f54cf1839) | kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 834b49b1-8901-4af8-83eb-bf0f54cf1839 batch = 16856 start at NativeMethodAccessorImpl.java:0 | 2026/06/29 09:46:32 | 3 s | 1/1 |
3/3
|
| 2276 (834b49b1-8901-4af8-83eb-bf0f54cf1839) | kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 834b49b1-8901-4af8-83eb-bf0f54cf1839 batch = 16855 start at NativeMethodAccessorImpl.java:0 | 2026/06/29 09:45:32 | 5 s | 1/1 |
3/3
|
| 2275 (ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412) | kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412 batch = 16853 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 | 2026/06/29 09:45:32 | 2 s | 1/1 |
3/3
|
| 2274 (834b49b1-8901-4af8-83eb-bf0f54cf1839) | kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 834b49b1-8901-4af8-83eb-bf0f54cf1839 batch = 16854 start at NativeMethodAccessorImpl.java:0 | 2026/06/29 09:44:32 | 5 s | 1/1 |
3/3
|
| 2273 (ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412) | kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412 batch = 16852 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 | 2026/06/29 09:44:32 | 2 s | 1/1 |
3/3
|
| 2272 (834b49b1-8901-4af8-83eb-bf0f54cf1839) | kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 834b49b1-8901-4af8-83eb-bf0f54cf1839 batch = 16853 start at NativeMethodAccessorImpl.java:0 | 2026/06/29 09:43:32 | 5 s | 1/1 |
3/3
|
| 2271 (ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412) | kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412 batch = 16851 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 | 2026/06/29 09:43:31 | 2 s | 1/1 |
3/3
|
| 2270 (ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412) | kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412 batch = 16850 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 | 2026/06/29 09:42:32 | 5 s | 1/1 |
3/3
|
| 2269 (834b49b1-8901-4af8-83eb-bf0f54cf1839) | kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 834b49b1-8901-4af8-83eb-bf0f54cf1839 batch = 16852 start at NativeMethodAccessorImpl.java:0 | 2026/06/29 09:42:32 | 4 s | 1/1 |
3/3
|
| 2268 (834b49b1-8901-4af8-83eb-bf0f54cf1839) | kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 834b49b1-8901-4af8-83eb-bf0f54cf1839 batch = 16851 start at NativeMethodAccessorImpl.java:0 | 2026/06/29 09:41:32 | 5 s | 1/1 |
3/3
|
| 2267 (ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412) | kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412 batch = 16849 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 | 2026/06/29 09:41:31 | 2 s | 1/1 |
3/3
|
| 2266 (834b49b1-8901-4af8-83eb-bf0f54cf1839) | kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 834b49b1-8901-4af8-83eb-bf0f54cf1839 batch = 16850 start at NativeMethodAccessorImpl.java:0 | 2026/06/29 09:40:32 | 5 s | 1/1 |
3/3
|
| 2265 (ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412) | kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412 batch = 16848 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 | 2026/06/29 09:40:32 | 2 s | 1/1 |
3/3
|
| 2264 (834b49b1-8901-4af8-83eb-bf0f54cf1839) | kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 834b49b1-8901-4af8-83eb-bf0f54cf1839 batch = 16849 start at NativeMethodAccessorImpl.java:0 | 2026/06/29 09:39:32 | 5 s | 1/1 |
3/3
|
| 2263 (ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412) | kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412 batch = 16847 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 | 2026/06/29 09:39:32 | 2 s | 1/1 |
3/3
|
| 2262 (834b49b1-8901-4af8-83eb-bf0f54cf1839) | kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 834b49b1-8901-4af8-83eb-bf0f54cf1839 batch = 16848 start at NativeMethodAccessorImpl.java:0 | 2026/06/29 09:38:32 | 5 s | 1/1 |
3/3
|
| 2261 (ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412) | kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412 batch = 16846 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 | 2026/06/29 09:38:32 | 2 s | 1/1 |
3/3
|
| 2260 (834b49b1-8901-4af8-83eb-bf0f54cf1839) | kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 834b49b1-8901-4af8-83eb-bf0f54cf1839 batch = 16847 start at NativeMethodAccessorImpl.java:0 | 2026/06/29 09:37:32 | 5 s | 1/1 |
3/3
|
| 2259 (ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412) | kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412 batch = 16845 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 | 2026/06/29 09:37:32 | 2 s | 1/1 |
3/3
|
| 2258 (ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412) | kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412 batch = 16844 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 | 2026/06/29 09:36:32 | 5 s | 1/1 |
3/3
|
| 2257 (834b49b1-8901-4af8-83eb-bf0f54cf1839) | kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 834b49b1-8901-4af8-83eb-bf0f54cf1839 batch = 16846 start at NativeMethodAccessorImpl.java:0 | 2026/06/29 09:36:32 | 4 s | 1/1 |
3/3
|
| 2256 (ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412) | kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412 batch = 16843 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 | 2026/06/29 09:35:32 | 5 s | 1/1 |
3/3
|
| 2255 (834b49b1-8901-4af8-83eb-bf0f54cf1839) | kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 834b49b1-8901-4af8-83eb-bf0f54cf1839 batch = 16845 start at NativeMethodAccessorImpl.java:0 | 2026/06/29 09:35:32 | 4 s | 1/1 |
3/3
|
| 2254 (834b49b1-8901-4af8-83eb-bf0f54cf1839) | kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 834b49b1-8901-4af8-83eb-bf0f54cf1839 batch = 16844 start at NativeMethodAccessorImpl.java:0 | 2026/06/29 09:34:32 | 5 s | 1/1 |
3/3
|
| 2253 (ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412) | kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412 batch = 16842 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 | 2026/06/29 09:34:31 | 2 s | 1/1 |
3/3
|
| 2252 (ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412) | kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412 batch = 16841 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 | 2026/06/29 09:33:32 | 5 s | 1/1 |
3/3
|
| 2251 (834b49b1-8901-4af8-83eb-bf0f54cf1839) | kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 834b49b1-8901-4af8-83eb-bf0f54cf1839 batch = 16843 start at NativeMethodAccessorImpl.java:0 | 2026/06/29 09:33:32 | 3 s | 1/1 |
3/3
|
| 2250 (ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412) | kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412 batch = 16840 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 | 2026/06/29 09:32:32 | 6 s | 1/1 |
3/3
|
| 2249 (834b49b1-8901-4af8-83eb-bf0f54cf1839) | kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 834b49b1-8901-4af8-83eb-bf0f54cf1839 batch = 16842 start at NativeMethodAccessorImpl.java:0 | 2026/06/29 09:32:32 | 4 s | 1/1 |
3/3
|
| 2248 (834b49b1-8901-4af8-83eb-bf0f54cf1839) | kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 834b49b1-8901-4af8-83eb-bf0f54cf1839 batch = 16841 start at NativeMethodAccessorImpl.java:0 | 2026/06/29 09:31:32 | 4 s | 1/1 |
3/3
|
| 2247 (ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412) | kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412 batch = 16839 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 | 2026/06/29 09:31:31 | 2 s | 1/1 |
3/3
|