• B
    Various fixes for Batch Source (#7965) · 1632dcaf
    Boyang Jerry Peng 提交于
    * Various fixes for Batch Source
    1. Create intermediate topic/subscription prior to function running in case auto topic creation is turned off
    2. Fix possible NPE in CronTrigger when calling stop()
    3. Stop all producers created in ContextImpl
    4. Delete intermediate topic for batch source
    Co-authored-by: NJerry Peng <jerryp@splunk.com>
    1632dcaf
CronTriggerer.java 2.3 KB