[
https://issues.apache.org/jira/browse/FLINK-25166?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17453970#comment-17453970
]
Yun Gao commented on FLINK-25166:
---------------------------------
The issue could not be reproduced in Idea. We might need to increase its
priority if it keeps fail the master cron pipeline.
> UpsertKafkaDynamicTableFactoryTest failed on azure
> --------------------------------------------------
>
> Key: FLINK-25166
> URL: https://issues.apache.org/jira/browse/FLINK-25166
> Project: Flink
> Issue Type: Bug
> Components: Connectors / Kafka
> Affects Versions: 1.15.0
> Reporter: Yun Gao
> Assignee: Fabian Paul
> Priority: Critical
> Labels: test-stability
>
> {code:java}
> 2021-12-04T01:23:22.9044771Z Dec 04 01:23:22 [ERROR]
> org.apache.flink.streaming.connectors.kafka.table.UpsertKafkaDynamicTableFactoryTest.testCreateSourceTableWithoutPK
> Time elapsed: 0.117 s <<< FAILURE!
> 2021-12-04T01:23:22.9046338Z Dec 04 01:23:22 java.lang.AssertionError:
> 2021-12-04T01:23:22.9047372Z Dec 04 01:23:22
> 2021-12-04T01:23:22.9050240Z Dec 04 01:23:22 Expected: (an instance of
> org.apache.flink.table.api.ValidationException and Expected failure cause is
> <org.apache.flink.table.api.ValidationException: 'upsert-kafka' tables
> require to define a PRIMARY KEY constraint. The PRIMARY KEY specifies which
> columns should be read from or write to the Kafka message key. The PRIMARY
> KEY also defines records in the 'upsert-kafka' table should update or delete
> on which keys.>)
> 2021-12-04T01:23:22.9054889Z Dec 04 01:23:22 but: Expected failure cause
> is <org.apache.flink.table.api.ValidationException: 'upsert-kafka' tables
> require to define a PRIMARY KEY constraint. The PRIMARY KEY specifies which
> columns should be read from or write to the Kafka message key. The PRIMARY
> KEY also defines records in the 'upsert-kafka' table should update or delete
> on which keys.> The throwable
> <org.apache.flink.table.api.ValidationException: Unable to create a source
> for reading table 'default.default.t1'.
> 2021-12-04T01:23:22.9057732Z Dec 04 01:23:22
> 2021-12-04T01:23:22.9058670Z Dec 04 01:23:22 Table options are:
> 2021-12-04T01:23:22.9059950Z Dec 04 01:23:22
> 2021-12-04T01:23:22.9061212Z Dec 04 01:23:22 'connector'='upsert-kafka'
> 2021-12-04T01:23:22.9062212Z Dec 04 01:23:22 'key.format'='test-format'
> 2021-12-04T01:23:22.9063039Z Dec 04 01:23:22
> 'key.test-format.changelog-mode'='I'
> 2021-12-04T01:23:22.9063986Z Dec 04 01:23:22 'key.test-format.delimiter'=','
> 2021-12-04T01:23:22.9065324Z Dec 04 01:23:22
> 'key.test-format.fail-on-missing'='true'
> 2021-12-04T01:23:22.9066125Z Dec 04 01:23:22
> 'properties.bootstrap.servers'='dummy'
> 2021-12-04T01:23:22.9066944Z Dec 04 01:23:22 'topic'='sourceTopic_1'
> 2021-12-04T01:23:22.9067839Z Dec 04 01:23:22 'value.format'='test-format'
> 2021-12-04T01:23:22.9068964Z Dec 04 01:23:22
> 'value.test-format.changelog-mode'='I'
> 2021-12-04T01:23:22.9069827Z Dec 04 01:23:22 'value.test-format.delimiter'=','
> 2021-12-04T01:23:22.9071583Z Dec 04 01:23:22
> 'value.test-format.fail-on-missing'='true'> does not contain the expected
> failure cause <org.apache.flink.table.api.ValidationException: 'upsert-kafka'
> tables require to define a PRIMARY KEY constraint. The PRIMARY KEY specifies
> which columns should be read from or write to the Kafka message key. The
> PRIMARY KEY also defines records in the 'upsert-kafka' table should update or
> delete on which keys.>
> 2021-12-04T01:23:22.9073152Z Dec 04 01:23:22 Stacktrace was:
> org.apache.flink.table.api.ValidationException: Unable to create a source for
> reading table 'default.default.t1'.
> 2021-12-04T01:23:22.9073787Z Dec 04 01:23:22
> 2021-12-04T01:23:22.9074202Z Dec 04 01:23:22 Table options are:
> 2021-12-04T01:23:22.9074871Z Dec 04 01:23:22
> 2021-12-04T01:23:22.9075467Z Dec 04 01:23:22 'connector'='upsert-kafka'
> 2021-12-04T01:23:22.9076416Z Dec 04 01:23:22 'key.format'='test-format'
> 2021-12-04T01:23:22.9077449Z Dec 04 01:23:22
> 'key.test-format.changelog-mode'='I'
> 2021-12-04T01:23:22.9078047Z Dec 04 01:23:22 'key.test-format.delimiter'=','
> 2021-12-04T01:23:22.9078684Z Dec 04 01:23:22
> 'key.test-format.fail-on-missing'='true'
> 2021-12-04T01:23:22.9079338Z Dec 04 01:23:22
> 'properties.bootstrap.servers'='dummy'
> 2021-12-04T01:23:22.9079984Z Dec 04 01:23:22 'topic'='sourceTopic_1'
> 2021-12-04T01:23:22.9080573Z Dec 04 01:23:22 'value.format'='test-format'
> 2021-12-04T01:23:22.9081181Z Dec 04 01:23:22
> 'value.test-format.changelog-mode'='I'
> 2021-12-04T01:23:22.9081869Z Dec 04 01:23:22 'value.test-format.delimiter'=','
> 2021-12-04T01:23:22.9082502Z Dec 04 01:23:22
> 'value.test-format.fail-on-missing'='true'
> 2021-12-04T01:23:22.9083130Z Dec 04 01:23:22 at
> org.apache.flink.table.factories.FactoryUtil.createDynamicTableSource(FactoryUtil.java:151)
> 2021-12-04T01:23:22.9084069Z Dec 04 01:23:22 at
> org.apache.flink.table.factories.utils.FactoryMocks.createTableSource(FactoryMocks.java:58)
> 2021-12-04T01:23:22.9085335Z Dec 04 01:23:22 at
> org.apache.flink.streaming.connectors.kafka.table.UpsertKafkaDynamicTableFactoryTest.testCreateSourceTableWithoutPK(UpsertKafkaDynamicTableFactoryTest.java:413)
> 2021-12-04T01:23:22.9087234Z Dec 04 01:23:22 at
> java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
> 2021-12-04T01:23:22.9088432Z Dec 04 01:23:22 at
> java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
> 2021-12-04T01:23:22.9089635Z Dec 04 01:23:22 at
> java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
> 2021-12-04T01:23:22.9090624Z Dec 04 01:23:22 at
> java.base/java.lang.reflect.Method.invoke(Method.java:566)
> 2021-12-04T01:23:22.9091202Z Dec 04 01:23:22 at
> org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:59)
> 2021-12-04T01:23:22.9092013Z Dec 04 01:23:22 at
> org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
> 2021-12-04T01:23:22.9092699Z Dec 04 01:23:22 at
> org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:56)
> 2021-12-04T01:23:22.9093385Z Dec 04 01:23:22 at
> org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:17)
> 2021-12-04T01:23:22.9094096Z Dec 04 01:23:22 at
> org.junit.rules.ExpectedException$ExpectedExceptionStatement.evaluate(ExpectedException.java:258)
> 2021-12-04T01:23:22.9095110Z Dec 04 01:23:22 at
> org.apache.flink.util.TestNameProvider$1.evaluate(TestNameProvider.java:45)
> 2021-12-04T01:23:22.9095817Z Dec 04 01:23:22 at
> org.junit.rules.TestWatcher$1.evaluate(TestWatcher.java:61)
> 2021-12-04T01:23:22.9096630Z Dec 04 01:23:22 at
> org.junit.runners.ParentRunner$3.evaluate(ParentRunner.java:306)
> 2021-12-04T01:23:22.9097273Z Dec 04 01:23:22 at
> org.junit.runners.BlockJUnit4ClassRunner$1.evaluate(BlockJUnit4ClassRunner.java:100)
> 2021-12-04T01:23:22.9097859Z Dec 04 01:23:22 at
> org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:366)
> 2021-12-04T01:23:22.9098505Z Dec 04 01:23:22 at
> org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:103)
> 2021-12-04T01:23:22.9099176Z Dec 04 01:23:22 at
> org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:63)
> 2021-12-04T01:23:22.9099802Z Dec 04 01:23:22 at
> org.junit.runners.ParentRunner$4.run(ParentRunner.java:331)
> 2021-12-04T01:23:22.9100404Z Dec 04 01:23:22 at
> org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:79)
> 2021-12-04T01:23:22.9101013Z Dec 04 01:23:22 at
> org.junit.runners.ParentRunner.runChildren(ParentRunner.java:329)
> 2021-12-04T01:23:22.9101749Z Dec 04 01:23:22 at
> org.junit.runners.ParentRunner.access$100(ParentRunner.java:66)
> 2021-12-04T01:23:22.9102360Z Dec 04 01:23:22 at
> org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:293)
> 2021-12-04T01:23:22.9102907Z Dec 04 01:23:22 at
> org.junit.runners.ParentRunner$3.evaluate(ParentRunner.java:306)
> 2021-12-04T01:23:22.9103511Z Dec 04 01:23:22 at
> org.junit.runners.ParentRunner.run(ParentRunner.java:413)
> 2021-12-04T01:23:22.9104083Z Dec 04 01:23:22 at
> org.junit.runner.JUnitCore.run(JUnitCore.java:137)
> 2021-12-04T01:23:22.9104831Z Dec 04 01:23:22 at
> org.junit.runner.JUnitCore.run(JUnitCore.java:115)
> 2021-12-04T01:23:22.9105699Z Dec 04 01:23:22 at
> org.junit.vintage.engine.execution.RunnerExecutor.execute(RunnerExecutor.java:42)
> 2021-12-04T01:23:22.9107364Z Dec 04 01:23:22 at
> org.junit.vintage.engine.VintageTestEngine.executeAllChildren(VintageTestEngine.java:80)
> 2021-12-04T01:23:22.9108170Z Dec 04 01:23:22 at
> org.junit.vintage.engine.VintageTestEngine.execute(VintageTestEngine.java:72)
> 2021-12-04T01:23:22.9108842Z Dec 04 01:23:22 at
> org.junit.platform.launcher.core.EngineExecutionOrchestrator.execute(EngineExecutionOrchestrator.java:107)
> 2021-12-04T01:23:22.9109840Z Dec 04 01:23:22 at
> org.junit.platform.launcher.core.EngineExecutionOrchestrator.execute(EngineExecutionOrchestrator.java:88)
> 2021-12-04T01:23:22.9111417Z Dec 04 01:23:22 at
> org.junit.platform.launcher.core.EngineExecutionOrchestrator.lambda$execute$0(EngineExecutionOrchestrator.java:54)
> 2021-12-04T01:23:22.9112749Z Dec 04 01:23:22 at
> org.junit.platform.launcher.core.EngineExecutionOrchestrator.withInterceptedStreams(EngineExecutionOrchestrator.java:67)
> 2021-12-04T01:23:22.9114055Z Dec 04 01:23:22 at
> org.junit.platform.launcher.core.EngineExecutionOrchestrator.execute(EngineExecutionOrchestrator.java:52)
> 2021-12-04T01:23:22.9115432Z Dec 04 01:23:22 at
> org.junit.platform.launcher.core.DefaultLauncher.execute(DefaultLauncher.java:114)
> 2021-12-04T01:23:22.9116270Z Dec 04 01:23:22 at
> org.junit.platform.launcher.core.DefaultLauncher.execute(DefaultLauncher.java:86)
> 2021-12-04T01:23:22.9117025Z Dec 04 01:23:22 at
> org.junit.platform.launcher.core.DefaultLauncherSession$DelegatingLauncher.execute(DefaultLauncherSession.java:86)
> 2021-12-04T01:23:22.9117792Z Dec 04 01:23:22 at
> org.junit.platform.launcher.core.SessionPerRequestLauncher.execute(SessionPerRequestLauncher.java:53)
> 2021-12-04T01:23:22.9118480Z Dec 04 01:23:22 at
> org.apache.maven.surefire.junitplatform.JUnitPlatformProvider.execute(JUnitPlatformProvider.java:188)
> 2021-12-04T01:23:22.9119256Z Dec 04 01:23:22 at
> org.apache.maven.surefire.junitplatform.JUnitPlatformProvider.invokeAllTests(JUnitPlatformProvider.java:154)
> 2021-12-04T01:23:22.9120005Z Dec 04 01:23:22 at
> org.apache.maven.surefire.junitplatform.JUnitPlatformProvider.invoke(JUnitPlatformProvider.java:128)
> 2021-12-04T01:23:22.9120717Z Dec 04 01:23:22 at
> org.apache.maven.surefire.booter.ForkedBooter.runSuitesInProcess(ForkedBooter.java:428)
> 2021-12-04T01:23:22.9121470Z Dec 04 01:23:22 at
> org.apache.maven.surefire.booter.ForkedBooter.execute(ForkedBooter.java:162)
> 2021-12-04T01:23:22.9122330Z Dec 04 01:23:22 at
> org.apache.maven.surefire.booter.ForkedBooter.run(ForkedBooter.java:562)
> 2021-12-04T01:23:22.9122964Z Dec 04 01:23:22 at
> org.apache.maven.surefire.booter.ForkedBooter.main(ForkedBooter.java:548)
> 2021-12-04T01:23:22.9123542Z Dec 04 01:23:22 Caused by:
> java.util.NoSuchElementException
> 2021-12-04T01:23:22.9124093Z Dec 04 01:23:22 at
> org.apache.flink.table.factories.ServiceLoaderUtil$SafeIterator.next(ServiceLoaderUtil.java:97)
> 2021-12-04T01:23:22.9125055Z Dec 04 01:23:22 at
> org.apache.flink.table.factories.ServiceLoaderUtil$SafeIterator.next(ServiceLoaderUtil.java:71)
> 2021-12-04T01:23:22.9125729Z Dec 04 01:23:22 at
> java.base/java.util.Iterator.forEachRemaining(Iterator.java:133)
> 2021-12-04T01:23:22.9126369Z Dec 04 01:23:22 at
> org.apache.flink.table.factories.FactoryUtil.discoverFactories(FactoryUtil.java:693)
> 2021-12-04T01:23:22.9127053Z Dec 04 01:23:22 at
> org.apache.flink.table.factories.FactoryUtil.discoverFactory(FactoryUtil.java:443)
> 2021-12-04T01:23:22.9127740Z Dec 04 01:23:22 at
> org.apache.flink.table.factories.FactoryUtil.discoverTableFactory(FactoryUtil.java:629)
> 2021-12-04T01:23:22.9128439Z Dec 04 01:23:22 at
> org.apache.flink.table.factories.FactoryUtil.createDynamicTableSource(FactoryUtil.java:147)
> 2021-12-04T01:23:22.9129140Z Dec 04 01:23:22 ... 46 more
> 2021-12-04T01:23:22.9129502Z Dec 04 01:23:22
> 2021-12-04T01:23:22.9129967Z Dec 04 01:23:22 at
> org.hamcrest.MatcherAssert.assertThat(MatcherAssert.java:20)
> 2021-12-04T01:23:22.9130531Z Dec 04 01:23:22 at
> org.junit.Assert.assertThat(Assert.java:964)
> 2021-12-04T01:23:22.9131000Z Dec 04 01:23:22 at
> org.junit.Assert.assertThat(Assert.java:930)
> 2021-12-04T01:23:22.9131664Z Dec 04 01:23:22 at
> org.junit.rules.ExpectedException.handleException(ExpectedException.java:271)
> 2021-12-04T01:23:22.9132320Z Dec 04 01:23:22 at
> org.junit.rules.ExpectedException.access$000(ExpectedException.java:111)
> 2021-12-04T01:23:22.9132980Z Dec 04 01:23:22 at
> org.junit.rules.ExpectedException$ExpectedExceptionStatement.evaluate(ExpectedException.java:260)
> 2021-12-04T01:23:22.9133660Z Dec 04 01:23:22 at
> org.apache.flink.util.TestNameProvider$1.evaluate(TestNameProvider.java:45)
> 2021-12-04T01:23:22.9134612Z Dec 04 01:23:22 at
> org.junit.rules.TestWatcher$1.evaluate(TestWatcher.java:61)
> 2021-12-04T01:23:22.9135235Z Dec 04 01:23:22 at
> org.junit.runners.ParentRunner$3.evaluate(ParentRunner.java:306)
> 2021-12-04T01:23:22.9135820Z Dec 04 01:23:22 at
> org.junit.runners.BlockJUnit4ClassRunner$1.evaluate(BlockJUnit4ClassRunner.java:100)
> 2021-12-04T01:23:22.9136455Z Dec 04 01:23:22 at
> org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:366)
> 2021-12-04T01:23:22.9137078Z Dec 04 01:23:22 at
> org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:103)
> 2021-12-04T01:23:22.9137726Z Dec 04 01:23:22 at
> org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:63)
> 2021-12-04T01:23:22.9138349Z Dec 04 01:23:22 at
> org.junit.runners.ParentRunner$4.run(ParentRunner.java:331)
> 2021-12-04T01:23:22.9138947Z Dec 04 01:23:22 at
> org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:79)
> 2021-12-04T01:23:22.9139558Z Dec 04 01:23:22 at
> org.junit.runners.ParentRunner.runChildren(ParentRunner.java:329)
> 2021-12-04T01:23:22.9140106Z Dec 04 01:23:22 at
> org.junit.runners.ParentRunner.access$100(ParentRunner.java:66)
> 2021-12-04T01:23:22.9140703Z Dec 04 01:23:22 at
> org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:293)
> 2021-12-04T01:23:22.9141371Z Dec 04 01:23:22 at
> org.junit.runners.ParentRunner$3.evaluate(ParentRunner.java:306)
> 2021-12-04T01:23:22.9141966Z Dec 04 01:23:22 at
> org.junit.runners.ParentRunner.run(ParentRunner.java:413)
> 2021-12-04T01:23:22.9142532Z Dec 04 01:23:22 at
> org.junit.runner.JUnitCore.run(JUnitCore.java:137)
> 2021-12-04T01:23:22.9143084Z Dec 04 01:23:22 at
> org.junit.runner.JUnitCore.run(JUnitCore.java:115)
> 2021-12-04T01:23:22.9143689Z Dec 04 01:23:22 at
> org.junit.vintage.engine.execution.RunnerExecutor.execute(RunnerExecutor.java:42)
> 2021-12-04T01:23:22.9144909Z Dec 04 01:23:22 at
> org.junit.vintage.engine.VintageTestEngine.executeAllChildren(VintageTestEngine.java:80)
> 2021-12-04T01:23:22.9145604Z Dec 04 01:23:22 at
> org.junit.vintage.engine.VintageTestEngine.execute(VintageTestEngine.java:72)
> 2021-12-04T01:23:22.9146690Z Dec 04 01:23:22 at
> org.junit.platform.launcher.core.EngineExecutionOrchestrator.execute(EngineExecutionOrchestrator.java:107)
> 2021-12-04T01:23:22.9147931Z Dec 04 01:23:22 at
> org.junit.platform.launcher.core.EngineExecutionOrchestrator.execute(EngineExecutionOrchestrator.java:88)
> 2021-12-04T01:23:22.9149198Z Dec 04 01:23:22 at
> org.junit.platform.launcher.core.EngineExecutionOrchestrator.lambda$execute$0(EngineExecutionOrchestrator.java:54)
> 2021-12-04T01:23:22.9150435Z Dec 04 01:23:22 at
> org.junit.platform.launcher.core.EngineExecutionOrchestrator.withInterceptedStreams(EngineExecutionOrchestrator.java:67)
> 2021-12-04T01:23:22.9151774Z Dec 04 01:23:22 at
> org.junit.platform.launcher.core.EngineExecutionOrchestrator.execute(EngineExecutionOrchestrator.java:52)
> 2021-12-04T01:23:22.9153053Z Dec 04 01:23:22 at
> org.junit.platform.launcher.core.DefaultLauncher.execute(DefaultLauncher.java:114)
> 2021-12-04T01:23:22.9154192Z Dec 04 01:23:22 at
> org.junit.platform.launcher.core.DefaultLauncher.execute(DefaultLauncher.java:86)
> 2021-12-04T01:23:22.9155074Z Dec 04 01:23:22 at
> org.junit.platform.launcher.core.DefaultLauncherSession$DelegatingLauncher.execute(DefaultLauncherSession.java:86)
> 2021-12-04T01:23:22.9155852Z Dec 04 01:23:22 at
> org.junit.platform.launcher.core.SessionPerRequestLauncher.execute(SessionPerRequestLauncher.java:53)
> 2021-12-04T01:23:22.9156606Z Dec 04 01:23:22 at
> org.apache.maven.surefire.junitplatform.JUnitPlatformProvider.execute(JUnitPlatformProvider.java:188)
> 2021-12-04T01:23:22.9157382Z Dec 04 01:23:22 at
> org.apache.maven.surefire.junitplatform.JUnitPlatformProvider.invokeAllTests(JUnitPlatformProvider.java:154)
> 2021-12-04T01:23:22.9158141Z Dec 04 01:23:22 at
> org.apache.maven.surefire.junitplatform.JUnitPlatformProvider.invoke(JUnitPlatformProvider.java:128)
> 2021-12-04T01:23:22.9158870Z Dec 04 01:23:22 at
> org.apache.maven.surefire.booter.ForkedBooter.runSuitesInProcess(ForkedBooter.java:428)
> 2021-12-04T01:23:22.9159552Z Dec 04 01:23:22 at
> org.apache.maven.surefire.booter.ForkedBooter.execute(ForkedBooter.java:162)
> 2021-12-04T01:23:22.9160351Z Dec 04 01:23:22 at
> org.apache.maven.surefire.booter.ForkedBooter.run(ForkedBooter.java:562)
> 2021-12-04T01:23:22.9161038Z Dec 04 01:23:22 at
> org.apache.maven.surefire.booter.ForkedBooter.main(ForkedBooter.java:548)
> {code}
> [https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=27550&view=logs&j=ce8f3cc3-c1ea-5281-f5eb-df9ebd24947f&t=918e890f-5ed9-5212-a25e-962628fb4bc5&l=6486]
>
> There are also other tests in this suite failed due to the same reason.
--
This message was sent by Atlassian Jira
(v8.20.1#820001)
