Skip to content

Commit

Permalink
test(flink): materialize results to avoid consuming an iterator to ch…
Browse files Browse the repository at this point in the history
…eck for element membership (#9611)
  • Loading branch information
cpcloud authored Jul 16, 2024
1 parent 3eafac4 commit 778f38d
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion ibis/backends/flink/tests/test_memtable.py
Original file line number Diff line number Diff line change
Expand Up @@ -35,7 +35,7 @@ def test_create_memtable(con, data, schema, expected):
# cannot use con.execute(t) directly because of some behavioral discrepancy between
# `TableEnvironment.execute_sql()` and `TableEnvironment.sql_query()`; this doesn't
# seem to be an issue if we don't execute memtable directly
result = con.raw_sql(con.compile(t)).collect()
result = list(con.raw_sql(con.compile(t)).collect())
for element in expected:
assert element in result

Expand Down

0 comments on commit 778f38d

Please sign in to comment.