[
https://issues.apache.org/jira/browse/APEXMALHAR-1970?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15093372#comment-15093372
]
ASF GitHub Bot commented on APEXMALHAR-1970:
--------------------------------------------
Github user siyuanh commented on a diff in the pull request:
https://github.com/apache/incubator-apex-malhar/pull/167#discussion_r49418958
--- Diff:
kafka/src/main/java/org/apache/apex/malhar/kafka/OneToManyPartitioner.java ---
@@ -52,8 +52,8 @@ public OneToManyPartitioner(String[] clusters, String[]
topics, AbstractKafkaInp
for (Map.Entry<String, List<PartitionInfo>> topicPartition :
clusterMap.getValue().entrySet()) {
for (PartitionInfo pif : topicPartition.getValue()) {
int index = i++ % partitionCount;
- if (eachPartitionAssignment.get(index) == null) {
--- End diff --
This will throw ArrayIndexOutOfBoundaryException even the space is
pre-allocated but not assigned
> ArrayOutOfBoundary error in One_To_Many Partitioner for 0.9 kafka input
> operator
> --------------------------------------------------------------------------------
>
> Key: APEXMALHAR-1970
> URL: https://issues.apache.org/jira/browse/APEXMALHAR-1970
> Project: Apache Apex Malhar
> Issue Type: Bug
> Reporter: Siyuan Hua
> Assignee: Siyuan Hua
> Fix For: 3.4.0
>
>
> Should have the same support as found in the 0.8.x implementation.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
