[jira] [Resolved] (SAMZA-2382) User specified side input processor should take precedence over the identity processor

["Hai Lu (Jira)" <ji...@apache.org>]

     [ https://issues.apache.org/jira/browse/SAMZA-2382?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Hai Lu resolved SAMZA-2382.
---------------------------
    Resolution: Fixed

> 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
>            Priority: Major
>             Fix For: 1.3
>
>          Time Spent: 20m
>  Remaining Estimate: 0h
>
> 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)