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

TaskContext#getStore should return KeyValueStore not Object

    XMLWordPrintableJSON

Details

    • Task
    • Status: Resolved
    • Minor
    • Resolution: Fixed
    • 0.13.0, 0.14.0, 0.13.1, 0.14.1
    • None
    • kv-store

    Description

      When setting custom made store not implementing org.apache.samza.storage.kv.KeyValueStore interface, job fails with CastCastException at TaskContext#getStore. Since getStore actually returns KeyValueStore object, the method's signature must be changed to

      KeyValueStore getStore(String name);

      as in org.apache.samza.container.TaskContextImpl.

      Attachments

        Activity

          People

            Unassigned Unassigned
            sardana Sardana Nazarova
            Votes:
            0 Vote for this issue
            Watchers:
            3 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved: