You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Huang Xingbo (Jira)" <ji...@apache.org> on 2022/06/06 12:08:00 UTC
[jira] [Commented] (FLINK-27917) PulsarUnorderedPartitionSplitReaderTest.consumeMessageCreatedBeforeHandleSplitsChangesAndResetToEarliestPosition failed with AssertionError
[ https://issues.apache.org/jira/browse/FLINK-27917?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17550441#comment-17550441 ]
Huang Xingbo commented on FLINK-27917:
--------------------------------------
cc [~affe]
> 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
> Priority: Major
> Labels: test-stability
>
> {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)