Yun Gao created FLINK-25166:
-------------------------------
Summary: 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
{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)
