[jira] [Commented] (FLINK-27917) PulsarUnorderedPartitionSplitReaderTest.consumeMessageCreatedBeforeHandleSplitsChangesAndResetToEarliestPosition failed with AssertionError

2022-12-01 Thread Martijn Visser (Jira) 


[ 
https://issues.apache.org/jira/browse/FLINK-27917?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17641786#comment-17641786
 ] 

Martijn Visser commented on FLINK-27917:


1.15: 
https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=43637=logs=298e20ef-7951-5965-0e79-ea664ddc435e=d4c90338-c843-57b0-3232-10ae74f00347=28411

> PulsarUnorderedPartitionSplitReaderTest.consumeMessageCreatedBeforeHandleSplitsChangesAndResetToEarliestPosition
>  failed with AssertionError
> ---
>
> Key: FLINK-27917
> URL: https://issues.apache.org/jira/browse/FLINK-27917
> Project: Flink
>  Issue Type: Sub-task
>  Components: Connectors / Pulsar
>Affects Versions: 1.14.5, 1.15.1
>Reporter: Huang Xingbo
>Assignee: Yufan Sheng
>Priority: Major
>  Labels: pull-request-available, test-stability
> Fix For: 1.14.7, 1.16.1, 1.15.4
>
>
> {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 
>

[jira] [Commented] (FLINK-27917) PulsarUnorderedPartitionSplitReaderTest.consumeMessageCreatedBeforeHandleSplitsChangesAndResetToEarliestPosition failed with AssertionError

2022-11-28 Thread Matthias Pohl (Jira) 


[ 
https://issues.apache.org/jira/browse/FLINK-27917?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17639921#comment-17639921
 ] 

Matthias Pohl commented on FLINK-27917:
---

https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=43513=logs=298e20ef-7951-5965-0e79-ea664ddc435e=d4c90338-c843-57b0-3232-10ae74f00347=28726

> PulsarUnorderedPartitionSplitReaderTest.consumeMessageCreatedBeforeHandleSplitsChangesAndResetToEarliestPosition
>  failed with AssertionError
> ---
>
> Key: FLINK-27917
> URL: https://issues.apache.org/jira/browse/FLINK-27917
> Project: Flink
>  Issue Type: Sub-task
>  Components: Connectors / Pulsar
>Affects Versions: 1.14.5, 1.15.1
>Reporter: Huang Xingbo
>Assignee: Yufan Sheng
>Priority: Major
>  Labels: pull-request-available, test-stability
> Fix For: 1.14.7, 1.16.1, 1.15.4
>
>
> {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 
>

[jira] [Commented] (FLINK-27917) PulsarUnorderedPartitionSplitReaderTest.consumeMessageCreatedBeforeHandleSplitsChangesAndResetToEarliestPosition failed with AssertionError

2022-09-07 Thread Xingbo Huang (Jira) 


[ 
https://issues.apache.org/jira/browse/FLINK-27917?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17601243#comment-17601243
 ] 

Xingbo Huang commented on FLINK-27917:
--

[~syhily] Thanks a lot for the investigation.

> PulsarUnorderedPartitionSplitReaderTest.consumeMessageCreatedBeforeHandleSplitsChangesAndResetToEarliestPosition
>  failed with AssertionError
> ---
>
> Key: FLINK-27917
> URL: https://issues.apache.org/jira/browse/FLINK-27917
> Project: Flink
>  Issue Type: Sub-task
>  Components: Connectors / Pulsar
>Affects Versions: 1.14.5, 1.15.1
>Reporter: Huang Xingbo
>Assignee: Yufan Sheng
>Priority: Major
>  Labels: pull-request-available, test-stability
> Fix For: 1.16.0, 1.14.6, 1.15.3
>
>
> {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 
>

[jira] [Commented] (FLINK-27917) PulsarUnorderedPartitionSplitReaderTest.consumeMessageCreatedBeforeHandleSplitsChangesAndResetToEarliestPosition failed with AssertionError

2022-09-05 Thread Yufan Sheng (Jira) 


[ 
https://issues.apache.org/jira/browse/FLINK-27917?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17600461#comment-17600461
 ] 

Yufan Sheng commented on FLINK-27917:
-

It seems like a bug on Pulsar broker: 
https://github.com/apache/pulsar/pull/17237. We can keep it open until we 
bumped the pulsar-client to 2.10.3

> PulsarUnorderedPartitionSplitReaderTest.consumeMessageCreatedBeforeHandleSplitsChangesAndResetToEarliestPosition
>  failed with AssertionError
> ---
>
> Key: FLINK-27917
> URL: https://issues.apache.org/jira/browse/FLINK-27917
> Project: Flink
>  Issue Type: Sub-task
>  Components: Connectors / Pulsar
>Affects Versions: 1.14.5, 1.15.1
>Reporter: Huang Xingbo
>Assignee: Yufan Sheng
>Priority: Major
>  Labels: pull-request-available, test-stability
> Fix For: 1.16.0, 1.14.6, 1.15.3
>
>
> {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 
>

[jira] [Commented] (FLINK-27917) PulsarUnorderedPartitionSplitReaderTest.consumeMessageCreatedBeforeHandleSplitsChangesAndResetToEarliestPosition failed with AssertionError

2022-09-05 Thread Yufan Sheng (Jira) 


[ 
https://issues.apache.org/jira/browse/FLINK-27917?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17600457#comment-17600457
 ] 

Yufan Sheng commented on FLINK-27917:
-

[~hxbks2ks] I'll check this.

> PulsarUnorderedPartitionSplitReaderTest.consumeMessageCreatedBeforeHandleSplitsChangesAndResetToEarliestPosition
>  failed with AssertionError
> ---
>
> Key: FLINK-27917
> URL: https://issues.apache.org/jira/browse/FLINK-27917
> Project: Flink
>  Issue Type: Sub-task
>  Components: Connectors / Pulsar
>Affects Versions: 1.14.5, 1.15.1
>Reporter: Huang Xingbo
>Assignee: Yufan Sheng
>Priority: Major
>  Labels: pull-request-available, test-stability
> Fix For: 1.16.0, 1.14.6, 1.15.3
>
>
> {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 
>

[jira] [Commented] (FLINK-27917) PulsarUnorderedPartitionSplitReaderTest.consumeMessageCreatedBeforeHandleSplitsChangesAndResetToEarliestPosition failed with AssertionError

2022-09-05 Thread Xingbo Huang (Jira) 


[ 
https://issues.apache.org/jira/browse/FLINK-27917?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17600329#comment-17600329
 ] 

Xingbo Huang commented on FLINK-27917:
--

[https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=40665=logs=aa18c3f6-13b8-5f58-86bb-c1cffb239496=502fb6c0-30a2-5e49-c5c2-a00fa3acb203]
 It seems to have happened again.
{code:java}
2022-09-05T05:19:03.9470055Z Sep 05 05:19:03 [ERROR] Failures: 
2022-09-05T05:19:03.9472058Z Sep 05 05:19:03 [ERROR]   
PulsarOrderedPartitionSplitReaderTest>PulsarPartitionSplitReaderTestBase.consumeMessageCreatedBeforeHandleSplitsChangesAndResetToEarliestPosition:260->PulsarPartitionSplitReaderTestBase.fetchedMessages:169->PulsarPartitionSplitReaderTestBase.fetchedMessages:199
 [We should fetch the expected size] 
2022-09-05T05:19:03.9473157Z Sep 05 05:19:03 Expected size: 20 but was: 23 in:
2022-09-05T05:19:03.9473660Z Sep 05 05:19:03 [PulsarMessage{id=148:0:0, 
value=xtvCoENDyD, eventTime=0},
2022-09-05T05:19:03.9474343Z Sep 05 05:19:03 PulsarMessage{id=148:1:0, 
value=LsfmAdOvPi, eventTime=0},
2022-09-05T05:19:03.9474926Z Sep 05 05:19:03 PulsarMessage{id=148:2:0, 
value=SADrPXpnsp, eventTime=0},
2022-09-05T05:19:03.9475652Z Sep 05 05:19:03 PulsarMessage{id=148:0:0, 
value=xtvCoENDyD, eventTime=0},
2022-09-05T05:19:03.9476632Z Sep 05 05:19:03 PulsarMessage{id=148:1:0, 
value=LsfmAdOvPi, eventTime=0},
2022-09-05T05:19:03.9477616Z Sep 05 05:19:03 PulsarMessage{id=148:2:0, 
value=SADrPXpnsp, eventTime=0},
2022-09-05T05:19:03.9478396Z Sep 05 05:19:03 PulsarMessage{id=148:3:0, 
value=BsEGjUZSJN, eventTime=0},
2022-09-05T05:19:03.9478942Z Sep 05 05:19:03 PulsarMessage{id=148:4:0, 
value=wvteCkUkjX, eventTime=0},
2022-09-05T05:19:03.9479500Z Sep 05 05:19:03 PulsarMessage{id=148:5:0, 
value=HUEpGPmjYy, eventTime=0},
2022-09-05T05:19:03.9480060Z Sep 05 05:19:03 PulsarMessage{id=148:6:0, 
value=kndeIFjLLK, eventTime=0},
2022-09-05T05:19:03.9480613Z Sep 05 05:19:03 PulsarMessage{id=148:7:0, 
value=gOmuNzCqbL, eventTime=0},
2022-09-05T05:19:03.9481348Z Sep 05 05:19:03 PulsarMessage{id=148:8:0, 
value=fvtNHyyqqj, eventTime=0},
2022-09-05T05:19:03.9482091Z Sep 05 05:19:03 PulsarMessage{id=148:9:0, 
value=iKrmISirqy, eventTime=0},
2022-09-05T05:19:03.9482628Z Sep 05 05:19:03 PulsarMessage{id=148:10:0, 
value=lQUCdQizRw, eventTime=0},
2022-09-05T05:19:03.9483196Z Sep 05 05:19:03 PulsarMessage{id=148:11:0, 
value=RkGRkfTAcS, eventTime=0},
2022-09-05T05:19:03.9483808Z Sep 05 05:19:03 PulsarMessage{id=148:12:0, 
value=mBcAGPkmpY, eventTime=0},
2022-09-05T05:19:03.9484447Z Sep 05 05:19:03 PulsarMessage{id=148:13:0, 
value=AMUWkVFpwU, eventTime=0},
2022-09-05T05:19:03.9485002Z Sep 05 05:19:03 PulsarMessage{id=148:14:0, 
value=zCtbxzylrl, eventTime=0},
2022-09-05T05:19:03.9485565Z Sep 05 05:19:03 PulsarMessage{id=148:15:0, 
value=OQNrSEYkFo, eventTime=0},
2022-09-05T05:19:03.9486121Z Sep 05 05:19:03 PulsarMessage{id=148:16:0, 
value=oLuIyaJZrI, eventTime=0},
2022-09-05T05:19:03.9486660Z Sep 05 05:19:03 PulsarMessage{id=148:17:0, 
value=PfbbxVuQKh, eventTime=0},
2022-09-05T05:19:03.9487384Z Sep 05 05:19:03 PulsarMessage{id=148:18:0, 
value=KeIgSeYDxM, eventTime=0},
2022-09-05T05:19:03.9487953Z Sep 05 05:19:03 PulsarMessage{id=148:19:0, 
value=KZkeATFOln, eventTime=0}]
2022-09-05T05:19:03.9488393Z Sep 05 05:19:03 [INFO] 
2022-09-05T05:19:03.9488819Z Sep 05 05:19:03 [ERROR] Tests run: 142, Failures: 
1, Errors: 0, Skipped: 0 {code}

> PulsarUnorderedPartitionSplitReaderTest.consumeMessageCreatedBeforeHandleSplitsChangesAndResetToEarliestPosition
>  failed with AssertionError
> ---
>
> Key: FLINK-27917
> URL: https://issues.apache.org/jira/browse/FLINK-27917
> Project: Flink
>  Issue Type: Sub-task
>  Components: Connectors / Pulsar
>Affects Versions: 1.14.5, 1.15.1
>Reporter: Huang Xingbo
>Assignee: Yufan Sheng
>Priority: Major
>  Labels: pull-request-available, test-stability
> Fix For: 1.16.0, 1.14.6, 1.15.3
>
>
> {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, 
>

[jira] [Commented] (FLINK-27917) PulsarUnorderedPartitionSplitReaderTest.consumeMessageCreatedBeforeHandleSplitsChangesAndResetToEarliestPosition failed with AssertionError

2022-08-22 Thread Zili Chen (Jira) 


[ 
https://issues.apache.org/jira/browse/FLINK-27917?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17583292#comment-17583292
 ] 

Zili Chen commented on FLINK-27917:
---

1.14 via 6ce74dd8e671688b79770dacf88fd31924cc2e33
1.15 via a526391a3c6ea6dc88fd408c5a17aeb573811b5f

> PulsarUnorderedPartitionSplitReaderTest.consumeMessageCreatedBeforeHandleSplitsChangesAndResetToEarliestPosition
>  failed with AssertionError
> ---
>
> Key: FLINK-27917
> URL: https://issues.apache.org/jira/browse/FLINK-27917
> Project: Flink
>  Issue Type: Sub-task
>  Components: Connectors / Pulsar
>Affects Versions: 1.14.5, 1.15.1
>Reporter: Huang Xingbo
>Assignee: Yufan Sheng
>Priority: Major
>  Labels: pull-request-available, test-stability
> Fix For: 1.16.0, 1.15.2, 1.14.6
>
>
> {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

[jira] [Commented] (FLINK-27917) PulsarUnorderedPartitionSplitReaderTest.consumeMessageCreatedBeforeHandleSplitsChangesAndResetToEarliestPosition failed with AssertionError

2022-08-14 Thread Yufan Sheng (Jira) 


[ 
https://issues.apache.org/jira/browse/FLINK-27917?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17579401#comment-17579401
 ] 

Yufan Sheng commented on FLINK-27917:
-

[~tison] Can you assign this issue to me? And the PR is ready for this issue.

> PulsarUnorderedPartitionSplitReaderTest.consumeMessageCreatedBeforeHandleSplitsChangesAndResetToEarliestPosition
>  failed with AssertionError
> ---
>
> Key: FLINK-27917
> URL: https://issues.apache.org/jira/browse/FLINK-27917
> Project: Flink
>  Issue Type: Sub-task
>  Components: Connectors / Pulsar
>Affects Versions: 1.16.0
>Reporter: Huang Xingbo
>Priority: Major
>  Labels: pull-request-available, 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 
>

[jira] [Commented] (FLINK-27917) PulsarUnorderedPartitionSplitReaderTest.consumeMessageCreatedBeforeHandleSplitsChangesAndResetToEarliestPosition failed with AssertionError

2022-08-13 Thread Yufan Sheng (Jira) 


[ 
https://issues.apache.org/jira/browse/FLINK-27917?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17579272#comment-17579272
 ] 

Yufan Sheng commented on FLINK-27917:
-

This is the same issue caused by https://github.com/apache/pulsar/pull/16171. I 
will push a hotfix PR for this test issue.

> PulsarUnorderedPartitionSplitReaderTest.consumeMessageCreatedBeforeHandleSplitsChangesAndResetToEarliestPosition
>  failed with AssertionError
> ---
>
> Key: FLINK-27917
> URL: https://issues.apache.org/jira/browse/FLINK-27917
> Project: Flink
>  Issue Type: Sub-task
>  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 
>

[jira] [Commented] (FLINK-27917) PulsarUnorderedPartitionSplitReaderTest.consumeMessageCreatedBeforeHandleSplitsChangesAndResetToEarliestPosition failed with AssertionError

2022-06-29 Thread Robert Metzger (Jira) 


[ 
https://issues.apache.org/jira/browse/FLINK-27917?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17560583#comment-17560583
 ] 

Robert Metzger commented on FLINK-27917:


https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=37363=logs=aa18c3f6-13b8-5f58-86bb-c1cffb239496=502fb6c0-30a2-5e49-c5c2-a00fa3acb203

> 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 
>

[jira] [Commented] (FLINK-27917) PulsarUnorderedPartitionSplitReaderTest.consumeMessageCreatedBeforeHandleSplitsChangesAndResetToEarliestPosition failed with AssertionError

2022-06-06 Thread Huang Xingbo (Jira) 


[ 
https://issues.apache.org/jira/browse/FLINK-27917?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=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 
>