Spark Jobs (?)

  • User: spark
  • Total Uptime: 10.8 h
  • Scheduling Mode: FIFO
  • Completed Jobs: 1323, only showing 923
Event Timeline

Completed Jobs (1323, only showing 923)

Job Id (Job Group) ▾ Description Submitted Duration Stages: Succeeded/Total Tasks (for all stages): Succeeded/Total
1322 (327b0da6-8357-4583-b7b6-9cc64f0a612a) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 327b0da6-8357-4583-b7b6-9cc64f0a612a batch = 22546 start at NativeMethodAccessorImpl.java:0 2026/07/03 07:25:32 5 s 1/1
3/3
1321 (b9dcd960-b87e-4142-ac4d-adff9e0770ad) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = b9dcd960-b87e-4142-ac4d-adff9e0770ad batch = 22469 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/07/03 07:25:32 2 s 1/1
3/3
1320 (327b0da6-8357-4583-b7b6-9cc64f0a612a) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 327b0da6-8357-4583-b7b6-9cc64f0a612a batch = 22545 start at NativeMethodAccessorImpl.java:0 2026/07/03 07:24:32 5 s 1/1
3/3
1319 (b9dcd960-b87e-4142-ac4d-adff9e0770ad) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = b9dcd960-b87e-4142-ac4d-adff9e0770ad batch = 22468 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/07/03 07:24:32 2 s 1/1
3/3
1318 (327b0da6-8357-4583-b7b6-9cc64f0a612a) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 327b0da6-8357-4583-b7b6-9cc64f0a612a batch = 22544 start at NativeMethodAccessorImpl.java:0 2026/07/03 07:23:32 5 s 1/1
3/3
1317 (b9dcd960-b87e-4142-ac4d-adff9e0770ad) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = b9dcd960-b87e-4142-ac4d-adff9e0770ad batch = 22467 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/07/03 07:23:32 2 s 1/1
3/3
1316 (b9dcd960-b87e-4142-ac4d-adff9e0770ad) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = b9dcd960-b87e-4142-ac4d-adff9e0770ad batch = 22466 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/07/03 07:22:32 6 s 1/1
3/3
1315 (327b0da6-8357-4583-b7b6-9cc64f0a612a) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 327b0da6-8357-4583-b7b6-9cc64f0a612a batch = 22543 start at NativeMethodAccessorImpl.java:0 2026/07/03 07:22:32 4 s 1/1
3/3
1314 (327b0da6-8357-4583-b7b6-9cc64f0a612a) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 327b0da6-8357-4583-b7b6-9cc64f0a612a batch = 22542 start at NativeMethodAccessorImpl.java:0 2026/07/03 07:21:33 5 s 1/1
3/3
1313 (b9dcd960-b87e-4142-ac4d-adff9e0770ad) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = b9dcd960-b87e-4142-ac4d-adff9e0770ad batch = 22465 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/07/03 07:21:32 2 s 1/1
3/3
1312 (327b0da6-8357-4583-b7b6-9cc64f0a612a) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 327b0da6-8357-4583-b7b6-9cc64f0a612a batch = 22541 start at NativeMethodAccessorImpl.java:0 2026/07/03 07:20:32 5 s 1/1
3/3
1311 (b9dcd960-b87e-4142-ac4d-adff9e0770ad) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = b9dcd960-b87e-4142-ac4d-adff9e0770ad batch = 22464 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/07/03 07:20:32 2 s 1/1
3/3
1310 (b9dcd960-b87e-4142-ac4d-adff9e0770ad) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = b9dcd960-b87e-4142-ac4d-adff9e0770ad batch = 22463 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/07/03 07:19:32 6 s 1/1
3/3
1309 (327b0da6-8357-4583-b7b6-9cc64f0a612a) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 327b0da6-8357-4583-b7b6-9cc64f0a612a batch = 22540 start at NativeMethodAccessorImpl.java:0 2026/07/03 07:19:32 4 s 1/1
3/3
1308 (327b0da6-8357-4583-b7b6-9cc64f0a612a) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 327b0da6-8357-4583-b7b6-9cc64f0a612a batch = 22539 start at NativeMethodAccessorImpl.java:0 2026/07/03 07:18:32 5 s 1/1
3/3
1307 (b9dcd960-b87e-4142-ac4d-adff9e0770ad) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = b9dcd960-b87e-4142-ac4d-adff9e0770ad batch = 22462 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/07/03 07:18:32 2 s 1/1
3/3
1306 (327b0da6-8357-4583-b7b6-9cc64f0a612a) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 327b0da6-8357-4583-b7b6-9cc64f0a612a batch = 22538 start at NativeMethodAccessorImpl.java:0 2026/07/03 07:17:32 5 s 1/1
3/3
1305 (b9dcd960-b87e-4142-ac4d-adff9e0770ad) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = b9dcd960-b87e-4142-ac4d-adff9e0770ad batch = 22461 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/07/03 07:17:32 2 s 1/1
3/3
1304 (327b0da6-8357-4583-b7b6-9cc64f0a612a) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 327b0da6-8357-4583-b7b6-9cc64f0a612a batch = 22537 start at NativeMethodAccessorImpl.java:0 2026/07/03 07:16:32 5 s 1/1
3/3
1303 (b9dcd960-b87e-4142-ac4d-adff9e0770ad) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = b9dcd960-b87e-4142-ac4d-adff9e0770ad batch = 22460 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/07/03 07:16:32 2 s 1/1
3/3
1302 (b9dcd960-b87e-4142-ac4d-adff9e0770ad) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = b9dcd960-b87e-4142-ac4d-adff9e0770ad batch = 22459 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/07/03 07:15:32 5 s 1/1
3/3
1301 (327b0da6-8357-4583-b7b6-9cc64f0a612a) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 327b0da6-8357-4583-b7b6-9cc64f0a612a batch = 22536 start at NativeMethodAccessorImpl.java:0 2026/07/03 07:15:32 4 s 1/1
3/3
1300 (327b0da6-8357-4583-b7b6-9cc64f0a612a) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 327b0da6-8357-4583-b7b6-9cc64f0a612a batch = 22535 start at NativeMethodAccessorImpl.java:0 2026/07/03 07:14:32 4 s 1/1
3/3
1299 (b9dcd960-b87e-4142-ac4d-adff9e0770ad) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = b9dcd960-b87e-4142-ac4d-adff9e0770ad batch = 22458 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/07/03 07:14:32 2 s 1/1
3/3
1298 (327b0da6-8357-4583-b7b6-9cc64f0a612a) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 327b0da6-8357-4583-b7b6-9cc64f0a612a batch = 22534 start at NativeMethodAccessorImpl.java:0 2026/07/03 07:13:32 5 s 1/1
3/3
1297 (b9dcd960-b87e-4142-ac4d-adff9e0770ad) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = b9dcd960-b87e-4142-ac4d-adff9e0770ad batch = 22457 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/07/03 07:13:32 2 s 1/1
3/3
1296 (327b0da6-8357-4583-b7b6-9cc64f0a612a) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 327b0da6-8357-4583-b7b6-9cc64f0a612a batch = 22533 start at NativeMethodAccessorImpl.java:0 2026/07/03 07:12:32 5 s 1/1
3/3
1295 (b9dcd960-b87e-4142-ac4d-adff9e0770ad) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = b9dcd960-b87e-4142-ac4d-adff9e0770ad batch = 22456 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/07/03 07:12:32 2 s 1/1
3/3
1294 (327b0da6-8357-4583-b7b6-9cc64f0a612a) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 327b0da6-8357-4583-b7b6-9cc64f0a612a batch = 22532 start at NativeMethodAccessorImpl.java:0 2026/07/03 07:11:32 5 s 1/1
3/3
1293 (b9dcd960-b87e-4142-ac4d-adff9e0770ad) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = b9dcd960-b87e-4142-ac4d-adff9e0770ad batch = 22455 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/07/03 07:11:32 2 s 1/1
3/3
1292 (b9dcd960-b87e-4142-ac4d-adff9e0770ad) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = b9dcd960-b87e-4142-ac4d-adff9e0770ad batch = 22454 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/07/03 07:10:32 5 s 1/1
3/3
1291 (327b0da6-8357-4583-b7b6-9cc64f0a612a) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 327b0da6-8357-4583-b7b6-9cc64f0a612a batch = 22531 start at NativeMethodAccessorImpl.java:0 2026/07/03 07:10:32 4 s 1/1
3/3
1290 (b9dcd960-b87e-4142-ac4d-adff9e0770ad) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = b9dcd960-b87e-4142-ac4d-adff9e0770ad batch = 22453 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/07/03 07:09:32 6 s 1/1
3/3
1289 (327b0da6-8357-4583-b7b6-9cc64f0a612a) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 327b0da6-8357-4583-b7b6-9cc64f0a612a batch = 22530 start at NativeMethodAccessorImpl.java:0 2026/07/03 07:09:32 4 s 1/1
3/3
1288 (327b0da6-8357-4583-b7b6-9cc64f0a612a) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 327b0da6-8357-4583-b7b6-9cc64f0a612a batch = 22529 start at NativeMethodAccessorImpl.java:0 2026/07/03 07:08:32 5 s 1/1
3/3
1287 (b9dcd960-b87e-4142-ac4d-adff9e0770ad) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = b9dcd960-b87e-4142-ac4d-adff9e0770ad batch = 22452 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/07/03 07:08:32 2 s 1/1
3/3
1286 (327b0da6-8357-4583-b7b6-9cc64f0a612a) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 327b0da6-8357-4583-b7b6-9cc64f0a612a batch = 22528 start at NativeMethodAccessorImpl.java:0 2026/07/03 07:07:32 5 s 1/1
3/3
1285 (b9dcd960-b87e-4142-ac4d-adff9e0770ad) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = b9dcd960-b87e-4142-ac4d-adff9e0770ad batch = 22451 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/07/03 07:07:32 2 s 1/1
3/3
1284 (327b0da6-8357-4583-b7b6-9cc64f0a612a) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 327b0da6-8357-4583-b7b6-9cc64f0a612a batch = 22527 start at NativeMethodAccessorImpl.java:0 2026/07/03 07:06:32 5 s 1/1
3/3
1283 (b9dcd960-b87e-4142-ac4d-adff9e0770ad) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = b9dcd960-b87e-4142-ac4d-adff9e0770ad batch = 22450 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/07/03 07:06:32 2 s 1/1
3/3
1282 (327b0da6-8357-4583-b7b6-9cc64f0a612a) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 327b0da6-8357-4583-b7b6-9cc64f0a612a batch = 22526 start at NativeMethodAccessorImpl.java:0 2026/07/03 07:05:32 4 s 1/1
3/3
1281 (b9dcd960-b87e-4142-ac4d-adff9e0770ad) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = b9dcd960-b87e-4142-ac4d-adff9e0770ad batch = 22449 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/07/03 07:05:32 2 s 1/1
3/3
1280 (327b0da6-8357-4583-b7b6-9cc64f0a612a) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 327b0da6-8357-4583-b7b6-9cc64f0a612a batch = 22525 start at NativeMethodAccessorImpl.java:0 2026/07/03 07:04:32 5 s 1/1
3/3
1279 (b9dcd960-b87e-4142-ac4d-adff9e0770ad) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = b9dcd960-b87e-4142-ac4d-adff9e0770ad batch = 22448 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/07/03 07:04:31 2 s 1/1
3/3
1278 (327b0da6-8357-4583-b7b6-9cc64f0a612a) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 327b0da6-8357-4583-b7b6-9cc64f0a612a batch = 22524 start at NativeMethodAccessorImpl.java:0 2026/07/03 07:03:33 4 s 1/1
3/3
1277 (b9dcd960-b87e-4142-ac4d-adff9e0770ad) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = b9dcd960-b87e-4142-ac4d-adff9e0770ad batch = 22447 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/07/03 07:03:32 2 s 1/1
3/3
1276 (327b0da6-8357-4583-b7b6-9cc64f0a612a) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 327b0da6-8357-4583-b7b6-9cc64f0a612a batch = 22523 start at NativeMethodAccessorImpl.java:0 2026/07/03 07:02:32 5 s 1/1
3/3
1275 (b9dcd960-b87e-4142-ac4d-adff9e0770ad) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = b9dcd960-b87e-4142-ac4d-adff9e0770ad batch = 22446 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/07/03 07:02:32 2 s 1/1
3/3
1274 (327b0da6-8357-4583-b7b6-9cc64f0a612a) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 327b0da6-8357-4583-b7b6-9cc64f0a612a batch = 22522 start at NativeMethodAccessorImpl.java:0 2026/07/03 07:01:32 5 s 1/1
3/3
1273 (b9dcd960-b87e-4142-ac4d-adff9e0770ad) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = b9dcd960-b87e-4142-ac4d-adff9e0770ad batch = 22445 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/07/03 07:01:32 2 s 1/1
3/3
1272 (327b0da6-8357-4583-b7b6-9cc64f0a612a) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 327b0da6-8357-4583-b7b6-9cc64f0a612a batch = 22521 start at NativeMethodAccessorImpl.java:0 2026/07/03 07:00:32 5 s 1/1
3/3
1271 (b9dcd960-b87e-4142-ac4d-adff9e0770ad) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = b9dcd960-b87e-4142-ac4d-adff9e0770ad batch = 22444 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/07/03 07:00:32 2 s 1/1
3/3
1270 (327b0da6-8357-4583-b7b6-9cc64f0a612a) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 327b0da6-8357-4583-b7b6-9cc64f0a612a batch = 22520 start at NativeMethodAccessorImpl.java:0 2026/07/03 07:00:03 3 s 1/1
3/3
1269 (327b0da6-8357-4583-b7b6-9cc64f0a612a) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 327b0da6-8357-4583-b7b6-9cc64f0a612a batch = 22519 start at NativeMethodAccessorImpl.java:0 2026/07/03 06:59:32 5 s 1/1
3/3
1268 (b9dcd960-b87e-4142-ac4d-adff9e0770ad) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = b9dcd960-b87e-4142-ac4d-adff9e0770ad batch = 22443 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/07/03 06:59:32 2 s 1/1
3/3
1267 (b9dcd960-b87e-4142-ac4d-adff9e0770ad) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = b9dcd960-b87e-4142-ac4d-adff9e0770ad batch = 22442 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/07/03 06:58:32 5 s 1/1
3/3
1266 (327b0da6-8357-4583-b7b6-9cc64f0a612a) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 327b0da6-8357-4583-b7b6-9cc64f0a612a batch = 22518 start at NativeMethodAccessorImpl.java:0 2026/07/03 06:58:32 3 s 1/1
3/3
1265 (327b0da6-8357-4583-b7b6-9cc64f0a612a) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 327b0da6-8357-4583-b7b6-9cc64f0a612a batch = 22517 start at NativeMethodAccessorImpl.java:0 2026/07/03 06:57:32 4 s 1/1
3/3
1264 (b9dcd960-b87e-4142-ac4d-adff9e0770ad) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = b9dcd960-b87e-4142-ac4d-adff9e0770ad batch = 22441 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/07/03 06:57:31 2 s 1/1
3/3
1263 (327b0da6-8357-4583-b7b6-9cc64f0a612a) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 327b0da6-8357-4583-b7b6-9cc64f0a612a batch = 22516 start at NativeMethodAccessorImpl.java:0 2026/07/03 06:56:32 6 s 1/1
3/3
1262 (b9dcd960-b87e-4142-ac4d-adff9e0770ad) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = b9dcd960-b87e-4142-ac4d-adff9e0770ad batch = 22440 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/07/03 06:56:32 2 s 1/1
3/3
1261 (327b0da6-8357-4583-b7b6-9cc64f0a612a) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 327b0da6-8357-4583-b7b6-9cc64f0a612a batch = 22515 start at NativeMethodAccessorImpl.java:0 2026/07/03 06:55:32 5 s 1/1
3/3
1260 (b9dcd960-b87e-4142-ac4d-adff9e0770ad) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = b9dcd960-b87e-4142-ac4d-adff9e0770ad batch = 22439 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/07/03 06:55:32 2 s 1/1
3/3
1259 (b9dcd960-b87e-4142-ac4d-adff9e0770ad) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = b9dcd960-b87e-4142-ac4d-adff9e0770ad batch = 22438 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/07/03 06:54:32 5 s 1/1
3/3
1258 (327b0da6-8357-4583-b7b6-9cc64f0a612a) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 327b0da6-8357-4583-b7b6-9cc64f0a612a batch = 22514 start at NativeMethodAccessorImpl.java:0 2026/07/03 06:54:32 4 s 1/1
3/3
1257 (327b0da6-8357-4583-b7b6-9cc64f0a612a) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 327b0da6-8357-4583-b7b6-9cc64f0a612a batch = 22513 start at NativeMethodAccessorImpl.java:0 2026/07/03 06:53:32 5 s 1/1
3/3
1256 (b9dcd960-b87e-4142-ac4d-adff9e0770ad) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = b9dcd960-b87e-4142-ac4d-adff9e0770ad batch = 22437 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/07/03 06:53:32 2 s 1/1
3/3
1255 (327b0da6-8357-4583-b7b6-9cc64f0a612a) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 327b0da6-8357-4583-b7b6-9cc64f0a612a batch = 22512 start at NativeMethodAccessorImpl.java:0 2026/07/03 06:52:32 5 s 1/1
3/3
1254 (b9dcd960-b87e-4142-ac4d-adff9e0770ad) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = b9dcd960-b87e-4142-ac4d-adff9e0770ad batch = 22436 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/07/03 06:52:32 2 s 1/1
3/3
1253 (b9dcd960-b87e-4142-ac4d-adff9e0770ad) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = b9dcd960-b87e-4142-ac4d-adff9e0770ad batch = 22435 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/07/03 06:51:32 6 s 1/1
3/3
1252 (327b0da6-8357-4583-b7b6-9cc64f0a612a) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 327b0da6-8357-4583-b7b6-9cc64f0a612a batch = 22511 start at NativeMethodAccessorImpl.java:0 2026/07/03 06:51:32 4 s 1/1
3/3
1251 (327b0da6-8357-4583-b7b6-9cc64f0a612a) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 327b0da6-8357-4583-b7b6-9cc64f0a612a batch = 22510 start at NativeMethodAccessorImpl.java:0 2026/07/03 06:51:02 2 s 1/1
3/3
1250 (327b0da6-8357-4583-b7b6-9cc64f0a612a) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 327b0da6-8357-4583-b7b6-9cc64f0a612a batch = 22509 start at NativeMethodAccessorImpl.java:0 2026/07/03 06:50:32 5 s 1/1
3/3
1249 (b9dcd960-b87e-4142-ac4d-adff9e0770ad) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = b9dcd960-b87e-4142-ac4d-adff9e0770ad batch = 22434 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/07/03 06:50:32 2 s 1/1
3/3
1248 (327b0da6-8357-4583-b7b6-9cc64f0a612a) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 327b0da6-8357-4583-b7b6-9cc64f0a612a batch = 22508 start at NativeMethodAccessorImpl.java:0 2026/07/03 06:49:33 5 s 1/1
3/3
1247 (b9dcd960-b87e-4142-ac4d-adff9e0770ad) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = b9dcd960-b87e-4142-ac4d-adff9e0770ad batch = 22433 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/07/03 06:49:32 2 s 1/1
3/3
1246 (327b0da6-8357-4583-b7b6-9cc64f0a612a) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 327b0da6-8357-4583-b7b6-9cc64f0a612a batch = 22507 start at NativeMethodAccessorImpl.java:0 2026/07/03 06:48:32 5 s 1/1
3/3
1245 (b9dcd960-b87e-4142-ac4d-adff9e0770ad) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = b9dcd960-b87e-4142-ac4d-adff9e0770ad batch = 22432 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/07/03 06:48:32 2 s 1/1
3/3
1244 (b9dcd960-b87e-4142-ac4d-adff9e0770ad) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = b9dcd960-b87e-4142-ac4d-adff9e0770ad batch = 22431 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/07/03 06:47:32 5 s 1/1
3/3
1243 (327b0da6-8357-4583-b7b6-9cc64f0a612a) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 327b0da6-8357-4583-b7b6-9cc64f0a612a batch = 22506 start at NativeMethodAccessorImpl.java:0 2026/07/03 06:47:32 3 s 1/1
3/3
1242 (b9dcd960-b87e-4142-ac4d-adff9e0770ad) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = b9dcd960-b87e-4142-ac4d-adff9e0770ad batch = 22430 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/07/03 06:46:32 5 s 1/1
3/3
1241 (327b0da6-8357-4583-b7b6-9cc64f0a612a) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 327b0da6-8357-4583-b7b6-9cc64f0a612a batch = 22505 start at NativeMethodAccessorImpl.java:0 2026/07/03 06:46:32 3 s 1/1
3/3
1240 (327b0da6-8357-4583-b7b6-9cc64f0a612a) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 327b0da6-8357-4583-b7b6-9cc64f0a612a batch = 22504 start at NativeMethodAccessorImpl.java:0 2026/07/03 06:45:32 5 s 1/1
3/3
1239 (b9dcd960-b87e-4142-ac4d-adff9e0770ad) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = b9dcd960-b87e-4142-ac4d-adff9e0770ad batch = 22429 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/07/03 06:45:32 2 s 1/1
3/3
1238 (327b0da6-8357-4583-b7b6-9cc64f0a612a) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 327b0da6-8357-4583-b7b6-9cc64f0a612a batch = 22503 start at NativeMethodAccessorImpl.java:0 2026/07/03 06:44:32 5 s 1/1
3/3
1237 (b9dcd960-b87e-4142-ac4d-adff9e0770ad) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = b9dcd960-b87e-4142-ac4d-adff9e0770ad batch = 22428 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/07/03 06:44:32 2 s 1/1
3/3
1236 (327b0da6-8357-4583-b7b6-9cc64f0a612a) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 327b0da6-8357-4583-b7b6-9cc64f0a612a batch = 22502 start at NativeMethodAccessorImpl.java:0 2026/07/03 06:43:32 5 s 1/1
3/3
1235 (b9dcd960-b87e-4142-ac4d-adff9e0770ad) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = b9dcd960-b87e-4142-ac4d-adff9e0770ad batch = 22427 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/07/03 06:43:32 2 s 1/1
3/3
1234 (327b0da6-8357-4583-b7b6-9cc64f0a612a) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 327b0da6-8357-4583-b7b6-9cc64f0a612a batch = 22501 start at NativeMethodAccessorImpl.java:0 2026/07/03 06:42:32 5 s 1/1
3/3
1233 (b9dcd960-b87e-4142-ac4d-adff9e0770ad) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = b9dcd960-b87e-4142-ac4d-adff9e0770ad batch = 22426 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/07/03 06:42:32 2 s 1/1
3/3
1232 (327b0da6-8357-4583-b7b6-9cc64f0a612a) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 327b0da6-8357-4583-b7b6-9cc64f0a612a batch = 22500 start at NativeMethodAccessorImpl.java:0 2026/07/03 06:41:32 5 s 1/1
3/3
1231 (b9dcd960-b87e-4142-ac4d-adff9e0770ad) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = b9dcd960-b87e-4142-ac4d-adff9e0770ad batch = 22425 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/07/03 06:41:32 2 s 1/1
3/3
1230 (327b0da6-8357-4583-b7b6-9cc64f0a612a) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 327b0da6-8357-4583-b7b6-9cc64f0a612a batch = 22499 start at NativeMethodAccessorImpl.java:0 2026/07/03 06:40:32 5 s 1/1
3/3
1229 (b9dcd960-b87e-4142-ac4d-adff9e0770ad) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = b9dcd960-b87e-4142-ac4d-adff9e0770ad batch = 22424 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/07/03 06:40:32 2 s 1/1
3/3
1228 (327b0da6-8357-4583-b7b6-9cc64f0a612a) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 327b0da6-8357-4583-b7b6-9cc64f0a612a batch = 22498 start at NativeMethodAccessorImpl.java:0 2026/07/03 06:39:32 5 s 1/1
3/3
1227 (b9dcd960-b87e-4142-ac4d-adff9e0770ad) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = b9dcd960-b87e-4142-ac4d-adff9e0770ad batch = 22423 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/07/03 06:39:32 2 s 1/1
3/3
1226 (327b0da6-8357-4583-b7b6-9cc64f0a612a) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 327b0da6-8357-4583-b7b6-9cc64f0a612a batch = 22497 start at NativeMethodAccessorImpl.java:0 2026/07/03 06:38:32 5 s 1/1
3/3
1225 (b9dcd960-b87e-4142-ac4d-adff9e0770ad) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = b9dcd960-b87e-4142-ac4d-adff9e0770ad batch = 22422 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/07/03 06:38:32 2 s 1/1
3/3
1224 (b9dcd960-b87e-4142-ac4d-adff9e0770ad) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = b9dcd960-b87e-4142-ac4d-adff9e0770ad batch = 22421 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/07/03 06:37:32 4 s 1/1
3/3
1223 (327b0da6-8357-4583-b7b6-9cc64f0a612a) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 327b0da6-8357-4583-b7b6-9cc64f0a612a batch = 22496 start at NativeMethodAccessorImpl.java:0 2026/07/03 06:37:32 3 s 1/1
3/3