Mailing-List: contact dev-help@kafka.apache.org; run by ezmlm
Precedence: bulk
Reply-To: dev@kafka.apache.org
Date: Fri, 17 Mar 2017 05:34:41 +0000 (UTC)
From: "Guozhang Wang (JIRA)" <jira@apache.org>
To: dev@kafka.apache.org
Message-ID: <JIRA.13050243.1489232293000.45856.1489728881670@Atlassian.JIRA>
In-Reply-To: <JIRA.13050243.1489232293000@Atlassian.JIRA>
References: <JIRA.13050243.1489232293000@Atlassian.JIRA> <JIRA.13050243.1489232293620@jira-lw-us.apache.org>
Subject: =?utf-8?Q?[jira]_[Resolved]_(KAFKA-4885)_processstreamwithcachedst?=
 =?utf-8?Q?atestore=EF=BB=BF_and_other_streams_?=
 =?utf-8?Q?benchmarks_fail_occasionally?=
MIME-Version: 1.0
Content-Type: text/plain; charset=utf-8
Content-Transfer-Encoding: quoted-printable
archived-at: Fri, 17 Mar 2017 05:34:47 -0000


     [ https://issues.apache.org/jira/browse/KAFKA-4885?page=3Dcom.atlassia=
n.jira.plugin.system.issuetabpanels:all-tabpanel ]

Guozhang Wang resolved KAFKA-4885.
----------------------------------
    Resolution: Fixed

Issue resolved by pull request 2693
[https://github.com/apache/kafka/pull/2693]

> processstreamwithcachedstatestore=EF=BB=BF and other streams benchmarks f=
ail occasionally
> -------------------------------------------------------------------------=
--------
>
>                 Key: KAFKA-4885
>                 URL: https://issues.apache.org/jira/browse/KAFKA-4885
>             Project: Kafka
>          Issue Type: Bug
>          Components: streams
>    Affects Versions: 0.10.2.0
>            Reporter: Eno Thereska
>            Assignee: Guozhang Wang
>             Fix For: 0.11.0.0
>
>
> test_id:    kafkatest.benchmarks.streams.streams_simple_benchmark_test.St=
reamsSimpleBenchmarkTest.test_simple_benchmark.test=3Dprocessstreamwithcach=
edstatestore.scale=3D2
> status:     FAIL
> run time:   14 minutes 58.069 seconds
>     Streams Test process on ubuntu@worker5 took too long to exit
> Traceback (most recent call last):
>   File "/var/lib/jenkins/workspace/system-test-kafka/kafka/venv/local/lib=
/python2.7/site-packages/ducktape-0.6.0-py2.7.egg/ducktape/tests/runner_cli=
ent.py", line 123, in run
>     data =3D self.run_test()
>   File "/var/lib/jenkins/workspace/system-test-kafka/kafka/venv/local/lib=
/python2.7/site-packages/ducktape-0.6.0-py2.7.egg/ducktape/tests/runner_cli=
ent.py", line 176, in run_test
>     return self.test_context.function(self.test)
>   File "/var/lib/jenkins/workspace/system-test-kafka/kafka/venv/local/lib=
/python2.7/site-packages/ducktape-0.6.0-py2.7.egg/ducktape/mark/_mark.py", =
line 321, in wrapper
>     return functools.partial(f, *args, **kwargs)(*w_args, **w_kwargs)
>   File "/var/lib/jenkins/workspace/system-test-kafka/kafka/tests/kafkates=
t/benchmarks/streams/streams_simple_benchmark_test.py", line 86, in test_si=
mple_benchmark
>     self.driver[num].wait()
>   File "/var/lib/jenkins/workspace/system-test-kafka/kafka/tests/kafkates=
t/services/streams.py", line 102, in wait
>     self.wait_node(node, timeout_sec)
>   File "/var/lib/jenkins/workspace/system-test-kafka/kafka/tests/kafkates=
t/services/streams.py", line 106, in wait_node
>     wait_until(lambda: not node.account.alive(pid), timeout_sec=3Dtimeout=
_sec, err_msg=3D"Streams Test process on " + str(node.account) + " took too=
 long to exit")
>   File "/var/lib/jenkins/workspace/system-test-kafka/kafka/venv/local/lib=
/python2.7/site-packages/ducktape-0.6.0-py2.7.egg/ducktape/utils/util.py", =
line 36, in wait_until
>     raise TimeoutError(err_msg)
> TimeoutError: Streams Test process on ubuntu@worker5 took too long to exi=
t
> The log contains several lines like:
> [2017-03-11 04:52:59,080] DEBUG Attempt to heartbeat failed for group sim=
ple-benchmark-streams-with-storetrue since it is rebalancing. (org.apache.k=
afka.clients.consumer.internals.AbstractCoordinator)
> [2017-03-11 04:53:01,987] DEBUG Sending Heartbeat request for group simpl=
e-benchmark-streams-with-storetrue to coordinator worker10:9092 (id: 214748=
3646 rack: null) (org.apache.kafka.clients.consumer.internals.AbstractCoord=
inator)
> [2017-03-11 04:53:02,088] DEBUG Attempt to heartbeat failed for group sim=
ple-benchmark-streams-with-storetrue since it is rebalancing. (org.apache.k=
afka.clients.consumer.internals.AbstractCoordinator)
> [2017-03-11 04:53:04,995] DEBUG Sending Heartbeat request for group simpl=
e-benchmark-streams-with-storetrue to coordinator worker10:9092 (id: 214748=
3646 rack: null) (org.apache.kafka.clients.consumer.internals.AbstractCoord=
inator)
> Other tests that fail the same way include:
> test_id:    kafkatest.benchmarks.streams.streams_simple_benchmark_test.St=
reamsSimpleBenchmarkTest.test_simple_benchmark.test=3Dcount.scale=3D2
> test_id:    kafkatest.benchmarks.streams.streams_simple_benchmark_test.St=
reamsSimpleBenchmarkTest.test_simple_benchmark.test=3Dprocessstreamwithsink=
.scale=3D1
> test_id:    kafkatest.tests.streams.streams_bounce_test.StreamsBounceTest=
.test_bounce


--
This message was sent by Atlassian JIRA
(v6.3.15#6346)