Uploaded image for project: 'Debezium'
  1. Debezium
  2. DBZ-8461

Randomly failing tests after migration to async engine

XMLWordPrintable

    • Icon: Bug Bug
    • Resolution: Done
    • Icon: Major Major
    • 3.0.4.Final
    • 3.0.3.Final
    • embedded-engine
    • None

      After migration of the testsuite to async engine (DBZ-7977) test on GH seems to be more or less stable, but on internal Jenkins instance I spotted several randomly failing tests, mostly related to improper start or stop of the engine:

      • io.debezium.connector.mongodb.transforms.LegacyExtractNewDocumentStateTestIT.shouldDropDeleteMessagesByDefault
        java.lang.IllegalStateException: Cannot stop engine while tasks are starting, this may lead to leaked resource. Wait for the tasks to be fully started.
        	at io.debezium.embedded.async.AsyncEmbeddedEngine.close(AsyncEmbeddedEngine.java:246)
        	at io.debezium.embedded.async.TestingAsyncEmbeddedEngine.close(TestingAsyncEmbeddedEngine.java:34)
        	at io.debezium.embedded.AbstractConnectorTest.stopConnector(AbstractConnectorTest.java:167)
        	at io.debezium.embedded.AbstractConnectorTest.stopConnector(AbstractConnectorTest.java:152)
        	at io.debezium.connector.mongodb.AbstractMongoConnectorIT.afterEach(AbstractMongoConnectorIT.java:76)
        	at io.debezium.connector.mongodb.transforms.AbstractExtractNewDocumentStateTestIT.afterEach(AbstractExtractNewDocumentStateTestIT.java:88)
        	at io.debezium.connector.mongodb.transforms.AbstractExtractNewDocumentStateTestIT.restartConnectorWithoutEmittingTombstones(AbstractExtractNewDocumentStateTestIT.java:94)
        	at io.debezium.connector.mongodb.transforms.LegacyExtractNewDocumentStateTestIT.shouldDropDeleteMessagesByDefault(LegacyExtractNewDocumentStateTestIT.java:902)
        
      • io.debezium.connector.mongodb.transforms.LegacyExtractNewDocumentStateTestIT.shouldRewriteDeleteMessage
        java.lang.IllegalStateException: Cannot stop engine while tasks are starting, this may lead to leaked resource. Wait for the tasks to be fully started.
        	at io.debezium.embedded.async.AsyncEmbeddedEngine.close(AsyncEmbeddedEngine.java:246)
        	at io.debezium.embedded.async.TestingAsyncEmbeddedEngine.close(TestingAsyncEmbeddedEngine.java:34)
        	at io.debezium.embedded.AbstractConnectorTest.stopConnector(AbstractConnectorTest.java:178)
        	at io.debezium.embedded.AbstractConnectorTest.stopConnector(AbstractConnectorTest.java:163)
        	at io.debezium.connector.mongodb.AbstractMongoConnectorIT.afterEach(AbstractMongoConnectorIT.java:76)
        	at io.debezium.connector.mongodb.transforms.AbstractExtractNewDocumentStateTestIT.afterEach(AbstractExtractNewDocumentStateTestIT.java:88)
        	at io.debezium.connector.mongodb.transforms.AbstractExtractNewDocumentStateTestIT.restartConnectorWithoutEmittingTombstones(AbstractExtractNewDocumentStateTestIT.java:94)
        	at io.debezium.connector.mongodb.transforms.LegacyExtractNewDocumentStateTestIT.shouldRewriteDeleteMessage(LegacyExtractNewDocumentStateTestIT.java:938)
        
      • io.debezium.connector.postgresql.RecordsStreamProducerIT.stopInTheMiddleOfTxAndResume
        java.lang.IllegalStateException: Engine is already being shutting down.
        	at io.debezium.embedded.async.AsyncEmbeddedEngine.close(AsyncEmbeddedEngine.java:251)
        	at io.debezium.embedded.async.TestingAsyncEmbeddedEngine.close(TestingAsyncEmbeddedEngine.java:34)
        	at io.debezium.embedded.AbstractConnectorTest.stopConnector(AbstractConnectorTest.java:167)
        	at io.debezium.embedded.AbstractConnectorTest.stopConnector(AbstractConnectorTest.java:152)
        	at io.debezium.connector.postgresql.RecordsStreamProducerIT.stopInTheMiddleOfTxAndResume(RecordsStreamProducerIT.java:2669)
        
      • io.debezium.connector.sqlserver.SqlServerConnectorIT.updatePrimaryKeyTwiceWithRestartInMiddleOfTx
        java.lang.IllegalStateException: Engine is already being shutting down.
        	at io.debezium.embedded.async.AsyncEmbeddedEngine.close(AsyncEmbeddedEngine.java:251)
        	at io.debezium.embedded.async.TestingAsyncEmbeddedEngine.close(TestingAsyncEmbeddedEngine.java:34)
        	at io.debezium.embedded.AbstractConnectorTest.stopConnector(AbstractConnectorTest.java:167)
        	at io.debezium.embedded.AbstractConnectorTest.stopConnector(AbstractConnectorTest.java:152)
        	at io.debezium.connector.sqlserver.SqlServerConnectorIT.updatePrimaryKeyTwiceWithRestartInMiddleOfTx(SqlServerConnectorIT.java:767)
        

              vjuranek@redhat.com Vojtech Juranek
              vjuranek@redhat.com Vojtech Juranek
              Votes:
              0 Vote for this issue
              Watchers:
              2 Start watching this issue

                Created:
                Updated:
                Resolved: