[jira] [Updated] (BAHIR-45) Add cleanup support to SQL-STREAMING-MQTT Source once SPARK-16963 is fixed.

[ https://issues.apache.org/jira/browse/BAHIR-45?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Prashant Sharma updated BAHIR-45: - Summary: Add cleanup support to SQL-STREAMING-MQTT Source once SPARK-16963 is fixed. (was: Add clea

[jira] [Updated] (BAHIR-45) Add cleanup support to SQL-STREAMING-MQTT Source once SPARK-16963 is fixed.

[ https://issues.apache.org/jira/browse/BAHIR-45?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Prashant Sharma updated BAHIR-45: - Description: Currently, source tries to persist all the incoming messages to allow for minimal level