Spark Jobs (?)

  • User: spark
  • Total Uptime: 3.3 h
  • Scheduling Mode: FIFO
  • Completed Jobs: 399
Event Timeline

Completed Jobs (399)

Page:
Job Id (Job Group) ▾ Description Submitted Duration Stages: Succeeded/Total Tasks (for all stages): Succeeded/Total
398 (b9dcd960-b87e-4142-ac4d-adff9e0770ad) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = b9dcd960-b87e-4142-ac4d-adff9e0770ad batch = 22019 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/07/02 23:55:32 5 s 1/1
3/3
397 (327b0da6-8357-4583-b7b6-9cc64f0a612a) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 327b0da6-8357-4583-b7b6-9cc64f0a612a batch = 22072 start at NativeMethodAccessorImpl.java:0 2026/07/02 23:55:32 4 s 1/1
3/3
396 (b9dcd960-b87e-4142-ac4d-adff9e0770ad) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = b9dcd960-b87e-4142-ac4d-adff9e0770ad batch = 22018 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/07/02 23:54:32 5 s 1/1
3/3
395 (327b0da6-8357-4583-b7b6-9cc64f0a612a) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 327b0da6-8357-4583-b7b6-9cc64f0a612a batch = 22071 start at NativeMethodAccessorImpl.java:0 2026/07/02 23:54:32 4 s 1/1
3/3
394 (327b0da6-8357-4583-b7b6-9cc64f0a612a) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 327b0da6-8357-4583-b7b6-9cc64f0a612a batch = 22070 start at NativeMethodAccessorImpl.java:0 2026/07/02 23:54:03 2 s 1/1
3/3
393 (327b0da6-8357-4583-b7b6-9cc64f0a612a) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 327b0da6-8357-4583-b7b6-9cc64f0a612a batch = 22069 start at NativeMethodAccessorImpl.java:0 2026/07/02 23:53:32 5 s 1/1
3/3
392 (b9dcd960-b87e-4142-ac4d-adff9e0770ad) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = b9dcd960-b87e-4142-ac4d-adff9e0770ad batch = 22017 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/07/02 23:53:32 2 s 1/1
3/3
391 (327b0da6-8357-4583-b7b6-9cc64f0a612a) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 327b0da6-8357-4583-b7b6-9cc64f0a612a batch = 22068 start at NativeMethodAccessorImpl.java:0 2026/07/02 23:52:32 5 s 1/1
3/3
390 (b9dcd960-b87e-4142-ac4d-adff9e0770ad) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = b9dcd960-b87e-4142-ac4d-adff9e0770ad batch = 22016 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/07/02 23:52:32 2 s 1/1
3/3
389 (327b0da6-8357-4583-b7b6-9cc64f0a612a) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 327b0da6-8357-4583-b7b6-9cc64f0a612a batch = 22067 start at NativeMethodAccessorImpl.java:0 2026/07/02 23:51:32 5 s 1/1
3/3
388 (b9dcd960-b87e-4142-ac4d-adff9e0770ad) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = b9dcd960-b87e-4142-ac4d-adff9e0770ad batch = 22015 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/07/02 23:51:32 2 s 1/1
3/3
387 (327b0da6-8357-4583-b7b6-9cc64f0a612a) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 327b0da6-8357-4583-b7b6-9cc64f0a612a batch = 22066 start at NativeMethodAccessorImpl.java:0 2026/07/02 23:50:32 5 s 1/1
3/3
386 (b9dcd960-b87e-4142-ac4d-adff9e0770ad) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = b9dcd960-b87e-4142-ac4d-adff9e0770ad batch = 22014 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/07/02 23:50:32 2 s 1/1
3/3
385 (b9dcd960-b87e-4142-ac4d-adff9e0770ad) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = b9dcd960-b87e-4142-ac4d-adff9e0770ad batch = 22013 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/07/02 23:49:32 6 s 1/1
3/3
384 (327b0da6-8357-4583-b7b6-9cc64f0a612a) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 327b0da6-8357-4583-b7b6-9cc64f0a612a batch = 22065 start at NativeMethodAccessorImpl.java:0 2026/07/02 23:49:32 4 s 1/1
3/3
383 (327b0da6-8357-4583-b7b6-9cc64f0a612a) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 327b0da6-8357-4583-b7b6-9cc64f0a612a batch = 22064 start at NativeMethodAccessorImpl.java:0 2026/07/02 23:48:32 5 s 1/1
3/3
382 (b9dcd960-b87e-4142-ac4d-adff9e0770ad) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = b9dcd960-b87e-4142-ac4d-adff9e0770ad batch = 22012 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/07/02 23:48:32 2 s 1/1
3/3
381 (b9dcd960-b87e-4142-ac4d-adff9e0770ad) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = b9dcd960-b87e-4142-ac4d-adff9e0770ad batch = 22011 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/07/02 23:47:33 6 s 1/1
3/3
380 (327b0da6-8357-4583-b7b6-9cc64f0a612a) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 327b0da6-8357-4583-b7b6-9cc64f0a612a batch = 22063 start at NativeMethodAccessorImpl.java:0 2026/07/02 23:47:33 4 s 1/1
3/3
379 (327b0da6-8357-4583-b7b6-9cc64f0a612a) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 327b0da6-8357-4583-b7b6-9cc64f0a612a batch = 22062 start at NativeMethodAccessorImpl.java:0 2026/07/02 23:46:32 5 s 1/1
3/3
378 (b9dcd960-b87e-4142-ac4d-adff9e0770ad) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = b9dcd960-b87e-4142-ac4d-adff9e0770ad batch = 22010 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/07/02 23:46:32 2 s 1/1
3/3
377 (b9dcd960-b87e-4142-ac4d-adff9e0770ad) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = b9dcd960-b87e-4142-ac4d-adff9e0770ad batch = 22009 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/07/02 23:45:32 5 s 1/1
3/3
376 (327b0da6-8357-4583-b7b6-9cc64f0a612a) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 327b0da6-8357-4583-b7b6-9cc64f0a612a batch = 22061 start at NativeMethodAccessorImpl.java:0 2026/07/02 23:45:32 4 s 1/1
3/3
375 (327b0da6-8357-4583-b7b6-9cc64f0a612a) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 327b0da6-8357-4583-b7b6-9cc64f0a612a batch = 22060 start at NativeMethodAccessorImpl.java:0 2026/07/02 23:45:03 2 s 1/1
3/3
374 (327b0da6-8357-4583-b7b6-9cc64f0a612a) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 327b0da6-8357-4583-b7b6-9cc64f0a612a batch = 22059 start at NativeMethodAccessorImpl.java:0 2026/07/02 23:44:33 5 s 1/1
3/3
373 (b9dcd960-b87e-4142-ac4d-adff9e0770ad) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = b9dcd960-b87e-4142-ac4d-adff9e0770ad batch = 22008 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/07/02 23:44:32 2 s 1/1
3/3
372 (327b0da6-8357-4583-b7b6-9cc64f0a612a) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 327b0da6-8357-4583-b7b6-9cc64f0a612a batch = 22058 start at NativeMethodAccessorImpl.java:0 2026/07/02 23:43:32 5 s 1/1
3/3
371 (b9dcd960-b87e-4142-ac4d-adff9e0770ad) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = b9dcd960-b87e-4142-ac4d-adff9e0770ad batch = 22007 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/07/02 23:43:32 2 s 1/1
3/3
370 (327b0da6-8357-4583-b7b6-9cc64f0a612a) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 327b0da6-8357-4583-b7b6-9cc64f0a612a batch = 22057 start at NativeMethodAccessorImpl.java:0 2026/07/02 23:42:32 5 s 1/1
3/3
369 (b9dcd960-b87e-4142-ac4d-adff9e0770ad) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = b9dcd960-b87e-4142-ac4d-adff9e0770ad batch = 22006 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/07/02 23:42:32 2 s 1/1
3/3
368 (b9dcd960-b87e-4142-ac4d-adff9e0770ad) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = b9dcd960-b87e-4142-ac4d-adff9e0770ad batch = 22005 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/07/02 23:41:32 6 s 1/1
3/3
367 (327b0da6-8357-4583-b7b6-9cc64f0a612a) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 327b0da6-8357-4583-b7b6-9cc64f0a612a batch = 22056 start at NativeMethodAccessorImpl.java:0 2026/07/02 23:41:32 4 s 1/1
3/3
366 (327b0da6-8357-4583-b7b6-9cc64f0a612a) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 327b0da6-8357-4583-b7b6-9cc64f0a612a batch = 22055 start at NativeMethodAccessorImpl.java:0 2026/07/02 23:40:32 5 s 1/1
3/3
365 (b9dcd960-b87e-4142-ac4d-adff9e0770ad) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = b9dcd960-b87e-4142-ac4d-adff9e0770ad batch = 22004 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/07/02 23:40:32 2 s 1/1
3/3
364 (327b0da6-8357-4583-b7b6-9cc64f0a612a) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 327b0da6-8357-4583-b7b6-9cc64f0a612a batch = 22054 start at NativeMethodAccessorImpl.java:0 2026/07/02 23:39:33 6 s 1/1
3/3
363 (b9dcd960-b87e-4142-ac4d-adff9e0770ad) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = b9dcd960-b87e-4142-ac4d-adff9e0770ad batch = 22003 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/07/02 23:39:33 2 s 1/1
3/3
362 (b9dcd960-b87e-4142-ac4d-adff9e0770ad) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = b9dcd960-b87e-4142-ac4d-adff9e0770ad batch = 22002 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/07/02 23:38:32 6 s 1/1
3/3
361 (327b0da6-8357-4583-b7b6-9cc64f0a612a) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 327b0da6-8357-4583-b7b6-9cc64f0a612a batch = 22053 start at NativeMethodAccessorImpl.java:0 2026/07/02 23:38:32 4 s 1/1
3/3
360 (327b0da6-8357-4583-b7b6-9cc64f0a612a) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 327b0da6-8357-4583-b7b6-9cc64f0a612a batch = 22052 start at NativeMethodAccessorImpl.java:0 2026/07/02 23:37:32 5 s 1/1
3/3
359 (b9dcd960-b87e-4142-ac4d-adff9e0770ad) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = b9dcd960-b87e-4142-ac4d-adff9e0770ad batch = 22001 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/07/02 23:37:32 2 s 1/1
3/3
358 (327b0da6-8357-4583-b7b6-9cc64f0a612a) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 327b0da6-8357-4583-b7b6-9cc64f0a612a batch = 22051 start at NativeMethodAccessorImpl.java:0 2026/07/02 23:36:32 5 s 1/1
3/3
357 (b9dcd960-b87e-4142-ac4d-adff9e0770ad) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = b9dcd960-b87e-4142-ac4d-adff9e0770ad batch = 22000 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/07/02 23:36:32 2 s 1/1
3/3
356 (327b0da6-8357-4583-b7b6-9cc64f0a612a) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 327b0da6-8357-4583-b7b6-9cc64f0a612a batch = 22050 start at NativeMethodAccessorImpl.java:0 2026/07/02 23:35:32 5 s 1/1
3/3
355 (b9dcd960-b87e-4142-ac4d-adff9e0770ad) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = b9dcd960-b87e-4142-ac4d-adff9e0770ad batch = 21999 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/07/02 23:35:32 2 s 1/1
3/3
354 (327b0da6-8357-4583-b7b6-9cc64f0a612a) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 327b0da6-8357-4583-b7b6-9cc64f0a612a batch = 22049 start at NativeMethodAccessorImpl.java:0 2026/07/02 23:34:32 5 s 1/1
3/3
353 (b9dcd960-b87e-4142-ac4d-adff9e0770ad) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = b9dcd960-b87e-4142-ac4d-adff9e0770ad batch = 21998 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/07/02 23:34:32 2 s 1/1
3/3
352 (b9dcd960-b87e-4142-ac4d-adff9e0770ad) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = b9dcd960-b87e-4142-ac4d-adff9e0770ad batch = 21997 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/07/02 23:33:33 6 s 1/1
3/3
351 (327b0da6-8357-4583-b7b6-9cc64f0a612a) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 327b0da6-8357-4583-b7b6-9cc64f0a612a batch = 22048 start at NativeMethodAccessorImpl.java:0 2026/07/02 23:33:32 4 s 1/1
3/3
350 (327b0da6-8357-4583-b7b6-9cc64f0a612a) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 327b0da6-8357-4583-b7b6-9cc64f0a612a batch = 22047 start at NativeMethodAccessorImpl.java:0 2026/07/02 23:32:32 5 s 1/1
3/3
349 (b9dcd960-b87e-4142-ac4d-adff9e0770ad) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = b9dcd960-b87e-4142-ac4d-adff9e0770ad batch = 21996 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/07/02 23:32:32 2 s 1/1
3/3
348 (b9dcd960-b87e-4142-ac4d-adff9e0770ad) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = b9dcd960-b87e-4142-ac4d-adff9e0770ad batch = 21995 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/07/02 23:31:32 6 s 1/1
3/3
347 (327b0da6-8357-4583-b7b6-9cc64f0a612a) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 327b0da6-8357-4583-b7b6-9cc64f0a612a batch = 22046 start at NativeMethodAccessorImpl.java:0 2026/07/02 23:31:32 4 s 1/1
3/3
346 (327b0da6-8357-4583-b7b6-9cc64f0a612a) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 327b0da6-8357-4583-b7b6-9cc64f0a612a batch = 22045 start at NativeMethodAccessorImpl.java:0 2026/07/02 23:30:32 5 s 1/1
3/3
345 (b9dcd960-b87e-4142-ac4d-adff9e0770ad) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = b9dcd960-b87e-4142-ac4d-adff9e0770ad batch = 21994 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/07/02 23:30:32 2 s 1/1
3/3
344 (327b0da6-8357-4583-b7b6-9cc64f0a612a) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 327b0da6-8357-4583-b7b6-9cc64f0a612a batch = 22044 start at NativeMethodAccessorImpl.java:0 2026/07/02 23:29:33 5 s 1/1
3/3
343 (b9dcd960-b87e-4142-ac4d-adff9e0770ad) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = b9dcd960-b87e-4142-ac4d-adff9e0770ad batch = 21993 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/07/02 23:29:32 2 s 1/1
3/3
342 (b9dcd960-b87e-4142-ac4d-adff9e0770ad) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = b9dcd960-b87e-4142-ac4d-adff9e0770ad batch = 21992 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/07/02 23:28:32 5 s 1/1
3/3
341 (327b0da6-8357-4583-b7b6-9cc64f0a612a) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 327b0da6-8357-4583-b7b6-9cc64f0a612a batch = 22043 start at NativeMethodAccessorImpl.java:0 2026/07/02 23:28:32 4 s 1/1
3/3
340 (327b0da6-8357-4583-b7b6-9cc64f0a612a) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 327b0da6-8357-4583-b7b6-9cc64f0a612a batch = 22042 start at NativeMethodAccessorImpl.java:0 2026/07/02 23:27:32 6 s 1/1
3/3
339 (b9dcd960-b87e-4142-ac4d-adff9e0770ad) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = b9dcd960-b87e-4142-ac4d-adff9e0770ad batch = 21991 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/07/02 23:27:32 2 s 1/1
3/3
338 (b9dcd960-b87e-4142-ac4d-adff9e0770ad) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = b9dcd960-b87e-4142-ac4d-adff9e0770ad batch = 21990 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/07/02 23:26:32 6 s 1/1
3/3
337 (327b0da6-8357-4583-b7b6-9cc64f0a612a) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 327b0da6-8357-4583-b7b6-9cc64f0a612a batch = 22041 start at NativeMethodAccessorImpl.java:0 2026/07/02 23:26:32 4 s 1/1
3/3
336 (327b0da6-8357-4583-b7b6-9cc64f0a612a) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 327b0da6-8357-4583-b7b6-9cc64f0a612a batch = 22040 start at NativeMethodAccessorImpl.java:0 2026/07/02 23:25:32 6 s 1/1
3/3
335 (b9dcd960-b87e-4142-ac4d-adff9e0770ad) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = b9dcd960-b87e-4142-ac4d-adff9e0770ad batch = 21989 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/07/02 23:25:32 2 s 1/1
3/3
334 (b9dcd960-b87e-4142-ac4d-adff9e0770ad) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = b9dcd960-b87e-4142-ac4d-adff9e0770ad batch = 21988 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/07/02 23:24:32 5 s 1/1
3/3
333 (327b0da6-8357-4583-b7b6-9cc64f0a612a) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 327b0da6-8357-4583-b7b6-9cc64f0a612a batch = 22039 start at NativeMethodAccessorImpl.java:0 2026/07/02 23:24:32 3 s 1/1
3/3
332 (327b0da6-8357-4583-b7b6-9cc64f0a612a) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 327b0da6-8357-4583-b7b6-9cc64f0a612a batch = 22038 start at NativeMethodAccessorImpl.java:0 2026/07/02 23:23:33 5 s 1/1
3/3
331 (b9dcd960-b87e-4142-ac4d-adff9e0770ad) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = b9dcd960-b87e-4142-ac4d-adff9e0770ad batch = 21987 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/07/02 23:23:32 2 s 1/1
3/3
330 (327b0da6-8357-4583-b7b6-9cc64f0a612a) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 327b0da6-8357-4583-b7b6-9cc64f0a612a batch = 22037 start at NativeMethodAccessorImpl.java:0 2026/07/02 23:22:32 5 s 1/1
3/3
329 (b9dcd960-b87e-4142-ac4d-adff9e0770ad) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = b9dcd960-b87e-4142-ac4d-adff9e0770ad batch = 21986 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/07/02 23:22:32 2 s 1/1
3/3
328 (b9dcd960-b87e-4142-ac4d-adff9e0770ad) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = b9dcd960-b87e-4142-ac4d-adff9e0770ad batch = 21985 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/07/02 23:21:33 6 s 1/1
3/3
327 (327b0da6-8357-4583-b7b6-9cc64f0a612a) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 327b0da6-8357-4583-b7b6-9cc64f0a612a batch = 22036 start at NativeMethodAccessorImpl.java:0 2026/07/02 23:21:33 4 s 1/1
3/3
326 (327b0da6-8357-4583-b7b6-9cc64f0a612a) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 327b0da6-8357-4583-b7b6-9cc64f0a612a batch = 22035 start at NativeMethodAccessorImpl.java:0 2026/07/02 23:20:32 5 s 1/1
3/3
325 (b9dcd960-b87e-4142-ac4d-adff9e0770ad) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = b9dcd960-b87e-4142-ac4d-adff9e0770ad batch = 21984 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/07/02 23:20:32 2 s 1/1
3/3
324 (327b0da6-8357-4583-b7b6-9cc64f0a612a) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 327b0da6-8357-4583-b7b6-9cc64f0a612a batch = 22034 start at NativeMethodAccessorImpl.java:0 2026/07/02 23:19:32 5 s 1/1
3/3
323 (b9dcd960-b87e-4142-ac4d-adff9e0770ad) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = b9dcd960-b87e-4142-ac4d-adff9e0770ad batch = 21983 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/07/02 23:19:32 2 s 1/1
3/3
322 (327b0da6-8357-4583-b7b6-9cc64f0a612a) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 327b0da6-8357-4583-b7b6-9cc64f0a612a batch = 22033 start at NativeMethodAccessorImpl.java:0 2026/07/02 23:18:32 6 s 1/1
3/3
321 (b9dcd960-b87e-4142-ac4d-adff9e0770ad) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = b9dcd960-b87e-4142-ac4d-adff9e0770ad batch = 21982 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/07/02 23:18:32 2 s 1/1
3/3
320 (327b0da6-8357-4583-b7b6-9cc64f0a612a) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 327b0da6-8357-4583-b7b6-9cc64f0a612a batch = 22032 start at NativeMethodAccessorImpl.java:0 2026/07/02 23:17:32 5 s 1/1
3/3
319 (b9dcd960-b87e-4142-ac4d-adff9e0770ad) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = b9dcd960-b87e-4142-ac4d-adff9e0770ad batch = 21981 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/07/02 23:17:32 2 s 1/1
3/3
318 (327b0da6-8357-4583-b7b6-9cc64f0a612a) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 327b0da6-8357-4583-b7b6-9cc64f0a612a batch = 22031 start at NativeMethodAccessorImpl.java:0 2026/07/02 23:16:33 5 s 1/1
3/3
317 (b9dcd960-b87e-4142-ac4d-adff9e0770ad) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = b9dcd960-b87e-4142-ac4d-adff9e0770ad batch = 21980 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/07/02 23:16:32 2 s 1/1
3/3
316 (327b0da6-8357-4583-b7b6-9cc64f0a612a) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 327b0da6-8357-4583-b7b6-9cc64f0a612a batch = 22030 start at NativeMethodAccessorImpl.java:0 2026/07/02 23:15:33 5 s 1/1
3/3
315 (b9dcd960-b87e-4142-ac4d-adff9e0770ad) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = b9dcd960-b87e-4142-ac4d-adff9e0770ad batch = 21979 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/07/02 23:15:32 2 s 1/1
3/3
314 (b9dcd960-b87e-4142-ac4d-adff9e0770ad) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = b9dcd960-b87e-4142-ac4d-adff9e0770ad batch = 21978 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/07/02 23:14:32 5 s 1/1
3/3
313 (327b0da6-8357-4583-b7b6-9cc64f0a612a) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 327b0da6-8357-4583-b7b6-9cc64f0a612a batch = 22029 start at NativeMethodAccessorImpl.java:0 2026/07/02 23:14:32 4 s 1/1
3/3
312 (327b0da6-8357-4583-b7b6-9cc64f0a612a) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 327b0da6-8357-4583-b7b6-9cc64f0a612a batch = 22028 start at NativeMethodAccessorImpl.java:0 2026/07/02 23:13:32 5 s 1/1
3/3
311 (b9dcd960-b87e-4142-ac4d-adff9e0770ad) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = b9dcd960-b87e-4142-ac4d-adff9e0770ad batch = 21977 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/07/02 23:13:32 2 s 1/1
3/3
310 (327b0da6-8357-4583-b7b6-9cc64f0a612a) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 327b0da6-8357-4583-b7b6-9cc64f0a612a batch = 22027 start at NativeMethodAccessorImpl.java:0 2026/07/02 23:12:32 4 s 1/1
3/3
309 (b9dcd960-b87e-4142-ac4d-adff9e0770ad) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = b9dcd960-b87e-4142-ac4d-adff9e0770ad batch = 21976 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/07/02 23:12:31 2 s 1/1
3/3
308 (327b0da6-8357-4583-b7b6-9cc64f0a612a) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 327b0da6-8357-4583-b7b6-9cc64f0a612a batch = 22026 start at NativeMethodAccessorImpl.java:0 2026/07/02 23:11:32 5 s 1/1
3/3
307 (b9dcd960-b87e-4142-ac4d-adff9e0770ad) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = b9dcd960-b87e-4142-ac4d-adff9e0770ad batch = 21975 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/07/02 23:11:31 2 s 1/1
3/3
306 (327b0da6-8357-4583-b7b6-9cc64f0a612a) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 327b0da6-8357-4583-b7b6-9cc64f0a612a batch = 22025 start at NativeMethodAccessorImpl.java:0 2026/07/02 23:10:32 6 s 1/1
3/3
305 (b9dcd960-b87e-4142-ac4d-adff9e0770ad) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = b9dcd960-b87e-4142-ac4d-adff9e0770ad batch = 21974 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/07/02 23:10:32 2 s 1/1
3/3
304 (327b0da6-8357-4583-b7b6-9cc64f0a612a) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 327b0da6-8357-4583-b7b6-9cc64f0a612a batch = 22024 start at NativeMethodAccessorImpl.java:0 2026/07/02 23:09:32 5 s 1/1
3/3
303 (b9dcd960-b87e-4142-ac4d-adff9e0770ad) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = b9dcd960-b87e-4142-ac4d-adff9e0770ad batch = 21973 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/07/02 23:09:32 2 s 1/1
3/3
302 (b9dcd960-b87e-4142-ac4d-adff9e0770ad) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = b9dcd960-b87e-4142-ac4d-adff9e0770ad batch = 21972 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/07/02 23:08:32 5 s 1/1
3/3
301 (327b0da6-8357-4583-b7b6-9cc64f0a612a) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 327b0da6-8357-4583-b7b6-9cc64f0a612a batch = 22023 start at NativeMethodAccessorImpl.java:0 2026/07/02 23:08:32 4 s 1/1
3/3
300 (327b0da6-8357-4583-b7b6-9cc64f0a612a) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 327b0da6-8357-4583-b7b6-9cc64f0a612a batch = 22022 start at NativeMethodAccessorImpl.java:0 2026/07/02 23:07:32 5 s 1/1
3/3
299 (b9dcd960-b87e-4142-ac4d-adff9e0770ad) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = b9dcd960-b87e-4142-ac4d-adff9e0770ad batch = 21971 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/07/02 23:07:32 2 s 1/1
3/3
Page: