Aditya commented on SAMZA-1612:

[~weisong44] is aware of this bug and is planning to fix it.

> 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
>            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

Reply via email to