Skip to content

Commit

Permalink
fix: Sets timezone of RestQueryTranslationTest test to make it work i…
Browse files Browse the repository at this point in the history
…n non UTC zones (#4407)
  • Loading branch information
AlanConfluent authored Jan 30, 2020
1 parent 48aa6ec commit 50b25d5
Showing 1 changed file with 1 addition and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -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}},
Expand Down

0 comments on commit 50b25d5

Please sign in to comment.