You are viewing a plain text version of this content. The canonical link for it is here.
Posted to jira@kafka.apache.org by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2020/04/04 02:04:00 UTC
[jira] [Commented] (KAFKA-9818) Flaky Test
RecordCollectorTest.shouldNotThrowStreamsExceptionOnSubsequentCallIfASendFailsWithContinueExceptionHandler
[ https://issues.apache.org/jira/browse/KAFKA-9818?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17075006#comment-17075006 ]
ASF GitHub Bot commented on KAFKA-9818:
---------------------------------------
mjsax commented on pull request #8423: KAFKA-9818: improve error message to debug test
URL: https://github.com/apache/kafka/pull/8423
The error message on the ticket is not helpful. To figure out why the test fails, we need to improve the error message first and wait until it fails again.
\cc @ableegoldman @vvcephei
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
> Flaky Test RecordCollectorTest.shouldNotThrowStreamsExceptionOnSubsequentCallIfASendFailsWithContinueExceptionHandler
> ---------------------------------------------------------------------------------------------------------------------
>
> Key: KAFKA-9818
> URL: https://issues.apache.org/jira/browse/KAFKA-9818
> Project: Kafka
> Issue Type: Bug
> Components: streams
> Reporter: Sophie Blee-Goldman
> Assignee: Matthias J. Sax
> Priority: Major
> Labels: flaky-test
>
> h3. Error Message
> java.lang.AssertionError
> h3. Stacktrace
> java.lang.AssertionError at org.junit.Assert.fail(Assert.java:87) at org.junit.Assert.assertTrue(Assert.java:42) at org.junit.Assert.assertTrue(Assert.java:53) at org.apache.kafka.streams.processor.internals.RecordCollectorTest.shouldNotThrowStreamsExceptionOnSubsequentCallIfASendFailsWithContinueExceptionHandler(RecordCollectorTest.java:521) at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) at java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) at java.base/java.lang.reflect.Method.invoke(Method.java:566) at org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:59) at org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12) at org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:56) at org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:17) at org.junit.internal.runners.statements.RunBefores.evaluate(RunBefores.java:26) at org.junit.internal.runners.statements.RunAfters.evaluate(RunAfters.java:27) at org.junit.runners.ParentRunner$3.evaluate(ParentRunner.java:306) at org.junit.runners.BlockJUnit4ClassRunner$1.evaluate(BlockJUnit4ClassRunner.java:100) at org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:366) at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:103) at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:63) at org.junit.runners.ParentRunner$4.run(ParentRunner.java:331) at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:79) at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:329) at org.junit.runners.ParentRunner.access$100(ParentRunner.java:66) at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:293) at org.junit.runners.ParentRunner$3.evaluate(ParentRunner.java:306) at org.junit.runners.ParentRunner.run(ParentRunner.java:413) at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecutor.runTestClass(JUnitTestClassExecutor.java:110) at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecutor.execute(JUnitTestClassExecutor.java:58) at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecutor.execute(JUnitTestClassExecutor.java:38) at org.gradle.api.internal.tasks.testing.junit.AbstractJUnitTestClassProcessor.processTestClass(AbstractJUnitTestClassProcessor.java:62) at org.gradle.api.internal.tasks.testing.SuiteTestClassProcessor.processTestClass(SuiteTestClassProcessor.java:51) at jdk.internal.reflect.GeneratedMethodAccessor20.invoke(Unknown Source) at java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) at java.base/java.lang.reflect.Method.invoke(Method.java:566) at org.gradle.internal.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:36) at org.gradle.internal.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:24) at org.gradle.internal.dispatch.ContextClassLoaderDispatch.dispatch(ContextClassLoaderDispatch.java:33) at org.gradle.internal.dispatch.ProxyDispatchAdapter$DispatchingInvocationHandler.invoke(ProxyDispatchAdapter.java:94) at com.sun.proxy.$Proxy5.processTestClass(Unknown Source) at org.gradle.api.internal.tasks.testing.worker.TestWorker.processTestClass(TestWorker.java:118) at jdk.internal.reflect.GeneratedMethodAccessor19.invoke(Unknown Source) at java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) at java.base/java.lang.reflect.Method.invoke(Method.java:566) at org.gradle.internal.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:36) at org.gradle.internal.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:24) at org.gradle.internal.remote.internal.hub.MessageHubBackedObjectConnection$DispatchWrapper.dispatch(MessageHubBackedObjectConnection.java:182) at org.gradle.internal.remote.internal.hub.MessageHubBackedObjectConnection$DispatchWrapper.dispatch(MessageHubBackedObjectConnection.java:164) at org.gradle.internal.remote.internal.hub.MessageHub$Handler.run(MessageHub.java:412) at org.gradle.internal.concurrent.ExecutorPolicy$CatchAndRecordFailures.onExecute(ExecutorPolicy.java:64) at org.gradle.internal.concurrent.ManagedExecutorImpl$1.run(ManagedExecutorImpl.java:48) at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128) at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) at org.gradle.internal.concurrent.ThreadFactoryImpl$ManagedThreadRunnable.run(ThreadFactoryImpl.java:56) at java.base/java.lang.Thread.run(Thread.java:834)
> h3. Standard Output
> [2020-04-03 21:02:04,472] WARN [AdminClient clientId=adminclient-91] Connection to node -1 (localhost/127.0.0.1:8080) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient:762) [2020-04-03 21:02:04,479] WARN [AdminClient clientId=adminclient-27] Connection to node -1 (localhost/127.0.0.1:8080) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient:762) [2020-04-03 21:02:04,481] WARN [AdminClient clientId=adminclient-18] Connection to node -1 (localhost/127.0.0.1:8080) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient:762) [2020-04-03 21:02:04,483] WARN [AdminClient clientId=adminclient-73] Connection to node -1 (localhost/127.0.0.1:8080) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient:762) [2020-04-03 21:02:04,484] WARN [AdminClient clientId=adminclient-80] Connection to node -1 (localhost/127.0.0.1:8080) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient:762) [2020-04-03 21:02:04,485] ERROR test Error encountered sending record to topic topic for task 0_0 due to: java.lang.Exception Exception handler choose to CONTINUE processing in spite of this error but written offsets would not be recorded. (org.apache.kafka.streams.processor.internals.RecordCollectorImpl:220) [2020-04-03 21:02:04,485] WARN [AdminClient clientId=adminclient-28] Connection to node -1 (localhost/127.0.0.1:8080) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient:762) [2020-04-03 21:02:04,489] ERROR test Error encountered sending record to topic topic for task 0_0 due to: org.apache.kafka.common.errors.ProducerFencedException: KABOOM! Written offsets would not be recorded and no more records would be sent since the producer is fenced, indicating the task may be migrated out (org.apache.kafka.streams.processor.internals.RecordCollectorImpl:220) [2020-04-03 21:02:04,491] WARN [AdminClient clientId=adminclient-63] Connection to node -1 (localhost/127.0.0.1:8080) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient:762) [2020-04-03 21:02:04,493] WARN [AdminClient clientId=adminclient-19] Connection to node -1 (localhost/127.0.0.1:8080) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient:762) [2020-04-03 21:02:04,495] WARN [AdminClient clientId=adminclient-81] Connection to node -1 (localhost/127.0.0.1:8080) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient:762) [2020-04-03 21:02:04,495] ERROR test Error encountered sending record to topic topic for task 0_0 due to: org.apache.kafka.common.errors.AuthenticationException: KABOOM! Written offsets would not be recorded and no more records would be sent since this is a fatal error. (org.apache.kafka.streams.processor.internals.RecordCollectorImpl:220) [2020-04-03 21:02:04,496] WARN [AdminClient clientId=adminclient-29] Connection to node -1 (localhost/127.0.0.1:8080) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient:762) [2020-04-03 21:02:04,498] ERROR test Error encountered sending record to topic topic for task 0_0 due to: org.apache.kafka.common.KafkaException: KABOOM! Exception handler choose to FAIL the processing, no more records would be sent. (org.apache.kafka.streams.processor.internals.RecordCollectorImpl:220) [2020-04-03 21:02:04,502] WARN [AdminClient clientId=adminclient-64] Connection to node -1 (localhost/127.0.0.1:8080) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient:762) [2020-04-03 21:02:04,511] WARN [AdminClient clientId=adminclient-76] Connection to node -1 (localhost/127.0.0.1:8080) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient:762) [2020-04-03 21:02:04,511] WARN [AdminClient clientId=adminclient-31] Connection to node -1 (localhost/127.0.0.1:8080) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient:762) [2020-04-03 21:02:04,518] WARN [AdminClient clientId=adminclient-84] Connection to node -1 (localhost/127.0.0.1:8080) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient:762) [2020-04-03 21:02:04,518] WARN [AdminClient clientId=adminclient-32] Connection to node -1 (localhost/127.0.0.1:8080) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient:762) [2020-04-03 21:02:04,520] WARN [AdminClient clientId=adminclient-44] Connection to node -1 (localhost/127.0.0.1:8080) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient:762) [2020-04-03 21:04:30,863] ERROR test Error encountered sending record to topic topic for task 0_0 due to: java.lang.Exception Exception handler choose to CONTINUE processing in spite of this error but written offsets would not be recorded. (org.apache.kafka.streams.processor.internals.RecordCollectorImpl:220) [2020-04-03 21:04:30,887] ERROR test Error encountered sending record to topic topic for task 0_0 due to: java.lang.Exception Exception handler choose to CONTINUE processing in spite of this error but written offsets would not be recorded. (org.apache.kafka.streams.processor.internals.RecordCollectorImpl:220)
--
This message was sent by Atlassian Jira
(v8.3.4#803005)