Skip to content

Commit

Permalink
ultimately deterministic & why bother 101 messages?
Browse files Browse the repository at this point in the history
Signed-off-by: xxchan <[email protected]>
  • Loading branch information
xxchan committed Jun 26, 2024
1 parent 39eb924 commit 97397eb
Showing 1 changed file with 5 additions and 5 deletions.
10 changes: 5 additions & 5 deletions e2e_test/source_inline/kafka/include_key_as.slt
Original file line number Diff line number Diff line change
Expand Up @@ -184,7 +184,7 @@ rpk topic create 'test_additional_columns'

# Note: `sh` doesn't have {..} brace expansion
system ok
bash -c 'for i in {0..100}; do echo "key\$i:{\\"a\\": \$i}" | rpk topic produce test_additional_columns -f "%k:%v\\n" -H "header1=v1" -H "header2=v2"; done'
bash -c 'for i in {0..10}; do echo "key\$i:{\\"a\\": \$i}" | rpk topic produce test_additional_columns -f "%k:%v\\n" -H "header1=v1" -H "header2=v2"; done'


statement error
Expand Down Expand Up @@ -273,16 +273,16 @@ WHERE key_col IS NOT NULL
AND timestamp_col IS NOT NULL
AND header_col_combined IS NOT NULL
----
101
11


query ??
WITH arr AS (SELECT header_col_combined FROM additional_columns),
unnested AS (SELECT unnest(header_col_combined) FROM arr)
select *, count(*) from unnested group by 1;
select *, count(*) from unnested group by 1 order by 1;
----
(header1,"\\x7631") 101
(header2,"\\x7632") 101
(header1,"\\x7631") 11
(header2,"\\x7632") 11

query ????
select header_col_1, header_col_2, header_col_3, header_col_4 from additional_columns limit 1
Expand Down

0 comments on commit 97397eb

Please sign in to comment.