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

Oracle dbname/signal with dots parsed incorrectly

    XMLWordPrintable

Details

    • Hide

      Connector config:

      {
        "name" : "testdwh",
        "config" : {
          "errors.log.enable" : "true",
          "errors.log.include.messages" : "true",
          "database.hostname" : "dbhostname.domain.com",
          "database.port" : "1521",
          "database.user" : "username",
          "database.password" : "password",
          "database.server.name" : "dbzxout",
          "database.dbname" : "RB02.DOMAIN.COM",
          "database.out.server.name" : "dbzxout",
          "database.connection.adapter" : "xstream",
          "snapshot.locking.mode" : "none",
          "database.history.kafka.bootstrap.servers" : "127.0.0.1:9092",
          "database.history.kafka.topic" : "schema-changes.inventory",
          "signal.data.collection" : "RB02.DOMAIN.COM.TBSLV.DEBEZIUM_SIGNAL",
          "table.include.list" : "TBSLV.DEBEZIUM_SIGNAL,TBSLV.NLENTA_SU_PK",
        }
      }
      Show
      Connector config: {   "name" : "testdwh" ,   "config" : {     "errors.log.enable" : " true " ,     "errors.log.include.messages" : " true " ,     "database.hostname" : "dbhostname.domain.com" ,     "database.port" : "1521" ,     "database.user" : "username" ,     "database.password" : "password" ,     "database.server.name" : "dbzxout" ,     "database.dbname" : "RB02.DOMAIN.COM" ,     "database.out.server.name" : "dbzxout" ,     "database.connection.adapter" : "xstream" ,     "snapshot.locking.mode" : "none" ,     "database.history.kafka.bootstrap.servers" : "127.0.0.1:9092" ,     "database.history.kafka.topic" : "schema-changes.inventory" ,     "signal.data.collection" : "RB02.DOMAIN.COM.TBSLV.DEBEZIUM_SIGNAL" ,     "table.include.list" : "TBSLV.DEBEZIUM_SIGNAL,TBSLV.NLENTA_SU_PK" ,   } }

    Description

      Testing xtreams connector to Oracle with dots in dbname.

      When sending ad-hoc shapshot signal- getting the following error. If trying signal.data.collection with databaseName in quotes- the signals are not getting received and processed.

       

      [2022-02-11 18:27:04,821] ERROR WorkerSourceTask{id=testdwh-0} Task threw an uncaught and unrecoverable exception. Task is being killed and will not recover until manually restarted (org.apache.kafka.connect.runtime.WorkerTask:190)
      org.apache.kafka.connect.errors.ConnectException: An exception occurred in the change event producer. This connector will be stopped.
              at io.debezium.pipeline.ErrorHandler.setProducerThrowable(ErrorHandler.java:42)
              at io.debezium.connector.oracle.xstream.LcrEventHandler.processLCR(LcrEventHandler.java:127)
              at oracle.streams.XStreamOut.XStreamOutReceiveLCRCallbackNative(Native Method)
              at oracle.streams.XStreamOut.receiveLCRCallback(XStreamOut.java:465)
              at io.debezium.connector.oracle.xstream.XstreamStreamingChangeEventSource.execute(XstreamStreamingChangeEventSource.java:108)
              at io.debezium.connector.oracle.xstream.XstreamStreamingChangeEventSource.execute(XstreamStreamingChangeEventSource.java:43)
              at io.debezium.pipeline.ChangeEventSourceCoordinator.streamEvents(ChangeEventSourceCoordinator.java:172)
              at io.debezium.pipeline.ChangeEventSourceCoordinator.executeChangeEventSources(ChangeEventSourceCoordinator.java:139)
              at io.debezium.pipeline.ChangeEventSourceCoordinator.lambda$start$0(ChangeEventSourceCoordinator.java:108)
              at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:539)
              at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264)
              at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136)
              at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635)
              at java.base/java.lang.Thread.run(Thread.java:833)
      Caused by: org.apache.kafka.connect.errors.ConnectException: Error while processing event at offset {transaction_id=null, lcr_position=080194957118000000010000000108019495710f000000020000000101, incremental_snapshot_maximum_key=aced00057
      0, incremental_snapshot_collections=RB02.DOMAIN.COM, incremental_snapshot_primary_key=aced000570}
              at io.debezium.pipeline.EventDispatcher.dispatchDataChangeEvent(EventDispatcher.java:252)
              at io.debezium.connector.oracle.xstream.LcrEventHandler.dispatchDataChangeEvent(LcrEventHandler.java:219)
              at io.debezium.connector.oracle.xstream.LcrEventHandler.processRowLCR(LcrEventHandler.java:146)
              at io.debezium.connector.oracle.xstream.LcrEventHandler.processLCR(LcrEventHandler.java:114)
              ... 12 more
      Caused by: io.debezium.DebeziumException: Database error while executing incremental snapshot for table 'RB02.DOMAIN.COM'
              at io.debezium.pipeline.source.snapshot.incremental.AbstractIncrementalSnapshotChangeEventSource.readChunk(AbstractIncrementalSnapshotChangeEventSource.java:312)
              at io.debezium.pipeline.source.snapshot.incremental.AbstractIncrementalSnapshotChangeEventSource.addDataCollectionNamesToSnapshot(AbstractIncrementalSnapshotChangeEventSource.java:398)
              at io.debezium.pipeline.signal.ExecuteSnapshot.arrived(ExecuteSnapshot.java:56)
              at io.debezium.pipeline.signal.Signal.process(Signal.java:137)
              at io.debezium.pipeline.signal.Signal.process(Signal.java:175)
              at io.debezium.pipeline.EventDispatcher$2.changeRecord(EventDispatcher.java:226)
              at io.debezium.relational.RelationalChangeRecordEmitter.emitCreateRecord(RelationalChangeRecordEmitter.java:78)
              at io.debezium.relational.RelationalChangeRecordEmitter.emitChangeRecords(RelationalChangeRecordEmitter.java:46)
              at io.debezium.pipeline.EventDispatcher.dispatchDataChangeEvent(EventDispatcher.java:215)
              ... 15 more
      Caused by: java.sql.SQLSyntaxErrorException: ORA-00942: table or view does not exist
              at oracle.jdbc.driver.T2CConnection.checkError(T2CConnection.java:1256)
              at oracle.jdbc.driver.T2CConnection.checkError(T2CConnection.java:1138)
              at oracle.jdbc.driver.T2CPreparedStatement.executeForDescribe(T2CPreparedStatement.java:784)
              at oracle.jdbc.driver.T2CPreparedStatement.executeForRows(T2CPreparedStatement.java:1027)
              at oracle.jdbc.driver.OracleStatement.executeSQLStatement(OracleStatement.java:1531)
              at oracle.jdbc.driver.OracleStatement.doExecuteWithTimeout(OracleStatement.java:1311)
              at oracle.jdbc.driver.OraclePreparedStatement.executeInternal(OraclePreparedStatement.java:3746)
              at oracle.jdbc.driver.OraclePreparedStatement.execute(OraclePreparedStatement.java:3941)
              at oracle.jdbc.driver.OraclePreparedStatementWrapper.execute(OraclePreparedStatementWrapper.java:1010)
              at io.debezium.jdbc.JdbcConnection.prepareUpdate(JdbcConnection.java:774)
              at io.debezium.pipeline.source.snapshot.incremental.SignalBasedIncrementalSnapshotChangeEventSource.emitWindowOpen(SignalBasedIncrementalSnapshotChangeEventSource.java:58)
              at io.debezium.pipeline.source.snapshot.incremental.AbstractIncrementalSnapshotChangeEventSource.readChunk(AbstractIncrementalSnapshotChangeEventSource.java:261)
              ... 23 more
      Caused by: Error : 942, Position : 17, Sql = INSERT INTO DOMAIN.COM VALUES (:1 , :2 , null), OriginalSql = INSERT INTO DOMAIN.COM VALUES (?, ?, null), Error Msg = ORA-00942: table or view does not exist
              at oracle.jdbc.driver.T2CConnection.checkError(T2CConnection.java:1270)
              ... 34 more

      Attachments

        Activity

          People

            ccranfor@redhat.com Chris Cranford
            andrws-1 Andrius Umbrasas (Inactive)
            Votes:
            0 Vote for this issue
            Watchers:
            6 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved: