[jira] [Created] (FLINK-28267) KafkaSourceLegacyITCase.testBrokerFailure hang on azure

["Zhu Zhu (Jira)" <ji...@apache.org>]

|  ![](cid:jira-generated-image-avatar-7c03c56d-f767-4f74-bdf0-9a2efe9c24a9) |
[Zhu Zhu](https://issues.apache.org/jira/secure/ViewProfile.jspa?name=zhuzh)
**created** an issue  
---|---  
|  
---  
|  [Flink](https://issues.apache.org/jira/browse/FLINK) / [![Bug](cid:jira-
generated-image-avatar-
bfa1c1a2-235b-4abd-a49f-30f95a64df07)](https://issues.apache.org/jira/browse/FLINK-28267)
[FLINK-28267](https://issues.apache.org/jira/browse/FLINK-28267)  
---  
[KafkaSourceLegacyITCase.testBrokerFailure hang on
azure](https://issues.apache.org/jira/browse/FLINK-28267)  
| Issue Type: |  ![Bug](cid:jira-generated-image-avatar-
bfa1c1a2-235b-4abd-a49f-30f95a64df07) Bug  
---|---  
Affects Versions: |  1.16.0  
Assignee: |  Unassigned  
Components: |  Connectors / Kafka  
Created: |  28/Jun/22 02:45  
Priority: |  ![Major](cid:jira-generated-image-static-
major-07906da2-3c77-4d87-9d36-a2a5ef2ffcbe) Major  
Reporter: |  [Zhu
Zhu](https://issues.apache.org/jira/secure/ViewProfile.jspa?name=zhuzh)  
|

"main" #1 prio=5 os_prio=0 tid=0x00007f5ae000b800 nid=0x22c2 waiting on
condition [0x00007f5ae8398000]  
java.lang.Thread.State: WAITING (parking)  
at sun.misc.Unsafe.park(Native Method)

  * parking to wait for <0x00000000a5565010> (a java.util.concurrent.CompletableFuture$Signaller)  
at java.util.concurrent.locks.LockSupport.park(LockSupport.java:175)  
at
java.util.concurrent.CompletableFuture$Signaller.block(CompletableFuture.java:1707)  
at java.util.concurrent.ForkJoinPool.managedBlock(ForkJoinPool.java:3323)  
at
java.util.concurrent.CompletableFuture.waitingGet(CompletableFuture.java:1742)  
at java.util.concurrent.CompletableFuture.get(CompletableFuture.java:1908)  
at org.apache.flink.test.util.TestUtils.tryExecute(TestUtils.java:67)  
at
org.apache.flink.streaming.connectors.kafka.KafkaConsumerTestBase.runBrokerFailureTest(KafkaConsumerTestBase.java:1506)  
at
org.apache.flink.connector.kafka.source.KafkaSourceLegacyITCase.testBrokerFailure(KafkaSourceLegacyITCase.java:94)  
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)  
at
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)  
at
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)  
at java.lang.reflect.Method.invoke(Method.java:498)

[https://dev.azure.com/apache-flink/apache-
flink/_build/results?buildId=37247&view=logs&j=aa18c3f6-13b8-5f58-86bb-c1cffb239496&t=502fb6c0-30a2-5e49-c5c2-a00fa3acb203&l=41526](https://dev.azure.com/apache-
flink/apache-
flink/_build/results?buildId=37247&view=logs&j=aa18c3f6-13b8-5f58-86bb-c1cffb239496&t=502fb6c0-30a2-5e49-c5c2-a00fa3acb203&l=41526)  
  
---  
|  |  [ ![Add Comment](cid:jira-generated-image-static-comment-
icon-5616a662-125c-45ad-9caa-8f2fd7970df1)
](https://issues.apache.org/jira/browse/FLINK-28267#add-comment "Add Comment")
|  [Add Comment](https://issues.apache.org/jira/browse/FLINK-28267#add-comment
"Add Comment")  
---|---  
  
|  This message was sent by Atlassian Jira (v8.20.10#820010-sha1:ace47f9) |  |
![Atlassian logo](https://issues.apache.org/jira/images/mail/atlassian-email-
logo.png)  
---