-
Bug
-
Resolution: Done
-
Major
-
None
-
None
-
False
-
None
-
False
Running RecordsStreamProducerIT failed as below:
2022-12-04T15:48:34.3366086Z [ERROR] Tests run: 89, Failures: 1, Errors: 2, Skipped: 0, Time elapsed: 268.979 s <<< FAILURE! - in io.debezium.connector.postgresql.RecordsStreamProducerIT 2022-12-04T15:48:34.3371107Z [ERROR] io.debezium.connector.postgresql.RecordsStreamProducerIT.shouldReceiveChangesForReplicaIdentityFullTableWithToastedValueTableFromStreamingFullDiff Time elapsed: 2.994 s <<< FAILURE! 2022-12-04T15:48:34.3372600Z org.junit.ComparisonFailure: expected:<null> but was:<Struct{pk=1}> 2022-12-04T15:48:34.3373899Z at java.base/jdk.internal.reflect.NativeConstructorAccessorImpl.newInstance0(Native Method) 2022-12-04T15:48:34.3374687Z at java.base/jdk.internal.reflect.NativeConstructorAccessorImpl.newInstance(NativeConstructorAccessorImpl.java:77) 2022-12-04T15:48:34.3375490Z at java.base/jdk.internal.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45) 2022-12-04T15:48:34.3376189Z at java.base/java.lang.reflect.Constructor.newInstanceWithCaller(Constructor.java:499) 2022-12-04T15:48:34.3376725Z at io.debezium.data.VerifyRecord.isValidInsert(VerifyRecord.java:134) 2022-12-04T15:48:34.3377225Z at io.debezium.data.VerifyRecord.isValidInsert(VerifyRecord.java:237) 2022-12-04T15:48:34.3377920Z at io.debezium.connector.postgresql.RecordsStreamProducerIT.assertRecordInserted(RecordsStreamProducerIT.java:2984) 2022-12-04T15:48:34.3378751Z at io.debezium.connector.postgresql.RecordsStreamProducerIT.assertRecordInserted(RecordsStreamProducerIT.java:3014) 2022-12-04T15:48:34.3379611Z at io.debezium.connector.postgresql.RecordsStreamProducerIT.assertInsert(RecordsStreamProducerIT.java:2947) 2022-12-04T15:48:34.3380378Z at io.debezium.connector.postgresql.RecordsStreamProducerIT.assertInsert(RecordsStreamProducerIT.java:2937) 2022-12-04T15:48:34.3381417Z at io.debezium.connector.postgresql.RecordsStreamProducerIT.testReceiveChangesForReplicaIdentityFullTableWithToastedValue(RecordsStreamProducerIT.java:2610) 2022-12-04T15:48:34.3382944Z at io.debezium.connector.postgresql.RecordsStreamProducerIT.shouldReceiveChangesForReplicaIdentityFullTableWithToastedValueTableFromStreamingFullDiff(RecordsStreamProducerIT.java:1672) 2022-12-04T15:48:34.3384076Z at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) 2022-12-04T15:48:34.3384696Z at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77) 2022-12-04T15:48:34.3385380Z at java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) 2022-12-04T15:48:34.3395632Z at java.base/java.lang.reflect.Method.invoke(Method.java:568) 2022-12-04T15:48:34.3396230Z at org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:59) 2022-12-04T15:48:34.3396813Z at org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12) 2022-12-04T15:48:34.3397427Z at org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:56) 2022-12-04T15:48:34.3398035Z at org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:17) 2022-12-04T15:48:34.3398628Z at org.junit.internal.runners.statements.RunBefores.evaluate(RunBefores.java:26) 2022-12-04T15:48:34.3399200Z at org.junit.internal.runners.statements.RunAfters.evaluate(RunAfters.java:27) 2022-12-04T15:48:34.3400247Z at org.junit.rules.TestWatcher$1.evaluate(TestWatcher.java:61) 2022-12-04T15:48:34.3400689Z at org.junit.runners.ParentRunner$3.evaluate(ParentRunner.java:306) 2022-12-04T15:48:34.3401250Z at org.junit.runners.BlockJUnit4ClassRunner$1.evaluate(BlockJUnit4ClassRunner.java:100) 2022-12-04T15:48:34.3401763Z at org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:366) 2022-12-04T15:48:34.3402288Z at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:103) 2022-12-04T15:48:34.3402867Z at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:63) 2022-12-04T15:48:34.3403369Z at org.junit.runners.ParentRunner$4.run(ParentRunner.java:331) 2022-12-04T15:48:34.3403808Z at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:79) 2022-12-04T15:48:34.3404264Z at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:329) 2022-12-04T15:48:34.3404744Z at org.junit.runners.ParentRunner.access$100(ParentRunner.java:66) 2022-12-04T15:48:34.3405194Z at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:293) 2022-12-04T15:48:34.3405640Z at org.junit.runners.ParentRunner$3.evaluate(ParentRunner.java:306) 2022-12-04T15:48:34.3406079Z at org.junit.runners.ParentRunner.run(ParentRunner.java:413) 2022-12-04T15:48:34.3406784Z at org.apache.maven.surefire.junit4.JUnit4Provider.execute(JUnit4Provider.java:377) 2022-12-04T15:48:34.3407388Z at org.apache.maven.surefire.junit4.JUnit4Provider.executeWithRerun(JUnit4Provider.java:284) 2022-12-04T15:48:34.3408030Z at org.apache.maven.surefire.junit4.JUnit4Provider.executeTestSet(JUnit4Provider.java:248) 2022-12-04T15:48:34.3408637Z at org.apache.maven.surefire.junit4.JUnit4Provider.invoke(JUnit4Provider.java:167) 2022-12-04T15:48:34.3409247Z at org.apache.maven.surefire.booter.ForkedBooter.runSuitesInProcess(ForkedBooter.java:456) 2022-12-04T15:48:34.3425274Z at org.apache.maven.surefire.booter.ForkedBooter.execute(ForkedBooter.java:169) 2022-12-04T15:48:34.3426121Z at org.apache.maven.surefire.booter.ForkedBooter.run(ForkedBooter.java:595) 2022-12-04T15:48:34.3426665Z at org.apache.maven.surefire.booter.ForkedBooter.main(ForkedBooter.java:581) 2022-12-04T15:48:34.3426965Z 2022-12-04T15:48:34.3427579Z [ERROR] io.debezium.connector.postgresql.RecordsStreamProducerIT.shouldReceiveChangesForDeletesDependingOnReplicaIdentity Time elapsed: 3.453 s <<< ERROR! 2022-12-04T15:48:34.3428329Z java.lang.RuntimeException: 2022-12-04T15:48:34.3428870Z org.postgresql.util.PSQLException: ERROR: cannot delete from table "test_table" because it does not have a replica identity and publishes deletes 2022-12-04T15:48:34.3429536Z Hint: To enable deleting from the table, set REPLICA IDENTITY using ALTER TABLE. 2022-12-04T15:48:34.3430145Z at io.debezium.connector.postgresql.TestHelper.execute(TestHelper.java:191) 2022-12-04T15:48:34.3430820Z at io.debezium.connector.postgresql.RecordsStreamProducerIT.executeAndWait(RecordsStreamProducerIT.java:3018) 2022-12-04T15:48:34.3431832Z at io.debezium.connector.postgresql.RecordsStreamProducerIT.shouldReceiveChangesForDeletesDependingOnReplicaIdentity(RecordsStreamProducerIT.java:1045) 2022-12-04T15:48:34.3432736Z at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) 2022-12-04T15:48:34.3433349Z at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77) 2022-12-04T15:48:34.3434029Z at java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) 2022-12-04T15:48:34.3434694Z at java.base/java.lang.reflect.Method.invoke(Method.java:568) 2022-12-04T15:48:34.3435161Z at org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:59) 2022-12-04T15:48:34.3435846Z at org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12) 2022-12-04T15:48:34.3436434Z at org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:56) 2022-12-04T15:48:34.3437260Z at org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:17) 2022-12-04T15:48:34.3437850Z at org.junit.internal.runners.statements.RunBefores.evaluate(RunBefores.java:26) 2022-12-04T15:48:34.3438418Z at org.junit.internal.runners.statements.RunAfters.evaluate(RunAfters.java:27) 2022-12-04T15:48:34.3438909Z at org.junit.rules.TestWatcher$1.evaluate(TestWatcher.java:61) 2022-12-04T15:48:34.3439345Z at org.junit.runners.ParentRunner$3.evaluate(ParentRunner.java:306) 2022-12-04T15:48:34.3439846Z at org.junit.runners.BlockJUnit4ClassRunner$1.evaluate(BlockJUnit4ClassRunner.java:100) 2022-12-04T15:48:34.3440331Z at org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:366) 2022-12-04T15:48:34.3440855Z at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:103) 2022-12-04T15:48:34.3441430Z at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:63) 2022-12-04T15:48:34.3441930Z at org.junit.runners.ParentRunner$4.run(ParentRunner.java:331) 2022-12-04T15:48:34.3442370Z at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:79) 2022-12-04T15:48:34.3442837Z at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:329) 2022-12-04T15:48:34.3443295Z at org.junit.runners.ParentRunner.access$100(ParentRunner.java:66) 2022-12-04T15:48:34.3443867Z at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:293) 2022-12-04T15:48:34.3444311Z at org.junit.runners.ParentRunner$3.evaluate(ParentRunner.java:306) 2022-12-04T15:48:34.3444748Z at org.junit.runners.ParentRunner.run(ParentRunner.java:413) 2022-12-04T15:48:34.3445301Z at org.apache.maven.surefire.junit4.JUnit4Provider.execute(JUnit4Provider.java:377) 2022-12-04T15:48:34.3445922Z at org.apache.maven.surefire.junit4.JUnit4Provider.executeWithRerun(JUnit4Provider.java:284) 2022-12-04T15:48:34.3446546Z at org.apache.maven.surefire.junit4.JUnit4Provider.executeTestSet(JUnit4Provider.java:248) 2022-12-04T15:48:34.3447147Z at org.apache.maven.surefire.junit4.JUnit4Provider.invoke(JUnit4Provider.java:167) 2022-12-04T15:48:34.3447765Z at org.apache.maven.surefire.booter.ForkedBooter.runSuitesInProcess(ForkedBooter.java:456) 2022-12-04T15:48:34.3448372Z at org.apache.maven.surefire.booter.ForkedBooter.execute(ForkedBooter.java:169) 2022-12-04T15:48:34.3448926Z at org.apache.maven.surefire.booter.ForkedBooter.run(ForkedBooter.java:595) 2022-12-04T15:48:34.3449463Z at org.apache.maven.surefire.booter.ForkedBooter.main(ForkedBooter.java:581) 2022-12-04T15:48:34.3450082Z Caused by: org.postgresql.util.PSQLException: ERROR: cannot delete from table "test_table" because it does not have a replica identity and publishes deletes 2022-12-04T15:48:34.3450624Z Hint: To enable deleting from the table, set REPLICA IDENTITY using ALTER TABLE. 2022-12-04T15:48:34.3451175Z at org.postgresql.core.v3.QueryExecutorImpl.receiveErrorResponse(QueryExecutorImpl.java:2676) 2022-12-04T15:48:34.3451808Z at org.postgresql.core.v3.QueryExecutorImpl.processResults(QueryExecutorImpl.java:2366) 2022-12-04T15:48:34.3452393Z at org.postgresql.core.v3.QueryExecutorImpl.execute(QueryExecutorImpl.java:356) 2022-12-04T15:48:34.3452933Z at org.postgresql.jdbc.PgStatement.executeInternal(PgStatement.java:496) 2022-12-04T15:48:34.3453433Z at org.postgresql.jdbc.PgStatement.execute(PgStatement.java:413) 2022-12-04T15:48:34.3453919Z at org.postgresql.jdbc.PgStatement.executeWithFlags(PgStatement.java:333) 2022-12-04T15:48:34.3454447Z at org.postgresql.jdbc.PgStatement.executeCachedSql(PgStatement.java:319) 2022-12-04T15:48:34.3454971Z at org.postgresql.jdbc.PgStatement.executeWithFlags(PgStatement.java:295) 2022-12-04T15:48:34.3455461Z at org.postgresql.jdbc.PgStatement.execute(PgStatement.java:290) 2022-12-04T15:48:34.3455994Z at io.debezium.jdbc.JdbcConnection.executeWithoutCommitting(JdbcConnection.java:1440) 2022-12-04T15:48:34.3456563Z at io.debezium.connector.postgresql.TestHelper.execute(TestHelper.java:178) 2022-12-04T15:48:34.3456940Z ... 33 more 2022-12-04T15:48:34.3457181Z 2022-12-04T15:48:34.3457629Z [ERROR] io.debezium.connector.postgresql.RecordsStreamProducerIT.shouldReceiveChangesForUpdates Time elapsed: 3.95 s <<< ERROR! 2022-12-04T15:48:34.3458220Z java.lang.RuntimeException: 2022-12-04T15:48:34.3458710Z org.postgresql.util.PSQLException: ERROR: cannot update table "test_table" because it does not have a replica identity and publishes updates 2022-12-04T15:48:34.3459246Z Hint: To enable updating the table, set REPLICA IDENTITY using ALTER TABLE. 2022-12-04T15:48:34.3459731Z at io.debezium.connector.postgresql.TestHelper.execute(TestHelper.java:191) 2022-12-04T15:48:34.3460461Z at io.debezium.connector.postgresql.RecordsStreamProducerIT.executeAndWaitForNoRecords(RecordsStreamProducerIT.java:3023) 2022-12-04T15:48:34.3461363Z at io.debezium.connector.postgresql.RecordsStreamProducerIT.shouldReceiveChangesForUpdates(RecordsStreamProducerIT.java:672) 2022-12-04T15:48:34.3462232Z at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) 2022-12-04T15:48:34.3462826Z at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77) 2022-12-04T15:48:34.3463484Z at java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) 2022-12-04T15:48:34.3464258Z at java.base/java.lang.reflect.Method.invoke(Method.java:568) 2022-12-04T15:48:34.3464741Z at org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:59) 2022-12-04T15:48:34.3466654Z at org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12) 2022-12-04T15:48:34.3467311Z at org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:56) 2022-12-04T15:48:34.3467918Z at org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:17) 2022-12-04T15:48:34.3468505Z at org.junit.internal.runners.statements.RunBefores.evaluate(RunBefores.java:26) 2022-12-04T15:48:34.3469073Z at org.junit.internal.runners.statements.RunAfters.evaluate(RunAfters.java:27) 2022-12-04T15:48:34.3469569Z at org.junit.rules.TestWatcher$1.evaluate(TestWatcher.java:61) 2022-12-04T15:48:34.3470357Z at org.junit.runners.ParentRunner$3.evaluate(ParentRunner.java:306) 2022-12-04T15:48:34.3470861Z at org.junit.runners.BlockJUnit4ClassRunner$1.evaluate(BlockJUnit4ClassRunner.java:100) 2022-12-04T15:48:34.3471373Z at org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:366) 2022-12-04T15:48:34.3471894Z at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:103) 2022-12-04T15:48:34.3472472Z at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:63) 2022-12-04T15:48:34.3472973Z at org.junit.runners.ParentRunner$4.run(ParentRunner.java:331) 2022-12-04T15:48:34.3473811Z at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:79) 2022-12-04T15:48:34.3474296Z at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:329) 2022-12-04T15:48:34.3474755Z at org.junit.runners.ParentRunner.access$100(ParentRunner.java:66) 2022-12-04T15:48:34.3475215Z at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:293) 2022-12-04T15:48:34.3475659Z at org.junit.runners.ParentRunner$3.evaluate(ParentRunner.java:306) 2022-12-04T15:48:34.3476098Z at org.junit.runners.ParentRunner.run(ParentRunner.java:413) 2022-12-04T15:48:34.3476614Z at org.apache.maven.surefire.junit4.JUnit4Provider.execute(JUnit4Provider.java:377) 2022-12-04T15:48:34.3477234Z at org.apache.maven.surefire.junit4.JUnit4Provider.executeWithRerun(JUnit4Provider.java:284) 2022-12-04T15:48:34.3477859Z at org.apache.maven.surefire.junit4.JUnit4Provider.executeTestSet(JUnit4Provider.java:248) 2022-12-04T15:48:34.3478504Z at org.apache.maven.surefire.junit4.JUnit4Provider.invoke(JUnit4Provider.java:167) 2022-12-04T15:48:34.3479115Z at org.apache.maven.surefire.booter.ForkedBooter.runSuitesInProcess(ForkedBooter.java:456) 2022-12-04T15:48:34.3479721Z at org.apache.maven.surefire.booter.ForkedBooter.execute(ForkedBooter.java:169) 2022-12-04T15:48:34.3481299Z at org.apache.maven.surefire.booter.ForkedBooter.run(ForkedBooter.java:595) 2022-12-04T15:48:34.3481852Z at org.apache.maven.surefire.booter.ForkedBooter.main(ForkedBooter.java:581) 2022-12-04T15:48:34.3482453Z Caused by: org.postgresql.util.PSQLException: ERROR: cannot update table "test_table" because it does not have a replica identity and publishes updates 2022-12-04T15:48:34.3483011Z Hint: To enable updating the table, set REPLICA IDENTITY using ALTER TABLE. 2022-12-04T15:48:34.3483556Z at org.postgresql.core.v3.QueryExecutorImpl.receiveErrorResponse(QueryExecutorImpl.java:2676) 2022-12-04T15:48:34.3484189Z at org.postgresql.core.v3.QueryExecutorImpl.processResults(QueryExecutorImpl.java:2366) 2022-12-04T15:48:34.3484768Z at org.postgresql.core.v3.QueryExecutorImpl.execute(QueryExecutorImpl.java:356) 2022-12-04T15:48:34.3485306Z at org.postgresql.jdbc.PgStatement.executeInternal(PgStatement.java:496) 2022-12-04T15:48:34.3485801Z at org.postgresql.jdbc.PgStatement.execute(PgStatement.java:413) 2022-12-04T15:48:34.3486287Z at org.postgresql.jdbc.PgStatement.executeWithFlags(PgStatement.java:333) 2022-12-04T15:48:34.3486816Z at org.postgresql.jdbc.PgStatement.executeCachedSql(PgStatement.java:319) 2022-12-04T15:48:34.3487344Z at org.postgresql.jdbc.PgStatement.executeWithFlags(PgStatement.java:295) 2022-12-04T15:48:34.3488042Z at org.postgresql.jdbc.PgStatement.execute(PgStatement.java:290) 2022-12-04T15:48:34.3488576Z at io.debezium.jdbc.JdbcConnection.executeWithoutCommitting(JdbcConnection.java:1440) 2022-12-04T15:48:34.3489145Z at io.debezium.connector.postgresql.TestHelper.execute(TestHelper.java:178) 2022-12-04T15:48:34.3489506Z ... 33 more 2022-12-04T15:48:34.3489645Z 2022-12-04T15:48:34.3805833Z [INFO] 2022-12-04T15:48:34.3806448Z [INFO] Results: 2022-12-04T15:48:34.3806795Z [INFO] 2022-12-04T15:48:34.3807115Z [ERROR] Failures: 2022-12-04T15:48:34.3808924Z [ERROR] RecordsStreamProducerIT.shouldReceiveChangesForReplicaIdentityFullTableWithToastedValueTableFromStreamingFullDiff:1672->testReceiveChangesForReplicaIdentityFullTableWithToastedValue:2610->assertInsert:2937->assertInsert:2947->assertRecordInserted:3014->assertRecordInserted:2984 expected:<null> but was:<Struct{pk=1}> 2022-12-04T15:48:34.3810154Z [ERROR] Errors: 2022-12-04T15:48:34.3811377Z [ERROR] RecordsStreamProducerIT.shouldReceiveChangesForDeletesDependingOnReplicaIdentity:1045->executeAndWait:3018 » Runtime org.postgresql.util.PSQLException: ERROR: cannot delete from table "test_table" because it does not have a replica identity and publishes deletes 2022-12-04T15:48:34.3812358Z Hint: To enable deleting from the table, set REPLICA IDENTITY using ALTER TABLE. 2022-12-04T15:48:34.3813484Z [ERROR] RecordsStreamProducerIT.shouldReceiveChangesForUpdates:672->executeAndWaitForNoRecords:3023 » Runtime org.postgresql.util.PSQLException: ERROR: cannot update table "test_table" because it does not have a replica identity and publishes updates 2022-12-04T15:48:34.3814354Z Hint: To enable updating the table, set REPLICA IDENTITY using ALTER TABLE. 2022-12-04T15:48:34.3814797Z [INFO] 2022-12-04T15:48:34.3815226Z [ERROR] Tests run: 294, Failures: 1, Errors: 2, Skipped: 4