Skip to content

Commit

Permalink
test: remove stale tests (#9308)
Browse files Browse the repository at this point in the history
  • Loading branch information
mjsax authored Jul 18, 2022
1 parent a5effb5 commit 4b2b75b
Showing 1 changed file with 1 addition and 20 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -323,23 +323,4 @@ CREATE TABLE b AS SELECT id, COUNT(*)
CREATE OR REPLACE TABLE b AS SELECT id, COUNT(*)
FROM a WINDOW TUMBLING (SIZE 30 SECONDS)
WHERE col1 > 0
GROUP BY id;

----------------------------------------------------------------------------------------------------
--@test: add filter to Suppress
--@expected.error: io.confluent.ksql.util.KsqlException
--@expected.message: Upgrades not yet supported for StreamWindowedAggregate
----------------------------------------------------------------------------------------------------
SET 'ksql.create.or.replace.enabled' = 'true';

CREATE STREAM a (id INT KEY, col1 INT) WITH (kafka_topic='a', value_format='JSON');
CREATE TABLE b AS SELECT id, COUNT(*)
FROM a WINDOW TUMBLING (SIZE 30 SECONDS)
GROUP BY id
EMIT FINAL;

CREATE OR REPLACE TABLE b AS SELECT id, COUNT(*)
FROM a WINDOW TUMBLING (SIZE 30 SECONDS)
WHERE col1 > 0
GROUP BY id
EMIT FINAL;
GROUP BY id;

0 comments on commit 4b2b75b

Please sign in to comment.