[
https://issues.apache.org/jira/browse/FLINK-25815?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17494431#comment-17494431
]
Matthias Pohl commented on FLINK-25815:
---------------------------------------
I experienced a timeout in [this
build|https://dev.azure.com/mapohl/flink/_build/results?buildId=748&view=logs&j=f3dc9b18-b77a-55c1-591e-264c46fe44d1&t=2d3cd81e-1c37-5c31-0ee4-f5d5cdb9324d&l=26778]
where the stacktrace looks different
> 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)
