Huang Xingbo created FLINK-27917:
------------------------------------
Summary:
PulsarUnorderedPartitionSplitReaderTest.consumeMessageCreatedBeforeHandleSplitsChangesAndResetToEarliestPosition
failed with AssertionError
Key: FLINK-27917
URL: https://issues.apache.org/jira/browse/FLINK-27917
Project: Flink
Issue Type: Bug
Components: Connectors / Pulsar
Affects Versions: 1.16.0
Reporter: Huang Xingbo
{code:java}
2022-06-06T06:34:46.7906026Z Jun 06 06:34:46 [ERROR]
org.apache.flink.connector.pulsar.source.reader.split.PulsarUnorderedPartitionSplitReaderTest.consumeMessageCreatedBeforeHandleSplitsChangesAndResetToEarliestPosition(PulsarPartitionSplitReaderBase)[1]
Time elapsed: 9.774 s <<< FAILURE!
2022-06-06T06:34:46.7919217Z Jun 06 06:34:46 java.lang.AssertionError:
2022-06-06T06:34:46.7920918Z Jun 06 06:34:46 [We should fetch the expected
size]
2022-06-06T06:34:46.7921479Z Jun 06 06:34:46 Expected size: 20 but was: 3 in:
2022-06-06T06:34:46.7922019Z Jun 06 06:34:46 [PulsarMessage{id=58:0:0:0,
value=ElpTDLGvKz, eventTime=0},
2022-06-06T06:34:46.7922757Z Jun 06 06:34:46 PulsarMessage{id=58:1:0:0,
value=cDGEGcCZnP, eventTime=0},
2022-06-06T06:34:46.7924900Z Jun 06 06:34:46 PulsarMessage{id=58:2:0:0,
value=rZmaCxrhZF, eventTime=0}]
2022-06-06T06:34:46.7926359Z Jun 06 06:34:46 at
org.apache.flink.connector.pulsar.source.reader.split.PulsarPartitionSplitReaderTestBase.fetchedMessages(PulsarPartitionSplitReaderTestBase.java:186)
2022-06-06T06:34:46.7928019Z Jun 06 06:34:46 at
org.apache.flink.connector.pulsar.source.reader.split.PulsarPartitionSplitReaderTestBase.fetchedMessages(PulsarPartitionSplitReaderTestBase.java:156)
2022-06-06T06:34:46.7930207Z Jun 06 06:34:46 at
org.apache.flink.connector.pulsar.source.reader.split.PulsarPartitionSplitReaderTestBase.consumeMessageCreatedBeforeHandleSplitsChangesAndResetToEarliestPosition(PulsarPartitionSplitReaderTestBase.java:247)
2022-06-06T06:34:46.7931943Z Jun 06 06:34:46 at
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
2022-06-06T06:34:46.7933282Z Jun 06 06:34:46 at
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
2022-06-06T06:34:46.7934885Z Jun 06 06:34:46 at
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
2022-06-06T06:34:46.7936182Z Jun 06 06:34:46 at
java.base/java.lang.reflect.Method.invoke(Method.java:566)
2022-06-06T06:34:46.7937301Z Jun 06 06:34:46 at
org.junit.platform.commons.util.ReflectionUtils.invokeMethod(ReflectionUtils.java:725)
2022-06-06T06:34:46.7938744Z Jun 06 06:34:46 at
org.junit.jupiter.engine.execution.MethodInvocation.proceed(MethodInvocation.java:60)
2022-06-06T06:34:46.7939650Z Jun 06 06:34:46 at
org.junit.jupiter.engine.execution.InvocationInterceptorChain$ValidatingInvocation.proceed(InvocationInterceptorChain.java:131)
2022-06-06T06:34:46.7940516Z Jun 06 06:34:46 at
org.junit.jupiter.engine.extension.TimeoutExtension.intercept(TimeoutExtension.java:149)
2022-06-06T06:34:46.7941737Z Jun 06 06:34:46 at
org.junit.jupiter.engine.extension.TimeoutExtension.interceptTestableMethod(TimeoutExtension.java:140)
2022-06-06T06:34:46.7942588Z Jun 06 06:34:46 at
org.junit.jupiter.engine.extension.TimeoutExtension.interceptTestTemplateMethod(TimeoutExtension.java:92)
2022-06-06T06:34:46.7943874Z Jun 06 06:34:46 at
org.junit.jupiter.engine.execution.ExecutableInvoker$ReflectiveInterceptorCall.lambda$ofVoidMethod$0(ExecutableInvoker.java:115)
2022-06-06T06:34:46.7945291Z Jun 06 06:34:46 at
org.junit.jupiter.engine.execution.ExecutableInvoker.lambda$invoke$0(ExecutableInvoker.java:105)
2022-06-06T06:34:46.7946812Z Jun 06 06:34:46 at
org.junit.jupiter.engine.execution.InvocationInterceptorChain$InterceptedInvocation.proceed(InvocationInterceptorChain.java:106)
2022-06-06T06:34:46.7948852Z Jun 06 06:34:46 at
org.junit.jupiter.engine.execution.InvocationInterceptorChain.proceed(InvocationInterceptorChain.java:64)
2022-06-06T06:34:46.7950462Z Jun 06 06:34:46 at
org.junit.jupiter.engine.execution.InvocationInterceptorChain.chainAndInvoke(InvocationInterceptorChain.java:45)
2022-06-06T06:34:46.7951929Z Jun 06 06:34:46 at
org.junit.jupiter.engine.execution.InvocationInterceptorChain.invoke(InvocationInterceptorChain.java:37)
2022-06-06T06:34:46.7953814Z Jun 06 06:34:46 at
org.junit.jupiter.engine.execution.ExecutableInvoker.invoke(ExecutableInvoker.java:104)
2022-06-06T06:34:46.7955421Z Jun 06 06:34:46 at
org.junit.jupiter.engine.execution.ExecutableInvoker.invoke(ExecutableInvoker.java:98)
2022-06-06T06:34:46.7956366Z Jun 06 06:34:46 at
org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.lambda$invokeTestMethod$7(TestMethodTestDescriptor.java:214)
2022-06-06T06:34:46.7957864Z Jun 06 06:34:46 at
org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
2022-06-06T06:34:46.7959784Z Jun 06 06:34:46 at
org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.invokeTestMethod(TestMethodTestDescriptor.java:210)
2022-06-06T06:34:46.7961360Z Jun 06 06:34:46 at
org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.execute(TestMethodTestDescriptor.java:135)
2022-06-06T06:34:46.7962379Z Jun 06 06:34:46 at
org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.execute(TestMethodTestDescriptor.java:66)
2022-06-06T06:34:46.7964049Z Jun 06 06:34:46 at
org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$6(NodeTestTask.java:151)
2022-06-06T06:34:46.7965451Z Jun 06 06:34:46 at
org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
2022-06-06T06:34:46.7966938Z Jun 06 06:34:46 at
org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$8(NodeTestTask.java:141)
2022-06-06T06:34:46.7968376Z Jun 06 06:34:46 at
org.junit.platform.engine.support.hierarchical.Node.around(Node.java:137)
2022-06-06T06:34:46.7969244Z Jun 06 06:34:46 at
org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$9(NodeTestTask.java:139)
2022-06-06T06:34:46.7970101Z Jun 06 06:34:46 at
org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
2022-06-06T06:34:46.7970936Z Jun 06 06:34:46 at
org.junit.platform.engine.support.hierarchical.NodeTestTask.executeRecursively(NodeTestTask.java:138)
2022-06-06T06:34:46.7971747Z Jun 06 06:34:46 at
org.junit.platform.engine.support.hierarchical.NodeTestTask.execute(NodeTestTask.java:95)
2022-06-06T06:34:46.7972706Z Jun 06 06:34:46 at
org.junit.platform.engine.support.hierarchical.ForkJoinPoolHierarchicalTestExecutorService$ExclusiveTask.compute(ForkJoinPoolHierarchicalTestExecutorService.java:185)
2022-06-06T06:34:46.7974307Z Jun 06 06:34:46 at
org.junit.platform.engine.support.hierarchical.ForkJoinPoolHierarchicalTestExecutorService.submit(ForkJoinPoolHierarchicalTestExecutorService.java:118)
2022-06-06T06:34:46.7975915Z Jun 06 06:34:46 at
org.junit.platform.engine.support.hierarchical.NodeTestTask$DefaultDynamicTestExecutor.execute(NodeTestTask.java:226)
2022-06-06T06:34:46.7977376Z Jun 06 06:34:46 at
org.junit.platform.engine.support.hierarchical.NodeTestTask$DefaultDynamicTestExecutor.execute(NodeTestTask.java:204)
2022-06-06T06:34:46.7978867Z Jun 06 06:34:46 at
org.junit.jupiter.engine.descriptor.TestTemplateTestDescriptor.execute(TestTemplateTestDescriptor.java:139)
2022-06-06T06:34:46.7980594Z Jun 06 06:34:46 at
org.junit.jupiter.engine.descriptor.TestTemplateTestDescriptor.lambda$execute$2(TestTemplateTestDescriptor.java:107)
2022-06-06T06:34:46.7981560Z Jun 06 06:34:46 at
java.base/java.util.stream.ForEachOps$ForEachOp$OfRef.accept(ForEachOps.java:183)
2022-06-06T06:34:46.7982574Z Jun 06 06:34:46 at
java.base/java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:195)
2022-06-06T06:34:46.7983541Z Jun 06 06:34:46 at
java.base/java.util.stream.ReferencePipeline$2$1.accept(ReferencePipeline.java:177)
2022-06-06T06:34:46.7984586Z Jun 06 06:34:46 at
java.base/java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:195)
2022-06-06T06:34:46.7985725Z Jun 06 06:34:46 at
java.base/java.util.stream.Streams$StreamBuilderImpl.forEachRemaining(Streams.java:411)
2022-06-06T06:34:46.7986875Z Jun 06 06:34:46 at
java.base/java.util.stream.ReferencePipeline$Head.forEach(ReferencePipeline.java:658)
2022-06-06T06:34:46.7988041Z Jun 06 06:34:46 at
java.base/java.util.stream.ReferencePipeline$7$1.accept(ReferencePipeline.java:274)
2022-06-06T06:34:46.7988789Z Jun 06 06:34:46 at
java.base/java.util.ArrayList$ArrayListSpliterator.forEachRemaining(ArrayList.java:1655)
2022-06-06T06:34:46.7989637Z Jun 06 06:34:46 at
java.base/java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:484)
2022-06-06T06:34:46.7990652Z Jun 06 06:34:46 at
java.base/java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:474)
2022-06-06T06:34:46.7991402Z Jun 06 06:34:46 at
java.base/java.util.stream.ForEachOps$ForEachOp.evaluateSequential(ForEachOps.java:150)
2022-06-06T06:34:46.7992140Z Jun 06 06:34:46 at
java.base/java.util.stream.ForEachOps$ForEachOp$OfRef.evaluateSequential(ForEachOps.java:173)
2022-06-06T06:34:46.7992882Z Jun 06 06:34:46 at
java.base/java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234)
2022-06-06T06:34:46.7993957Z Jun 06 06:34:46 at
java.base/java.util.stream.ReferencePipeline.forEach(ReferencePipeline.java:497)
2022-06-06T06:34:46.7995208Z Jun 06 06:34:46 at
org.junit.jupiter.engine.descriptor.TestTemplateTestDescriptor.execute(TestTemplateTestDescriptor.java:107)
2022-06-06T06:34:46.7996080Z Jun 06 06:34:46 at
org.junit.jupiter.engine.descriptor.TestTemplateTestDescriptor.execute(TestTemplateTestDescriptor.java:42)
2022-06-06T06:34:46.7996945Z Jun 06 06:34:46 at
org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$6(NodeTestTask.java:151)
2022-06-06T06:34:46.7997809Z Jun 06 06:34:46 at
org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
2022-06-06T06:34:46.7998733Z Jun 06 06:34:46 at
org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$8(NodeTestTask.java:141)
2022-06-06T06:34:46.7999552Z Jun 06 06:34:46 at
org.junit.platform.engine.support.hierarchical.Node.around(Node.java:137)
2022-06-06T06:34:46.8000332Z Jun 06 06:34:46 at
org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$9(NodeTestTask.java:139)
2022-06-06T06:34:46.8001415Z Jun 06 06:34:46 at
org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
2022-06-06T06:34:46.8002331Z Jun 06 06:34:46 at
org.junit.platform.engine.support.hierarchical.NodeTestTask.executeRecursively(NodeTestTask.java:138)
2022-06-06T06:34:46.8003215Z Jun 06 06:34:46 at
org.junit.platform.engine.support.hierarchical.NodeTestTask.execute(NodeTestTask.java:95)
2022-06-06T06:34:46.8004405Z Jun 06 06:34:46 at
org.junit.platform.engine.support.hierarchical.ForkJoinPoolHierarchicalTestExecutorService$ExclusiveTask.compute(ForkJoinPoolHierarchicalTestExecutorService.java:185)
2022-06-06T06:34:46.8006351Z Jun 06 06:34:46 at
org.junit.platform.engine.support.hierarchical.ForkJoinPoolHierarchicalTestExecutorService.executeNonConcurrentTasks(ForkJoinPoolHierarchicalTestExecutorService.java:155)
2022-06-06T06:34:46.8007998Z Jun 06 06:34:46 at
org.junit.platform.engine.support.hierarchical.ForkJoinPoolHierarchicalTestExecutorService.invokeAll(ForkJoinPoolHierarchicalTestExecutorService.java:135)
2022-06-06T06:34:46.8009591Z Jun 06 06:34:46 at
org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$6(NodeTestTask.java:155)
2022-06-06T06:34:46.8010934Z Jun 06 06:34:46 at
org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
2022-06-06T06:34:46.8012417Z Jun 06 06:34:46 at
org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$8(NodeTestTask.java:141)
2022-06-06T06:34:46.8013427Z Jun 06 06:34:46 at
org.junit.platform.engine.support.hierarchical.Node.around(Node.java:137)
2022-06-06T06:34:46.8014793Z Jun 06 06:34:46 at
org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$9(NodeTestTask.java:139)
2022-06-06T06:34:46.8015651Z Jun 06 06:34:46 at
org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
2022-06-06T06:34:46.8016657Z Jun 06 06:34:46 at
org.junit.platform.engine.support.hierarchical.NodeTestTask.executeRecursively(NodeTestTask.java:138)
2022-06-06T06:34:46.8017452Z Jun 06 06:34:46 at
org.junit.platform.engine.support.hierarchical.NodeTestTask.execute(NodeTestTask.java:95)
2022-06-06T06:34:46.8018479Z Jun 06 06:34:46 at
org.junit.platform.engine.support.hierarchical.ForkJoinPoolHierarchicalTestExecutorService$ExclusiveTask.compute(ForkJoinPoolHierarchicalTestExecutorService.java:185)
2022-06-06T06:34:46.8020026Z Jun 06 06:34:46 at
org.junit.platform.engine.support.hierarchical.ForkJoinPoolHierarchicalTestExecutorService.invokeAll(ForkJoinPoolHierarchicalTestExecutorService.java:129)
2022-06-06T06:34:46.8021190Z Jun 06 06:34:46 at
org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$6(NodeTestTask.java:155)
2022-06-06T06:34:46.8022045Z Jun 06 06:34:46 at
org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
2022-06-06T06:34:46.8022897Z Jun 06 06:34:46 at
org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$8(NodeTestTask.java:141)
2022-06-06T06:34:46.8023935Z Jun 06 06:34:46 at
org.junit.platform.engine.support.hierarchical.Node.around(Node.java:137)
2022-06-06T06:34:46.8025212Z Jun 06 06:34:46 at
org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$9(NodeTestTask.java:139)
2022-06-06T06:34:46.8026078Z Jun 06 06:34:46 at
org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
2022-06-06T06:34:46.8026902Z Jun 06 06:34:46 at
org.junit.platform.engine.support.hierarchical.NodeTestTask.executeRecursively(NodeTestTask.java:138)
2022-06-06T06:34:46.8027676Z Jun 06 06:34:46 at
org.junit.platform.engine.support.hierarchical.NodeTestTask.execute(NodeTestTask.java:95)
2022-06-06T06:34:46.8028669Z Jun 06 06:34:46 at
org.junit.platform.engine.support.hierarchical.ForkJoinPoolHierarchicalTestExecutorService$ExclusiveTask.compute(ForkJoinPoolHierarchicalTestExecutorService.java:185)
2022-06-06T06:34:46.8029819Z Jun 06 06:34:46 at
java.base/java.util.concurrent.RecursiveAction.exec(RecursiveAction.java:189)
2022-06-06T06:34:46.8030512Z Jun 06 06:34:46 at
java.base/java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:290)
2022-06-06T06:34:46.8031508Z Jun 06 06:34:46 at
java.base/java.util.concurrent.ForkJoinPool$WorkQueue.topLevelExec(ForkJoinPool.java:1020)
2022-06-06T06:34:46.8032648Z Jun 06 06:34:46 at
java.base/java.util.concurrent.ForkJoinPool.scan(ForkJoinPool.java:1656)
2022-06-06T06:34:46.8034238Z Jun 06 06:34:46 at
java.base/java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1594)
2022-06-06T06:34:46.8035284Z Jun 06 06:34:46 at
java.base/java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:183)
2022-06-06T06:34:46.8035834Z Jun 06 06:34:46
2022-06-06T06:35:51.0359908Z Jun 06 06:35:51 [INFO] Tests run: 14, Failures: 0,
Errors: 0, Skipped: 0, Time elapsed: 144.364 s - in
org.apache.flink.connector.pulsar.source.reader.split.PulsarOrderedPartitionSplitReaderTest
2022-06-06T06:35:51.5089719Z Jun 06 06:35:51 [INFO]
2022-06-06T06:35:51.5091416Z Jun 06 06:35:51 [INFO] Results:
2022-06-06T06:35:51.5092235Z Jun 06 06:35:51 [INFO]
2022-06-06T06:35:51.5092685Z Jun 06 06:35:51 [ERROR] Failures:
2022-06-06T06:35:51.5094990Z Jun 06 06:35:51 [ERROR]
PulsarUnorderedPartitionSplitReaderTest>PulsarPartitionSplitReaderTestBase.consumeMessageCreatedBeforeHandleSplitsChangesAndResetToEarliestPosition:247->PulsarPartitionSplitReaderTestBase.fetchedMessages:156->PulsarPartitionSplitReaderTestBase.fetchedMessages:186
[We should fetch the expected size]
2022-06-06T06:35:51.5096131Z Jun 06 06:35:51 Expected size: 20 but was: 3 in:
2022-06-06T06:35:51.5096647Z Jun 06 06:35:51 [PulsarMessage{id=58:0:0:0,
value=ElpTDLGvKz, eventTime=0},
2022-06-06T06:35:51.5097260Z Jun 06 06:35:51 PulsarMessage{id=58:1:0:0,
value=cDGEGcCZnP, eventTime=0},
2022-06-06T06:35:51.5098057Z Jun 06 06:35:51 PulsarMessage{id=58:2:0:0,
value=rZmaCxrhZF, eventTime=0}]
2022-06-06T06:35:51.5098512Z Jun 06 06:35:51 [INFO]
2022-06-06T06:35:51.5098942Z Jun 06 06:35:51 [ERROR] Tests run: 133, Failures:
1, Errors: 0, Skipped: 0
2022-06-06T06:35:51.5099370Z
{code}
https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=36316&view=logs&j=fa307d6d-91b1-5ab6-d460-ef50f552b1fe&t=21eae189-b04c-5c04-662b-17dc80ffc83a
--
This message was sent by Atlassian Jira
(v8.20.7#820007)
