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)
