[
https://issues.apache.org/jira/browse/FLINK-25753?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17482282#comment-17482282
]
Hang Ruan commented on FLINK-25753:
-----------------------------------
This test contains 3 phases:
# insert data
# flink job starts to read and set to latest offsets
# add new data and check
All these three phases are submitted by `executeSql`.
But it seems like the third phase will finish before the set to latest offsets
operation in the second phase. It causes that the new data will not be read.
So I need add some sleep time before adding new data. I have tried to use
`CommonTestUtils.waitForAllTaskRunning`, but it does not work.
> KafkaTableITCase.testStartFromGroupOffsetsLatest fails on AZP
> -------------------------------------------------------------
>
> Key: FLINK-25753
> URL: https://issues.apache.org/jira/browse/FLINK-25753
> Project: Flink
> Issue Type: Bug
> Components: Connectors / Kafka
> Affects Versions: 1.15.0
> Reporter: Till Rohrmann
> Assignee: Fabian Paul
> Priority: Critical
> Labels: test-stability
>
> The test {{KafkaTableITCase.testStartFromGroupOffsetsLatest}} fails on AZP
> with
> {code}
> 2022-01-21T08:48:26.7044016Z Jan 21 08:48:26 [ERROR]
> KafkaTableITCase.testStartFromGroupOffsetsLatest Time elapsed: 5.308 s <<<
> ERROR!
> 2022-01-21T08:48:26.7044630Z Jan 21 08:48:26
> java.util.concurrent.TimeoutException: Can not get the expected result.
> 2022-01-21T08:48:26.7047268Z Jan 21 08:48:26 at
> org.apache.flink.core.testutils.CommonTestUtils.waitUtil(CommonTestUtils.java:214)
> 2022-01-21T08:48:26.7048108Z Jan 21 08:48:26 at
> org.apache.flink.core.testutils.CommonTestUtils.waitUtil(CommonTestUtils.java:230)
> 2022-01-21T08:48:26.7048836Z Jan 21 08:48:26 at
> org.apache.flink.streaming.connectors.kafka.table.KafkaTableTestUtils.waitingExpectedResults(KafkaTableTestUtils.java:82)
> 2022-01-21T08:48:26.7049632Z Jan 21 08:48:26 at
> org.apache.flink.streaming.connectors.kafka.table.KafkaTableITCase.testStartFromGroupOffsets(KafkaTableITCase.java:942)
> 2022-01-21T08:48:26.7050427Z Jan 21 08:48:26 at
> org.apache.flink.streaming.connectors.kafka.table.KafkaTableITCase.testStartFromGroupOffsetsLatest(KafkaTableITCase.java:831)
> 2022-01-21T08:48:26.7051077Z Jan 21 08:48:26 at
> sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
> 2022-01-21T08:48:26.7051638Z Jan 21 08:48:26 at
> sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
> 2022-01-21T08:48:26.7052284Z Jan 21 08:48:26 at
> sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
> 2022-01-21T08:48:26.7053008Z Jan 21 08:48:26 at
> java.lang.reflect.Method.invoke(Method.java:498)
> 2022-01-21T08:48:26.7053681Z Jan 21 08:48:26 at
> org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:59)
> 2022-01-21T08:48:26.7054328Z Jan 21 08:48:26 at
> org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
> 2022-01-21T08:48:26.7054976Z Jan 21 08:48:26 at
> org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:56)
> 2022-01-21T08:48:26.7055621Z Jan 21 08:48:26 at
> org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:17)
> 2022-01-21T08:48:26.7056251Z Jan 21 08:48:26 at
> org.junit.internal.runners.statements.RunBefores.evaluate(RunBefores.java:26)
> 2022-01-21T08:48:26.7056904Z Jan 21 08:48:26 at
> org.junit.internal.runners.statements.RunAfters.evaluate(RunAfters.java:27)
> 2022-01-21T08:48:26.7057520Z Jan 21 08:48:26 at
> org.apache.flink.util.TestNameProvider$1.evaluate(TestNameProvider.java:45)
> 2022-01-21T08:48:26.7058445Z Jan 21 08:48:26 at
> org.junit.rules.TestWatcher$1.evaluate(TestWatcher.java:61)
> 2022-01-21T08:48:26.7059155Z Jan 21 08:48:26 at
> org.junit.runners.ParentRunner$3.evaluate(ParentRunner.java:306)
> 2022-01-21T08:48:26.7059779Z Jan 21 08:48:26 at
> org.junit.runners.BlockJUnit4ClassRunner$1.evaluate(BlockJUnit4ClassRunner.java:100)
> 2022-01-21T08:48:26.7060382Z Jan 21 08:48:26 at
> org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:366)
> 2022-01-21T08:48:26.7061036Z Jan 21 08:48:26 at
> org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:103)
> 2022-01-21T08:48:26.7061670Z Jan 21 08:48:26 at
> org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:63)
> 2022-01-21T08:48:26.7062369Z Jan 21 08:48:26 at
> org.junit.runners.ParentRunner$4.run(ParentRunner.java:331)
> 2022-01-21T08:48:26.7063456Z Jan 21 08:48:26 at
> org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:79)
> 2022-01-21T08:48:26.7064218Z Jan 21 08:48:26 at
> org.junit.runners.ParentRunner.runChildren(ParentRunner.java:329)
> 2022-01-21T08:48:26.7064805Z Jan 21 08:48:26 at
> org.junit.runners.ParentRunner.access$100(ParentRunner.java:66)
> 2022-01-21T08:48:26.7065375Z Jan 21 08:48:26 at
> org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:293)
> 2022-01-21T08:48:26.7065919Z Jan 21 08:48:26 at
> org.junit.runners.ParentRunner.run(ParentRunner.java:413)
> 2022-01-21T08:48:26.7066437Z Jan 21 08:48:26 at
> org.junit.runners.Suite.runChild(Suite.java:128)
> 2022-01-21T08:48:26.7066934Z Jan 21 08:48:26 at
> org.junit.runners.Suite.runChild(Suite.java:27)
> 2022-01-21T08:48:26.7067448Z Jan 21 08:48:26 at
> org.junit.runners.ParentRunner$4.run(ParentRunner.java:331)
> 2022-01-21T08:48:26.7067979Z Jan 21 08:48:26 at
> org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:79)
> 2022-01-21T08:48:26.7068601Z Jan 21 08:48:26 at
> org.junit.runners.ParentRunner.runChildren(ParentRunner.java:329)
> 2022-01-21T08:48:26.7069167Z Jan 21 08:48:26 at
> org.junit.runners.ParentRunner.access$100(ParentRunner.java:66)
> 2022-01-21T08:48:26.7069745Z Jan 21 08:48:26 at
> org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:293)
> 2022-01-21T08:48:26.7070398Z Jan 21 08:48:26 at
> org.testcontainers.containers.FailureDetectingExternalResource$1.evaluate(FailureDetectingExternalResource.java:30)
> 2022-01-21T08:48:26.7071065Z Jan 21 08:48:26 at
> org.junit.rules.ExternalResource$1.evaluate(ExternalResource.java:54)
> 2022-01-21T08:48:26.7071644Z Jan 21 08:48:26 at
> org.junit.rules.ExternalResource$1.evaluate(ExternalResource.java:54)
> 2022-01-21T08:48:26.7072328Z Jan 21 08:48:26 at
> org.junit.rules.RunRules.evaluate(RunRules.java:20)
> 2022-01-21T08:48:26.7072930Z Jan 21 08:48:26 at
> org.junit.runners.ParentRunner$3.evaluate(ParentRunner.java:306)
> 2022-01-21T08:48:26.7073561Z Jan 21 08:48:26 at
> org.junit.runners.ParentRunner.run(ParentRunner.java:413)
> 2022-01-21T08:48:26.7074080Z Jan 21 08:48:26 at
> org.junit.runner.JUnitCore.run(JUnitCore.java:137)
> 2022-01-21T08:48:26.7074580Z Jan 21 08:48:26 at
> org.junit.runner.JUnitCore.run(JUnitCore.java:115)
> 2022-01-21T08:48:26.7075162Z Jan 21 08:48:26 at
> org.junit.vintage.engine.execution.RunnerExecutor.execute(RunnerExecutor.java:42)
> 2022-01-21T08:48:26.7075811Z Jan 21 08:48:26 at
> org.junit.vintage.engine.VintageTestEngine.executeAllChildren(VintageTestEngine.java:80)
> 2022-01-21T08:48:26.7076442Z Jan 21 08:48:26 at
> org.junit.vintage.engine.VintageTestEngine.execute(VintageTestEngine.java:72)
> 2022-01-21T08:48:26.7077116Z Jan 21 08:48:26 at
> org.junit.platform.launcher.core.EngineExecutionOrchestrator.execute(EngineExecutionOrchestrator.java:107)
> 2022-01-21T08:48:26.7077973Z Jan 21 08:48:26 at
> org.junit.platform.launcher.core.EngineExecutionOrchestrator.execute(EngineExecutionOrchestrator.java:88)
> 2022-01-21T08:48:26.7078904Z Jan 21 08:48:26 at
> org.junit.platform.launcher.core.EngineExecutionOrchestrator.lambda$execute$0(EngineExecutionOrchestrator.java:54)
> 2022-01-21T08:48:26.7079693Z Jan 21 08:48:26 at
> org.junit.platform.launcher.core.EngineExecutionOrchestrator.withInterceptedStreams(EngineExecutionOrchestrator.java:67)
> 2022-01-21T08:48:26.7080712Z Jan 21 08:48:26 at
> org.junit.platform.launcher.core.EngineExecutionOrchestrator.execute(EngineExecutionOrchestrator.java:52)
> 2022-01-21T08:48:26.7081383Z Jan 21 08:48:26 at
> org.junit.platform.launcher.core.DefaultLauncher.execute(DefaultLauncher.java:114)
> 2022-01-21T08:48:26.7082019Z Jan 21 08:48:26 at
> org.junit.platform.launcher.core.DefaultLauncher.execute(DefaultLauncher.java:86)
> 2022-01-21T08:48:26.7082949Z Jan 21 08:48:26 at
> org.junit.platform.launcher.core.DefaultLauncherSession$DelegatingLauncher.execute(DefaultLauncherSession.java:86)
> 2022-01-21T08:48:26.7083840Z Jan 21 08:48:26 at
> org.junit.platform.launcher.core.SessionPerRequestLauncher.execute(SessionPerRequestLauncher.java:53)
> 2022-01-21T08:48:26.7084561Z Jan 21 08:48:26 at
> org.apache.maven.surefire.junitplatform.JUnitPlatformProvider.execute(JUnitPlatformProvider.java:188)
> 2022-01-21T08:48:26.7085276Z Jan 21 08:48:26 at
> org.apache.maven.surefire.junitplatform.JUnitPlatformProvider.invokeAllTests(JUnitPlatformProvider.java:154)
> 2022-01-21T08:48:26.7086184Z Jan 21 08:48:26 at
> org.apache.maven.surefire.junitplatform.JUnitPlatformProvider.invoke(JUnitPlatformProvider.java:124)
> 2022-01-21T08:48:26.7086873Z Jan 21 08:48:26 at
> org.apache.maven.surefire.booter.ForkedBooter.runSuitesInProcess(ForkedBooter.java:428)
> 2022-01-21T08:48:26.7087545Z Jan 21 08:48:26 at
> org.apache.maven.surefire.booter.ForkedBooter.execute(ForkedBooter.java:162)
> 2022-01-21T08:48:26.7088159Z Jan 21 08:48:26 at
> org.apache.maven.surefire.booter.ForkedBooter.run(ForkedBooter.java:562)
> 2022-01-21T08:48:26.7088755Z Jan 21 08:48:26 at
> org.apache.maven.surefire.booter.ForkedBooter.main(ForkedBooter.java:548)
> {code}
> https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=29867&view=logs&j=c5f0071e-1851-543e-9a45-9ac140befc32&t=15a22db7-8faa-5b34-3920-d33c9f0ca23c&l=35254
--
This message was sent by Atlassian Jira
(v8.20.1#820001)
