Aditya created SAMZA-1612:
-----------------------------
Summary: Stream-table join: Number of partitions deduced for
partitionBy for the stream to be joined does not take into account the
partitions in the table
Key: SAMZA-1612
URL: https://issues.apache.org/jira/browse/SAMZA-1612
Project: Samza
Issue Type: Bug
Reporter: Aditya
While creating intermediate streams via partitionBy operator, ExecutionPlanner
deduces the number of partitions for the intermediate partitions by looking at
the sources, sinks and any reachable joins in the DAG. For stream-table join
(local table) with the stream being partitioned and then joined with the table,
the stream behind the table is not reachable in the DAG from the stream that
needs to be joined and hence the number of partitions in the table are
incorrectly not taken into account.
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
