You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
CREATE SOURCE IF NOT EXISTS live_stream_metrics (
client_ip varchar,
user_id varchar,
report_timestamp timestamp,
)
WITH (
connector='kafka',
topic='live_stream_metrics',
privatelink.endpoint='xxx',
privatelink.targets='[{"port": 9092}]',
properties.bootstrap.server='b0-kafka.demosrc.risingwave.internal:9092',
scan.startup.mode='latest'
) ROW FORMAT JSON
privatelink.targets is denied as an unknown field.
Error message/log
"msg": "ERROR: Failed to run the query\n\nCaused by these errors (recent errors listed first):\n 1: gRPC request to meta service failed: Internal error\n 2: Unknown fields in the WITH clause: {\"privatelink.targets\": \"[{\\\"port\\\": 9092}]\"}\n (SQLSTATE XX000)"
To Reproduce
No response
Expected behavior
No response
How did you deploy RisingWave?
No response
The version of RisingWave
No response
Additional context
No response
The text was updated successfully, but these errors were encountered:
Related: #13362 (can be patched similarly as a temporary workaround)
Our current approach of rejecting unknown fields (in create_source.rs) is still WRONG - and to be honest I do not have a solution either ... Certain properties (e.g. the one in this issue) are only used in compute node but the check happens in frontend, assuming most properties shall be used/checked in frontend - which is wrong or hard to maintain. 🥲
Describe the bug
privatelink.targets
is denied as an unknown field.Error message/log
To Reproduce
No response
Expected behavior
No response
How did you deploy RisingWave?
No response
The version of RisingWave
No response
Additional context
No response
The text was updated successfully, but these errors were encountered: