[SAMZA-1416] Better logging around the exception where class loading failed in initializing the SystemFactory for a input/output system

• Type: Bug
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 0.14.0
• Assignee: Daniel Nishimura
• Reporter: Yi Pan
• Created: 07/Sep/17 23:24
• Updated: 25/Sep/17 17:08
• Resolved: 19/Sep/17 21:28

Description

Currently, there is no log line showing the failure is on which system and which class name failed, when the config variable exists but is an empty string.

    val systemFactories = systemNames.map(systemName => {
      val systemFactoryClassName = config
        .getSystemFactory(systemName)
        .getOrElse(throw new SamzaException("A stream uses system %s, which is missing from the configuration." format systemName))
      (systemName, Util.getObj[SystemFactory](systemFactoryClassName))
    }).toMap

Issue Links

• links to: GitHub Pull Request #296