[ https://issues.apache.org/jira/browse/FLINK-26980?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Martijn Visser closed FLINK-26980. ---------------------------------- Fix Version/s: 1.16.0 Resolution: Fixed > PulsarUnorderedSourceReaderTest hang on azure > --------------------------------------------- > > Key: FLINK-26980 > URL: https://issues.apache.org/jira/browse/FLINK-26980 > Project: Flink > Issue Type: Sub-task > Components: Connectors / Pulsar > Affects Versions: 1.16.0 > Reporter: Yun Gao > Priority: Major > Labels: test-stability > Fix For: 1.16.0 > > > {code:java} > 2022-03-30T13:04:22.7440894Z "main" #1 prio=5 os_prio=0 > tid=0x00007ff99000b000 nid=0x207d waiting on condition [0x00007ff9991d3000] > 2022-03-30T13:04:22.7441395Z java.lang.Thread.State: WAITING (parking) > 2022-03-30T13:04:22.7441786Z at sun.misc.Unsafe.park(Native Method) > 2022-03-30T13:04:22.7442444Z - parking to wait for <0x00000000f7173b40> (a > java.util.concurrent.CompletableFuture$Signaller) > 2022-03-30T13:04:22.7443345Z at > java.util.concurrent.locks.LockSupport.park(LockSupport.java:175) > 2022-03-30T13:04:22.7443991Z at > java.util.concurrent.CompletableFuture$Signaller.block(CompletableFuture.java:1707) > 2022-03-30T13:04:22.7444607Z at > java.util.concurrent.ForkJoinPool.managedBlock(ForkJoinPool.java:3323) > 2022-03-30T13:04:22.7445207Z at > java.util.concurrent.CompletableFuture.waitingGet(CompletableFuture.java:1742) > 2022-03-30T13:04:22.7445802Z at > java.util.concurrent.CompletableFuture.get(CompletableFuture.java:1908) > 2022-03-30T13:04:22.7446435Z at > org.apache.pulsar.broker.systopic.SystemTopicClientBase.close(SystemTopicClientBase.java:100) > 2022-03-30T13:04:22.7447212Z at > org.apache.pulsar.broker.service.SystemTopicBaseTxnBufferSnapshotService.close(SystemTopicBaseTxnBufferSnapshotService.java:83) > 2022-03-30T13:04:22.7447938Z at > org.apache.pulsar.broker.PulsarService.closeAsync(PulsarService.java:449) > 2022-03-30T13:04:22.7448501Z at > org.apache.pulsar.broker.PulsarService.close(PulsarService.java:350) > 2022-03-30T13:04:22.7449168Z at > org.apache.flink.connector.pulsar.testutils.runtime.mock.PulsarMockRuntime.tearDown(PulsarMockRuntime.java:67) > 2022-03-30T13:04:22.7449932Z at > org.apache.flink.connector.pulsar.testutils.PulsarTestEnvironment.afterAll(PulsarTestEnvironment.java:102) > 2022-03-30T13:04:22.7450729Z at > org.junit.jupiter.engine.descriptor.ClassBasedTestDescriptor.lambda$invokeAfterAllCallbacks$16(ClassBasedTestDescriptor.java:447) > 2022-03-30T13:04:22.7451485Z at > org.junit.jupiter.engine.descriptor.ClassBasedTestDescriptor$$Lambda$1403/485877014.execute(Unknown > Source) > 2022-03-30T13:04:22.7452178Z at > org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73) > 2022-03-30T13:04:22.7453169Z at > org.junit.jupiter.engine.descriptor.ClassBasedTestDescriptor.lambda$invokeAfterAllCallbacks$17(ClassBasedTestDescriptor.java:447) > 2022-03-30T13:04:22.7453937Z at > org.junit.jupiter.engine.descriptor.ClassBasedTestDescriptor$$Lambda$459/1334008558.accept(Unknown > Source) > 2022-03-30T13:04:22.7454508Z at > java.util.ArrayList.forEach(ArrayList.java:1259) > 2022-03-30T13:04:22.7455157Z at > org.junit.jupiter.engine.descriptor.ClassBasedTestDescriptor.invokeAfterAllCallbacks(ClassBasedTestDescriptor.java:447) > 2022-03-30T13:04:22.7455928Z at > org.junit.jupiter.engine.descriptor.ClassBasedTestDescriptor.after(ClassBasedTestDescriptor.java:229) > 2022-03-30T13:04:22.7456645Z at > org.junit.jupiter.engine.descriptor.ClassBasedTestDescriptor.after(ClassBasedTestDescriptor.java:80) > 2022-03-30T13:04:22.7457386Z at > org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$7(NodeTestTask.java:161) > 2022-03-30T13:04:22.7458173Z at > org.junit.platform.engine.support.hierarchical.NodeTestTask$$Lambda$319/1589876871.execute(Unknown > Source) > 2022-03-30T13:04:22.7458864Z at > org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73) > 2022-03-30T13:04:22.7459604Z at > org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$8(NodeTestTask.java:161) > 2022-03-30T13:04:22.7460308Z at > org.junit.platform.engine.support.hierarchical.NodeTestTask$$Lambda$306/2123533871.invoke(Unknown > Source) > 2022-03-30T13:04:22.7460995Z at > org.junit.platform.engine.support.hierarchical.Node.around(Node.java:137) > 2022-03-30T13:04:22.7461674Z at > org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$9(NodeTestTask.java:139) > 2022-03-30T13:04:22.7462377Z at > org.junit.platform.engine.support.hierarchical.NodeTestTask$$Lambda$305/1406253491.execute(Unknown > Source) > 2022-03-30T13:04:22.7463351Z at > org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73) > 2022-03-30T13:04:22.7464091Z at > org.junit.platform.engine.support.hierarchical.NodeTestTask.executeRecursively(NodeTestTask.java:138) > 2022-03-30T13:04:22.7464778Z at > org.junit.platform.engine.support.hierarchical.NodeTestTask.execute(NodeTestTask.java:95) > 2022-03-30T13:04:22.7465496Z at > org.junit.platform.engine.support.hierarchical.SameThreadHierarchicalTestExecutorService$$Lambda$311/848097505.accept(Unknown > Source) > 2022-03-30T13:04:22.7466119Z at > java.util.ArrayList.forEach(ArrayList.java:1259) > 2022-03-30T13:04:22.7466837Z at > org.junit.platform.engine.support.hierarchical.SameThreadHierarchicalTestExecutorService.invokeAll(SameThreadHierarchicalTestExecutorService.java:41) > 2022-03-30T13:04:22.7467690Z at > org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$6(NodeTestTask.java:155) > 2022-03-30T13:04:22.7468377Z at > org.junit.platform.engine.support.hierarchical.NodeTestTask$$Lambda$307/16148478.execute(Unknown > Source) > 2022-03-30T13:04:22.7469061Z at > org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73) > 2022-03-30T13:04:22.7469803Z at > org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$8(NodeTestTask.java:141) > 2022-03-30T13:04:22.7470504Z at > org.junit.platform.engine.support.hierarchical.NodeTestTask$$Lambda$306/2123533871.invoke(Unknown > Source) > 2022-03-30T13:04:22.7471121Z at > org.junit.platform.engine.support.hierarchical.Node.around(Node.java:137) > 2022-03-30T13:04:22.7471801Z at > org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$9(NodeTestTask.java:139) > 2022-03-30T13:04:22.7472484Z at > org.junit.platform.engine.support.hierarchical.NodeTestTask$$Lambda$305/1406253491.execute(Unknown > Source) > 2022-03-30T13:04:22.7473416Z at > org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73) > 2022-03-30T13:04:22.7474141Z at > org.junit.platform.engine.support.hierarchical.NodeTestTask.executeRecursively(NodeTestTask.java:138) > 2022-03-30T13:04:22.7474836Z at > org.junit.platform.engine.support.hierarchical.NodeTestTask.execute(NodeTestTask.java:95) > 2022-03-30T13:04:22.7475635Z at > org.junit.platform.engine.support.hierarchical.SameThreadHierarchicalTestExecutorService.submit(SameThreadHierarchicalTestExecutorService.java:35) > 2022-03-30T13:04:22.7476489Z at > org.junit.platform.engine.support.hierarchical.HierarchicalTestExecutor.execute(HierarchicalTestExecutor.java:57) > 2022-03-30T13:04:22.7477268Z at > org.junit.platform.engine.support.hierarchical.HierarchicalTestEngine.execute(HierarchicalTestEngine.java:54) > 2022-03-30T13:04:22.7478020Z at > org.junit.platform.launcher.core.EngineExecutionOrchestrator.execute(EngineExecutionOrchestrator.java:107) > 2022-03-30T13:04:22.7478738Z at > org.junit.platform.launcher.core.EngineExecutionOrchestrator.execute(EngineExecutionOrchestrator.java:88) > 2022-03-30T13:04:22.7479494Z at > org.junit.platform.launcher.core.EngineExecutionOrchestrator.lambda$execute$0(EngineExecutionOrchestrator.java:54) > 2022-03-30T13:04:22.7480297Z at > org.junit.platform.launcher.core.EngineExecutionOrchestrator$$Lambda$273/2001115307.accept(Unknown > Source) > 2022-03-30T13:04:22.7481031Z at > org.junit.platform.launcher.core.EngineExecutionOrchestrator.withInterceptedStreams(EngineExecutionOrchestrator.java:67) > 2022-03-30T13:04:22.7481803Z at > org.junit.platform.launcher.core.EngineExecutionOrchestrator.execute(EngineExecutionOrchestrator.java:52) > 2022-03-30T13:04:22.7482567Z at > org.junit.platform.launcher.core.DefaultLauncher.execute(DefaultLauncher.java:114) > 2022-03-30T13:04:22.7483448Z at > org.junit.platform.launcher.core.DefaultLauncher.execute(DefaultLauncher.java:86) > 2022-03-30T13:04:22.7484166Z at > org.junit.platform.launcher.core.DefaultLauncherSession$DelegatingLauncher.execute(DefaultLauncherSession.java:86) > 2022-03-30T13:04:22.7484926Z at > org.junit.platform.launcher.core.SessionPerRequestLauncher.execute(SessionPerRequestLauncher.java:53) > 2022-03-30T13:04:22.7485656Z at > org.apache.maven.surefire.junitplatform.JUnitPlatformProvider.execute(JUnitPlatformProvider.java:188) > 2022-03-30T13:04:22.7486399Z at > org.apache.maven.surefire.junitplatform.JUnitPlatformProvider.invokeAllTests(JUnitPlatformProvider.java:154) > 2022-03-30T13:04:22.7487133Z at > org.apache.maven.surefire.junitplatform.JUnitPlatformProvider.invoke(JUnitPlatformProvider.java:128) > 2022-03-30T13:04:22.7487818Z at > org.apache.maven.surefire.booter.ForkedBooter.runSuitesInProcess(ForkedBooter.java:428) > 2022-03-30T13:04:22.7488430Z at > org.apache.maven.surefire.booter.ForkedBooter.execute(ForkedBooter.java:162) > 2022-03-30T13:04:22.7489028Z at > org.apache.maven.surefire.booter.ForkedBooter.run(ForkedBooter.java:562) > 2022-03-30T13:04:22.7489615Z at > org.apache.maven.surefire.booter.ForkedBooter.main(ForkedBooter.java:548) > 2022-03-30T13:04:22.7489888Z > {code} > https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=33945&view=logs&j=fc5181b0-e452-5c8f-68de-1097947f6483&t=995c650b-6573-581c-9ce6-7ad4cc038461&l=28511 -- This message was sent by Atlassian Jira (v8.20.10#820010)