Skip to content

Commit

Permalink
testdrive: Remove further source stats flakiness
Browse files Browse the repository at this point in the history
  • Loading branch information
def- committed Jan 2, 2025
1 parent 74ebdd6 commit 85b5cbc
Showing 1 changed file with 3 additions and 6 deletions.
9 changes: 3 additions & 6 deletions test/testdrive-old-kafka-src-syntax/statistics-maintenance.td
Original file line number Diff line number Diff line change
Expand Up @@ -53,13 +53,12 @@ one:two
sink1 1 1 true true

> SELECT s.name,
SUM(u.updates_committed) > 0,
SUM(u.messages_received)
FROM mz_sources s
JOIN mz_internal.mz_source_statistics_raw u ON s.id = u.id
WHERE s.name IN ('upsert1')
GROUP BY s.id, s.name
upsert1 true 1
upsert1 1

# Shut down the cluster
> ALTER CLUSTER cluster1 SET (REPLICATION FACTOR = 0)
Expand All @@ -73,13 +72,12 @@ upsert1 true 1
sink1 1 1 true true

> SELECT s.name,
SUM(u.updates_committed) > 0,
SUM(u.messages_received)
FROM mz_sources s
JOIN mz_internal.mz_source_statistics_raw u ON s.id = u.id
WHERE s.name IN ('upsert1')
GROUP BY s.id, s.name
upsert1 true 1
upsert1 1

# Ingest some more data, and ensure counters are maintained

Expand All @@ -97,10 +95,9 @@ two:three
sink1 2 2 true true

> SELECT s.name,
SUM(u.updates_committed) > 0,
SUM(u.messages_received)
FROM mz_sources s
JOIN mz_internal.mz_source_statistics_raw u ON s.id = u.id
WHERE s.name IN ('upsert1')
GROUP BY s.id, s.name
upsert1 true 2
upsert1 2

0 comments on commit 85b5cbc

Please sign in to comment.