search

apache / incubator-streampark

Make stream processing easier! Easy-to-use streaming application development framework and operation platform.
https://streampark.apache.org/
Apache License 2.0
3.91k stars 1.01k forks source link

kafka异步sink clickhouse 404 问题 #1804

Closed zjialin closed 2 years ago

zjialin commented 2 years ago

Search before asking

What happened

2022-10-11 13:55:45 | ERROR | ClickHouse-writer-callback-executor-1 | com.streamxhub.streamx.flink.connector.clickhouse.internal.ClickHouseWriterTask | [StreamX] Error ClickHouseSink executing callback, params = { user: default, password: **, hosts: http://10.96.183.39:8123 } , StatusCode = 404 2022-10-11 13:55:45 | WARN | ClickHouse-writer-callback-executor-1 | com.streamxhub.streamx.flink.connector.clickhouse.internal.ClickHouseWriterTask | [StreamX] Next attempt to send data to ClickHouse, table = icc_test.BoardContNPMCycleTime2, buffer size = 10, current attempt num = 1, max attempt num = 1, response = NettyResponse { statusCode=404 headers= Date: Tue, 11 Oct 2022 05:51:10 GMT Connection: Keep-Alive Content-Type: text/plain; charset=UTF-8 X-ClickHouse-Server-Display-Name: icc-bigdata-db Transfer-Encoding: chunked X-ClickHouse-Exception-Code: 47 Keep-Alive: timeout=3 X-ClickHouse-Summary: {"read_rows":"0","read_bytes":"0","written_rows":"0","written_bytes":"0","total_rows_to_read":"0","result_rows":"0","result_bytes":"0"} body= Code: 47. DB::Exception: Missing columns: 'S17B' while processing query: 'S17B', required columns: 'S17B' 'S17B': While executing ValuesBlockInputFormat. (UNKNOWN_IDENTIFIER) (version 22.9.3.18 (official build))

StreamPark Version

v1.2.3

Java Version

1.8

Flink Version

v1.4.0

Scala Version of Flink

2.11

Error Exception

2022-10-11 13:55:45 | ERROR | ClickHouse-writer-callback-executor-1 | com.streamxhub.streamx.flink.connector.clickhouse.internal.ClickHouseWriterTask | [StreamX] Error ClickHouseSink executing callback, params = 
{ user: default, password: ******, hosts: http://10.96.183.39:8123 }
, StatusCode = 404 
2022-10-11 13:55:45 | WARN  | ClickHouse-writer-callback-executor-1 | com.streamxhub.streamx.flink.connector.clickhouse.internal.ClickHouseWriterTask | [StreamX] Next attempt to send data to ClickHouse, table = icc_test.BoardContNPMCycleTime2, buffer size = 10, current attempt num = 1, max attempt num = 1, response = NettyResponse {
    statusCode=404
    headers=
        Date: Tue, 11 Oct 2022 05:51:10 GMT
        Connection: Keep-Alive
        Content-Type: text/plain; charset=UTF-8
        X-ClickHouse-Server-Display-Name: icc-bigdata-db
        Transfer-Encoding: chunked
        X-ClickHouse-Exception-Code: 47
        Keep-Alive: timeout=3
        X-ClickHouse-Summary: {"read_rows":"0","read_bytes":"0","written_rows":"0","written_bytes":"0","total_rows_to_read":"0","result_rows":"0","result_bytes":"0"}
    body=
Code: 47. DB::Exception: Missing columns: 'S17B' while processing query: 'S17B', required columns: 'S17B' 'S17B': While executing ValuesBlockInputFormat. (UNKNOWN_IDENTIFIER) (version 22.9.3.18 (official build))

Screenshots

No response

Are you willing to submit PR?

Code of Conduct

wolfboys commented 2 years ago

please use english and describe your problem clearly