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

Lucas Brutschy updated KAFKA-15977:
-----------------------------------
    Description: 
[https://ci-builds.apache.org/blue/rest/organizations/jenkins/pipelines/Kafka/pipelines/kafka-pr/branches/PR-14878/runs/8/nodes/11/steps/90/log/?start=0]

 

I had an unrelated PR fail with the following thread leak:

 
{code:java}
Gradle Test Run :core:test > Gradle Test Executor 95 > 
DelegationTokenEndToEndAuthorizationWithOwnerTest > executionError STARTED
kafka.api.DelegationTokenEndToEndAuthorizationWithOwnerTest.executionError 
failed, log available in 
/home/jenkins/workspace/Kafka_kafka-pr_PR-14878/core/build/reports/testOutput/kafka.api.DelegationTokenEndToEndAuthorizationWithOwnerTest.executionError.test.stdoutGradle
 Test Run :core:test > Gradle Test Executor 95 > 
DelegationTokenEndToEndAuthorizationWithOwnerTest > executionError FAILED
    org.opentest4j.AssertionFailedError: Found 1 unexpected threads during 
@AfterAll: `kafka-admin-client-thread | adminclient-483` ==> expected: <true> 
but was: <false>{code}
 

All the following tests on that error fail with initialization errors, because 
the admin client thread is never closed.

 

This is preceded by the following test failure:

 
{code:java}
Gradle Test Run :core:test > Gradle Test Executor 95 > 
DelegationTokenEndToEndAuthorizationWithOwnerTest > 
testNoDescribeProduceOrConsumeWithoutTopicDescribeAcl(String, boolean) > [1] 
quorum=kraft, isIdempotenceEnabled=true FAILED
    org.opentest4j.AssertionFailedError: expected acls:
     (principal=User:scram-user2, host=*, operation=CREATE_TOKENS, 
permissionType=ALLOW)
     (principal=User:scram-user2, host=*, operation=DESCRIBE_TOKENS, 
permissionType=ALLOW)
    but got:
 
        at 
app//org.junit.jupiter.api.AssertionUtils.fail(AssertionUtils.java:38)
        at app//org.junit.jupiter.api.Assertions.fail(Assertions.java:134)
        at app//kafka.utils.TestUtils$.waitAndVerifyAcls(TestUtils.scala:1142)
        at 
app//kafka.api.DelegationTokenEndToEndAuthorizationWithOwnerTest.$anonfun$configureSecurityAfterServersStart$1(DelegationTokenEndToEndAuthorizationWithOwnerTest.scala:71)
        at 
app//kafka.api.DelegationTokenEndToEndAuthorizationWithOwnerTest.$anonfun$configureSecurityAfterServersStart$1$adapted(DelegationTokenEndToEndAuthorizationWithOwnerTest.scala:70)
        at app//scala.collection.IterableOnceOps.foreach(IterableOnce.scala:576)
        at 
app//scala.collection.IterableOnceOps.foreach$(IterableOnce.scala:574)
        at app//scala.collection.AbstractIterable.foreach(Iterable.scala:933)
        at 
app//kafka.api.DelegationTokenEndToEndAuthorizationWithOwnerTest.configureSecurityAfterServersStart(DelegationTokenEndToEndAuthorizationWithOwnerTest.scala:70){code}
 

 

  was:
[https://ci-builds.apache.org/blue/rest/organizations/jenkins/pipelines/Kafka/pipelines/kafka-pr/branches/PR-14878/runs/8/nodes/11/steps/90/log/?start=0]

 

I had an unrelated PR fail with the following thread leak:

 

```

Gradle Test Run :core:test > Gradle Test Executor 95 > 
DelegationTokenEndToEndAuthorizationWithOwnerTest > executionError STARTED 
kafka.api.DelegationTokenEndToEndAuthorizationWithOwnerTest.executionError 
failed, log available in 
/home/jenkins/workspace/Kafka_kafka-pr_PR-14878/core/build/reports/testOutput/kafka.api.DelegationTokenEndToEndAuthorizationWithOwnerTest.executionError.test.stdout
 Gradle Test Run :core:test > Gradle Test Executor 95 > 
DelegationTokenEndToEndAuthorizationWithOwnerTest > executionError FAILED 
org.opentest4j.AssertionFailedError: Found 1 unexpected threads during 
@AfterAll: `kafka-admin-client-thread | adminclient-483` ==> expected: <true> 
but was: <false>

```

 

All the following tests on that error fail with initialization errors, because 
the admin client thread is never closed.

 

This is preceded by the following test failure:

 

```

Gradle Test Run :core:test > Gradle Test Executor 95 > 
DelegationTokenEndToEndAuthorizationWithOwnerTest > 
testNoDescribeProduceOrConsumeWithoutTopicDescribeAcl(String, boolean) > [1] 
quorum=kraft, isIdempotenceEnabled=true FAILED 
org.opentest4j.AssertionFailedError: expected acls: 
(principal=User:scram-user2, host=*, operation=CREATE_TOKENS, 
permissionType=ALLOW) (principal=User:scram-user2, host=*, 
operation=DESCRIBE_TOKENS, permissionType=ALLOW) but got: at 
app//org.junit.jupiter.api.AssertionUtils.fail(AssertionUtils.java:38) at 
app//org.junit.jupiter.api.Assertions.fail(Assertions.java:134) at 
app//kafka.utils.TestUtils$.waitAndVerifyAcls(TestUtils.scala:1142) at 
app//kafka.api.DelegationTokenEndToEndAuthorizationWithOwnerTest.$anonfun$configureSecurityAfterServersStart$1(DelegationTokenEndToEndAuthorizationWithOwnerTest.scala:71)
 at 
app//kafka.api.DelegationTokenEndToEndAuthorizationWithOwnerTest.$anonfun$configureSecurityAfterServersStart$1$adapted(DelegationTokenEndToEndAuthorizationWithOwnerTest.scala:70)
 at app//scala.collection.IterableOnceOps.foreach(IterableOnce.scala:576) at 
app//scala.collection.IterableOnceOps.foreach$(IterableOnce.scala:574) at 
app//scala.collection.AbstractIterable.foreach(Iterable.scala:933) at 
app//kafka.api.DelegationTokenEndToEndAuthorizationWithOwnerTest.configureSecurityAfterServersStart(DelegationTokenEndToEndAuthorizationWithOwnerTest.scala:70)

```

 

 


> DelegationTokenEndToEndAuthorizationWithOwnerTest leaks threads
> ---------------------------------------------------------------
>
>                 Key: KAFKA-15977
>                 URL: https://issues.apache.org/jira/browse/KAFKA-15977
>             Project: Kafka
>          Issue Type: Bug
>            Reporter: Lucas Brutschy
>            Priority: Major
>
> [https://ci-builds.apache.org/blue/rest/organizations/jenkins/pipelines/Kafka/pipelines/kafka-pr/branches/PR-14878/runs/8/nodes/11/steps/90/log/?start=0]
>  
> I had an unrelated PR fail with the following thread leak:
>  
> {code:java}
> Gradle Test Run :core:test > Gradle Test Executor 95 > 
> DelegationTokenEndToEndAuthorizationWithOwnerTest > executionError STARTED
> kafka.api.DelegationTokenEndToEndAuthorizationWithOwnerTest.executionError 
> failed, log available in 
> /home/jenkins/workspace/Kafka_kafka-pr_PR-14878/core/build/reports/testOutput/kafka.api.DelegationTokenEndToEndAuthorizationWithOwnerTest.executionError.test.stdoutGradle
>  Test Run :core:test > Gradle Test Executor 95 > 
> DelegationTokenEndToEndAuthorizationWithOwnerTest > executionError FAILED
>     org.opentest4j.AssertionFailedError: Found 1 unexpected threads during 
> @AfterAll: `kafka-admin-client-thread | adminclient-483` ==> expected: <true> 
> but was: <false>{code}
>  
> All the following tests on that error fail with initialization errors, 
> because the admin client thread is never closed.
>  
> This is preceded by the following test failure:
>  
> {code:java}
> Gradle Test Run :core:test > Gradle Test Executor 95 > 
> DelegationTokenEndToEndAuthorizationWithOwnerTest > 
> testNoDescribeProduceOrConsumeWithoutTopicDescribeAcl(String, boolean) > [1] 
> quorum=kraft, isIdempotenceEnabled=true FAILED
>     org.opentest4j.AssertionFailedError: expected acls:
>      (principal=User:scram-user2, host=*, operation=CREATE_TOKENS, 
> permissionType=ALLOW)
>      (principal=User:scram-user2, host=*, operation=DESCRIBE_TOKENS, 
> permissionType=ALLOW)
>     but got:
>  
>         at 
> app//org.junit.jupiter.api.AssertionUtils.fail(AssertionUtils.java:38)
>         at app//org.junit.jupiter.api.Assertions.fail(Assertions.java:134)
>         at app//kafka.utils.TestUtils$.waitAndVerifyAcls(TestUtils.scala:1142)
>         at 
> app//kafka.api.DelegationTokenEndToEndAuthorizationWithOwnerTest.$anonfun$configureSecurityAfterServersStart$1(DelegationTokenEndToEndAuthorizationWithOwnerTest.scala:71)
>         at 
> app//kafka.api.DelegationTokenEndToEndAuthorizationWithOwnerTest.$anonfun$configureSecurityAfterServersStart$1$adapted(DelegationTokenEndToEndAuthorizationWithOwnerTest.scala:70)
>         at 
> app//scala.collection.IterableOnceOps.foreach(IterableOnce.scala:576)
>         at 
> app//scala.collection.IterableOnceOps.foreach$(IterableOnce.scala:574)
>         at app//scala.collection.AbstractIterable.foreach(Iterable.scala:933)
>         at 
> app//kafka.api.DelegationTokenEndToEndAuthorizationWithOwnerTest.configureSecurityAfterServersStart(DelegationTokenEndToEndAuthorizationWithOwnerTest.scala:70){code}
>  
>  



--
This message was sent by Atlassian Jira
(v8.20.10#820010)

Reply via email to