Spark Jobs (?)

  • User: spark
  • Total Uptime: 17.5 h
  • Scheduling Mode: FIFO
  • Completed Jobs: 2098, only showing 998
Event Timeline

Completed Jobs (2098, only showing 998)

Job Id (Job Group) ▾ Description Submitted Duration Stages: Succeeded/Total Tasks (for all stages): Succeeded/Total
2097 (9d34b5c4-f091-4879-bfb3-239334e38f7e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 9d34b5c4-f091-4879-bfb3-239334e38f7e batch = 9795 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/24 12:01:32 5 s 1/1
3/3
2096 (df563956-55c5-4a9d-9126-d7d731c8280f) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = df563956-55c5-4a9d-9126-d7d731c8280f batch = 9796 start at NativeMethodAccessorImpl.java:0 2026/06/24 12:01:32 3 s 1/1
3/3
2095 (9d34b5c4-f091-4879-bfb3-239334e38f7e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 9d34b5c4-f091-4879-bfb3-239334e38f7e batch = 9794 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/24 12:00:33 5 s 1/1
3/3
2094 (df563956-55c5-4a9d-9126-d7d731c8280f) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = df563956-55c5-4a9d-9126-d7d731c8280f batch = 9795 start at NativeMethodAccessorImpl.java:0 2026/06/24 12:00:32 4 s 1/1
3/3
2093 (9d34b5c4-f091-4879-bfb3-239334e38f7e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 9d34b5c4-f091-4879-bfb3-239334e38f7e batch = 9793 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/24 11:59:32 5 s 1/1
3/3
2092 (df563956-55c5-4a9d-9126-d7d731c8280f) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = df563956-55c5-4a9d-9126-d7d731c8280f batch = 9794 start at NativeMethodAccessorImpl.java:0 2026/06/24 11:59:32 3 s 1/1
3/3
2091 (df563956-55c5-4a9d-9126-d7d731c8280f) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = df563956-55c5-4a9d-9126-d7d731c8280f batch = 9793 start at NativeMethodAccessorImpl.java:0 2026/06/24 11:58:32 4 s 1/1
3/3
2090 (9d34b5c4-f091-4879-bfb3-239334e38f7e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 9d34b5c4-f091-4879-bfb3-239334e38f7e batch = 9792 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/24 11:58:32 2 s 1/1
3/3
2089 (df563956-55c5-4a9d-9126-d7d731c8280f) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = df563956-55c5-4a9d-9126-d7d731c8280f batch = 9792 start at NativeMethodAccessorImpl.java:0 2026/06/24 11:57:32 5 s 1/1
3/3
2088 (9d34b5c4-f091-4879-bfb3-239334e38f7e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 9d34b5c4-f091-4879-bfb3-239334e38f7e batch = 9791 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/24 11:57:32 2 s 1/1
3/3
2087 (df563956-55c5-4a9d-9126-d7d731c8280f) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = df563956-55c5-4a9d-9126-d7d731c8280f batch = 9791 start at NativeMethodAccessorImpl.java:0 2026/06/24 11:56:32 4 s 1/1
3/3
2086 (9d34b5c4-f091-4879-bfb3-239334e38f7e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 9d34b5c4-f091-4879-bfb3-239334e38f7e batch = 9790 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/24 11:56:32 2 s 1/1
3/3
2085 (df563956-55c5-4a9d-9126-d7d731c8280f) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = df563956-55c5-4a9d-9126-d7d731c8280f batch = 9790 start at NativeMethodAccessorImpl.java:0 2026/06/24 11:55:32 4 s 1/1
3/3
2084 (9d34b5c4-f091-4879-bfb3-239334e38f7e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 9d34b5c4-f091-4879-bfb3-239334e38f7e batch = 9789 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/24 11:55:32 2 s 1/1
3/3
2083 (df563956-55c5-4a9d-9126-d7d731c8280f) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = df563956-55c5-4a9d-9126-d7d731c8280f batch = 9789 start at NativeMethodAccessorImpl.java:0 2026/06/24 11:54:32 5 s 1/1
3/3
2082 (9d34b5c4-f091-4879-bfb3-239334e38f7e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 9d34b5c4-f091-4879-bfb3-239334e38f7e batch = 9788 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/24 11:54:32 2 s 1/1
3/3
2081 (df563956-55c5-4a9d-9126-d7d731c8280f) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = df563956-55c5-4a9d-9126-d7d731c8280f batch = 9788 start at NativeMethodAccessorImpl.java:0 2026/06/24 11:53:32 5 s 1/1
3/3
2080 (9d34b5c4-f091-4879-bfb3-239334e38f7e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 9d34b5c4-f091-4879-bfb3-239334e38f7e batch = 9787 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/24 11:53:31 2 s 1/1
3/3
2079 (9d34b5c4-f091-4879-bfb3-239334e38f7e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 9d34b5c4-f091-4879-bfb3-239334e38f7e batch = 9786 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/24 11:52:32 5 s 1/1
3/3
2078 (df563956-55c5-4a9d-9126-d7d731c8280f) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = df563956-55c5-4a9d-9126-d7d731c8280f batch = 9787 start at NativeMethodAccessorImpl.java:0 2026/06/24 11:52:32 3 s 1/1
3/3
2077 (df563956-55c5-4a9d-9126-d7d731c8280f) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = df563956-55c5-4a9d-9126-d7d731c8280f batch = 9786 start at NativeMethodAccessorImpl.java:0 2026/06/24 11:51:33 3 s 1/1
3/3
2076 (9d34b5c4-f091-4879-bfb3-239334e38f7e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 9d34b5c4-f091-4879-bfb3-239334e38f7e batch = 9785 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/24 11:51:32 2 s 1/1
3/3
2075 (9d34b5c4-f091-4879-bfb3-239334e38f7e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 9d34b5c4-f091-4879-bfb3-239334e38f7e batch = 9784 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/24 11:50:32 5 s 1/1
3/3
2074 (df563956-55c5-4a9d-9126-d7d731c8280f) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = df563956-55c5-4a9d-9126-d7d731c8280f batch = 9785 start at NativeMethodAccessorImpl.java:0 2026/06/24 11:50:31 4 s 1/1
3/3
2073 (9d34b5c4-f091-4879-bfb3-239334e38f7e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 9d34b5c4-f091-4879-bfb3-239334e38f7e batch = 9783 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/24 11:49:32 5 s 1/1
3/3
2072 (df563956-55c5-4a9d-9126-d7d731c8280f) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = df563956-55c5-4a9d-9126-d7d731c8280f batch = 9784 start at NativeMethodAccessorImpl.java:0 2026/06/24 11:49:31 4 s 1/1
3/3
2071 (9d34b5c4-f091-4879-bfb3-239334e38f7e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 9d34b5c4-f091-4879-bfb3-239334e38f7e batch = 9782 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/24 11:48:32 5 s 1/1
3/3
2070 (df563956-55c5-4a9d-9126-d7d731c8280f) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = df563956-55c5-4a9d-9126-d7d731c8280f batch = 9783 start at NativeMethodAccessorImpl.java:0 2026/06/24 11:48:32 3 s 1/1
3/3
2069 (df563956-55c5-4a9d-9126-d7d731c8280f) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = df563956-55c5-4a9d-9126-d7d731c8280f batch = 9782 start at NativeMethodAccessorImpl.java:0 2026/06/24 11:47:32 5 s 1/1
3/3
2068 (9d34b5c4-f091-4879-bfb3-239334e38f7e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 9d34b5c4-f091-4879-bfb3-239334e38f7e batch = 9781 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/24 11:47:32 2 s 1/1
3/3
2067 (df563956-55c5-4a9d-9126-d7d731c8280f) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = df563956-55c5-4a9d-9126-d7d731c8280f batch = 9781 start at NativeMethodAccessorImpl.java:0 2026/06/24 11:46:32 4 s 1/1
3/3
2066 (9d34b5c4-f091-4879-bfb3-239334e38f7e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 9d34b5c4-f091-4879-bfb3-239334e38f7e batch = 9780 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/24 11:46:31 2 s 1/1
3/3
2065 (df563956-55c5-4a9d-9126-d7d731c8280f) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = df563956-55c5-4a9d-9126-d7d731c8280f batch = 9780 start at NativeMethodAccessorImpl.java:0 2026/06/24 11:45:32 5 s 1/1
3/3
2064 (9d34b5c4-f091-4879-bfb3-239334e38f7e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 9d34b5c4-f091-4879-bfb3-239334e38f7e batch = 9779 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/24 11:45:32 2 s 1/1
3/3
2063 (df563956-55c5-4a9d-9126-d7d731c8280f) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = df563956-55c5-4a9d-9126-d7d731c8280f batch = 9779 start at NativeMethodAccessorImpl.java:0 2026/06/24 11:44:32 5 s 1/1
3/3
2062 (9d34b5c4-f091-4879-bfb3-239334e38f7e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 9d34b5c4-f091-4879-bfb3-239334e38f7e batch = 9778 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/24 11:44:31 2 s 1/1
3/3
2061 (9d34b5c4-f091-4879-bfb3-239334e38f7e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 9d34b5c4-f091-4879-bfb3-239334e38f7e batch = 9777 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/24 11:43:32 5 s 1/1
3/3
2060 (df563956-55c5-4a9d-9126-d7d731c8280f) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = df563956-55c5-4a9d-9126-d7d731c8280f batch = 9778 start at NativeMethodAccessorImpl.java:0 2026/06/24 11:43:32 3 s 1/1
3/3
2059 (df563956-55c5-4a9d-9126-d7d731c8280f) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = df563956-55c5-4a9d-9126-d7d731c8280f batch = 9777 start at NativeMethodAccessorImpl.java:0 2026/06/24 11:42:32 5 s 1/1
3/3
2058 (9d34b5c4-f091-4879-bfb3-239334e38f7e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 9d34b5c4-f091-4879-bfb3-239334e38f7e batch = 9776 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/24 11:42:31 2 s 1/1
3/3
2057 (df563956-55c5-4a9d-9126-d7d731c8280f) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = df563956-55c5-4a9d-9126-d7d731c8280f batch = 9776 start at NativeMethodAccessorImpl.java:0 2026/06/24 11:41:33 4 s 1/1
3/3
2056 (9d34b5c4-f091-4879-bfb3-239334e38f7e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 9d34b5c4-f091-4879-bfb3-239334e38f7e batch = 9775 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/24 11:41:32 2 s 1/1
3/3
2055 (df563956-55c5-4a9d-9126-d7d731c8280f) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = df563956-55c5-4a9d-9126-d7d731c8280f batch = 9775 start at NativeMethodAccessorImpl.java:0 2026/06/24 11:40:32 5 s 1/1
3/3
2054 (9d34b5c4-f091-4879-bfb3-239334e38f7e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 9d34b5c4-f091-4879-bfb3-239334e38f7e batch = 9774 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/24 11:40:32 2 s 1/1
3/3
2053 (df563956-55c5-4a9d-9126-d7d731c8280f) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = df563956-55c5-4a9d-9126-d7d731c8280f batch = 9774 start at NativeMethodAccessorImpl.java:0 2026/06/24 11:39:32 5 s 1/1
3/3
2052 (9d34b5c4-f091-4879-bfb3-239334e38f7e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 9d34b5c4-f091-4879-bfb3-239334e38f7e batch = 9773 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/24 11:39:32 2 s 1/1
3/3
2051 (df563956-55c5-4a9d-9126-d7d731c8280f) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = df563956-55c5-4a9d-9126-d7d731c8280f batch = 9773 start at NativeMethodAccessorImpl.java:0 2026/06/24 11:38:32 5 s 1/1
3/3
2050 (9d34b5c4-f091-4879-bfb3-239334e38f7e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 9d34b5c4-f091-4879-bfb3-239334e38f7e batch = 9772 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/24 11:38:32 2 s 1/1
3/3
2049 (9d34b5c4-f091-4879-bfb3-239334e38f7e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 9d34b5c4-f091-4879-bfb3-239334e38f7e batch = 9771 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/24 11:37:32 5 s 1/1
3/3
2048 (df563956-55c5-4a9d-9126-d7d731c8280f) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = df563956-55c5-4a9d-9126-d7d731c8280f batch = 9772 start at NativeMethodAccessorImpl.java:0 2026/06/24 11:37:32 4 s 1/1
3/3
2047 (df563956-55c5-4a9d-9126-d7d731c8280f) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = df563956-55c5-4a9d-9126-d7d731c8280f batch = 9771 start at NativeMethodAccessorImpl.java:0 2026/06/24 11:36:32 6 s 1/1
4/4
2046 (9d34b5c4-f091-4879-bfb3-239334e38f7e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 9d34b5c4-f091-4879-bfb3-239334e38f7e batch = 9770 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/24 11:36:32 2 s 1/1
4/4
2045 (df563956-55c5-4a9d-9126-d7d731c8280f) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = df563956-55c5-4a9d-9126-d7d731c8280f batch = 9770 start at NativeMethodAccessorImpl.java:0 2026/06/24 11:35:32 5 s 1/1
3/3
2044 (9d34b5c4-f091-4879-bfb3-239334e38f7e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 9d34b5c4-f091-4879-bfb3-239334e38f7e batch = 9769 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/24 11:35:32 2 s 1/1
3/3
2043 (df563956-55c5-4a9d-9126-d7d731c8280f) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = df563956-55c5-4a9d-9126-d7d731c8280f batch = 9769 start at NativeMethodAccessorImpl.java:0 2026/06/24 11:34:32 5 s 1/1
3/3
2042 (9d34b5c4-f091-4879-bfb3-239334e38f7e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 9d34b5c4-f091-4879-bfb3-239334e38f7e batch = 9768 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/24 11:34:32 2 s 1/1
3/3
2041 (9d34b5c4-f091-4879-bfb3-239334e38f7e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 9d34b5c4-f091-4879-bfb3-239334e38f7e batch = 9767 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/24 11:33:32 4 s 1/1
3/3
2040 (df563956-55c5-4a9d-9126-d7d731c8280f) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = df563956-55c5-4a9d-9126-d7d731c8280f batch = 9768 start at NativeMethodAccessorImpl.java:0 2026/06/24 11:33:32 3 s 1/1
3/3
2039 (df563956-55c5-4a9d-9126-d7d731c8280f) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = df563956-55c5-4a9d-9126-d7d731c8280f batch = 9767 start at NativeMethodAccessorImpl.java:0 2026/06/24 11:32:32 5 s 1/1
3/3
2038 (9d34b5c4-f091-4879-bfb3-239334e38f7e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 9d34b5c4-f091-4879-bfb3-239334e38f7e batch = 9766 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/24 11:32:32 2 s 1/1
3/3
2037 (df563956-55c5-4a9d-9126-d7d731c8280f) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = df563956-55c5-4a9d-9126-d7d731c8280f batch = 9766 start at NativeMethodAccessorImpl.java:0 2026/06/24 11:31:32 4 s 1/1
3/3
2036 (9d34b5c4-f091-4879-bfb3-239334e38f7e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 9d34b5c4-f091-4879-bfb3-239334e38f7e batch = 9765 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/24 11:31:32 2 s 1/1
3/3
2035 (df563956-55c5-4a9d-9126-d7d731c8280f) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = df563956-55c5-4a9d-9126-d7d731c8280f batch = 9765 start at NativeMethodAccessorImpl.java:0 2026/06/24 11:30:32 5 s 1/1
3/3
2034 (9d34b5c4-f091-4879-bfb3-239334e38f7e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 9d34b5c4-f091-4879-bfb3-239334e38f7e batch = 9764 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/24 11:30:32 2 s 1/1
3/3
2033 (9d34b5c4-f091-4879-bfb3-239334e38f7e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 9d34b5c4-f091-4879-bfb3-239334e38f7e batch = 9763 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/24 11:29:32 4 s 1/1
3/3
2032 (df563956-55c5-4a9d-9126-d7d731c8280f) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = df563956-55c5-4a9d-9126-d7d731c8280f batch = 9764 start at NativeMethodAccessorImpl.java:0 2026/06/24 11:29:32 3 s 1/1
3/3
2031 (9d34b5c4-f091-4879-bfb3-239334e38f7e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 9d34b5c4-f091-4879-bfb3-239334e38f7e batch = 9762 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/24 11:28:32 5 s 1/1
3/3
2030 (df563956-55c5-4a9d-9126-d7d731c8280f) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = df563956-55c5-4a9d-9126-d7d731c8280f batch = 9763 start at NativeMethodAccessorImpl.java:0 2026/06/24 11:28:32 3 s 1/1
3/3
2029 (9d34b5c4-f091-4879-bfb3-239334e38f7e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 9d34b5c4-f091-4879-bfb3-239334e38f7e batch = 9761 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/24 11:27:32 4 s 1/1
3/3
2028 (df563956-55c5-4a9d-9126-d7d731c8280f) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = df563956-55c5-4a9d-9126-d7d731c8280f batch = 9762 start at NativeMethodAccessorImpl.java:0 2026/06/24 11:27:31 3 s 1/1
3/3
2027 (9d34b5c4-f091-4879-bfb3-239334e38f7e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 9d34b5c4-f091-4879-bfb3-239334e38f7e batch = 9760 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/24 11:26:32 5 s 1/1
3/3
2026 (df563956-55c5-4a9d-9126-d7d731c8280f) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = df563956-55c5-4a9d-9126-d7d731c8280f batch = 9761 start at NativeMethodAccessorImpl.java:0 2026/06/24 11:26:31 3 s 1/1
3/3
2025 (df563956-55c5-4a9d-9126-d7d731c8280f) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = df563956-55c5-4a9d-9126-d7d731c8280f batch = 9760 start at NativeMethodAccessorImpl.java:0 2026/06/24 11:25:32 5 s 1/1
3/3
2024 (9d34b5c4-f091-4879-bfb3-239334e38f7e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 9d34b5c4-f091-4879-bfb3-239334e38f7e batch = 9759 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/24 11:25:32 2 s 1/1
3/3
2023 (df563956-55c5-4a9d-9126-d7d731c8280f) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = df563956-55c5-4a9d-9126-d7d731c8280f batch = 9759 start at NativeMethodAccessorImpl.java:0 2026/06/24 11:24:32 5 s 1/1
3/3
2022 (9d34b5c4-f091-4879-bfb3-239334e38f7e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 9d34b5c4-f091-4879-bfb3-239334e38f7e batch = 9758 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/24 11:24:32 2 s 1/1
3/3
2021 (df563956-55c5-4a9d-9126-d7d731c8280f) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = df563956-55c5-4a9d-9126-d7d731c8280f batch = 9758 start at NativeMethodAccessorImpl.java:0 2026/06/24 11:23:32 4 s 1/1
3/3
2020 (9d34b5c4-f091-4879-bfb3-239334e38f7e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 9d34b5c4-f091-4879-bfb3-239334e38f7e batch = 9757 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/24 11:23:32 2 s 1/1
3/3
2019 (df563956-55c5-4a9d-9126-d7d731c8280f) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = df563956-55c5-4a9d-9126-d7d731c8280f batch = 9757 start at NativeMethodAccessorImpl.java:0 2026/06/24 11:22:32 5 s 1/1
3/3
2018 (9d34b5c4-f091-4879-bfb3-239334e38f7e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 9d34b5c4-f091-4879-bfb3-239334e38f7e batch = 9756 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/24 11:22:32 2 s 1/1
3/3
2017 (9d34b5c4-f091-4879-bfb3-239334e38f7e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 9d34b5c4-f091-4879-bfb3-239334e38f7e batch = 9755 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/24 11:21:32 6 s 1/1
3/3
2016 (df563956-55c5-4a9d-9126-d7d731c8280f) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = df563956-55c5-4a9d-9126-d7d731c8280f batch = 9756 start at NativeMethodAccessorImpl.java:0 2026/06/24 11:21:31 4 s 1/1
3/3
2015 (df563956-55c5-4a9d-9126-d7d731c8280f) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = df563956-55c5-4a9d-9126-d7d731c8280f batch = 9755 start at NativeMethodAccessorImpl.java:0 2026/06/24 11:20:32 5 s 1/1
3/3
2014 (9d34b5c4-f091-4879-bfb3-239334e38f7e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 9d34b5c4-f091-4879-bfb3-239334e38f7e batch = 9754 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/24 11:20:32 2 s 1/1
3/3
2013 (df563956-55c5-4a9d-9126-d7d731c8280f) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = df563956-55c5-4a9d-9126-d7d731c8280f batch = 9754 start at NativeMethodAccessorImpl.java:0 2026/06/24 11:19:32 4 s 1/1
3/3
2012 (9d34b5c4-f091-4879-bfb3-239334e38f7e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 9d34b5c4-f091-4879-bfb3-239334e38f7e batch = 9753 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/24 11:19:32 2 s 1/1
3/3
2011 (df563956-55c5-4a9d-9126-d7d731c8280f) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = df563956-55c5-4a9d-9126-d7d731c8280f batch = 9753 start at NativeMethodAccessorImpl.java:0 2026/06/24 11:18:32 5 s 1/1
3/3
2010 (9d34b5c4-f091-4879-bfb3-239334e38f7e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 9d34b5c4-f091-4879-bfb3-239334e38f7e batch = 9752 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/24 11:18:32 2 s 1/1
3/3
2009 (df563956-55c5-4a9d-9126-d7d731c8280f) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = df563956-55c5-4a9d-9126-d7d731c8280f batch = 9752 start at NativeMethodAccessorImpl.java:0 2026/06/24 11:17:32 5 s 1/1
3/3
2008 (9d34b5c4-f091-4879-bfb3-239334e38f7e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 9d34b5c4-f091-4879-bfb3-239334e38f7e batch = 9751 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/24 11:17:32 2 s 1/1
3/3
2007 (9d34b5c4-f091-4879-bfb3-239334e38f7e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 9d34b5c4-f091-4879-bfb3-239334e38f7e batch = 9750 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/24 11:16:32 5 s 1/1
3/3
2006 (df563956-55c5-4a9d-9126-d7d731c8280f) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = df563956-55c5-4a9d-9126-d7d731c8280f batch = 9751 start at NativeMethodAccessorImpl.java:0 2026/06/24 11:16:32 3 s 1/1
3/3
2005 (9d34b5c4-f091-4879-bfb3-239334e38f7e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 9d34b5c4-f091-4879-bfb3-239334e38f7e batch = 9749 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/24 11:15:32 5 s 1/1
3/3
2004 (df563956-55c5-4a9d-9126-d7d731c8280f) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = df563956-55c5-4a9d-9126-d7d731c8280f batch = 9750 start at NativeMethodAccessorImpl.java:0 2026/06/24 11:15:32 3 s 1/1
3/3
2003 (df563956-55c5-4a9d-9126-d7d731c8280f) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = df563956-55c5-4a9d-9126-d7d731c8280f batch = 9749 start at NativeMethodAccessorImpl.java:0 2026/06/24 11:14:32 6 s 1/1
4/4
2002 (9d34b5c4-f091-4879-bfb3-239334e38f7e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 9d34b5c4-f091-4879-bfb3-239334e38f7e batch = 9748 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/24 11:14:32 2 s 1/1
4/4
2001 (df563956-55c5-4a9d-9126-d7d731c8280f) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = df563956-55c5-4a9d-9126-d7d731c8280f batch = 9748 start at NativeMethodAccessorImpl.java:0 2026/06/24 11:13:32 4 s 1/1
3/3
2000 (9d34b5c4-f091-4879-bfb3-239334e38f7e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 9d34b5c4-f091-4879-bfb3-239334e38f7e batch = 9747 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/24 11:13:32 2 s 1/1
3/3
1999 (df563956-55c5-4a9d-9126-d7d731c8280f) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = df563956-55c5-4a9d-9126-d7d731c8280f batch = 9747 start at NativeMethodAccessorImpl.java:0 2026/06/24 11:12:32 5 s 1/1
3/3
1998 (9d34b5c4-f091-4879-bfb3-239334e38f7e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 9d34b5c4-f091-4879-bfb3-239334e38f7e batch = 9746 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/24 11:12:32 2 s 1/1
3/3