Bharath Kumarasubramanian created SAMZA-2382:
------------------------------------------------
Summary: User specified side input processor should take
precedence over the identity processor
Key: SAMZA-2382
URL: https://issues.apache.org/jira/browse/SAMZA-2382
Project: Samza
Issue Type: Bug
Affects Versions: 1.1, 1.2
Reporter: Bharath Kumarasubramanian
Fix For: 1.3
For standby containers, we use side inputs to restore stores. Stores are
typically backed by either changelog stream or side inputs stream. For stores
backed by changelog, we use the identity(No op) side inputs processor before
writing the data to store. For stores backed by side inputs, we should be using
the user specified side inputs processor. However, we currently use identity
side inputs processor for both of these stores.
The fix is to make the side inputs processor specified in the user
configuration take precedence over the identity processor.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
