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

LIST_VALUE_CLAUSE not allowing TIMESTAMP LITERAL

XMLWordPrintable

    • False
    • None
    • False

      Bug report

      What Debezium connector do you use and what version?

      1.9.4.Final

      What is the connector configuration?

      {
          "name": "src-ase2-22081s4",
          "config":

      {         "connector.class": "io.debezium.connector.oracle.OracleConnector",         "key.converter": "io.confluent.connect.avro.AvroConverter",         "key.converter.schema.registry.url": "http://swwkafi01c1.suvanet.ch:8081",         "value.converter": "io.confluent.connect.avro.AvroConverter",         "value.converter.schema.registry.url": "http://swwkafi01c1.suvanet.ch:8081",         "database.url": "url",         "database.user": "user",         "database.password": "ENC[AES256_GCM,data:sIK/KSYlegGs0w==,iv:Vk+jBI/EHDJBPeVbT3pe3KLYUSG00SMo0B+I2WY+6vY=,tag:SXC54XgjqOjoDuT70qiIOA==,type:str]",         "database.dbname": "dbname",         "database.server.name": "servername",         "table.include.list": "ASEDBUSR.DOCBESTELLUNG,ASEDBUSR.DOCBESTEMPFAENGER,ASEDBUSR.DOCBESTPARAMATTR,ASEDBUSR.DOCEMPFPARAMATTR,ASEDBUSR.DOCROUTING,ASEDBUSR.DRITTE,ASEDBUSR.ECLAIMINVOICE,ASEDBUSR.ECLAIMINVOICEDET,ASEDBUSR.ECLAIMKOAMAPPCON,ASEDBUSR.ECLAIMKOAMAPPING,ASEDBUSR.ECLAIMMEDKLASS,ASEDBUSR.ECLAIMPARTNER,ASEDBUSR.ECLAIMPROCESS,ASEDBUSR.ELZAHLUNGEN,ASEDBUSR.EMAIL,ASEDBUSR.EXTZAHLUNGEN",         "snapshot.fetch.size": "10000",         "event.processing.failure.handling.mode": "fail",         "tombstones.on.delete": true,         "message.key.columns": "ASEDBUSR.DOCBESTELLUNG:PKEY;ASEDBUSR.DOCBESTEMPFAENGER:PKEY;ASEDBUSR.DOCBESTPARAMATTR:PKEY;ASEDBUSR.DOCEMPFPARAMATTR:PKEY;ASEDBUSR.DOCROUTING:PKEY;ASEDBUSR.DRITTE:PKEY;ASEDBUSR.ECLAIMINVOICE:PKEY;ASEDBUSR.ECLAIMINVOICEDET:PKEY;ASEDBUSR.ECLAIMKOAMAPPCON:PKEY;ASEDBUSR.ECLAIMKOAMAPPING:PKEY;ASEDBUSR.ECLAIMMEDKLASS:PKEY;ASEDBUSR.ECLAIMPARTNER:PKEY;ASEDBUSR.ECLAIMPROCESS:PKEY;ASEDBUSR.ELZAHLUNGEN:PKEY;ASEDBUSR.EMAIL:PKEY;ASEDBUSR.EXTZAHLUNGEN:PKEY",         "log.mining.strategy": "online_catalog",         "log.mining.archive.destination.name": "LOG_ARCHIVE_DEST_10",         "lob.enabled": true,         "log.mining.transaction.retention.hours": "24",         "internal.log.mining.log.query.max.retries": "10",         "time.precision.mode": "connect",         "tasks.max": "1",         "database.history.kafka.bootstrap.servers": "swwkafi01.suvanet.ch:9092",         "database.history.kafka.topic": "ase.schema-changes.asedbusr",         "database.history.consumer.security.protocol": "SASL_SSL",         "database.history.producer.security.protocol": "SASL_SSL",         "database.history.consumer.sasl.mechanism": "SCRAM-SHA-512",         "database.history.producer.sasl.mechanism": "SCRAM-SHA-512",         "database.history.consumer.sasl.jaas.config": "ENC[AES256_GCM,data:QodTYDbC1PxIrG5PnKnuc9dISHyTNYyzDL8vU+jC1+4uevNi5B3ItpOYNvjL/ppSNac2ncrIDwRMd054U+YyAymuhfTdvjz4AVUjaU5Q5V35H6HUR3BqTtHSF71hiFQSTXoN/6WZ5p/7DXB0/ITrFXfAuQ==,iv:xGTVNto5azYmd2J03Le+0kiPjMv5iRWM+m7kYv4Z+Zk=,tag:y4Nxq7lk7QiM+Mys2SBOsQ==,type:str]",         "database.history.producer.sasl.jaas.config": "ENC[AES256_GCM,data:0oYtrt+g+rHOku9Q1KUkMbtiWxQf0lmqxCJAoYv4rfI7D9IiUQ5JvxJZHXXxahscPa068am6D9LA9dzxqJ7obdr+3jaGb/meHHIt9tIfln7oSoN8st7n4sFJ7C3/8E4mtjE9ivCZrFtLOlwu7kirGuD+Gw==,iv:EsDmauMOyatZAQg59pY8W3YIgvxDfipKnIdx2nj1jQg=,tag:KXW5P3Zqu90Bd8uhZzdiuQ==,type:str]",         "transforms": "unwrap",         "transforms.unwrap.type": "io.debezium.transforms.ExtractNewRecordState",         "transforms.unwrap.add.fields": "source.table:META_SRC_TABLENAME,source.ts_ms:META_SRC_TS,op:META_SRC_OP,source.scn:META_SRC_SCN,source.snapshot:META_SRC_SNAPSHOT",         "transforms.unwrap.delete.handling.mode": "rewrite",         "transforms.unwrap.drop.tombstones": false     }

      ,
          "sops": {
              "kms": null,
              "gcp_kms": null,
              "azure_kv": null,
              "hc_vault": null,
              "age": null,
              "lastmodified": "2022-01-31T15:41:38Z",
              "mac": "ENC[AES256_GCM,data:M9XjPssFMm1y72OldOPbWkLZk6OKiNEqNz1YAtLHwAtXmfDyXaNGL+rRnM5JSGBOpStAIWMq9PbAU39NJJTBKcKOjpLLlU716705U8qjWo7LULCrhF10TBOqH2uQTlP38xB9NWY5o/UwOckSPRRgVKGWw4eGmy5UEFNhPvVnfio=,iv:Kv3Egsbr7M+SUl3Bq2iFup2bIS+kZwY7aBIa3l8ahlk=,tag:3sTj7FSzV86m1/pzzV8lSA==,type:str]",
              "pgp": [
                 

      {                 "created_at": "2022-01-31T15:41:08Z",                 "enc": "-----BEGIN PGP MESSAGE-----\n\nhQEMA243CXYlIAr3AQf/Y9Iwsh3K7M+em98P8p6QMlQhVYYhz1TXd3cCX6URmlhd\nkSNHWx+OQKE/wqeWWZvZB9lHJl2ISoqpPjybgRM5Kje3yafuPY/m1kGdVn8FUtXa\ngbCv+O13Hs3Q8qS1hVowq2cIHipaeBp6rQC6WzPPprJGES8K1IuvHz9TJTP8FEae\nuVACYQUCtE+TFL9nAaP37Bp8Yx1gihKUyNEougHkj/5i5LqxYK/CgT5g1LIJl4Xn\ngQyR/THI+lZ5ZhJlFzHMCh+fCAUqpb+RUvbPHOFr2khBv3uJqBNZfODLUDOkoplr\nHLHYKo6viiL9KvI2zPt3pbTbK8gGtt8Hx7Rn1KAtldJeAfoO0XXPil8yecB7XNYe\nrkhpJlmcN+vVbl0MWImKW5CdTBbttRk7LPJjh6SN+FZtNfVlWFRhKfriQ2o6TUkS\n3vdJyDGjOu0eIM9oresH/1ciezyfXjIzyi8zIBA/vA==\n=RcqY\n-----END PGP MESSAGE-----\n",                 "fp": "F7067DB106402AABEBEF13F8C6E64E19DC477D85"             }

              ],
              "encrypted_regex": "(database.password|database.history.consumer.sasl.jaas.config|database.history.producer.sasl.jaas.config)",
              "version": "3.7.1"
          }
      }

      What is the captured database version and mode of depoyment?

      Oracle 19c, on prem, non-cdb

      What behaviour do you see? -> see attached file

            "state": "FAILED",
            "worker_id": "10.85.80.15:8083",
            "trace": "org.apache.kafka.connect.errors.ConnectException: An exception occurred in the change event producer.
            This connector will be stopped.\n\
            tat io.debezium.pipeline.ErrorHandler.setProducerThrowable(ErrorHandler.java:50)\n\
            tat io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSource.execute(LogMinerStreamingChangeEventSource.java:222)\n\
            tat io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSource.execute(LogMinerStreamingChangeEventSource.java:60)\n\
            tat io.debezium.pipeline.ChangeEventSourceCoordinator.streamEvents(ChangeEventSourceCoordinator.java:174)\n\
            tat io.debezium.pipeline.ChangeEventSourceCoordinator.executeChangeEventSources(ChangeEventSourceCoordinator.java:141)\n\
            tat io.debezium.pipeline.ChangeEventSourceCoordinator.lambda$start$0(ChangeEventSourceCoordinator.java:109)\n\
            tat java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515)\n\
            tat java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264)\n\
            tat java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)\n\
            tat java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)\n\
            tat java.base/java.lang.Thread.run(Thread.java:829)\n
            Caused by: io.debezium.text.ParsingException: DDL statement couldn't be parsed. Please open a Jira issue with the statement '\n\n
            CREATE TABLE versionCheckTable AS SELECT  Tablename as TableName, Attrname as Spalte, DECODE (type, 'Code', type ||';' ||codekopf, type) TYP from ( \n
                SELECT mb.Tablename as Tablename, a.Attrname as Attrname,a.type, a.codekopf FROM MetaBO mb\n
                    INNER JOIN AttributeMeta a ON mb.BOID = a.MetaID\n
                        WHERE Tablename in ('EClaimProcess','EClaimInvoice','EClaimInvoiceDet','TarifZiffer','TSTarifZiffer','TarifGruppe', 'EClaimMCD', 'EClaimKonstell','EClaimMedKlass','EClaimCaseDet','EClaimNotification', 'EClaimPartner')\n
      ......
       

       

        1. ddl_parser_error.txt
          77 kB
          René Rütter
        2. docbestellung.sql
          5 kB
          René Rütter
        3. docbestempfaenger.sql
          3 kB
          René Rütter
        4. docbestparamattr.sql
          2 kB
          René Rütter
        5. docempfparamattr.sql
          2 kB
          René Rütter
        6. dritte.sql
          3 kB
          René Rütter
        7. eclaiminvoice.sql
          8 kB
          René Rütter
        8. eclaiminvoicedet.sql
          6 kB
          René Rütter
        9. eclaimkoamappcon.sql
          2 kB
          René Rütter
        10. eclaimkoamapping.sql
          5 kB
          René Rütter
        11. eclaimmedklass.sql
          3 kB
          René Rütter
        12. eclaimpartner.sql
          4 kB
          René Rütter
        13. eclaimprocess.sql
          6 kB
          René Rütter
        14. elzahlungen.sql
          3 kB
          René Rütter
        15. email.sql
          2 kB
          René Rütter
        16. extzahlungen.sql
          5 kB
          René Rütter

              anmohant Anisha Mohanty
              renerh René Rütter (Inactive)
              Votes:
              0 Vote for this issue
              Watchers:
              5 Start watching this issue

                Created:
                Updated:
                Resolved: