[BEAM-4820] Add timeout to Future.get when waiting for Pubsub messages

• Type: Bug
• Status: Resolved
• Priority: P2
• Resolution: Fixed
• Fix Version/s: Not applicable
• Component/s: dsl-sql
• Assignee: Rui Wang
• Reporter: Rui Wang
• Created: 18/Jul/18 21:34
• Updated: 24/Jul/20 20:17
• Resolved: 24/Jul/18 17:28

Description

Should have a timeout when waiting for Pubsub messages because if unbounded limit is broken, the Future.get() will be blocking and never return.

 

Issue Links

• links to: GitHub Pull Request #5985