[
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:
[email protected]
> 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)
