Kenneth Knowles created BEAM-4688:
-------------------------------------

             Summary: Beam SQL should clean up resources upon termination of 
the pipeline
                 Key: BEAM-4688
                 URL: https://issues.apache.org/jira/browse/BEAM-4688
             Project: Beam
          Issue Type: New Feature
          Components: dsl-sql
            Reporter: Kenneth Knowles


Currently {{PubsubIO.read().fromTopic(...)}} always creates a subscription that 
will never be deleted. Beam doesn't have an adequate model for cleanup tasks, 
but relies on external orchestration to clean up such things. Beam SQL can do 
this for LIMIT-bounded queries that actually do terminate.



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)

Reply via email to