WINDOWSTART doesn't work in push query predicate

[rmoff]

Tested using ksqlDB built on 20200207 from commit hash f8bb986

Works with pull query

ksql> SELECT TIMESTAMPTOSTRING(WINDOWSTART, 'yyyy-MM-dd HH:mm:ss') AS WINDOW_START_TS,
>       FULL_NAME,
>       RATINGS_COUNT
>  FROM RATINGS_PER_CUSTOMER_PER_MINUTE
>  WHERE ROWKEY='Rica Blaisdell'
>  AND  WINDOWSTART > '2020-02-07T17:08:00.000'
>  ;
+----------------------------+----------------------------+----------------------------+
|WINDOW_START_TS             |FULL_NAME                   |RATINGS_COUNT               |
+----------------------------+----------------------------+----------------------------+
|2020-02-07 17:09:00         |Rica Blaisdell              |8                           |
|2020-02-07 17:10:00         |Rica Blaisdell              |14                          |
|2020-02-07 17:11:00         |Rica Blaisdell              |6                           |
|2020-02-07 17:12:00         |Rica Blaisdell              |8                           |
|2020-02-07 17:13:00         |Rica Blaisdell              |1                           |
Query terminated

Doesn't work in push query

ksql> SELECT TIMESTAMPTOSTRING(WINDOWSTART, 'yyyy-MM-dd HH:mm:ss') AS WINDOW_START_TS,
>       FULL_NAME,
>       RATINGS_COUNT
>  FROM RATINGS_PER_CUSTOMER_PER_MINUTE
>  WHERE ROWKEY='Rica Blaisdell'
>  AND  WINDOWSTART > '2020-02-07T17:08:00.000'
>  EMIT CHANGES;
Code generation failed for Predicate: Operator GREATER_THAN cannot be used to compare BIGINT and STRING. expression:((ROWKEY = 'Rica Blaisdell') AND (WINDOWSTART > '2020-02-07T17:08:00.000')), schema:`ROWKEY` STRING KEY, `FULL_NAME` STRING, `RATINGS_COUNT` BIGINT, `ROWTIME` BIGINT, `ROWKEY` STRING, `WINDOWSTART` BIGINT, `WINDOWEND` BIGINT
ksql>

Note : works fine in push query if using rowtime

ksql> SELECT TIMESTAMPTOSTRING(WINDOWSTART, 'yyyy-MM-dd HH:mm:ss') AS WINDOW_START_TS,
>       FULL_NAME,
>       RATINGS_COUNT
>  FROM RATINGS_PER_CUSTOMER_PER_MINUTE
>  WHERE ROWKEY='Rica Blaisdell'
>  AND  rowtime > '2020-02-07T17:08:00.000'
>  EMIT CHANGES;
+----------------------------+----------------------------+----------------------------+
|WINDOW_START_TS             |FULL_NAME                   |RATINGS_COUNT               |
+----------------------------+----------------------------+----------------------------+
|2020-02-07 17:08:00         |Rica Blaisdell              |6                           |
|2020-02-07 17:09:00         |Rica Blaisdell              |8                           |
|2020-02-07 17:10:00         |Rica Blaisdell              |14                          |
|2020-02-07 17:11:00         |Rica Blaisdell              |6                           |
|2020-02-07 17:12:00         |Rica Blaisdell              |8                           |
|2020-02-07 17:13:00         |Rica Blaisdell              |5                           |
|2020-02-07 17:14:00         |Rica Blaisdell              |5                           |
|2020-02-07 17:15:00         |Rica Blaisdell              |2                           |
^CQuery terminated

[rmoff]

CREATE TABLE RATINGS_PER_CUSTOMER_PER_MINUTE AS 
SELECT FULL_NAME,COUNT(*) AS RATINGS_COUNT
  FROM RATINGS_WITH_CUSTOMER_DATA 
        WINDOW TUMBLING (SIZE 1 MINUTE) 
  GROUP BY FULL_NAME
  EMIT CHANGES;

ksql> describe RATINGS_PER_CUSTOMER_PER_MINUTE;

Name                 : RATINGS_PER_CUSTOMER_PER_MINUTE
 Field         | Type
-------------------------------------------------------------------
 ROWTIME       | BIGINT           (system)
 ROWKEY        | VARCHAR(STRING)  (system) (Window type: TUMBLING)
 FULL_NAME     | VARCHAR(STRING)
 RATINGS_COUNT | BIGINT
-------------------------------------------------------------------
For runtime statistics and query details run: DESCRIBE EXTENDED <Stream,Table>;
ksql>