[jira] [Created] (SAMZA-1842) Need consistent logic to calculate input, output, and intermediate streams in high and low-level API applications

["Yi Pan (Data Infrastructure) (JIRA)" <ji...@apache.org>]

Yi Pan (Data Infrastructure) created SAMZA-1842:
---------------------------------------------------

             Summary: Need consistent logic to calculate input, output, and intermediate streams in high and low-level API applications
                 Key: SAMZA-1842
                 URL: https://issues.apache.org/jira/browse/SAMZA-1842
             Project: Samza
          Issue Type: Improvement
            Reporter: Yi Pan (Data Infrastructure)


Currently, the input and output descriptors for input, output, and intermediate streams are explicitly set in TaskApplication, while only the external input and output descriptors are created and set in high-level StreamApplication.

This creates a discrepancy in how we compute the input, output, and intermediate streams in the planner for TaskApplication and StreamApplication (i.e. intermediate streams don't have descriptors in StreamApplication, but have both input and output descriptors in TaskApplication). We should make the logic consistent between TaskApplication and StreamApplication. 



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)