apex-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "ASF GitHub Bot (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (APEXMALHAR-1970) ArrayOutOfBoundary error in One_To_Many Partitioner for 0.9 kafka input operator
Date Tue, 12 Jan 2016 06:16:40 GMT

    [ https://issues.apache.org/jira/browse/APEXMALHAR-1970?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15093375#comment-15093375
] 

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_r49418985
  
    --- Diff: kafka/src/test/java/org/apache/apex/malhar/kafka/KafkaInputOperatorTest.java
---
    @@ -48,26 +48,30 @@
     
       private int totalBrokers = 0;
     
    +  private String partition = null;
     
    -
    -  @Parameterized.Parameters(name = "multi-cluster: {0}, multi-partition: {1}")
    -  public static Collection<Boolean[]> testScenario()
    +  @Parameterized.Parameters(name = "multi-cluster: {0}, multi-partition: {1}, partition:
{2}")
    +  public static Collection<Object[]> testScenario()
       {
    -    return Arrays.asList(new Boolean[][]{{true, false}, // multi cluster with single
partition
    -      {true, true}, // multi cluster with multi partitions
    -      {false, true}, // single cluster with multi partitions
    -      {false, false}, // single cluster with single partitions
    +    return Arrays.asList(new Object[][]{{true, false, "one_to_one"},// multi cluster
with single partition
    --- End diff --
    
    Add different partition strategy settings


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

Mime
View raw message