[
https://issues.apache.org/jira/browse/SAMZA-1612?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ahmed Abdul Hamid resolved SAMZA-1612.
--------------------------------------
Resolution: Fixed
> 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
> Assignee: Ahmed Abdul Hamid
> Priority: Major
>
> 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)
