[ https://issues.apache.org/jira/browse/FLINK-25815?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17515175#comment-17515175 ]
Piotr Nowojski commented on FLINK-25815: ---------------------------------------- I've seen the same issue as reported by Matthias here: https://dev.azure.com/pnowojski/Flink/_build/results?buildId=642&view=logs&j=f3dc9b18-b77a-55c1-591e-264c46fe44d1&t=2d3cd81e-1c37-5c31-0ee4-f5d5cdb9324d in a branch that was basing on the latest master. > PulsarSourceITCase.testTaskManagerFailure failed on azure due to timeout > ------------------------------------------------------------------------ > > Key: FLINK-25815 > URL: https://issues.apache.org/jira/browse/FLINK-25815 > Project: Flink > Issue Type: Bug > Components: Connectors / Pulsar > Affects Versions: 1.15.0 > Reporter: Yun Gao > Priority: Major > Labels: test-stability > > {code:java} > 022-01-25T06:46:46.5112869Z Jan 25 06:46:46 [ERROR] > org.apache.flink.connector.pulsar.source.PulsarSourceITCase.testTaskManagerFailure(TestEnvironment, > DataStreamSourceExternalContext, ClusterControllable)[2] Time elapsed: > 74.695 s <<< ERROR! > 2022-01-25T06:46:46.5116004Z Jan 25 06:46:46 > org.apache.pulsar.client.api.PulsarClientException$TimeoutException: The > producer mock-pulsar-wpuQ1c-1-19 can not send message to the topic > persistent://public/default/pulsar-multiple-topic-0-bhxPrLuS-partition-0 > within given timeout : createdAt 30002788101 ns ago, firstSentAt > 2488196546830074 ns ago, lastSentAt 30002746662 ns ago, retryCount 1 > 2022-01-25T06:46:46.5117924Z Jan 25 06:46:46 at > org.apache.pulsar.client.api.PulsarClientException.unwrap(PulsarClientException.java:961) > 2022-01-25T06:46:46.5143390Z Jan 25 06:46:46 at > org.apache.pulsar.client.impl.TypedMessageBuilderImpl.send(TypedMessageBuilderImpl.java:91) > 2022-01-25T06:46:46.5145068Z Jan 25 06:46:46 at > org.apache.flink.connector.pulsar.testutils.runtime.PulsarRuntimeOperator.sendMessages(PulsarRuntimeOperator.java:178) > 2022-01-25T06:46:46.5146447Z Jan 25 06:46:46 at > org.apache.flink.connector.pulsar.testutils.runtime.PulsarRuntimeOperator.sendMessages(PulsarRuntimeOperator.java:167) > 2022-01-25T06:46:46.5147666Z Jan 25 06:46:46 at > org.apache.flink.connector.pulsar.testutils.PulsarPartitionDataWriter.writeRecords(PulsarPartitionDataWriter.java:41) > 2022-01-25T06:46:46.5148974Z Jan 25 06:46:46 at > org.apache.flink.connector.testframe.testsuites.SourceTestSuiteBase.testTaskManagerFailure(SourceTestSuiteBase.java:328) > 2022-01-25T06:46:46.5150053Z Jan 25 06:46:46 at > sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) > 2022-01-25T06:46:46.5150969Z Jan 25 06:46:46 at > sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) > 2022-01-25T06:46:46.5152137Z Jan 25 06:46:46 at > sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) > 2022-01-25T06:46:46.5153083Z Jan 25 06:46:46 at > java.lang.reflect.Method.invoke(Method.java:498) > 2022-01-25T06:46:46.5154039Z Jan 25 06:46:46 at > org.junit.platform.commons.util.ReflectionUtils.invokeMethod(ReflectionUtils.java:725) > 2022-01-25T06:46:46.5155081Z Jan 25 06:46:46 at > org.junit.jupiter.engine.execution.MethodInvocation.proceed(MethodInvocation.java:60) > 2022-01-25T06:46:46.5156548Z Jan 25 06:46:46 at > org.junit.jupiter.engine.execution.InvocationInterceptorChain$ValidatingInvocation.proceed(InvocationInterceptorChain.java:131) > 2022-01-25T06:46:46.5157869Z Jan 25 06:46:46 at > org.junit.jupiter.engine.extension.TimeoutExtension.intercept(TimeoutExtension.java:149) > 2022-01-25T06:46:46.5158984Z Jan 25 06:46:46 at > org.junit.jupiter.engine.extension.TimeoutExtension.interceptTestableMethod(TimeoutExtension.java:140) > 2022-01-25T06:46:46.5160169Z Jan 25 06:46:46 at > org.junit.jupiter.engine.extension.TimeoutExtension.interceptTestTemplateMethod(TimeoutExtension.java:92) > 2022-01-25T06:46:46.5161460Z Jan 25 06:46:46 at > org.junit.jupiter.engine.execution.ExecutableInvoker$ReflectiveInterceptorCall.lambda$ofVoidMethod$0(ExecutableInvoker.java:115) > 2022-01-25T06:46:46.5162858Z Jan 25 06:46:46 at > org.junit.jupiter.engine.execution.ExecutableInvoker.lambda$invoke$0(ExecutableInvoker.java:105) > 2022-01-25T06:46:46.5164100Z Jan 25 06:46:46 at > org.junit.jupiter.engine.execution.InvocationInterceptorChain$InterceptedInvocation.proceed(InvocationInterceptorChain.java:106) > 2022-01-25T06:46:46.5165365Z Jan 25 06:46:46 at > org.junit.jupiter.engine.execution.InvocationInterceptorChain.proceed(InvocationInterceptorChain.java:64) > 2022-01-25T06:46:46.5166709Z Jan 25 06:46:46 at > org.junit.jupiter.engine.execution.InvocationInterceptorChain.chainAndInvoke(InvocationInterceptorChain.java:45) > 2022-01-25T06:46:46.5167925Z Jan 25 06:46:46 at > org.junit.jupiter.engine.execution.InvocationInterceptorChain.invoke(InvocationInterceptorChain.java:37) > 2022-01-25T06:46:46.5169043Z Jan 25 06:46:46 at > org.junit.jupiter.engine.execution.ExecutableInvoker.invoke(ExecutableInvoker.java:104) > 2022-01-25T06:46:46.5170296Z Jan 25 06:46:46 at > org.junit.jupiter.engine.execution.ExecutableInvoker.invoke(ExecutableInvoker.java:98) > 2022-01-25T06:46:46.5171457Z Jan 25 06:46:46 at > org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.lambda$invokeTestMethod$7(TestMethodTestDescriptor.java:214) > 2022-01-25T06:46:46.5172734Z Jan 25 06:46:46 at > org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73) > 2022-01-25T06:46:46.5173875Z Jan 25 06:46:46 at > org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.invokeTestMethod(TestMethodTestDescriptor.java:210) > 2022-01-25T06:46:46.5175048Z Jan 25 06:46:46 at > org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.execute(TestMethodTestDescriptor.java:135) > 2022-01-25T06:46:46.5176358Z Jan 25 06:46:46 at > org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.execute(TestMethodTestDescriptor.java:66) > 2022-01-25T06:46:46.5177782Z Jan 25 06:46:46 at > org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$6(NodeTestTask.java:151) > 2022-01-25T06:46:46.5178983Z Jan 25 06:46:46 at > org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73) > 2022-01-25T06:46:46.5180139Z Jan 25 06:46:46 at > org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$8(NodeTestTask.java:141) > 2022-01-25T06:46:46.5181216Z Jan 25 06:46:46 at > org.junit.platform.engine.support.hierarchical.Node.around(Node.java:137) > 2022-01-25T06:46:46.5182446Z Jan 25 06:46:46 at > org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$9(NodeTestTask.java:139) > 2022-01-25T06:46:46.5183645Z Jan 25 06:46:46 at > org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73) > 2022-01-25T06:46:46.5184810Z Jan 25 06:46:46 at > org.junit.platform.engine.support.hierarchical.NodeTestTask.executeRecursively(NodeTestTask.java:138) > 2022-01-25T06:46:46.5186072Z Jan 25 06:46:46 at > org.junit.platform.engine.support.hierarchical.NodeTestTask.execute(NodeTestTask.java:95) > 2022-01-25T06:46:46.5187277Z Jan 25 06:46:46 at > org.junit.platform.engine.support.hierarchical.SameThreadHierarchicalTestExecutorService.submit(SameThreadHierarchicalTestExecutorService.java:35) > 2022-01-25T06:46:46.5188540Z Jan 25 06:46:46 at > org.junit.platform.engine.support.hierarchical.NodeTestTask$DefaultDynamicTestExecutor.execute(NodeTestTask.java:226) > 2022-01-25T06:46:46.5189755Z Jan 25 06:46:46 at > org.junit.platform.engine.support.hierarchical.NodeTestTask$DefaultDynamicTestExecutor.execute(NodeTestTask.java:204) > 2022-01-25T06:46:46.5190987Z Jan 25 06:46:46 at > org.junit.jupiter.engine.descriptor.TestTemplateTestDescriptor.execute(TestTemplateTestDescriptor.java:139) > 2022-01-25T06:46:46.5192312Z Jan 25 06:46:46 at > org.junit.jupiter.engine.descriptor.TestTemplateTestDescriptor.lambda$execute$2(TestTemplateTestDescriptor.java:107) > 2022-01-25T06:46:46.5193457Z Jan 25 06:46:46 at > java.util.stream.ForEachOps$ForEachOp$OfRef.accept(ForEachOps.java:183) > 2022-01-25T06:46:46.5194460Z Jan 25 06:46:46 at > java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:193) > 2022-01-25T06:46:46.5195406Z Jan 25 06:46:46 at > java.util.stream.ReferencePipeline$2$1.accept(ReferencePipeline.java:175) > 2022-01-25T06:46:46.5196414Z Jan 25 06:46:46 at > java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:193) > 2022-01-25T06:46:46.5197377Z Jan 25 06:46:46 at > java.util.stream.ForEachOps$ForEachOp$OfRef.accept(ForEachOps.java:183) > 2022-01-25T06:46:46.5198365Z Jan 25 06:46:46 at > java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:193) > 2022-01-25T06:46:46.5199368Z Jan 25 06:46:46 at > java.util.ArrayList$ArrayListSpliterator.forEachRemaining(ArrayList.java:1384) > 2022-01-25T06:46:46.5200342Z Jan 25 06:46:46 at > java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:482) > 2022-01-25T06:46:46.5201326Z Jan 25 06:46:46 at > java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:472) > 2022-01-25T06:46:46.5202587Z Jan 25 06:46:46 at > java.util.stream.ForEachOps$ForEachOp.evaluateSequential(ForEachOps.java:150) > 2022-01-25T06:46:46.5203614Z Jan 25 06:46:46 at > java.util.stream.ForEachOps$ForEachOp$OfRef.evaluateSequential(ForEachOps.java:173) > 2022-01-25T06:46:46.5204620Z Jan 25 06:46:46 at > java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234) > 2022-01-25T06:46:46.5205692Z Jan 25 06:46:46 at > java.util.stream.ReferencePipeline.forEach(ReferencePipeline.java:485) > 2022-01-25T06:46:46.5206649Z Jan 25 06:46:46 at > java.util.stream.ReferencePipeline$7$1.accept(ReferencePipeline.java:272) > 2022-01-25T06:46:46.5207595Z Jan 25 06:46:46 at > java.util.ArrayList$ArrayListSpliterator.forEachRemaining(ArrayList.java:1384) > 2022-01-25T06:46:46.5208597Z Jan 25 06:46:46 at > java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:482) > 2022-01-25T06:46:46.5209538Z Jan 25 06:46:46 at > java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:472) > 2022-01-25T06:46:46.5210736Z Jan 25 06:46:46 at > java.util.stream.ForEachOps$ForEachOp.evaluateSequential(ForEachOps.java:150) > 2022-01-25T06:46:46.5211773Z Jan 25 06:46:46 at > java.util.stream.ForEachOps$ForEachOp$OfRef.evaluateSequential(ForEachOps.java:173) > 2022-01-25T06:46:46.5212901Z Jan 25 06:46:46 at > java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234) > 2022-01-25T06:46:46.5213876Z Jan 25 06:46:46 at > java.util.stream.ReferencePipeline.forEach(ReferencePipeline.java:485) > 2022-01-25T06:46:46.5214955Z Jan 25 06:46:46 at > org.junit.jupiter.engine.descriptor.TestTemplateTestDescriptor.execute(TestTemplateTestDescriptor.java:107) > 2022-01-25T06:46:46.5216231Z Jan 25 06:46:46 at > org.junit.jupiter.engine.descriptor.TestTemplateTestDescriptor.execute(TestTemplateTestDescriptor.java:42) > 2022-01-25T06:46:46.5217451Z Jan 25 06:46:46 at > org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$6(NodeTestTask.java:151) > 2022-01-25T06:46:46.5218669Z Jan 25 06:46:46 at > org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73) > 2022-01-25T06:46:46.5219857Z Jan 25 06:46:46 at > org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$8(NodeTestTask.java:141) > 2022-01-25T06:46:46.5220944Z Jan 25 06:46:46 at > org.junit.platform.engine.support.hierarchical.Node.around(Node.java:137) > 2022-01-25T06:46:46.5222161Z Jan 25 06:46:46 at > org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$9(NodeTestTask.java:139) > 2022-01-25T06:46:46.5223351Z Jan 25 06:46:46 at > org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73) > 2022-01-25T06:46:46.5224511Z Jan 25 06:46:46 at > org.junit.platform.engine.support.hierarchical.NodeTestTask.executeRecursively(NodeTestTask.java:138) > 2022-01-25T06:46:46.5225727Z Jan 25 06:46:46 at > org.junit.platform.engine.support.hierarchical.NodeTestTask.execute(NodeTestTask.java:95) > 2022-01-25T06:46:46.5226678Z Jan 25 06:46:46 at > java.util.ArrayList.forEach(ArrayList.java:1259) > 2022-01-25T06:46:46.5227807Z Jan 25 06:46:46 at > org.junit.platform.engine.support.hierarchical.SameThreadHierarchicalTestExecutorService.invokeAll(SameThreadHierarchicalTestExecutorService.java:41) > 2022-01-25T06:46:46.5229133Z Jan 25 06:46:46 at > org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$6(NodeTestTask.java:155) > 2022-01-25T06:46:46.5230295Z Jan 25 06:46:46 at > org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73) > 2022-01-25T06:46:46.5231395Z Jan 25 06:46:46 at > org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$8(NodeTestTask.java:141) > 2022-01-25T06:46:46.5232460Z Jan 25 06:46:46 at > org.junit.platform.engine.support.hierarchical.Node.around(Node.java:137) > 2022-01-25T06:46:46.5233444Z Jan 25 06:46:46 at > org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$9(NodeTestTask.java:139) > 2022-01-25T06:46:46.5234753Z Jan 25 06:46:46 at > org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73) > 2022-01-25T06:46:46.5236017Z Jan 25 06:46:46 at > org.junit.platform.engine.support.hierarchical.NodeTestTask.executeRecursively(NodeTestTask.java:138) > 2022-01-25T06:46:46.5237105Z Jan 25 06:46:46 at > org.junit.platform.engine.support.hierarchical.NodeTestTask.execute(NodeTestTask.java:95) > 2022-01-25T06:46:46.5237978Z Jan 25 06:46:46 at > java.util.ArrayList.forEach(ArrayList.java:1259) > 2022-01-25T06:46:46.5239089Z Jan 25 06:46:46 at > org.junit.platform.engine.support.hierarchical.SameThreadHierarchicalTestExecutorService.invokeAll(SameThreadHierarchicalTestExecutorService.java:41) > 2022-01-25T06:46:46.5240440Z Jan 25 06:46:46 at > org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$6(NodeTestTask.java:155) > 2022-01-25T06:46:46.5241623Z Jan 25 06:46:46 at > org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73) > 2022-01-25T06:46:46.5243121Z Jan 25 06:46:46 at > org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$8(NodeTestTask.java:141) > 2022-01-25T06:46:46.5244217Z Jan 25 06:46:46 at > org.junit.platform.engine.support.hierarchical.Node.around(Node.java:137) > 2022-01-25T06:46:46.5245265Z Jan 25 06:46:46 at > org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$9(NodeTestTask.java:139) > 2022-01-25T06:46:46.5246613Z Jan 25 06:46:46 at > org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73) > 2022-01-25T06:46:46.5247777Z Jan 25 06:46:46 at > org.junit.platform.engine.support.hierarchical.NodeTestTask.executeRecursively(NodeTestTask.java:138) > 2022-01-25T06:46:46.5248892Z Jan 25 06:46:46 at > org.junit.platform.engine.support.hierarchical.NodeTestTask.execute(NodeTestTask.java:95) > 2022-01-25T06:46:46.5250127Z Jan 25 06:46:46 at > org.junit.platform.engine.support.hierarchical.SameThreadHierarchicalTestExecutorService.submit(SameThreadHierarchicalTestExecutorService.java:35) > 2022-01-25T06:46:46.5251470Z Jan 25 06:46:46 at > org.junit.platform.engine.support.hierarchical.HierarchicalTestExecutor.execute(HierarchicalTestExecutor.java:57) > 2022-01-25T06:46:46.5252843Z Jan 25 06:46:46 at > org.junit.platform.engine.support.hierarchical.HierarchicalTestEngine.execute(HierarchicalTestEngine.java:54) > 2022-01-25T06:46:46.5254054Z Jan 25 06:46:46 at > org.junit.platform.launcher.core.EngineExecutionOrchestrator.execute(EngineExecutionOrchestrator.java:107) > 2022-01-25T06:46:46.5255244Z Jan 25 06:46:46 at > org.junit.platform.launcher.core.EngineExecutionOrchestrator.execute(EngineExecutionOrchestrator.java:88) > 2022-01-25T06:46:46.5256573Z Jan 25 06:46:46 at > org.junit.platform.launcher.core.EngineExecutionOrchestrator.lambda$execute$0(EngineExecutionOrchestrator.java:54) > 2022-01-25T06:46:46.5257847Z Jan 25 06:46:46 at > org.junit.platform.launcher.core.EngineExecutionOrchestrator.withInterceptedStreams(EngineExecutionOrchestrator.java:67) > 2022-01-25T06:46:46.5259083Z Jan 25 06:46:46 at > org.junit.platform.launcher.core.EngineExecutionOrchestrator.execute(EngineExecutionOrchestrator.java:52) > 2022-01-25T06:46:46.5260208Z Jan 25 06:46:46 at > org.junit.platform.launcher.core.DefaultLauncher.execute(DefaultLauncher.java:114) > 2022-01-25T06:46:46.5261262Z Jan 25 06:46:46 at > org.junit.platform.launcher.core.DefaultLauncher.execute(DefaultLauncher.java:86) > 2022-01-25T06:46:46.5262514Z Jan 25 06:46:46 at > org.junit.platform.launcher.core.DefaultLauncherSession$DelegatingLauncher.execute(DefaultLauncherSession.java:86) > 2022-01-25T06:46:46.5263717Z Jan 25 06:46:46 at > org.junit.platform.launcher.core.SessionPerRequestLauncher.execute(SessionPerRequestLauncher.java:53) > 2022-01-25T06:46:46.5264899Z Jan 25 06:46:46 at > org.apache.maven.surefire.junitplatform.JUnitPlatformProvider.execute(JUnitPlatformProvider.java:188) > 2022-01-25T06:46:46.5266193Z Jan 25 06:46:46 at > org.apache.maven.surefire.junitplatform.JUnitPlatformProvider.invokeAllTests(JUnitPlatformProvider.java:154) > 2022-01-25T06:46:46.5267571Z Jan 25 06:46:46 at > org.apache.maven.surefire.junitplatform.JUnitPlatformProvider.invoke(JUnitPlatformProvider.java:124) > 2022-01-25T06:46:46.5268692Z Jan 25 06:46:46 at > org.apache.maven.surefire.booter.ForkedBooter.runSuitesInProcess(ForkedBooter.java:428) > 2022-01-25T06:46:46.5269712Z Jan 25 06:46:46 at > org.apache.maven.surefire.booter.ForkedBooter.execute(ForkedBooter.java:162) > 2022-01-25T06:46:46.5270574Z Jan 25 06:46:46 at > org.apache.maven.surefire.booter.ForkedBooter.run(ForkedBooter.java:562) > 2022-01-25T06:46:46.5271475Z Jan 25 06:46:46 at > org.apache.maven.surefire.booter.ForkedBooter.main(ForkedBooter.java:548) > 2022-01-25T06:46:46.5272618Z Jan 25 06:46:46 Suppressed: > org.apache.pulsar.client.api.PulsarClientException$TimeoutException: 79 > request timedout after ms 30000 > 2022-01-25T06:46:46.5273737Z Jan 25 06:46:46 at > org.apache.pulsar.client.api.PulsarClientException.unwrap(PulsarClientException.java:961) > 2022-01-25T06:46:46.5274941Z Jan 25 06:46:46 at > org.apache.pulsar.client.impl.ProducerBase.close(ProducerBase.java:138) > 2022-01-25T06:46:46.5276177Z Jan 25 06:46:46 at > org.apache.flink.connector.pulsar.testutils.runtime.PulsarRuntimeOperator.sendMessages(PulsarRuntimeOperator.java:186) > 2022-01-25T06:46:46.5277084Z Jan 25 06:46:46 ... 109 more > 2022-01-25T06:46:46.5277582Z Jan 25 06:46:46 > 2022-01-25T06:46:47.0001202Z Jan 25 06:46:46 [INFO] > 2022-01-25T06:46:47.0002203Z Jan 25 06:46:46 [INFO] Results: > 2022-01-25T06:46:47.0002696Z Jan 25 06:46:46 [INFO] > 2022-01-25T06:46:47.0003063Z Jan 25 06:46:46 [ERROR] Errors: > 2022-01-25T06:46:47.0004360Z Jan 25 06:46:46 [ERROR] > PulsarSourceITCase>SourceTestSuiteBase.testTaskManagerFailure:328 ยป Timeout > Th... > 2022-01-25T06:46:47.0004873Z Jan 25 06:46:46 [INFO] > 2022-01-25T06:46:47.0005320Z Jan 25 06:46:46 [ERROR] Tests run: 8, Failures: > 0, Errors: 1, Skipped: 0 > {code} > https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=30091&view=logs&j=fc5181b0-e452-5c8f-68de-1097947f6483&t=995c650b-6573-581c-9ce6-7ad4cc038461&l=24962 -- This message was sent by Atlassian Jira (v8.20.1#820001)