[jira] [Resolved] (SAMZA-1405) Unit tests failure in TestKafkaSystemAdminJava

["Xinyu Liu (JIRA)" <ji...@apache.org>]

     [ https://issues.apache.org/jira/browse/SAMZA-1405?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Xinyu Liu resolved SAMZA-1405.
------------------------------
    Resolution: Won't Fix

> Unit tests failure in TestKafkaSystemAdminJava
> ----------------------------------------------
>
>                 Key: SAMZA-1405
>                 URL: https://issues.apache.org/jira/browse/SAMZA-1405
>             Project: Samza
>          Issue Type: Bug
>            Reporter: Xinyu Liu
>            Priority: Minor
>
> Run into this unit test failure with JDK8/SCALA 0.12/Yarn 1.7.1:
> :samza-kafka_2.12:test
> testValidateChangelogStreamDelegatesToValidateStream FAILED
>     org.apache.samza.system.StreamValidationException: Topic validation failed for topic testChangeLogValidate because partition count 11 did not match expected partition count of 12
>         at org.apache.samza.system.kafka.KafkaSystemAdmin.$anonfun$validateStream$2(KafkaSystemAdmin.scala:476)
>         at org.apache.samza.system.kafka.KafkaSystemAdmin.$anonfun$validateStream$2$adapted(KafkaSystemAdmin.scala:468)
>         at org.apache.samza.util.ExponentialSleepStrategy.run(ExponentialSleepStrategy.scala:82)
>         at org.apache.samza.system.kafka.KafkaSystemAdmin.validateStream(KafkaSystemAdmin.scala:483)
>         at org.apache.samza.system.kafka.TestKafkaSystemAdminJava.testValidateChangelogStreamDelegatesToValidateStream(TestKafkaSystemAdminJava.java:145)
> 87 tests completed, 1 failed
> :samza-kafka_2.12:test FAILED
> Couldn't figure out where the partition count 11 comes from. Seems to be a testing env problem.



--
This message was sent by Atlassian JIRA
(v6.4.14#64029)