Huang Xingbo created FLINK-27833:
------------------------------------
Summary: PulsarSourceITCase.testTaskManagerFailure failed with
AssertionError
Key: FLINK-27833
URL: https://issues.apache.org/jira/browse/FLINK-27833
Project: Flink
Issue Type: Bug
Components: Connectors / Pulsar
Affects Versions: 1.14.4
Reporter: Huang Xingbo
{code:java}
2022-05-28T02:40:24.3137097Z May 28 02:40:24 [ERROR] Tests run: 8, Failures: 1,
Errors: 0, Skipped: 0, Time elapsed: 123.914 s <<< FAILURE! - in
org.apache.flink.connector.pulsar.source.PulsarSourceITCase
2022-05-28T02:40:24.3139274Z May 28 02:40:24 [ERROR]
testTaskManagerFailure{TestEnvironment, ExternalContext,
ClusterControllable}[2] Time elapsed: 25.823 s <<< FAILURE!
2022-05-28T02:40:24.3140450Z May 28 02:40:24 java.lang.AssertionError:
2022-05-28T02:40:24.3141062Z May 28 02:40:24
2022-05-28T02:40:24.3141875Z May 28 02:40:24 Expected: Records consumed by
Flink should be identical to test data and preserve the order in split
2022-05-28T02:40:24.3143710Z May 28 02:40:24 but: Mismatched record at
position 18: Expected '0-iuKyiUwhhuO3NoDPvpLxIUw3' but was '0-98Y'
2022-05-28T02:40:24.3145019Z May 28 02:40:24 at
org.hamcrest.MatcherAssert.assertThat(MatcherAssert.java:20)
2022-05-28T02:40:24.3146064Z May 28 02:40:24 at
org.hamcrest.MatcherAssert.assertThat(MatcherAssert.java:8)
2022-05-28T02:40:24.3147334Z May 28 02:40:24 at
org.apache.flink.connectors.test.common.testsuites.SourceTestSuiteBase.testTaskManagerFailure(SourceTestSuiteBase.java:289)
2022-05-28T02:40:24.3148548Z May 28 02:40:24 at
sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
2022-05-28T02:40:24.3149690Z May 28 02:40:24 at
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
2022-05-28T02:40:24.3150910Z May 28 02:40:24 at
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
2022-05-28T02:40:24.3158249Z May 28 02:40:24 at
java.lang.reflect.Method.invoke(Method.java:498)
2022-05-28T02:40:24.3159819Z May 28 02:40:24 at
org.junit.platform.commons.util.ReflectionUtils.invokeMethod(ReflectionUtils.java:688)
2022-05-28T02:40:24.3161222Z May 28 02:40:24 at
org.junit.jupiter.engine.execution.MethodInvocation.proceed(MethodInvocation.java:60)
2022-05-28T02:40:24.3162609Z May 28 02:40:24 at
org.junit.jupiter.engine.execution.InvocationInterceptorChain$ValidatingInvocation.proceed(InvocationInterceptorChain.java:131)
2022-05-28T02:40:24.3164030Z May 28 02:40:24 at
org.junit.jupiter.engine.extension.TimeoutExtension.intercept(TimeoutExtension.java:149)
2022-05-28T02:40:24.3165548Z May 28 02:40:24 at
org.junit.jupiter.engine.extension.TimeoutExtension.interceptTestableMethod(TimeoutExtension.java:140)
2022-05-28T02:40:24.3167224Z May 28 02:40:24 at
org.junit.jupiter.engine.extension.TimeoutExtension.interceptTestTemplateMethod(TimeoutExtension.java:92)
2022-05-28T02:40:24.3169087Z May 28 02:40:24 at
org.junit.jupiter.engine.execution.ExecutableInvoker$ReflectiveInterceptorCall.lambda$ofVoidMethod$0(ExecutableInvoker.java:115)
2022-05-28T02:40:24.3170540Z May 28 02:40:24 at
org.junit.jupiter.engine.execution.ExecutableInvoker.lambda$invoke$0(ExecutableInvoker.java:105)
2022-05-28T02:40:24.3171970Z May 28 02:40:24 at
org.junit.jupiter.engine.execution.InvocationInterceptorChain$InterceptedInvocation.proceed(InvocationInterceptorChain.java:106)
2022-05-28T02:40:24.3173499Z May 28 02:40:24 at
org.junit.jupiter.engine.execution.InvocationInterceptorChain.proceed(InvocationInterceptorChain.java:64)
2022-05-28T02:40:24.3175023Z May 28 02:40:24 at
org.junit.jupiter.engine.execution.InvocationInterceptorChain.chainAndInvoke(InvocationInterceptorChain.java:45)
2022-05-28T02:40:24.3176435Z May 28 02:40:24 at
org.junit.jupiter.engine.execution.InvocationInterceptorChain.invoke(InvocationInterceptorChain.java:37)
2022-05-28T02:40:24.3177715Z May 28 02:40:24 at
org.junit.jupiter.engine.execution.ExecutableInvoker.invoke(ExecutableInvoker.java:104)
2022-05-28T02:40:24.3178985Z May 28 02:40:24 at
org.junit.jupiter.engine.execution.ExecutableInvoker.invoke(ExecutableInvoker.java:98)
2022-05-28T02:40:24.3180563Z May 28 02:40:24 at
org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.lambda$invokeTestMethod$6(TestMethodTestDescriptor.java:210)
2022-05-28T02:40:24.3182004Z May 28 02:40:24 at
org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
2022-05-28T02:40:24.3183400Z May 28 02:40:24 at
org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.invokeTestMethod(TestMethodTestDescriptor.java:206)
2022-05-28T02:40:24.3184865Z May 28 02:40:24 at
org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.execute(TestMethodTestDescriptor.java:131)
2022-05-28T02:40:24.3185720Z May 28 02:40:24 at
org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.execute(TestMethodTestDescriptor.java:65)
2022-05-28T02:40:24.3186545Z May 28 02:40:24 at
org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$5(NodeTestTask.java:139)
2022-05-28T02:40:24.3187411Z May 28 02:40:24 at
org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
2022-05-28T02:40:24.3188239Z May 28 02:40:24 at
org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$7(NodeTestTask.java:129)
2022-05-28T02:40:24.3189060Z May 28 02:40:24 at
org.junit.platform.engine.support.hierarchical.Node.around(Node.java:137)
2022-05-28T02:40:24.3189814Z May 28 02:40:24 at
org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$8(NodeTestTask.java:127)
2022-05-28T02:40:24.3190641Z May 28 02:40:24 at
org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
2022-05-28T02:40:24.3191449Z May 28 02:40:24 at
org.junit.platform.engine.support.hierarchical.NodeTestTask.executeRecursively(NodeTestTask.java:126)
2022-05-28T02:40:24.3192225Z May 28 02:40:24 at
org.junit.platform.engine.support.hierarchical.NodeTestTask.execute(NodeTestTask.java:84)
2022-05-28T02:40:24.3193099Z May 28 02:40:24 at
org.junit.platform.engine.support.hierarchical.SameThreadHierarchicalTestExecutorService.submit(SameThreadHierarchicalTestExecutorService.java:32)
2022-05-28T02:40:24.3194049Z May 28 02:40:24 at
org.junit.platform.engine.support.hierarchical.NodeTestTask$DefaultDynamicTestExecutor.execute(NodeTestTask.java:212)
2022-05-28T02:40:24.3195149Z May 28 02:40:24 at
org.junit.platform.engine.support.hierarchical.NodeTestTask$DefaultDynamicTestExecutor.execute(NodeTestTask.java:192)
2022-05-28T02:40:24.3196014Z May 28 02:40:24 at
org.junit.jupiter.engine.descriptor.TestTemplateTestDescriptor.execute(TestTemplateTestDescriptor.java:139)
2022-05-28T02:40:24.3197002Z May 28 02:40:24 at
org.junit.jupiter.engine.descriptor.TestTemplateTestDescriptor.lambda$execute$2(TestTemplateTestDescriptor.java:107)
2022-05-28T02:40:24.3197765Z May 28 02:40:24 at
java.util.stream.ForEachOps$ForEachOp$OfRef.accept(ForEachOps.java:183)
2022-05-28T02:40:24.3198433Z May 28 02:40:24 at
java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:193)
2022-05-28T02:40:24.3199174Z May 28 02:40:24 at
java.util.stream.ReferencePipeline$2$1.accept(ReferencePipeline.java:175)
2022-05-28T02:40:24.3199822Z May 28 02:40:24 at
java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:193)
2022-05-28T02:40:24.3200477Z May 28 02:40:24 at
java.util.stream.ForEachOps$ForEachOp$OfRef.accept(ForEachOps.java:183)
2022-05-28T02:40:24.3201136Z May 28 02:40:24 at
java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:193)
2022-05-28T02:40:24.3201821Z May 28 02:40:24 at
java.util.ArrayList$ArrayListSpliterator.forEachRemaining(ArrayList.java:1384)
2022-05-28T02:40:24.3202501Z May 28 02:40:24 at
java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:482)
2022-05-28T02:40:24.3203167Z May 28 02:40:24 at
java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:472)
2022-05-28T02:40:24.3203832Z May 28 02:40:24 at
java.util.stream.ForEachOps$ForEachOp.evaluateSequential(ForEachOps.java:150)
2022-05-28T02:40:24.3204687Z May 28 02:40:24 at
java.util.stream.ForEachOps$ForEachOp$OfRef.evaluateSequential(ForEachOps.java:173)
2022-05-28T02:40:24.3205372Z May 28 02:40:24 at
java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234)
2022-05-28T02:40:24.3206024Z May 28 02:40:24 at
java.util.stream.ReferencePipeline.forEach(ReferencePipeline.java:485)
2022-05-28T02:40:24.3206687Z May 28 02:40:24 at
java.util.stream.ReferencePipeline$7$1.accept(ReferencePipeline.java:272)
2022-05-28T02:40:24.3207365Z May 28 02:40:24 at
java.util.ArrayList$ArrayListSpliterator.forEachRemaining(ArrayList.java:1384)
2022-05-28T02:40:24.3208036Z May 28 02:40:24 at
java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:482)
2022-05-28T02:40:24.3208737Z May 28 02:40:24 at
java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:472)
2022-05-28T02:40:24.3209433Z May 28 02:40:24 at
java.util.stream.ForEachOps$ForEachOp.evaluateSequential(ForEachOps.java:150)
2022-05-28T02:40:24.3210132Z May 28 02:40:24 at
java.util.stream.ForEachOps$ForEachOp$OfRef.evaluateSequential(ForEachOps.java:173)
2022-05-28T02:40:24.3210811Z May 28 02:40:24 at
java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234)
2022-05-28T02:40:24.3211465Z May 28 02:40:24 at
java.util.stream.ReferencePipeline.forEach(ReferencePipeline.java:485)
2022-05-28T02:40:24.3212200Z May 28 02:40:24 at
org.junit.jupiter.engine.descriptor.TestTemplateTestDescriptor.execute(TestTemplateTestDescriptor.java:107)
2022-05-28T02:40:24.3213007Z May 28 02:40:24 at
org.junit.jupiter.engine.descriptor.TestTemplateTestDescriptor.execute(TestTemplateTestDescriptor.java:42)
2022-05-28T02:40:24.3213844Z May 28 02:40:24 at
org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$5(NodeTestTask.java:139)
2022-05-28T02:40:24.3214728Z May 28 02:40:24 at
org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
2022-05-28T02:40:24.3215591Z May 28 02:40:24 at
org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$7(NodeTestTask.java:129)
2022-05-28T02:40:24.3216357Z May 28 02:40:24 at
org.junit.platform.engine.support.hierarchical.Node.around(Node.java:137)
2022-05-28T02:40:24.3217117Z May 28 02:40:24 at
org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$8(NodeTestTask.java:127)
2022-05-28T02:40:24.3217932Z May 28 02:40:24 at
org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
2022-05-28T02:40:24.3218774Z May 28 02:40:24 at
org.junit.platform.engine.support.hierarchical.NodeTestTask.executeRecursively(NodeTestTask.java:126)
2022-05-28T02:40:24.3219626Z May 28 02:40:24 at
org.junit.platform.engine.support.hierarchical.NodeTestTask.execute(NodeTestTask.java:84)
2022-05-28T02:40:24.3220273Z May 28 02:40:24 at
java.util.ArrayList.forEach(ArrayList.java:1259)
2022-05-28T02:40:24.3221065Z May 28 02:40:24 at
org.junit.platform.engine.support.hierarchical.SameThreadHierarchicalTestExecutorService.invokeAll(SameThreadHierarchicalTestExecutorService.java:38)
2022-05-28T02:40:24.3222000Z May 28 02:40:24 at
org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$5(NodeTestTask.java:143)
2022-05-28T02:40:24.3222815Z May 28 02:40:24 at
org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
2022-05-28T02:40:24.3223620Z May 28 02:40:24 at
org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$7(NodeTestTask.java:129)
2022-05-28T02:40:24.3224446Z May 28 02:40:24 at
org.junit.platform.engine.support.hierarchical.Node.around(Node.java:137)
2022-05-28T02:40:24.3225193Z May 28 02:40:24 at
org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$8(NodeTestTask.java:127)
2022-05-28T02:40:24.3225996Z May 28 02:40:24 at
org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
2022-05-28T02:40:24.3226872Z May 28 02:40:24 at
org.junit.platform.engine.support.hierarchical.NodeTestTask.executeRecursively(NodeTestTask.java:126)
2022-05-28T02:40:24.3227632Z May 28 02:40:24 at
org.junit.platform.engine.support.hierarchical.NodeTestTask.execute(NodeTestTask.java:84)
2022-05-28T02:40:24.3228281Z May 28 02:40:24 at
java.util.ArrayList.forEach(ArrayList.java:1259)
2022-05-28T02:40:24.3229160Z May 28 02:40:24 at
org.junit.platform.engine.support.hierarchical.SameThreadHierarchicalTestExecutorService.invokeAll(SameThreadHierarchicalTestExecutorService.java:38)
2022-05-28T02:40:24.3230090Z May 28 02:40:24 at
org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$5(NodeTestTask.java:143)
2022-05-28T02:40:24.3230893Z May 28 02:40:24 at
org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
2022-05-28T02:40:24.3231707Z May 28 02:40:24 at
org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$7(NodeTestTask.java:129)
2022-05-28T02:40:24.3232462Z May 28 02:40:24 at
org.junit.platform.engine.support.hierarchical.Node.around(Node.java:137)
2022-05-28T02:40:24.3233226Z May 28 02:40:24 at
org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$8(NodeTestTask.java:127)
2022-05-28T02:40:24.3234051Z May 28 02:40:24 at
org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
2022-05-28T02:40:24.3234981Z May 28 02:40:24 at
org.junit.platform.engine.support.hierarchical.NodeTestTask.executeRecursively(NodeTestTask.java:126)
2022-05-28T02:40:24.3235754Z May 28 02:40:24 at
org.junit.platform.engine.support.hierarchical.NodeTestTask.execute(NodeTestTask.java:84)
2022-05-28T02:40:24.3236609Z May 28 02:40:24 at
org.junit.platform.engine.support.hierarchical.SameThreadHierarchicalTestExecutorService.submit(SameThreadHierarchicalTestExecutorService.java:32)
2022-05-28T02:40:24.3237540Z May 28 02:40:24 at
org.junit.platform.engine.support.hierarchical.HierarchicalTestExecutor.execute(HierarchicalTestExecutor.java:57)
2022-05-28T02:40:24.3238393Z May 28 02:40:24 at
org.junit.platform.engine.support.hierarchical.HierarchicalTestEngine.execute(HierarchicalTestEngine.java:51)
2022-05-28T02:40:24.3239229Z May 28 02:40:24 at
org.junit.platform.launcher.core.DefaultLauncher.execute(DefaultLauncher.java:220)
2022-05-28T02:40:24.3239960Z May 28 02:40:24 at
org.junit.platform.launcher.core.DefaultLauncher.lambda$execute$6(DefaultLauncher.java:188)
2022-05-28T02:40:24.3240727Z May 28 02:40:24 at
org.junit.platform.launcher.core.DefaultLauncher.withInterceptedStreams(DefaultLauncher.java:202)
2022-05-28T02:40:24.3241545Z May 28 02:40:24 at
org.junit.platform.launcher.core.DefaultLauncher.execute(DefaultLauncher.java:181)
2022-05-28T02:40:24.3242256Z May 28 02:40:24 at
org.junit.platform.launcher.core.DefaultLauncher.execute(DefaultLauncher.java:128)
2022-05-28T02:40:24.3243015Z May 28 02:40:24 at
org.apache.maven.surefire.junitplatform.JUnitPlatformProvider.invokeAllTests(JUnitPlatformProvider.java:150)
2022-05-28T02:40:24.3243840Z May 28 02:40:24 at
org.apache.maven.surefire.junitplatform.JUnitPlatformProvider.invoke(JUnitPlatformProvider.java:120)
2022-05-28T02:40:24.3244720Z May 28 02:40:24 at
org.apache.maven.surefire.booter.ForkedBooter.invokeProviderInSameClassLoader(ForkedBooter.java:384)
2022-05-28T02:40:24.3245482Z May 28 02:40:24 at
org.apache.maven.surefire.booter.ForkedBooter.runSuitesInProcess(ForkedBooter.java:345)
2022-05-28T02:40:24.3246199Z May 28 02:40:24 at
org.apache.maven.surefire.booter.ForkedBooter.execute(ForkedBooter.java:126)
2022-05-28T02:40:24.3246883Z May 28 02:40:24 at
org.apache.maven.surefire.booter.ForkedBooter.main(ForkedBooter.java:418)
2022-05-28T02:40:24.3247368Z May 28 02:40:24
2022-05-28T02:40:24.8576345Z May 28 02:40:24 [INFO]
2022-05-28T02:40:24.8585402Z May 28 02:40:24 [INFO] Results:
2022-05-28T02:40:24.8586151Z May 28 02:40:24 [INFO]
2022-05-28T02:40:24.8586789Z May 28 02:40:24 [ERROR] Failures:
2022-05-28T02:40:24.8588065Z May 28 02:40:24 [ERROR]
PulsarSourceITCase>SourceTestSuiteBase.testTaskManagerFailure:289
2022-05-28T02:40:24.8589448Z May 28 02:40:24 Expected: Records consumed by
Flink should be identical to test data and preserve the order in split
2022-05-28T02:40:24.8591601Z May 28 02:40:24 but: Mismatched record at
position 18: Expected '0-iuKyiUwhhuO3NoDPvpLxIUw3' but was '0-98Y'
2022-05-28T02:40:24.8592500Z May 28 02:40:24 [INFO]
2022-05-28T02:40:24.8593254Z May 28 02:40:24 [ERROR] Tests run: 8, Failures: 1,
Errors: 0, Skipped: 0
{code}
https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=36141&view=logs&j=a5ef94ef-68c2-57fd-3794-dc108ed1c495&t=2c68b137-b01d-55c9-e603-3ff3f320364b
--
This message was sent by Atlassian Jira
(v8.20.7#820007)
