Spark Jobs (?)

  • User: spark
  • Total Uptime: 18.7 h
  • Scheduling Mode: FIFO
  • Completed Jobs: 2242, only showing 942
Event Timeline

Completed Jobs (2242, only showing 942)

Job Id (Job Group) ▾ Description Submitted Duration Stages: Succeeded/Total Tasks (for all stages): Succeeded/Total
2241 (e1eacc71-943b-4bb4-a8fe-09129b09bc0c) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = e1eacc71-943b-4bb4-a8fe-09129b09bc0c batch = 3615 start at NativeMethodAccessorImpl.java:0 2026/06/20 04:48:32 5 s 1/1
3/3
2240 (56fcc6b3-ca26-4cdf-b4b8-e5181c15bdb7) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 56fcc6b3-ca26-4cdf-b4b8-e5181c15bdb7 batch = 3615 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/20 04:48:32 2 s 1/1
3/3
2239 (56fcc6b3-ca26-4cdf-b4b8-e5181c15bdb7) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 56fcc6b3-ca26-4cdf-b4b8-e5181c15bdb7 batch = 3614 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/20 04:47:32 5 s 1/1
3/3
2238 (e1eacc71-943b-4bb4-a8fe-09129b09bc0c) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = e1eacc71-943b-4bb4-a8fe-09129b09bc0c batch = 3614 start at NativeMethodAccessorImpl.java:0 2026/06/20 04:47:32 3 s 1/1
3/3
2237 (e1eacc71-943b-4bb4-a8fe-09129b09bc0c) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = e1eacc71-943b-4bb4-a8fe-09129b09bc0c batch = 3613 start at NativeMethodAccessorImpl.java:0 2026/06/20 04:46:32 5 s 1/1
3/3
2236 (56fcc6b3-ca26-4cdf-b4b8-e5181c15bdb7) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 56fcc6b3-ca26-4cdf-b4b8-e5181c15bdb7 batch = 3613 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/20 04:46:31 2 s 1/1
3/3
2235 (e1eacc71-943b-4bb4-a8fe-09129b09bc0c) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = e1eacc71-943b-4bb4-a8fe-09129b09bc0c batch = 3612 start at NativeMethodAccessorImpl.java:0 2026/06/20 04:45:32 4 s 1/1
3/3
2234 (56fcc6b3-ca26-4cdf-b4b8-e5181c15bdb7) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 56fcc6b3-ca26-4cdf-b4b8-e5181c15bdb7 batch = 3612 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/20 04:45:32 2 s 1/1
3/3
2233 (e1eacc71-943b-4bb4-a8fe-09129b09bc0c) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = e1eacc71-943b-4bb4-a8fe-09129b09bc0c batch = 3611 start at NativeMethodAccessorImpl.java:0 2026/06/20 04:44:32 5 s 1/1
3/3
2232 (56fcc6b3-ca26-4cdf-b4b8-e5181c15bdb7) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 56fcc6b3-ca26-4cdf-b4b8-e5181c15bdb7 batch = 3611 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/20 04:44:32 2 s 1/1
3/3
2231 (56fcc6b3-ca26-4cdf-b4b8-e5181c15bdb7) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 56fcc6b3-ca26-4cdf-b4b8-e5181c15bdb7 batch = 3610 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/20 04:43:32 5 s 1/1
3/3
2230 (e1eacc71-943b-4bb4-a8fe-09129b09bc0c) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = e1eacc71-943b-4bb4-a8fe-09129b09bc0c batch = 3610 start at NativeMethodAccessorImpl.java:0 2026/06/20 04:43:32 3 s 1/1
3/3
2229 (56fcc6b3-ca26-4cdf-b4b8-e5181c15bdb7) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 56fcc6b3-ca26-4cdf-b4b8-e5181c15bdb7 batch = 3609 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/20 04:42:32 5 s 1/1
3/3
2228 (e1eacc71-943b-4bb4-a8fe-09129b09bc0c) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = e1eacc71-943b-4bb4-a8fe-09129b09bc0c batch = 3609 start at NativeMethodAccessorImpl.java:0 2026/06/20 04:42:32 3 s 1/1
3/3
2227 (e1eacc71-943b-4bb4-a8fe-09129b09bc0c) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = e1eacc71-943b-4bb4-a8fe-09129b09bc0c batch = 3608 start at NativeMethodAccessorImpl.java:0 2026/06/20 04:41:32 4 s 1/1
3/3
2226 (56fcc6b3-ca26-4cdf-b4b8-e5181c15bdb7) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 56fcc6b3-ca26-4cdf-b4b8-e5181c15bdb7 batch = 3608 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/20 04:41:32 2 s 1/1
3/3
2225 (e1eacc71-943b-4bb4-a8fe-09129b09bc0c) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = e1eacc71-943b-4bb4-a8fe-09129b09bc0c batch = 3607 start at NativeMethodAccessorImpl.java:0 2026/06/20 04:40:32 5 s 1/1
3/3
2224 (56fcc6b3-ca26-4cdf-b4b8-e5181c15bdb7) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 56fcc6b3-ca26-4cdf-b4b8-e5181c15bdb7 batch = 3607 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/20 04:40:32 2 s 1/1
3/3
2223 (e1eacc71-943b-4bb4-a8fe-09129b09bc0c) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = e1eacc71-943b-4bb4-a8fe-09129b09bc0c batch = 3606 start at NativeMethodAccessorImpl.java:0 2026/06/20 04:39:32 4 s 1/1
3/3
2222 (56fcc6b3-ca26-4cdf-b4b8-e5181c15bdb7) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 56fcc6b3-ca26-4cdf-b4b8-e5181c15bdb7 batch = 3606 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/20 04:39:31 2 s 1/1
3/3
2221 (56fcc6b3-ca26-4cdf-b4b8-e5181c15bdb7) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 56fcc6b3-ca26-4cdf-b4b8-e5181c15bdb7 batch = 3605 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/20 04:38:32 5 s 1/1
3/3
2220 (e1eacc71-943b-4bb4-a8fe-09129b09bc0c) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = e1eacc71-943b-4bb4-a8fe-09129b09bc0c batch = 3605 start at NativeMethodAccessorImpl.java:0 2026/06/20 04:38:32 3 s 1/1
3/3
2219 (56fcc6b3-ca26-4cdf-b4b8-e5181c15bdb7) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 56fcc6b3-ca26-4cdf-b4b8-e5181c15bdb7 batch = 3604 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/20 04:37:32 4 s 1/1
3/3
2218 (e1eacc71-943b-4bb4-a8fe-09129b09bc0c) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = e1eacc71-943b-4bb4-a8fe-09129b09bc0c batch = 3604 start at NativeMethodAccessorImpl.java:0 2026/06/20 04:37:31 3 s 1/1
3/3
2217 (e1eacc71-943b-4bb4-a8fe-09129b09bc0c) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = e1eacc71-943b-4bb4-a8fe-09129b09bc0c batch = 3603 start at NativeMethodAccessorImpl.java:0 2026/06/20 04:36:32 4 s 1/1
3/3
2216 (56fcc6b3-ca26-4cdf-b4b8-e5181c15bdb7) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 56fcc6b3-ca26-4cdf-b4b8-e5181c15bdb7 batch = 3603 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/20 04:36:32 2 s 1/1
3/3
2215 (e1eacc71-943b-4bb4-a8fe-09129b09bc0c) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = e1eacc71-943b-4bb4-a8fe-09129b09bc0c batch = 3602 start at NativeMethodAccessorImpl.java:0 2026/06/20 04:35:32 5 s 1/1
3/3
2214 (56fcc6b3-ca26-4cdf-b4b8-e5181c15bdb7) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 56fcc6b3-ca26-4cdf-b4b8-e5181c15bdb7 batch = 3602 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/20 04:35:31 2 s 1/1
3/3
2213 (e1eacc71-943b-4bb4-a8fe-09129b09bc0c) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = e1eacc71-943b-4bb4-a8fe-09129b09bc0c batch = 3601 start at NativeMethodAccessorImpl.java:0 2026/06/20 04:34:32 4 s 1/1
3/3
2212 (56fcc6b3-ca26-4cdf-b4b8-e5181c15bdb7) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 56fcc6b3-ca26-4cdf-b4b8-e5181c15bdb7 batch = 3601 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/20 04:34:32 2 s 1/1
3/3
2211 (56fcc6b3-ca26-4cdf-b4b8-e5181c15bdb7) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 56fcc6b3-ca26-4cdf-b4b8-e5181c15bdb7 batch = 3600 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/20 04:33:32 4 s 1/1
3/3
2210 (e1eacc71-943b-4bb4-a8fe-09129b09bc0c) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = e1eacc71-943b-4bb4-a8fe-09129b09bc0c batch = 3600 start at NativeMethodAccessorImpl.java:0 2026/06/20 04:33:32 3 s 1/1
3/3
2209 (e1eacc71-943b-4bb4-a8fe-09129b09bc0c) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = e1eacc71-943b-4bb4-a8fe-09129b09bc0c batch = 3599 start at NativeMethodAccessorImpl.java:0 2026/06/20 04:32:32 4 s 1/1
3/3
2208 (56fcc6b3-ca26-4cdf-b4b8-e5181c15bdb7) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 56fcc6b3-ca26-4cdf-b4b8-e5181c15bdb7 batch = 3599 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/20 04:32:31 2 s 1/1
3/3
2207 (e1eacc71-943b-4bb4-a8fe-09129b09bc0c) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = e1eacc71-943b-4bb4-a8fe-09129b09bc0c batch = 3598 start at NativeMethodAccessorImpl.java:0 2026/06/20 04:31:32 5 s 1/1
3/3
2206 (56fcc6b3-ca26-4cdf-b4b8-e5181c15bdb7) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 56fcc6b3-ca26-4cdf-b4b8-e5181c15bdb7 batch = 3598 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/20 04:31:31 2 s 1/1
3/3
2205 (56fcc6b3-ca26-4cdf-b4b8-e5181c15bdb7) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 56fcc6b3-ca26-4cdf-b4b8-e5181c15bdb7 batch = 3597 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/20 04:30:33 5 s 1/1
3/3
2204 (e1eacc71-943b-4bb4-a8fe-09129b09bc0c) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = e1eacc71-943b-4bb4-a8fe-09129b09bc0c batch = 3597 start at NativeMethodAccessorImpl.java:0 2026/06/20 04:30:32 3 s 1/1
3/3
2203 (e1eacc71-943b-4bb4-a8fe-09129b09bc0c) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = e1eacc71-943b-4bb4-a8fe-09129b09bc0c batch = 3596 start at NativeMethodAccessorImpl.java:0 2026/06/20 04:29:32 5 s 1/1
3/3
2202 (56fcc6b3-ca26-4cdf-b4b8-e5181c15bdb7) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 56fcc6b3-ca26-4cdf-b4b8-e5181c15bdb7 batch = 3596 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/20 04:29:32 2 s 1/1
3/3
2201 (e1eacc71-943b-4bb4-a8fe-09129b09bc0c) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = e1eacc71-943b-4bb4-a8fe-09129b09bc0c batch = 3595 start at NativeMethodAccessorImpl.java:0 2026/06/20 04:28:32 5 s 1/1
3/3
2200 (56fcc6b3-ca26-4cdf-b4b8-e5181c15bdb7) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 56fcc6b3-ca26-4cdf-b4b8-e5181c15bdb7 batch = 3595 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/20 04:28:32 2 s 1/1
3/3
2199 (e1eacc71-943b-4bb4-a8fe-09129b09bc0c) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = e1eacc71-943b-4bb4-a8fe-09129b09bc0c batch = 3594 start at NativeMethodAccessorImpl.java:0 2026/06/20 04:27:32 5 s 1/1
3/3
2198 (56fcc6b3-ca26-4cdf-b4b8-e5181c15bdb7) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 56fcc6b3-ca26-4cdf-b4b8-e5181c15bdb7 batch = 3594 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/20 04:27:32 2 s 1/1
3/3
2197 (56fcc6b3-ca26-4cdf-b4b8-e5181c15bdb7) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 56fcc6b3-ca26-4cdf-b4b8-e5181c15bdb7 batch = 3593 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/20 04:26:32 5 s 1/1
3/3
2196 (e1eacc71-943b-4bb4-a8fe-09129b09bc0c) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = e1eacc71-943b-4bb4-a8fe-09129b09bc0c batch = 3593 start at NativeMethodAccessorImpl.java:0 2026/06/20 04:26:31 3 s 1/1
3/3
2195 (e1eacc71-943b-4bb4-a8fe-09129b09bc0c) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = e1eacc71-943b-4bb4-a8fe-09129b09bc0c batch = 3592 start at NativeMethodAccessorImpl.java:0 2026/06/20 04:25:32 5 s 1/1
3/3
2194 (56fcc6b3-ca26-4cdf-b4b8-e5181c15bdb7) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 56fcc6b3-ca26-4cdf-b4b8-e5181c15bdb7 batch = 3592 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/20 04:25:32 2 s 1/1
3/3
2193 (e1eacc71-943b-4bb4-a8fe-09129b09bc0c) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = e1eacc71-943b-4bb4-a8fe-09129b09bc0c batch = 3591 start at NativeMethodAccessorImpl.java:0 2026/06/20 04:24:32 5 s 1/1
3/3
2192 (56fcc6b3-ca26-4cdf-b4b8-e5181c15bdb7) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 56fcc6b3-ca26-4cdf-b4b8-e5181c15bdb7 batch = 3591 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/20 04:24:32 2 s 1/1
3/3
2191 (56fcc6b3-ca26-4cdf-b4b8-e5181c15bdb7) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 56fcc6b3-ca26-4cdf-b4b8-e5181c15bdb7 batch = 3590 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/20 04:23:32 5 s 1/1
3/3
2190 (e1eacc71-943b-4bb4-a8fe-09129b09bc0c) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = e1eacc71-943b-4bb4-a8fe-09129b09bc0c batch = 3590 start at NativeMethodAccessorImpl.java:0 2026/06/20 04:23:32 3 s 1/1
3/3
2189 (e1eacc71-943b-4bb4-a8fe-09129b09bc0c) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = e1eacc71-943b-4bb4-a8fe-09129b09bc0c batch = 3589 start at NativeMethodAccessorImpl.java:0 2026/06/20 04:22:32 5 s 1/1
3/3
2188 (56fcc6b3-ca26-4cdf-b4b8-e5181c15bdb7) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 56fcc6b3-ca26-4cdf-b4b8-e5181c15bdb7 batch = 3589 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/20 04:22:32 2 s 1/1
3/3
2187 (56fcc6b3-ca26-4cdf-b4b8-e5181c15bdb7) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 56fcc6b3-ca26-4cdf-b4b8-e5181c15bdb7 batch = 3588 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/20 04:21:32 5 s 1/1
3/3
2186 (e1eacc71-943b-4bb4-a8fe-09129b09bc0c) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = e1eacc71-943b-4bb4-a8fe-09129b09bc0c batch = 3588 start at NativeMethodAccessorImpl.java:0 2026/06/20 04:21:32 4 s 1/1
3/3
2185 (56fcc6b3-ca26-4cdf-b4b8-e5181c15bdb7) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 56fcc6b3-ca26-4cdf-b4b8-e5181c15bdb7 batch = 3587 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/20 04:20:32 5 s 1/1
3/3
2184 (e1eacc71-943b-4bb4-a8fe-09129b09bc0c) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = e1eacc71-943b-4bb4-a8fe-09129b09bc0c batch = 3587 start at NativeMethodAccessorImpl.java:0 2026/06/20 04:20:32 3 s 1/1
3/3
2183 (e1eacc71-943b-4bb4-a8fe-09129b09bc0c) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = e1eacc71-943b-4bb4-a8fe-09129b09bc0c batch = 3586 start at NativeMethodAccessorImpl.java:0 2026/06/20 04:19:32 4 s 1/1
3/3
2182 (56fcc6b3-ca26-4cdf-b4b8-e5181c15bdb7) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 56fcc6b3-ca26-4cdf-b4b8-e5181c15bdb7 batch = 3586 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/20 04:19:32 2 s 1/1
3/3
2181 (e1eacc71-943b-4bb4-a8fe-09129b09bc0c) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = e1eacc71-943b-4bb4-a8fe-09129b09bc0c batch = 3585 start at NativeMethodAccessorImpl.java:0 2026/06/20 04:18:32 4 s 1/1
3/3
2180 (56fcc6b3-ca26-4cdf-b4b8-e5181c15bdb7) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 56fcc6b3-ca26-4cdf-b4b8-e5181c15bdb7 batch = 3585 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/20 04:18:31 2 s 1/1
3/3
2179 (e1eacc71-943b-4bb4-a8fe-09129b09bc0c) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = e1eacc71-943b-4bb4-a8fe-09129b09bc0c batch = 3584 start at NativeMethodAccessorImpl.java:0 2026/06/20 04:17:32 5 s 1/1
3/3
2178 (56fcc6b3-ca26-4cdf-b4b8-e5181c15bdb7) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 56fcc6b3-ca26-4cdf-b4b8-e5181c15bdb7 batch = 3584 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/20 04:17:31 2 s 1/1
3/3
2177 (e1eacc71-943b-4bb4-a8fe-09129b09bc0c) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = e1eacc71-943b-4bb4-a8fe-09129b09bc0c batch = 3583 start at NativeMethodAccessorImpl.java:0 2026/06/20 04:16:32 5 s 1/1
3/3
2176 (56fcc6b3-ca26-4cdf-b4b8-e5181c15bdb7) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 56fcc6b3-ca26-4cdf-b4b8-e5181c15bdb7 batch = 3583 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/20 04:16:32 2 s 1/1
3/3
2175 (56fcc6b3-ca26-4cdf-b4b8-e5181c15bdb7) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 56fcc6b3-ca26-4cdf-b4b8-e5181c15bdb7 batch = 3582 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/20 04:15:32 6 s 1/1
3/3
2174 (e1eacc71-943b-4bb4-a8fe-09129b09bc0c) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = e1eacc71-943b-4bb4-a8fe-09129b09bc0c batch = 3582 start at NativeMethodAccessorImpl.java:0 2026/06/20 04:15:32 3 s 1/1
3/3
2173 (e1eacc71-943b-4bb4-a8fe-09129b09bc0c) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = e1eacc71-943b-4bb4-a8fe-09129b09bc0c batch = 3581 start at NativeMethodAccessorImpl.java:0 2026/06/20 04:14:32 5 s 1/1
3/3
2172 (56fcc6b3-ca26-4cdf-b4b8-e5181c15bdb7) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 56fcc6b3-ca26-4cdf-b4b8-e5181c15bdb7 batch = 3581 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/20 04:14:32 2 s 1/1
3/3
2171 (56fcc6b3-ca26-4cdf-b4b8-e5181c15bdb7) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 56fcc6b3-ca26-4cdf-b4b8-e5181c15bdb7 batch = 3580 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/20 04:13:32 5 s 1/1
3/3
2170 (e1eacc71-943b-4bb4-a8fe-09129b09bc0c) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = e1eacc71-943b-4bb4-a8fe-09129b09bc0c batch = 3580 start at NativeMethodAccessorImpl.java:0 2026/06/20 04:13:31 4 s 1/1
3/3
2169 (56fcc6b3-ca26-4cdf-b4b8-e5181c15bdb7) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 56fcc6b3-ca26-4cdf-b4b8-e5181c15bdb7 batch = 3579 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/20 04:12:33 5 s 1/1
3/3
2168 (e1eacc71-943b-4bb4-a8fe-09129b09bc0c) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = e1eacc71-943b-4bb4-a8fe-09129b09bc0c batch = 3579 start at NativeMethodAccessorImpl.java:0 2026/06/20 04:12:32 3 s 1/1
3/3
2167 (e1eacc71-943b-4bb4-a8fe-09129b09bc0c) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = e1eacc71-943b-4bb4-a8fe-09129b09bc0c batch = 3578 start at NativeMethodAccessorImpl.java:0 2026/06/20 04:11:32 4 s 1/1
3/3
2166 (56fcc6b3-ca26-4cdf-b4b8-e5181c15bdb7) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 56fcc6b3-ca26-4cdf-b4b8-e5181c15bdb7 batch = 3578 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/20 04:11:31 2 s 1/1
3/3
2165 (56fcc6b3-ca26-4cdf-b4b8-e5181c15bdb7) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 56fcc6b3-ca26-4cdf-b4b8-e5181c15bdb7 batch = 3577 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/20 04:10:32 4 s 1/1
3/3
2164 (e1eacc71-943b-4bb4-a8fe-09129b09bc0c) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = e1eacc71-943b-4bb4-a8fe-09129b09bc0c batch = 3577 start at NativeMethodAccessorImpl.java:0 2026/06/20 04:10:32 3 s 1/1
3/3
2163 (e1eacc71-943b-4bb4-a8fe-09129b09bc0c) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = e1eacc71-943b-4bb4-a8fe-09129b09bc0c batch = 3576 start at NativeMethodAccessorImpl.java:0 2026/06/20 04:09:32 5 s 1/1
3/3
2162 (56fcc6b3-ca26-4cdf-b4b8-e5181c15bdb7) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 56fcc6b3-ca26-4cdf-b4b8-e5181c15bdb7 batch = 3576 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/20 04:09:32 2 s 1/1
3/3
2161 (e1eacc71-943b-4bb4-a8fe-09129b09bc0c) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = e1eacc71-943b-4bb4-a8fe-09129b09bc0c batch = 3575 start at NativeMethodAccessorImpl.java:0 2026/06/20 04:08:32 5 s 1/1
3/3
2160 (56fcc6b3-ca26-4cdf-b4b8-e5181c15bdb7) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 56fcc6b3-ca26-4cdf-b4b8-e5181c15bdb7 batch = 3575 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/20 04:08:31 2 s 1/1
3/3
2159 (e1eacc71-943b-4bb4-a8fe-09129b09bc0c) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = e1eacc71-943b-4bb4-a8fe-09129b09bc0c batch = 3574 start at NativeMethodAccessorImpl.java:0 2026/06/20 04:07:32 4 s 1/1
3/3
2158 (56fcc6b3-ca26-4cdf-b4b8-e5181c15bdb7) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 56fcc6b3-ca26-4cdf-b4b8-e5181c15bdb7 batch = 3574 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/20 04:07:32 2 s 1/1
3/3
2157 (e1eacc71-943b-4bb4-a8fe-09129b09bc0c) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = e1eacc71-943b-4bb4-a8fe-09129b09bc0c batch = 3573 start at NativeMethodAccessorImpl.java:0 2026/06/20 04:06:32 5 s 1/1
3/3
2156 (56fcc6b3-ca26-4cdf-b4b8-e5181c15bdb7) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 56fcc6b3-ca26-4cdf-b4b8-e5181c15bdb7 batch = 3573 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/20 04:06:32 2 s 1/1
3/3
2155 (e1eacc71-943b-4bb4-a8fe-09129b09bc0c) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = e1eacc71-943b-4bb4-a8fe-09129b09bc0c batch = 3572 start at NativeMethodAccessorImpl.java:0 2026/06/20 04:05:32 5 s 1/1
3/3
2154 (56fcc6b3-ca26-4cdf-b4b8-e5181c15bdb7) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 56fcc6b3-ca26-4cdf-b4b8-e5181c15bdb7 batch = 3572 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/20 04:05:32 2 s 1/1
3/3
2153 (56fcc6b3-ca26-4cdf-b4b8-e5181c15bdb7) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 56fcc6b3-ca26-4cdf-b4b8-e5181c15bdb7 batch = 3571 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/20 04:04:32 5 s 1/1
3/3
2152 (e1eacc71-943b-4bb4-a8fe-09129b09bc0c) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = e1eacc71-943b-4bb4-a8fe-09129b09bc0c batch = 3571 start at NativeMethodAccessorImpl.java:0 2026/06/20 04:04:32 3 s 1/1
3/3
2151 (e1eacc71-943b-4bb4-a8fe-09129b09bc0c) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = e1eacc71-943b-4bb4-a8fe-09129b09bc0c batch = 3570 start at NativeMethodAccessorImpl.java:0 2026/06/20 04:03:31 5 s 1/1
3/3
2150 (56fcc6b3-ca26-4cdf-b4b8-e5181c15bdb7) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 56fcc6b3-ca26-4cdf-b4b8-e5181c15bdb7 batch = 3570 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/20 04:03:31 2 s 1/1
3/3
2149 (e1eacc71-943b-4bb4-a8fe-09129b09bc0c) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = e1eacc71-943b-4bb4-a8fe-09129b09bc0c batch = 3569 start at NativeMethodAccessorImpl.java:0 2026/06/20 04:02:32 5 s 1/1
3/3
2148 (56fcc6b3-ca26-4cdf-b4b8-e5181c15bdb7) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 56fcc6b3-ca26-4cdf-b4b8-e5181c15bdb7 batch = 3569 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/20 04:02:32 2 s 1/1
3/3
2147 (e1eacc71-943b-4bb4-a8fe-09129b09bc0c) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = e1eacc71-943b-4bb4-a8fe-09129b09bc0c batch = 3568 start at NativeMethodAccessorImpl.java:0 2026/06/20 04:01:32 5 s 1/1
3/3
2146 (56fcc6b3-ca26-4cdf-b4b8-e5181c15bdb7) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 56fcc6b3-ca26-4cdf-b4b8-e5181c15bdb7 batch = 3568 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/20 04:01:31 2 s 1/1
3/3
2145 (e1eacc71-943b-4bb4-a8fe-09129b09bc0c) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = e1eacc71-943b-4bb4-a8fe-09129b09bc0c batch = 3567 start at NativeMethodAccessorImpl.java:0 2026/06/20 04:00:32 5 s 1/1
3/3
2144 (56fcc6b3-ca26-4cdf-b4b8-e5181c15bdb7) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 56fcc6b3-ca26-4cdf-b4b8-e5181c15bdb7 batch = 3567 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/20 04:00:32 2 s 1/1
3/3
2143 (e1eacc71-943b-4bb4-a8fe-09129b09bc0c) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = e1eacc71-943b-4bb4-a8fe-09129b09bc0c batch = 3566 start at NativeMethodAccessorImpl.java:0 2026/06/20 03:59:32 4 s 1/1
3/3
2142 (56fcc6b3-ca26-4cdf-b4b8-e5181c15bdb7) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 56fcc6b3-ca26-4cdf-b4b8-e5181c15bdb7 batch = 3566 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/20 03:59:32 2 s 1/1
3/3