diff --git a/ksql-functional-tests/src/test/resources/rest-query-validation-tests/push-queries.json b/ksql-functional-tests/src/test/resources/rest-query-validation-tests/push-queries.json index aa3d00aad089..94940b698b29 100644 --- a/ksql-functional-tests/src/test/resources/rest-query-validation-tests/push-queries.json +++ b/ksql-functional-tests/src/test/resources/rest-query-validation-tests/push-queries.json @@ -256,7 +256,7 @@ "statements": [ "CREATE STREAM INPUT (IGNORED INT) WITH (kafka_topic='test_topic', value_format='JSON');", "CREATE TABLE AGGREGATE AS SELECT COUNT(1) AS COUNT FROM INPUT WINDOW TUMBLING(SIZE 1 SECOND) GROUP BY ROWKEY;", - "SELECT TIMESTAMPTOSTRING(WINDOWSTART, 'yyyy-MM-dd HH:mm:ss Z') AS WSTART, TIMESTAMPTOSTRING(WINDOWEND, 'yyyy-MM-dd HH:mm:ss Z') AS WEND, COUNT FROM AGGREGATE EMIT CHANGES LIMIT 2;" + "SELECT TIMESTAMPTOSTRING(WINDOWSTART, 'yyyy-MM-dd HH:mm:ss Z', 'UTC') AS WSTART, TIMESTAMPTOSTRING(WINDOWEND, 'yyyy-MM-dd HH:mm:ss Z', 'UTC') AS WEND, COUNT FROM AGGREGATE EMIT CHANGES LIMIT 2;" ], "inputs": [ {"topic": "test_topic", "timestamp": 1580223282123, "key": "11", "value": {"id": 100}},