You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Matthias Pohl (Jira)" <ji...@apache.org> on 2022/12/23 08:01:00 UTC
[jira] [Commented] (FLINK-30298) KafkaTableITCase.testStartFromGroupOffsetsNone failed due to timeout
[ https://issues.apache.org/jira/browse/FLINK-30298?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17651531#comment-17651531 ]
Matthias Pohl commented on FLINK-30298:
---------------------------------------
Here's another one: https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=44191&view=logs&j=fa307d6d-91b1-5ab6-d460-ef50f552b1fe&t=21eae189-b04c-5c04-662b-17dc80ffc83a&l=37378
This time, we see the test failure in {{KafkaTableITCase.testKafkaSourceSinkWithKeyAndFullValue}} which is also caused by a request timeout:
{code}
Dec 23 02:39:07 [ERROR] KafkaTableITCase.testKafkaSourceSinkWithKeyAndFullValue Time elapsed: 31.81 s <<< ERROR!
Dec 23 02:39:07 java.lang.IllegalStateException: Fail to create topic [key_full_value_topic_avro_814ad733-9fb0-4afe-866d-d5677d114196 partitions: 1 replication factor: 1].
Dec 23 02:39:07 at org.apache.flink.streaming.connectors.kafka.table.KafkaTableTestBase.createTestTopic(KafkaTableTestBase.java:143)
Dec 23 02:39:07 at org.apache.flink.streaming.connectors.kafka.table.KafkaTableITCase.testKafkaSourceSinkWithKeyAndFullValue(KafkaTableITCase.java:453)
Dec 23 02:39:07 at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
Dec 23 02:39:07 at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
Dec 23 02:39:07 at java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
Dec 23 02:39:07 at java.base/java.lang.reflect.Method.invoke(Method.java:566)
Dec 23 02:39:07 at org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:59)
Dec 23 02:39:07 at org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
Dec 23 02:39:07 at org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:56)
Dec 23 02:39:07 at org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:17)
Dec 23 02:39:07 at org.junit.internal.runners.statements.RunBefores.evaluate(RunBefores.java:26)
Dec 23 02:39:07 at org.junit.internal.runners.statements.RunAfters.evaluate(RunAfters.java:27)
Dec 23 02:39:07 at org.apache.flink.util.TestNameProvider$1.evaluate(TestNameProvider.java:45)
Dec 23 02:39:07 at org.junit.rules.TestWatcher$1.evaluate(TestWatcher.java:61)
Dec 23 02:39:07 at org.junit.runners.ParentRunner$3.evaluate(ParentRunner.java:306)
Dec 23 02:39:07 at org.junit.runners.BlockJUnit4ClassRunner$1.evaluate(BlockJUnit4ClassRunner.java:100)
Dec 23 02:39:07 at org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:366)
Dec 23 02:39:07 at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:103)
Dec 23 02:39:07 at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:63)
Dec 23 02:39:07 at org.junit.runners.ParentRunner$4.run(ParentRunner.java:331)
Dec 23 02:39:07 at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:79)
Dec 23 02:39:07 at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:329)
Dec 23 02:39:07 at org.junit.runners.ParentRunner.access$100(ParentRunner.java:66)
Dec 23 02:39:07 at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:293)
Dec 23 02:39:07 at org.junit.runners.ParentRunner.run(ParentRunner.java:413)
Dec 23 02:39:07 at org.junit.runners.Suite.runChild(Suite.java:128)
Dec 23 02:39:07 at org.junit.runners.Suite.runChild(Suite.java:27)
Dec 23 02:39:07 at org.junit.runners.ParentRunner$4.run(ParentRunner.java:331)
Dec 23 02:39:07 at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:79)
Dec 23 02:39:07 at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:329)
Dec 23 02:39:07 at org.junit.runners.ParentRunner.access$100(ParentRunner.java:66)
Dec 23 02:39:07 at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:293)
Dec 23 02:39:07 at org.testcontainers.containers.FailureDetectingExternalResource$1.evaluate(FailureDetectingExternalResource.java:30)
Dec 23 02:39:07 at org.junit.rules.ExternalResource$1.evaluate(ExternalResource.java:54)
Dec 23 02:39:07 at org.junit.rules.ExternalResource$1.evaluate(ExternalResource.java:54)
Dec 23 02:39:07 at org.junit.rules.RunRules.evaluate(RunRules.java:20)
Dec 23 02:39:07 at org.junit.runners.ParentRunner$3.evaluate(ParentRunner.java:306)
Dec 23 02:39:07 at org.junit.runners.ParentRunner.run(ParentRunner.java:413)
Dec 23 02:39:07 at org.junit.runner.JUnitCore.run(JUnitCore.java:137)
Dec 23 02:39:07 at org.junit.runner.JUnitCore.run(JUnitCore.java:115)
Dec 23 02:39:07 at org.junit.vintage.engine.execution.RunnerExecutor.execute(RunnerExecutor.java:42)
Dec 23 02:39:07 at org.junit.vintage.engine.VintageTestEngine.executeAllChildren(VintageTestEngine.java:80)
Dec 23 02:39:07 at org.junit.vintage.engine.VintageTestEngine.execute(VintageTestEngine.java:72)
Dec 23 02:39:07 at org.junit.platform.launcher.core.EngineExecutionOrchestrator.execute(EngineExecutionOrchestrator.java:107)
Dec 23 02:39:07 at org.junit.platform.launcher.core.EngineExecutionOrchestrator.execute(EngineExecutionOrchestrator.java:88)
Dec 23 02:39:07 at org.junit.platform.launcher.core.EngineExecutionOrchestrator.lambda$execute$0(EngineExecutionOrchestrator.java:54)
Dec 23 02:39:07 at org.junit.platform.launcher.core.EngineExecutionOrchestrator.withInterceptedStreams(EngineExecutionOrchestrator.java:67)
Dec 23 02:39:07 at org.junit.platform.launcher.core.EngineExecutionOrchestrator.execute(EngineExecutionOrchestrator.java:52)
Dec 23 02:39:07 at org.junit.platform.launcher.core.DefaultLauncher.execute(DefaultLauncher.java:114)
Dec 23 02:39:07 at org.junit.platform.launcher.core.DefaultLauncher.execute(DefaultLauncher.java:86)
Dec 23 02:39:07 at org.junit.platform.launcher.core.DefaultLauncherSession$DelegatingLauncher.execute(DefaultLauncherSession.java:86)
Dec 23 02:39:07 at org.junit.platform.launcher.core.SessionPerRequestLauncher.execute(SessionPerRequestLauncher.java:53)
Dec 23 02:39:07 at org.apache.maven.surefire.junitplatform.JUnitPlatformProvider.execute(JUnitPlatformProvider.java:188)
Dec 23 02:39:07 at org.apache.maven.surefire.junitplatform.JUnitPlatformProvider.invokeAllTests(JUnitPlatformProvider.java:154)
Dec 23 02:39:07 at org.apache.maven.surefire.junitplatform.JUnitPlatformProvider.invoke(JUnitPlatformProvider.java:124)
Dec 23 02:39:07 at org.apache.maven.surefire.booter.ForkedBooter.runSuitesInProcess(ForkedBooter.java:428)
Dec 23 02:39:07 at org.apache.maven.surefire.booter.ForkedBooter.execute(ForkedBooter.java:162)
Dec 23 02:39:07 at org.apache.maven.surefire.booter.ForkedBooter.run(ForkedBooter.java:562)
Dec 23 02:39:07 at org.apache.maven.surefire.booter.ForkedBooter.main(ForkedBooter.java:548)
Dec 23 02:39:07 Caused by: java.util.concurrent.ExecutionException: org.apache.kafka.common.errors.TimeoutException: The request timed out.
Dec 23 02:39:07 at java.base/java.util.concurrent.CompletableFuture.reportGet(CompletableFuture.java:395)
Dec 23 02:39:07 at java.base/java.util.concurrent.CompletableFuture.get(CompletableFuture.java:1999)
Dec 23 02:39:07 at org.apache.kafka.common.internals.KafkaFutureImpl.get(KafkaFutureImpl.java:165)
Dec 23 02:39:07 at org.apache.flink.streaming.connectors.kafka.table.KafkaTableTestBase.createTestTopic(KafkaTableTestBase.java:140)
Dec 23 02:39:07 ... 58 more
Dec 23 02:39:07 Caused by: org.apache.kafka.common.errors.TimeoutException: The request timed out.
{code}
> KafkaTableITCase.testStartFromGroupOffsetsNone failed due to timeout
> --------------------------------------------------------------------
>
> Key: FLINK-30298
> URL: https://issues.apache.org/jira/browse/FLINK-30298
> Project: Flink
> Issue Type: Bug
> Components: Connectors / Kafka
> Affects Versions: 1.17.0
> Reporter: Matthias Pohl
> Priority: Major
> Labels: test-stability
>
> KafkaTableITCase.testStartFromGroupOffsetsNone failed due to timeout in the following build:
> {code:java}
> Dec 03 01:07:31 org.assertj.core.error.AssertJMultipleFailuresError:
> Dec 03 01:07:31
> Dec 03 01:07:31 Multiple Failures (1 failure)
> Dec 03 01:07:31 -- failure 1 --
> Dec 03 01:07:31 [Any cause is instance of class 'class org.apache.kafka.clients.consumer.NoOffsetForPartitionException']
> Dec 03 01:07:31 Expecting any element of:
> Dec 03 01:07:31 [java.lang.IllegalStateException: Fail to create topic [groupOffset_json_dc640086-d1f1-48b8-ad7a-f83d33b6a03c partitions: 4 replication factor: 1].
> Dec 03 01:07:31 at org.apache.flink.streaming.connectors.kafka.table.KafkaTableTestBase.createTestTopic(KafkaTableTestBase.java:143)
> Dec 03 01:07:31 at org.apache.flink.streaming.connectors.kafka.table.KafkaTableITCase.startFromGroupOffset(KafkaTableITCase.java:881)
> Dec 03 01:07:31 at org.apache.flink.streaming.connectors.kafka.table.KafkaTableITCase.testStartFromGroupOffsetsWithNoneResetStrategy(KafkaTableITCase.java:981)
> Dec 03 01:07:31 ...(64 remaining lines not displayed - this can be changed with Assertions.setMaxStackTraceElementsDisplayed),
> Dec 03 01:07:31 java.util.concurrent.ExecutionException: org.apache.kafka.common.errors.TimeoutException: The request timed out.
> Dec 03 01:07:31 at java.base/java.util.concurrent.CompletableFuture.reportGet(CompletableFuture.java:395)
> Dec 03 01:07:31 at java.base/java.util.concurrent.CompletableFuture.get(CompletableFuture.java:1999)
> Dec 03 01:07:31 at org.apache.kafka.common.internals.KafkaFutureImpl.get(KafkaFutureImpl.java:165)
> Dec 03 01:07:31 ...(67 remaining lines not displayed - this can be changed with Assertions.setMaxStackTraceElementsDisplayed),
> Dec 03 01:07:31 org.apache.kafka.common.errors.TimeoutException: The request timed out.
> Dec 03 01:07:31 ]
> Dec 03 01:07:31 to satisfy the given assertions requirements but none did:
> [...] {code}
> https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=43692&view=logs&j=fa307d6d-91b1-5ab6-d460-ef50f552b1fe&t=21eae189-b04c-5c04-662b-17dc80ffc83a&l=37708
--
This message was sent by Atlassian Jira
(v8.20.10#820010)