ksql icon indicating copy to clipboard operation
ksql copied to clipboard

Show consistent error message for pull queries not running for header columns

Open SamiShaikh opened this issue 2 years ago • 0 comments

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

SamiShaikh avatar Jun 13 '22 16:06 SamiShaikh