故障SQL如下:

CREATE TABLE server_logs ( client_ip STRING,client_identity STRING, userid STRING, request_line STRING, status_code STRING, log_time AS PROCTIME() ) WITH ('connector' = 'faker', 'fields.client_ip.expression' = '#{Internet.publicIpV4Address}','fields.client_identity.expression' = '-','fields.userid.expression' = '-','fields.log_time.expression' = '#{date.past ''15'',''5'',''SECONDS''}','fields.status_code.expression' = '#{regexify (200|201|204|400|401|403|301){1}''}' );

完整報錯如下

[ERROR] Could not execute SQL statement. Reason:
org.apache.flink.table.api.ValidationException: Every column needs a corresponding expression. No expression found for request_line.

?

原因:

這個報錯信息只會出現在flink-faker這個connector中

這是因為沒有在with語句中增加隨機生成的模板表達式

?

解決方案:

在with語句中增加隨機生成的模板表達式即可

或者刪除request_line STRING,?

這行SQL也行.

?

總結

以上是生活随笔為你收集整理的Every column needs a corresponding expression. No expression found for xxxx的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。