| Job Id (Job Group) ▾ | Description | Submitted | Duration | Stages: Succeeded/Total | Tasks (for all stages): Succeeded/Total |
|---|---|---|---|---|---|
| 379 (56fcc6b3-ca26-4cdf-b4b8-e5181c15bdb7) | kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 56fcc6b3-ca26-4cdf-b4b8-e5181c15bdb7 batch = 2684 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 | 2026/06/19 13:17:32 | 5 s | 1/1 |
3/3
|
| 378 (e1eacc71-943b-4bb4-a8fe-09129b09bc0c) | kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = e1eacc71-943b-4bb4-a8fe-09129b09bc0c batch = 2684 start at NativeMethodAccessorImpl.java:0 | 2026/06/19 13:17:31 | 4 s | 1/1 |
3/3
|
| 377 (56fcc6b3-ca26-4cdf-b4b8-e5181c15bdb7) | kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 56fcc6b3-ca26-4cdf-b4b8-e5181c15bdb7 batch = 2683 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 | 2026/06/19 13:16:32 | 5 s | 1/1 |
3/3
|
| 376 (e1eacc71-943b-4bb4-a8fe-09129b09bc0c) | kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = e1eacc71-943b-4bb4-a8fe-09129b09bc0c batch = 2683 start at NativeMethodAccessorImpl.java:0 | 2026/06/19 13:16:31 | 4 s | 1/1 |
3/3
|
| 375 (e1eacc71-943b-4bb4-a8fe-09129b09bc0c) | kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = e1eacc71-943b-4bb4-a8fe-09129b09bc0c batch = 2682 start at NativeMethodAccessorImpl.java:0 | 2026/06/19 13:15:32 | 6 s | 1/1 |
4/4
|
| 374 (56fcc6b3-ca26-4cdf-b4b8-e5181c15bdb7) | kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 56fcc6b3-ca26-4cdf-b4b8-e5181c15bdb7 batch = 2682 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 | 2026/06/19 13:15:32 | 2 s | 1/1 |
4/4
|
| 373 (e1eacc71-943b-4bb4-a8fe-09129b09bc0c) | kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = e1eacc71-943b-4bb4-a8fe-09129b09bc0c batch = 2681 start at NativeMethodAccessorImpl.java:0 | 2026/06/19 13:14:32 | 5 s | 1/1 |
3/3
|
| 372 (56fcc6b3-ca26-4cdf-b4b8-e5181c15bdb7) | kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 56fcc6b3-ca26-4cdf-b4b8-e5181c15bdb7 batch = 2681 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 | 2026/06/19 13:14:32 | 2 s | 1/1 |
3/3
|
| 371 (e1eacc71-943b-4bb4-a8fe-09129b09bc0c) | kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = e1eacc71-943b-4bb4-a8fe-09129b09bc0c batch = 2680 start at NativeMethodAccessorImpl.java:0 | 2026/06/19 13:13:31 | 5 s | 1/1 |
3/3
|
| 370 (56fcc6b3-ca26-4cdf-b4b8-e5181c15bdb7) | kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 56fcc6b3-ca26-4cdf-b4b8-e5181c15bdb7 batch = 2680 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 | 2026/06/19 13:13:31 | 2 s | 1/1 |
3/3
|
| 369 (e1eacc71-943b-4bb4-a8fe-09129b09bc0c) | kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = e1eacc71-943b-4bb4-a8fe-09129b09bc0c batch = 2679 start at NativeMethodAccessorImpl.java:0 | 2026/06/19 13:12:32 | 5 s | 1/1 |
3/3
|
| 368 (56fcc6b3-ca26-4cdf-b4b8-e5181c15bdb7) | kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 56fcc6b3-ca26-4cdf-b4b8-e5181c15bdb7 batch = 2679 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 | 2026/06/19 13:12:31 | 2 s | 1/1 |
3/3
|
| 367 (56fcc6b3-ca26-4cdf-b4b8-e5181c15bdb7) | kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 56fcc6b3-ca26-4cdf-b4b8-e5181c15bdb7 batch = 2678 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 | 2026/06/19 13:11:32 | 5 s | 1/1 |
3/3
|
| 366 (e1eacc71-943b-4bb4-a8fe-09129b09bc0c) | kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = e1eacc71-943b-4bb4-a8fe-09129b09bc0c batch = 2678 start at NativeMethodAccessorImpl.java:0 | 2026/06/19 13:11:32 | 4 s | 1/1 |
3/3
|
| 365 (56fcc6b3-ca26-4cdf-b4b8-e5181c15bdb7) | kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 56fcc6b3-ca26-4cdf-b4b8-e5181c15bdb7 batch = 2677 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 | 2026/06/19 13:10:32 | 6 s | 1/1 |
3/3
|
| 364 (e1eacc71-943b-4bb4-a8fe-09129b09bc0c) | kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = e1eacc71-943b-4bb4-a8fe-09129b09bc0c batch = 2677 start at NativeMethodAccessorImpl.java:0 | 2026/06/19 13:10:32 | 4 s | 1/1 |
3/3
|
| 363 (e1eacc71-943b-4bb4-a8fe-09129b09bc0c) | kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = e1eacc71-943b-4bb4-a8fe-09129b09bc0c batch = 2676 start at NativeMethodAccessorImpl.java:0 | 2026/06/19 13:09:32 | 4 s | 1/1 |
3/3
|
| 362 (56fcc6b3-ca26-4cdf-b4b8-e5181c15bdb7) | kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 56fcc6b3-ca26-4cdf-b4b8-e5181c15bdb7 batch = 2676 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 | 2026/06/19 13:09:31 | 2 s | 1/1 |
3/3
|
| 361 (e1eacc71-943b-4bb4-a8fe-09129b09bc0c) | kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = e1eacc71-943b-4bb4-a8fe-09129b09bc0c batch = 2675 start at NativeMethodAccessorImpl.java:0 | 2026/06/19 13:08:32 | 5 s | 1/1 |
3/3
|
| 360 (56fcc6b3-ca26-4cdf-b4b8-e5181c15bdb7) | kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 56fcc6b3-ca26-4cdf-b4b8-e5181c15bdb7 batch = 2675 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 | 2026/06/19 13:08:32 | 2 s | 1/1 |
3/3
|
| 359 (e1eacc71-943b-4bb4-a8fe-09129b09bc0c) | kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = e1eacc71-943b-4bb4-a8fe-09129b09bc0c batch = 2674 start at NativeMethodAccessorImpl.java:0 | 2026/06/19 13:07:32 | 5 s | 1/1 |
3/3
|
| 358 (56fcc6b3-ca26-4cdf-b4b8-e5181c15bdb7) | kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 56fcc6b3-ca26-4cdf-b4b8-e5181c15bdb7 batch = 2674 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 | 2026/06/19 13:07:32 | 2 s | 1/1 |
3/3
|
| 357 (e1eacc71-943b-4bb4-a8fe-09129b09bc0c) | kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = e1eacc71-943b-4bb4-a8fe-09129b09bc0c batch = 2673 start at NativeMethodAccessorImpl.java:0 | 2026/06/19 13:06:32 | 6 s | 1/1 |
3/3
|
| 356 (56fcc6b3-ca26-4cdf-b4b8-e5181c15bdb7) | kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 56fcc6b3-ca26-4cdf-b4b8-e5181c15bdb7 batch = 2673 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 | 2026/06/19 13:06:32 | 2 s | 1/1 |
3/3
|
| 355 (e1eacc71-943b-4bb4-a8fe-09129b09bc0c) | kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = e1eacc71-943b-4bb4-a8fe-09129b09bc0c batch = 2672 start at NativeMethodAccessorImpl.java:0 | 2026/06/19 13:05:32 | 5 s | 1/1 |
3/3
|
| 354 (56fcc6b3-ca26-4cdf-b4b8-e5181c15bdb7) | kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 56fcc6b3-ca26-4cdf-b4b8-e5181c15bdb7 batch = 2672 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 | 2026/06/19 13:05:32 | 2 s | 1/1 |
3/3
|
| 353 (56fcc6b3-ca26-4cdf-b4b8-e5181c15bdb7) | kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 56fcc6b3-ca26-4cdf-b4b8-e5181c15bdb7 batch = 2671 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 | 2026/06/19 13:04:32 | 5 s | 1/1 |
3/3
|
| 352 (e1eacc71-943b-4bb4-a8fe-09129b09bc0c) | kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = e1eacc71-943b-4bb4-a8fe-09129b09bc0c batch = 2671 start at NativeMethodAccessorImpl.java:0 | 2026/06/19 13:04:32 | 4 s | 1/1 |
3/3
|
| 351 (56fcc6b3-ca26-4cdf-b4b8-e5181c15bdb7) | kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 56fcc6b3-ca26-4cdf-b4b8-e5181c15bdb7 batch = 2670 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 | 2026/06/19 13:03:32 | 5 s | 1/1 |
3/3
|
| 350 (e1eacc71-943b-4bb4-a8fe-09129b09bc0c) | kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = e1eacc71-943b-4bb4-a8fe-09129b09bc0c batch = 2670 start at NativeMethodAccessorImpl.java:0 | 2026/06/19 13:03:32 | 3 s | 1/1 |
3/3
|
| 349 (e1eacc71-943b-4bb4-a8fe-09129b09bc0c) | kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = e1eacc71-943b-4bb4-a8fe-09129b09bc0c batch = 2669 start at NativeMethodAccessorImpl.java:0 | 2026/06/19 13:02:32 | 5 s | 1/1 |
3/3
|
| 348 (56fcc6b3-ca26-4cdf-b4b8-e5181c15bdb7) | kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 56fcc6b3-ca26-4cdf-b4b8-e5181c15bdb7 batch = 2669 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 | 2026/06/19 13:02:31 | 2 s | 1/1 |
3/3
|
| 347 (56fcc6b3-ca26-4cdf-b4b8-e5181c15bdb7) | kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 56fcc6b3-ca26-4cdf-b4b8-e5181c15bdb7 batch = 2668 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 | 2026/06/19 13:01:32 | 5 s | 1/1 |
3/3
|
| 346 (e1eacc71-943b-4bb4-a8fe-09129b09bc0c) | kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = e1eacc71-943b-4bb4-a8fe-09129b09bc0c batch = 2668 start at NativeMethodAccessorImpl.java:0 | 2026/06/19 13:01:31 | 4 s | 1/1 |
3/3
|
| 345 (e1eacc71-943b-4bb4-a8fe-09129b09bc0c) | kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = e1eacc71-943b-4bb4-a8fe-09129b09bc0c batch = 2667 start at NativeMethodAccessorImpl.java:0 | 2026/06/19 13:00:32 | 4 s | 1/1 |
3/3
|
| 344 (56fcc6b3-ca26-4cdf-b4b8-e5181c15bdb7) | kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 56fcc6b3-ca26-4cdf-b4b8-e5181c15bdb7 batch = 2667 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 | 2026/06/19 13:00:31 | 2 s | 1/1 |
3/3
|
| 343 (e1eacc71-943b-4bb4-a8fe-09129b09bc0c) | kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = e1eacc71-943b-4bb4-a8fe-09129b09bc0c batch = 2666 start at NativeMethodAccessorImpl.java:0 | 2026/06/19 12:59:32 | 5 s | 1/1 |
3/3
|
| 342 (56fcc6b3-ca26-4cdf-b4b8-e5181c15bdb7) | kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 56fcc6b3-ca26-4cdf-b4b8-e5181c15bdb7 batch = 2666 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 | 2026/06/19 12:59:31 | 2 s | 1/1 |
3/3
|
| 341 (e1eacc71-943b-4bb4-a8fe-09129b09bc0c) | kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = e1eacc71-943b-4bb4-a8fe-09129b09bc0c batch = 2665 start at NativeMethodAccessorImpl.java:0 | 2026/06/19 12:58:32 | 5 s | 1/1 |
3/3
|
| 340 (56fcc6b3-ca26-4cdf-b4b8-e5181c15bdb7) | kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 56fcc6b3-ca26-4cdf-b4b8-e5181c15bdb7 batch = 2665 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 | 2026/06/19 12:58:32 | 2 s | 1/1 |
3/3
|
| 339 (e1eacc71-943b-4bb4-a8fe-09129b09bc0c) | kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = e1eacc71-943b-4bb4-a8fe-09129b09bc0c batch = 2664 start at NativeMethodAccessorImpl.java:0 | 2026/06/19 12:57:32 | 5 s | 1/1 |
3/3
|
| 338 (56fcc6b3-ca26-4cdf-b4b8-e5181c15bdb7) | kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 56fcc6b3-ca26-4cdf-b4b8-e5181c15bdb7 batch = 2664 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 | 2026/06/19 12:57:32 | 2 s | 1/1 |
3/3
|
| 337 (e1eacc71-943b-4bb4-a8fe-09129b09bc0c) | kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = e1eacc71-943b-4bb4-a8fe-09129b09bc0c batch = 2663 start at NativeMethodAccessorImpl.java:0 | 2026/06/19 12:56:32 | 5 s | 1/1 |
3/3
|
| 336 (56fcc6b3-ca26-4cdf-b4b8-e5181c15bdb7) | kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 56fcc6b3-ca26-4cdf-b4b8-e5181c15bdb7 batch = 2663 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 | 2026/06/19 12:56:31 | 2 s | 1/1 |
3/3
|
| 335 (e1eacc71-943b-4bb4-a8fe-09129b09bc0c) | kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = e1eacc71-943b-4bb4-a8fe-09129b09bc0c batch = 2662 start at NativeMethodAccessorImpl.java:0 | 2026/06/19 12:55:32 | 5 s | 1/1 |
3/3
|
| 334 (56fcc6b3-ca26-4cdf-b4b8-e5181c15bdb7) | kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 56fcc6b3-ca26-4cdf-b4b8-e5181c15bdb7 batch = 2662 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 | 2026/06/19 12:55:32 | 2 s | 1/1 |
3/3
|
| 333 (e1eacc71-943b-4bb4-a8fe-09129b09bc0c) | kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = e1eacc71-943b-4bb4-a8fe-09129b09bc0c batch = 2661 start at NativeMethodAccessorImpl.java:0 | 2026/06/19 12:54:32 | 5 s | 1/1 |
3/3
|
| 332 (56fcc6b3-ca26-4cdf-b4b8-e5181c15bdb7) | kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 56fcc6b3-ca26-4cdf-b4b8-e5181c15bdb7 batch = 2661 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 | 2026/06/19 12:54:32 | 2 s | 1/1 |
3/3
|
| 331 (e1eacc71-943b-4bb4-a8fe-09129b09bc0c) | kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = e1eacc71-943b-4bb4-a8fe-09129b09bc0c batch = 2660 start at NativeMethodAccessorImpl.java:0 | 2026/06/19 12:53:32 | 4 s | 1/1 |
3/3
|
| 330 (56fcc6b3-ca26-4cdf-b4b8-e5181c15bdb7) | kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 56fcc6b3-ca26-4cdf-b4b8-e5181c15bdb7 batch = 2660 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 | 2026/06/19 12:53:31 | 2 s | 1/1 |
3/3
|
| 329 (e1eacc71-943b-4bb4-a8fe-09129b09bc0c) | kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = e1eacc71-943b-4bb4-a8fe-09129b09bc0c batch = 2659 start at NativeMethodAccessorImpl.java:0 | 2026/06/19 12:52:32 | 4 s | 1/1 |
3/3
|
| 328 (56fcc6b3-ca26-4cdf-b4b8-e5181c15bdb7) | kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 56fcc6b3-ca26-4cdf-b4b8-e5181c15bdb7 batch = 2659 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 | 2026/06/19 12:52:31 | 2 s | 1/1 |
3/3
|
| 327 (56fcc6b3-ca26-4cdf-b4b8-e5181c15bdb7) | kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 56fcc6b3-ca26-4cdf-b4b8-e5181c15bdb7 batch = 2658 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 | 2026/06/19 12:51:32 | 5 s | 1/1 |
3/3
|
| 326 (e1eacc71-943b-4bb4-a8fe-09129b09bc0c) | kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = e1eacc71-943b-4bb4-a8fe-09129b09bc0c batch = 2658 start at NativeMethodAccessorImpl.java:0 | 2026/06/19 12:51:32 | 4 s | 1/1 |
3/3
|
| 325 (e1eacc71-943b-4bb4-a8fe-09129b09bc0c) | kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = e1eacc71-943b-4bb4-a8fe-09129b09bc0c batch = 2657 start at NativeMethodAccessorImpl.java:0 | 2026/06/19 12:50:32 | 6 s | 1/1 |
3/3
|
| 324 (56fcc6b3-ca26-4cdf-b4b8-e5181c15bdb7) | kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 56fcc6b3-ca26-4cdf-b4b8-e5181c15bdb7 batch = 2657 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 | 2026/06/19 12:50:32 | 2 s | 1/1 |
3/3
|
| 323 (56fcc6b3-ca26-4cdf-b4b8-e5181c15bdb7) | kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 56fcc6b3-ca26-4cdf-b4b8-e5181c15bdb7 batch = 2656 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 | 2026/06/19 12:49:32 | 5 s | 1/1 |
3/3
|
| 322 (e1eacc71-943b-4bb4-a8fe-09129b09bc0c) | kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = e1eacc71-943b-4bb4-a8fe-09129b09bc0c batch = 2656 start at NativeMethodAccessorImpl.java:0 | 2026/06/19 12:49:32 | 4 s | 1/1 |
3/3
|
| 321 (e1eacc71-943b-4bb4-a8fe-09129b09bc0c) | kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = e1eacc71-943b-4bb4-a8fe-09129b09bc0c batch = 2655 start at NativeMethodAccessorImpl.java:0 | 2026/06/19 12:48:32 | 5 s | 1/1 |
3/3
|
| 320 (56fcc6b3-ca26-4cdf-b4b8-e5181c15bdb7) | kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 56fcc6b3-ca26-4cdf-b4b8-e5181c15bdb7 batch = 2655 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 | 2026/06/19 12:48:32 | 2 s | 1/1 |
3/3
|
| 319 (e1eacc71-943b-4bb4-a8fe-09129b09bc0c) | kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = e1eacc71-943b-4bb4-a8fe-09129b09bc0c batch = 2654 start at NativeMethodAccessorImpl.java:0 | 2026/06/19 12:47:32 | 4 s | 1/1 |
3/3
|
| 318 (56fcc6b3-ca26-4cdf-b4b8-e5181c15bdb7) | kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 56fcc6b3-ca26-4cdf-b4b8-e5181c15bdb7 batch = 2654 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 | 2026/06/19 12:47:31 | 2 s | 1/1 |
3/3
|
| 317 (e1eacc71-943b-4bb4-a8fe-09129b09bc0c) | kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = e1eacc71-943b-4bb4-a8fe-09129b09bc0c batch = 2653 start at NativeMethodAccessorImpl.java:0 | 2026/06/19 12:46:32 | 4 s | 1/1 |
3/3
|
| 316 (56fcc6b3-ca26-4cdf-b4b8-e5181c15bdb7) | kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 56fcc6b3-ca26-4cdf-b4b8-e5181c15bdb7 batch = 2653 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 | 2026/06/19 12:46:31 | 2 s | 1/1 |
3/3
|
| 315 (e1eacc71-943b-4bb4-a8fe-09129b09bc0c) | kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = e1eacc71-943b-4bb4-a8fe-09129b09bc0c batch = 2652 start at NativeMethodAccessorImpl.java:0 | 2026/06/19 12:45:32 | 5 s | 1/1 |
3/3
|
| 314 (56fcc6b3-ca26-4cdf-b4b8-e5181c15bdb7) | kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 56fcc6b3-ca26-4cdf-b4b8-e5181c15bdb7 batch = 2652 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 | 2026/06/19 12:45:32 | 2 s | 1/1 |
3/3
|
| 313 (e1eacc71-943b-4bb4-a8fe-09129b09bc0c) | kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = e1eacc71-943b-4bb4-a8fe-09129b09bc0c batch = 2651 start at NativeMethodAccessorImpl.java:0 | 2026/06/19 12:44:32 | 5 s | 1/1 |
3/3
|
| 312 (56fcc6b3-ca26-4cdf-b4b8-e5181c15bdb7) | kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 56fcc6b3-ca26-4cdf-b4b8-e5181c15bdb7 batch = 2651 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 | 2026/06/19 12:44:31 | 2 s | 1/1 |
3/3
|
| 311 (56fcc6b3-ca26-4cdf-b4b8-e5181c15bdb7) | kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 56fcc6b3-ca26-4cdf-b4b8-e5181c15bdb7 batch = 2650 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 | 2026/06/19 12:43:32 | 5 s | 1/1 |
3/3
|
| 310 (e1eacc71-943b-4bb4-a8fe-09129b09bc0c) | kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = e1eacc71-943b-4bb4-a8fe-09129b09bc0c batch = 2650 start at NativeMethodAccessorImpl.java:0 | 2026/06/19 12:43:32 | 4 s | 1/1 |
3/3
|
| 309 (e1eacc71-943b-4bb4-a8fe-09129b09bc0c) | kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = e1eacc71-943b-4bb4-a8fe-09129b09bc0c batch = 2649 start at NativeMethodAccessorImpl.java:0 | 2026/06/19 12:42:32 | 5 s | 1/1 |
3/3
|
| 308 (56fcc6b3-ca26-4cdf-b4b8-e5181c15bdb7) | kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 56fcc6b3-ca26-4cdf-b4b8-e5181c15bdb7 batch = 2649 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 | 2026/06/19 12:42:32 | 2 s | 1/1 |
3/3
|
| 307 (e1eacc71-943b-4bb4-a8fe-09129b09bc0c) | kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = e1eacc71-943b-4bb4-a8fe-09129b09bc0c batch = 2648 start at NativeMethodAccessorImpl.java:0 | 2026/06/19 12:41:32 | 4 s | 1/1 |
3/3
|
| 306 (56fcc6b3-ca26-4cdf-b4b8-e5181c15bdb7) | kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 56fcc6b3-ca26-4cdf-b4b8-e5181c15bdb7 batch = 2648 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 | 2026/06/19 12:41:32 | 2 s | 1/1 |
3/3
|
| 305 (e1eacc71-943b-4bb4-a8fe-09129b09bc0c) | kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = e1eacc71-943b-4bb4-a8fe-09129b09bc0c batch = 2647 start at NativeMethodAccessorImpl.java:0 | 2026/06/19 12:40:32 | 5 s | 1/1 |
3/3
|
| 304 (56fcc6b3-ca26-4cdf-b4b8-e5181c15bdb7) | kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 56fcc6b3-ca26-4cdf-b4b8-e5181c15bdb7 batch = 2647 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 | 2026/06/19 12:40:32 | 2 s | 1/1 |
3/3
|
| 303 (e1eacc71-943b-4bb4-a8fe-09129b09bc0c) | kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = e1eacc71-943b-4bb4-a8fe-09129b09bc0c batch = 2646 start at NativeMethodAccessorImpl.java:0 | 2026/06/19 12:39:32 | 5 s | 1/1 |
3/3
|
| 302 (56fcc6b3-ca26-4cdf-b4b8-e5181c15bdb7) | kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 56fcc6b3-ca26-4cdf-b4b8-e5181c15bdb7 batch = 2646 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 | 2026/06/19 12:39:32 | 2 s | 1/1 |
3/3
|
| 301 (e1eacc71-943b-4bb4-a8fe-09129b09bc0c) | kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = e1eacc71-943b-4bb4-a8fe-09129b09bc0c batch = 2645 start at NativeMethodAccessorImpl.java:0 | 2026/06/19 12:38:32 | 5 s | 1/1 |
3/3
|
| 300 (56fcc6b3-ca26-4cdf-b4b8-e5181c15bdb7) | kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 56fcc6b3-ca26-4cdf-b4b8-e5181c15bdb7 batch = 2645 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 | 2026/06/19 12:38:32 | 2 s | 1/1 |
3/3
|
| 299 (e1eacc71-943b-4bb4-a8fe-09129b09bc0c) | kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = e1eacc71-943b-4bb4-a8fe-09129b09bc0c batch = 2644 start at NativeMethodAccessorImpl.java:0 | 2026/06/19 12:37:32 | 5 s | 1/1 |
3/3
|
| 298 (56fcc6b3-ca26-4cdf-b4b8-e5181c15bdb7) | kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 56fcc6b3-ca26-4cdf-b4b8-e5181c15bdb7 batch = 2644 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 | 2026/06/19 12:37:32 | 2 s | 1/1 |
3/3
|
| 297 (e1eacc71-943b-4bb4-a8fe-09129b09bc0c) | kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = e1eacc71-943b-4bb4-a8fe-09129b09bc0c batch = 2643 start at NativeMethodAccessorImpl.java:0 | 2026/06/19 12:36:32 | 6 s | 1/1 |
4/4
|
| 296 (56fcc6b3-ca26-4cdf-b4b8-e5181c15bdb7) | kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 56fcc6b3-ca26-4cdf-b4b8-e5181c15bdb7 batch = 2643 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 | 2026/06/19 12:36:32 | 2 s | 1/1 |
4/4
|
| 295 (56fcc6b3-ca26-4cdf-b4b8-e5181c15bdb7) | kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 56fcc6b3-ca26-4cdf-b4b8-e5181c15bdb7 batch = 2642 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 | 2026/06/19 12:35:32 | 5 s | 1/1 |
3/3
|
| 294 (e1eacc71-943b-4bb4-a8fe-09129b09bc0c) | kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = e1eacc71-943b-4bb4-a8fe-09129b09bc0c batch = 2642 start at NativeMethodAccessorImpl.java:0 | 2026/06/19 12:35:32 | 4 s | 1/1 |
3/3
|
| 293 (e1eacc71-943b-4bb4-a8fe-09129b09bc0c) | kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = e1eacc71-943b-4bb4-a8fe-09129b09bc0c batch = 2641 start at NativeMethodAccessorImpl.java:0 | 2026/06/19 12:34:32 | 5 s | 1/1 |
3/3
|
| 292 (56fcc6b3-ca26-4cdf-b4b8-e5181c15bdb7) | kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 56fcc6b3-ca26-4cdf-b4b8-e5181c15bdb7 batch = 2641 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 | 2026/06/19 12:34:32 | 2 s | 1/1 |
3/3
|
| 291 (e1eacc71-943b-4bb4-a8fe-09129b09bc0c) | kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = e1eacc71-943b-4bb4-a8fe-09129b09bc0c batch = 2640 start at NativeMethodAccessorImpl.java:0 | 2026/06/19 12:33:32 | 5 s | 1/1 |
3/3
|
| 290 (56fcc6b3-ca26-4cdf-b4b8-e5181c15bdb7) | kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 56fcc6b3-ca26-4cdf-b4b8-e5181c15bdb7 batch = 2640 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 | 2026/06/19 12:33:32 | 2 s | 1/1 |
3/3
|
| 289 (e1eacc71-943b-4bb4-a8fe-09129b09bc0c) | kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = e1eacc71-943b-4bb4-a8fe-09129b09bc0c batch = 2639 start at NativeMethodAccessorImpl.java:0 | 2026/06/19 12:32:32 | 5 s | 1/1 |
3/3
|
| 288 (56fcc6b3-ca26-4cdf-b4b8-e5181c15bdb7) | kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 56fcc6b3-ca26-4cdf-b4b8-e5181c15bdb7 batch = 2639 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 | 2026/06/19 12:32:31 | 2 s | 1/1 |
3/3
|
| 287 (e1eacc71-943b-4bb4-a8fe-09129b09bc0c) | kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = e1eacc71-943b-4bb4-a8fe-09129b09bc0c batch = 2638 start at NativeMethodAccessorImpl.java:0 | 2026/06/19 12:31:32 | 5 s | 1/1 |
3/3
|
| 286 (56fcc6b3-ca26-4cdf-b4b8-e5181c15bdb7) | kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 56fcc6b3-ca26-4cdf-b4b8-e5181c15bdb7 batch = 2638 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 | 2026/06/19 12:31:32 | 2 s | 1/1 |
3/3
|
| 285 (e1eacc71-943b-4bb4-a8fe-09129b09bc0c) | kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = e1eacc71-943b-4bb4-a8fe-09129b09bc0c batch = 2637 start at NativeMethodAccessorImpl.java:0 | 2026/06/19 12:30:32 | 5 s | 1/1 |
3/3
|
| 284 (56fcc6b3-ca26-4cdf-b4b8-e5181c15bdb7) | kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 56fcc6b3-ca26-4cdf-b4b8-e5181c15bdb7 batch = 2637 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 | 2026/06/19 12:30:32 | 2 s | 1/1 |
3/3
|
| 283 (56fcc6b3-ca26-4cdf-b4b8-e5181c15bdb7) | kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 56fcc6b3-ca26-4cdf-b4b8-e5181c15bdb7 batch = 2636 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 | 2026/06/19 12:29:32 | 5 s | 1/1 |
3/3
|
| 282 (e1eacc71-943b-4bb4-a8fe-09129b09bc0c) | kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = e1eacc71-943b-4bb4-a8fe-09129b09bc0c batch = 2636 start at NativeMethodAccessorImpl.java:0 | 2026/06/19 12:29:32 | 3 s | 1/1 |
3/3
|
| 281 (56fcc6b3-ca26-4cdf-b4b8-e5181c15bdb7) | kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 56fcc6b3-ca26-4cdf-b4b8-e5181c15bdb7 batch = 2635 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 | 2026/06/19 12:28:32 | 5 s | 1/1 |
3/3
|
| 280 (e1eacc71-943b-4bb4-a8fe-09129b09bc0c) | kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = e1eacc71-943b-4bb4-a8fe-09129b09bc0c batch = 2635 start at NativeMethodAccessorImpl.java:0 | 2026/06/19 12:28:32 | 3 s | 1/1 |
3/3
|