Streaming queries with positive start time will run forever.

[sync-by-unito[bot]]

This is due to the way memory_source_node.cc handles not finding the start time. Any streaming query with a start time in the future, will run forever outputting Zero row row batches.

┆Issue is synchronized with this Jira Bug by Unito

[sync-by-unito[bot]]

➤ James Bartlett commented:

Actually looking at the code a bit closer, it might be hanging for some other reason, because it should set eos if it doesn’t find the start time.

[sync-by-unito[bot]]

➤ James Bartlett commented:

import px

df = px.DataFrame('http_events', start_time='+5m') df = df.stream()

px.display(df)