Uploaded image for project: 'Samza'
  1. Samza
  2. SAMZA-1416

Better logging around the exception where class loading failed in initializing the SystemFactory for a input/output system

    XMLWordPrintableJSON

    Details

    • Type: Bug
    • Status: Resolved
    • Priority: Major
    • Resolution: Fixed
    • Affects Version/s: None
    • Fix Version/s: 0.14.0
    • Component/s: None
    • Labels:
      None

      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
      

        Attachments

          Issue Links

            Activity

              People

              • Assignee:
                dnishimura Daniel Nishimura
                Reporter:
                nickpan47 Yi Pan
              • Votes:
                0 Vote for this issue
                Watchers:
                3 Start watching this issue

                Dates

                • Created:
                  Updated:
                  Resolved: