ksql
ksql copied to clipboard
Show consistent error message for pull queries not running for header columns
Describe the bug Pull queries do not work for header columns From the docs it looks like this is possibly because only ROWTIME is allowed for PULL queries from pseudocolumns. However, the error is not consistent.
To Reproduce Error for ROWPARTITON
ksql> select key,value, window_start from window_change_table where ROWPARTITION=1234;
Pull queries don't support the following columns in WHERE clauses: `ROWPARTITION`
Error for header columns
ksql> CREATE SOURCE TABLE window_change_table(
> key VARCHAR PRIMARY KEY,
> value VARCHAR,
> window_start BYTES HEADER('start'),
> window_end BYTES HEADER('end')
>) WITH (
> kafka_topic = 'test_window_change1',
> partitions=1,value_format = 'json'
> );
Message
--------------------------------------------------
Created query with ID CST_WINDOW_CHANGE_TABLE_39
--------------------------------------------------
ksql> select key,value, window_start from window_change_table
>where window_start = to_bytes('2022-06-07T14:40:12.680','ascii');
Invalid expression: Unknown column WINDOW_START.. expression: (WINDOW_START = TO_BYTES('2022-06-07T14:40:12.680', 'ascii')), schema:`KEY` STRING KEY, `WINDOW_START` BYTES HEADER('start'), `WINDOW_END` BYTES HEADER('end'), `VALUE` STRING
Expected behavior Both above errors should be consistent
Actual behaviour Unknown column for pull query on header column
Additional context