Picked up JAVA_TOOL_OPTIONS: -Dfile.encoding=UTF8 __ ____ __ _____ ___ __ ____ ______ --/ __ \/ / / / _ | / _ \/ //_/ / / / __/ -/ /_/ / /_/ / __ |/ , _/ ,< / /_/ /\ \ --\___\_\____/_/ |_/_/|_/_/|_|\____/___/ 2022-02-06 20:18:20,572 INFO [io.deb.ser.BaseChangeConsumer] (main) Using 'io.debezium.server.BaseChangeConsumer$$Lambda$204/0x0000000840253040@9f6e406' stream name mapper 2022-02-06 20:18:20,674 INFO [io.deb.ser.red.RedisStreamChangeConsumer] (main) Using default Jedis 'redis.clients.jedis.Jedis@69b2f8e5' 2022-02-06 20:18:20,675 INFO [io.deb.ser.DebeziumServer] (main) Consumer 'io.debezium.server.redis.RedisStreamChangeConsumer' instantiated 2022-02-06 20:18:20,980 INFO [org.apa.kaf.con.jso.JsonConverterConfig] (main) JsonConverterConfig values: converter.type = key decimal.format = BASE64 schemas.cache.size = 1000 schemas.enable = true 2022-02-06 20:18:20,984 INFO [org.apa.kaf.con.jso.JsonConverterConfig] (main) JsonConverterConfig values: converter.type = value decimal.format = BASE64 schemas.cache.size = 1000 schemas.enable = false 2022-02-06 20:18:21,074 INFO [io.deb.emb.EmbeddedEngine$EmbeddedConfig] (main) EmbeddedConfig values: access.control.allow.methods = access.control.allow.origin = admin.listeners = null bootstrap.servers = [localhost:9092] client.dns.lookup = use_all_dns_ips config.providers = [] connector.client.config.override.policy = None header.converter = class org.apache.kafka.connect.storage.SimpleHeaderConverter internal.key.converter = class org.apache.kafka.connect.json.JsonConverter internal.value.converter = class org.apache.kafka.connect.json.JsonConverter key.converter = class org.apache.kafka.connect.json.JsonConverter listeners = null metric.reporters = [] metrics.num.samples = 2 metrics.recording.level = INFO metrics.sample.window.ms = 30000 offset.flush.interval.ms = 0 offset.flush.timeout.ms = 5000 offset.storage.file.filename = data/offsets.dat offset.storage.partitions = null offset.storage.replication.factor = null offset.storage.topic = plugin.path = null response.http.headers.config = rest.advertised.host.name = null rest.advertised.listener = null rest.advertised.port = null rest.extension.classes = [] rest.host.name = null rest.port = 8083 ssl.cipher.suites = null ssl.client.auth = none ssl.enabled.protocols = [TLSv1.2, TLSv1.3] ssl.endpoint.identification.algorithm = https ssl.engine.factory.class = null ssl.key.password = null ssl.keymanager.algorithm = SunX509 ssl.keystore.certificate.chain = null ssl.keystore.key = null ssl.keystore.location = null ssl.keystore.password = null ssl.keystore.type = JKS ssl.protocol = TLSv1.3 ssl.provider = null ssl.secure.random.implementation = null ssl.trustmanager.algorithm = PKIX ssl.truststore.certificates = null ssl.truststore.location = null ssl.truststore.password = null ssl.truststore.type = JKS task.shutdown.graceful.timeout.ms = 5000 topic.creation.enable = true topic.tracking.allow.reset = true topic.tracking.enable = true value.converter = class org.apache.kafka.connect.json.JsonConverter 2022-02-06 20:18:21,075 INFO [org.apa.kaf.con.run.WorkerConfig] (main) Worker configuration property 'internal.key.converter' is deprecated and may be removed in an upcoming release. The specified value 'org.apache.kafka.connect.json.JsonConverter' matches the default, so this property can be safely removed from the worker configuration. 2022-02-06 20:18:21,076 INFO [org.apa.kaf.con.run.WorkerConfig] (main) Worker configuration property 'internal.value.converter' is deprecated and may be removed in an upcoming release. The specified value 'org.apache.kafka.connect.json.JsonConverter' matches the default, so this property can be safely removed from the worker configuration. 2022-02-06 20:18:21,076 WARN [org.apa.kaf.con.run.WorkerConfig] (main) Variables cannot be used in the 'plugin.path' property, since the property is used by plugin scanning before the config providers that replace the variables are initialized. The raw value 'null' was used for plugin scanning, as opposed to the transformed value 'null', and this may cause unexpected results. 2022-02-06 20:18:21,078 INFO [org.apa.kaf.con.jso.JsonConverterConfig] (main) JsonConverterConfig values: converter.type = key decimal.format = BASE64 schemas.cache.size = 1000 schemas.enable = true 2022-02-06 20:18:21,079 INFO [org.apa.kaf.con.jso.JsonConverterConfig] (main) JsonConverterConfig values: converter.type = value decimal.format = BASE64 schemas.cache.size = 1000 schemas.enable = true 2022-02-06 20:18:21,081 INFO [io.deb.ser.DebeziumServer] (main) Engine executor started 2022-02-06 20:18:21,169 INFO [org.apa.kaf.con.sto.FileOffsetBackingStore] (pool-7-thread-1) Starting FileOffsetBackingStore with file data/offsets.dat 2022-02-06 20:18:21,775 INFO [io.deb.con.com.BaseSourceTask] (pool-7-thread-1) Starting OracleConnectorTask with configuration: 2022-02-06 20:18:21,780 INFO [io.deb.con.com.BaseSourceTask] (pool-7-thread-1) connector.class = io.debezium.connector.oracle.OracleConnector 2022-02-06 20:18:21,781 INFO [io.deb.con.com.BaseSourceTask] (pool-7-thread-1) database.history.file.filename = data/db_history.dat 2022-02-06 20:18:21,781 INFO [io.deb.con.com.BaseSourceTask] (pool-7-thread-1) database.user = c##dbzuser 2022-02-06 20:18:21,781 INFO [io.deb.con.com.BaseSourceTask] (pool-7-thread-1) database.dbname = CDB$ROOT 2022-02-06 20:18:21,782 INFO [io.deb.con.com.BaseSourceTask] (pool-7-thread-1) tasks.max = 1 2022-02-06 20:18:21,782 INFO [io.deb.con.com.BaseSourceTask] (pool-7-thread-1) database.pdb.name = PDB1 2022-02-06 20:18:21,782 INFO [io.deb.con.com.BaseSourceTask] (pool-7-thread-1) database.url = jdbc:oracle:thin:@(DESCRIPTION=(CONNECT_TIMEOUT=5)(TRANSPORT_CONNECT_TIMEOUT=3)(RETRY_COUNT=3)(ADDRESS_LIST=(FAILOVER = on)(LOAD_BALANCE = off)(ADDRESS = (PROTOCOL = TCP)(HOST = 10.20.22.12)(PORT = 1521))(ADDRESS = (PROTOCOL = TCP)(HOST = 10.20.22.13)(PORT = 1521)))(CONNECT_DATA = (SERVER = DEDICATED)(SERVICE_NAME = xxpdb1.eunetuat.eunet.oraclevcn.com))) 2022-02-06 20:18:21,782 INFO [io.deb.con.com.BaseSourceTask] (pool-7-thread-1) database.server.name = xxpdb1.eunetuat.eunet.oraclevcn.com 2022-02-06 20:18:21,784 INFO [io.deb.con.com.BaseSourceTask] (pool-7-thread-1) event.processing.failure.handling.mode = warn 2022-02-06 20:18:21,784 INFO [io.deb.con.com.BaseSourceTask] (pool-7-thread-1) internal.log.mining.dml.parser = legacy 2022-02-06 20:18:21,785 INFO [io.deb.con.com.BaseSourceTask] (pool-7-thread-1) log.mining.strategy = online_catalog 2022-02-06 20:18:21,785 INFO [io.deb.con.com.BaseSourceTask] (pool-7-thread-1) offset.flush.interval.ms = 0 2022-02-06 20:18:21,785 INFO [io.deb.con.com.BaseSourceTask] (pool-7-thread-1) tombstones.on.delete = false 2022-02-06 20:18:21,785 INFO [io.deb.con.com.BaseSourceTask] (pool-7-thread-1) offset.storage.file.filename = data/offsets.dat 2022-02-06 20:18:21,785 INFO [io.deb.con.com.BaseSourceTask] (pool-7-thread-1) column.exclude.list = APPLICATION.PUB_SERVICE_AREAS.AREA_GEOM,APPLICATION.PUB_PARKING_PLACES.AREA_GEOM 2022-02-06 20:18:21,787 INFO [io.deb.con.com.BaseSourceTask] (pool-7-thread-1) database.password = ******** 2022-02-06 20:18:21,788 INFO [io.deb.con.com.BaseSourceTask] (pool-7-thread-1) name = redis 2022-02-06 20:18:21,789 INFO [io.deb.con.com.BaseSourceTask] (pool-7-thread-1) lob.enabled = true 2022-02-06 20:18:21,791 INFO [io.deb.con.com.BaseSourceTask] (pool-7-thread-1) table.include.list = APPLICATION.PUB_VEHICLES,APPLICATION.PUB_VEHICLE_TYPES,APPLICATION.PUB_SERVICE_AREAS,APPLICATION.PUB_PARKING_PLACES,APPLICATION.PUB_CHARGERS,APPLICATION.PUB_PARTNERS,APPLICATION.COR_PARAMETER_VALUES,APPLICATION.COM_INBOXES,APPLICATION.PAY_BALANCES,APPLICATION.PUB_PARTNER_BANK_CARDS,APPLICATION.SAL_BALANCES,APPLICATION.SAL_CONTRACT_PERSONS,APPLICATION.SAL_CONTRACTS,APPLICATION.SAL_RADAR,APPLICATION.SAL_RENTAL_CANCELLATIONS,APPLICATION.PUB_PARTNER_DOCUMENTS,APPLICATION.SAL_CONTRACT_VEHICLES,APPLICATION.COR_LOOKUP_VALUES,APPLICATION.PUB_PARTNER_ADDRESSES,APPLICATION.PUB_PARTNER_ACCEPTANCES 2022-02-06 20:18:21,791 INFO [io.deb.con.com.BaseSourceTask] (pool-7-thread-1) database.history = io.debezium.relational.history.FileDatabaseHistory 2022-02-06 20:18:21,792 INFO [io.deb.con.com.BaseSourceTask] (pool-7-thread-1) snapshot.mode = schema_only 2022-02-06 20:18:22,171 INFO [io.quarkus] (main) debezium-server-dist 1.7.2.Final on JVM (powered by Quarkus 2.0.0.Final) started in 8.680s. Listening on: http://0.0.0.0:8080 2022-02-06 20:18:22,172 INFO [io.quarkus] (main) Profile prod activated. 2022-02-06 20:18:22,173 INFO [io.quarkus] (main) Installed features: [cdi, resteasy, resteasy-jackson, smallrye-context-propagation, smallrye-health] 2022-02-06 20:18:26,569 INFO [io.deb.con.ora.OracleConnection] (pool-7-thread-1) Database Version: Oracle Database 12c Enterprise Edition Release 12.2.0.1.0 - 64bit Production 2022-02-06 20:18:27,083 INFO [io.deb.con.com.BaseSourceTask] (pool-7-thread-1) No previous offsets found 2022-02-06 20:18:27,173 INFO [io.deb.uti.Threads] (pool-7-thread-1) Requested thread factory for connector OracleConnector, id = xxpdb1.eunetuat.eunet.oraclevcn.com named = change-event-source-coordinator 2022-02-06 20:18:27,175 INFO [io.deb.uti.Threads] (pool-7-thread-1) Creating thread debezium-oracleconnector-xxpdb1.eunetuat.eunet.oraclevcn.com-change-event-source-coordinator 2022-02-06 20:18:27,192 INFO [io.deb.pip.ChangeEventSourceCoordinator] (debezium-oracleconnector-xxpdb1.eunetuat.eunet.oraclevcn.com-change-event-source-coordinator) Metrics registered 2022-02-06 20:18:27,267 INFO [io.deb.pip.ChangeEventSourceCoordinator] (debezium-oracleconnector-xxpdb1.eunetuat.eunet.oraclevcn.com-change-event-source-coordinator) Context created 2022-02-06 20:18:27,275 INFO [io.deb.rel.RelationalSnapshotChangeEventSource] (debezium-oracleconnector-xxpdb1.eunetuat.eunet.oraclevcn.com-change-event-source-coordinator) Snapshot step 1 - Preparing 2022-02-06 20:18:27,275 INFO [io.deb.rel.RelationalSnapshotChangeEventSource] (debezium-oracleconnector-xxpdb1.eunetuat.eunet.oraclevcn.com-change-event-source-coordinator) Snapshot step 2 - Determining captured tables 2022-02-06 20:18:27,974 INFO [io.deb.rel.RelationalSnapshotChangeEventSource] (debezium-oracleconnector-xxpdb1.eunetuat.eunet.oraclevcn.com-change-event-source-coordinator) Snapshot step 3 - Locking captured tables [PDB1.APPLICATION.PUB_VEHICLES, PDB1.APPLICATION.PUB_VEHICLE_TYPES, PDB1.APPLICATION.PUB_SERVICE_AREAS, PDB1.APPLICATION.PUB_PARKING_PLACES, PDB1.APPLICATION.PUB_CHARGERS, PDB1.APPLICATION.PUB_PARTNERS, PDB1.APPLICATION.COR_PARAMETER_VALUES, PDB1.APPLICATION.COM_INBOXES, PDB1.APPLICATION.PAY_BALANCES, PDB1.APPLICATION.PUB_PARTNER_BANK_CARDS, PDB1.APPLICATION.SAL_BALANCES, PDB1.APPLICATION.SAL_CONTRACT_PERSONS, PDB1.APPLICATION.SAL_CONTRACTS, PDB1.APPLICATION.SAL_RADAR, PDB1.APPLICATION.SAL_RENTAL_CANCELLATIONS, PDB1.APPLICATION.PUB_PARTNER_DOCUMENTS, PDB1.APPLICATION.SAL_CONTRACT_VEHICLES, PDB1.APPLICATION.COR_LOOKUP_VALUES, PDB1.APPLICATION.PUB_PARTNER_ADDRESSES, PDB1.APPLICATION.PUB_PARTNER_ACCEPTANCES] 2022-02-06 20:18:28,115 INFO [io.deb.rel.RelationalSnapshotChangeEventSource] (debezium-oracleconnector-xxpdb1.eunetuat.eunet.oraclevcn.com-change-event-source-coordinator) Snapshot step 4 - Determining snapshot offset 2022-02-06 20:18:28,231 INFO [io.deb.con.ora.OracleSnapshotChangeEventSource] (debezium-oracleconnector-xxpdb1.eunetuat.eunet.oraclevcn.com-change-event-source-coordinator) No latest table SCN could be resolved, defaulting to current SCN 2022-02-06 20:18:28,255 INFO [io.deb.rel.RelationalSnapshotChangeEventSource] (debezium-oracleconnector-xxpdb1.eunetuat.eunet.oraclevcn.com-change-event-source-coordinator) Snapshot step 5 - Reading structure of captured tables 2022-02-06 20:18:30,129 INFO [io.deb.rel.RelationalSnapshotChangeEventSource] (debezium-oracleconnector-xxpdb1.eunetuat.eunet.oraclevcn.com-change-event-source-coordinator) Snapshot step 6 - Persisting schema history 2022-02-06 20:18:34,698 INFO [io.deb.con.com.BaseSourceTask] (pool-7-thread-1) 1 records sent during previous 00:00:13.396, last recorded offset: {snapshot=true, scn=19703922590, snapshot_completed=false} 2022-02-06 20:18:43,860 INFO [io.deb.rel.his.DatabaseHistoryMetrics] (debezium-oracleconnector-xxpdb1.eunetuat.eunet.oraclevcn.com-change-event-source-coordinator) Already applied 3 database changes 2022-02-06 20:18:44,247 INFO [io.deb.con.com.BaseSourceTask] (pool-7-thread-1) 2 records sent during previous 00:00:09.551, last recorded offset: {snapshot=true, scn=19703922590, snapshot_completed=false} 2022-02-06 20:18:51,175 INFO [io.deb.rel.RelationalSnapshotChangeEventSource] (debezium-oracleconnector-xxpdb1.eunetuat.eunet.oraclevcn.com-change-event-source-coordinator) Snapshot step 7 - Skipping snapshotting of data 2022-02-06 20:18:51,177 INFO [io.deb.pip.sou.AbstractSnapshotChangeEventSource] (debezium-oracleconnector-xxpdb1.eunetuat.eunet.oraclevcn.com-change-event-source-coordinator) Snapshot - Final stage 2022-02-06 20:18:51,186 INFO [io.deb.pip.ChangeEventSourceCoordinator] (debezium-oracleconnector-xxpdb1.eunetuat.eunet.oraclevcn.com-change-event-source-coordinator) Snapshot ended with SnapshotResult [status=COMPLETED, offset=OracleOffsetContext [scn=19703922590]] 2022-02-06 20:18:51,191 INFO [io.deb.pip.met.StreamingChangeEventSourceMetrics] (debezium-oracleconnector-xxpdb1.eunetuat.eunet.oraclevcn.com-change-event-source-coordinator) Connected metrics set to 'true' 2022-02-06 20:18:51,191 INFO [io.deb.pip.ChangeEventSourceCoordinator] (debezium-oracleconnector-xxpdb1.eunetuat.eunet.oraclevcn.com-change-event-source-coordinator) Starting streaming 2022-02-06 20:21:42,092 ERROR [io.deb.con.ora.log.LogMinerHelper] (debezium-oracleconnector-xxpdb1.eunetuat.eunet.oraclevcn.com-change-event-source-coordinator) Mining session stopped due to the {}: io.debezium.text.ParsingException: DDL statement couldn't be parsed. Please open a Jira issue with the statement 'ALTER TABLE EXT_SIX LOCATION ('b3cc675b-a95b-b6e4-ed80-dd567c9e891c-3KSOe1Hz-20220206212138.csv');' mismatched input 'LOCATION' expecting {'ADD', 'ALLOCATE', 'CACHE', 'COALESCE', 'COLUMN', 'COMPRESS', 'DEALLOCATE', 'DISABLE', 'DROP', 'ENABLE', 'EXCHANGE', 'FILESYSTEM_LIKE_LOGGING', 'FLASHBACK', 'INITRANS', 'LOGGING', 'MAXTRANS', 'MERGE', 'MINIMIZE', 'MODIFY', 'MOVE', 'NOCACHE', 'NOCOMPRESS', 'NOLOGGING', 'NOMINIMIZE', 'NO', 'NOPARALLEL', 'PARALLEL', 'PCTFREE', 'PCTUSED', 'READ', 'RECORDS_PER_BLOCK', 'REKEY', 'RENAME', 'RESULT_CACHE', 'ROW', 'SET', 'SHRINK', 'SPLIT', 'STORAGE', 'TRUNCATE', 'UPGRADE', ';'} at io.debezium.antlr.ParsingErrorListener.syntaxError(ParsingErrorListener.java:43) at org.antlr.v4.runtime.ProxyErrorListener.syntaxError(ProxyErrorListener.java:41) at org.antlr.v4.runtime.Parser.notifyErrorListeners(Parser.java:544) at org.antlr.v4.runtime.DefaultErrorStrategy.reportInputMismatch(DefaultErrorStrategy.java:327) at org.antlr.v4.runtime.DefaultErrorStrategy.reportError(DefaultErrorStrategy.java:139) at io.debezium.ddl.parser.oracle.generated.PlSqlParser.alter_table(PlSqlParser.java) at io.debezium.ddl.parser.oracle.generated.PlSqlParser.unit_statement(PlSqlParser.java:2316) at io.debezium.ddl.parser.oracle.generated.PlSqlParser.sql_script(PlSqlParser.java:2007) at io.debezium.connector.oracle.antlr.OracleDdlParser.parseTree(OracleDdlParser.java:68) at io.debezium.connector.oracle.antlr.OracleDdlParser.parseTree(OracleDdlParser.java:32) at io.debezium.antlr.AntlrDdlParser.parse(AntlrDdlParser.java:82) at io.debezium.connector.oracle.antlr.OracleDdlParser.parse(OracleDdlParser.java:63) at io.debezium.connector.oracle.OracleSchemaChangeEventEmitter.emitSchemaChangeEvent(OracleSchemaChangeEventEmitter.java:81) at io.debezium.pipeline.EventDispatcher.dispatchSchemaChangeEvent(EventDispatcher.java:311) at io.debezium.connector.oracle.logminer.processor.AbstractLogMinerEventProcessor.handleSchemaChange(AbstractLogMinerEventProcessor.java:286) at io.debezium.connector.oracle.logminer.processor.memory.MemoryLogMinerEventProcessor.handleSchemaChange(MemoryLogMinerEventProcessor.java:347) at io.debezium.connector.oracle.logminer.processor.AbstractLogMinerEventProcessor.processRow(AbstractLogMinerEventProcessor.java:206) at io.debezium.connector.oracle.logminer.processor.AbstractLogMinerEventProcessor.processResults(AbstractLogMinerEventProcessor.java:178) at io.debezium.connector.oracle.logminer.processor.memory.MemoryLogMinerEventProcessor.process(MemoryLogMinerEventProcessor.java:134) at io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSource.execute(LogMinerStreamingChangeEventSource.java:169) at io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSource.execute(LogMinerStreamingChangeEventSource.java:58) at io.debezium.pipeline.ChangeEventSourceCoordinator.streamEvents(ChangeEventSourceCoordinator.java:166) at io.debezium.pipeline.ChangeEventSourceCoordinator.lambda$start$0(ChangeEventSourceCoordinator.java:127) at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515) at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264) at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128) at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) at java.base/java.lang.Thread.run(Thread.java:829) Caused by: org.antlr.v4.runtime.InputMismatchException at org.antlr.v4.runtime.DefaultErrorStrategy.sync(DefaultErrorStrategy.java:270) ... 23 more 2022-02-06 20:21:42,094 ERROR [io.deb.pip.ErrorHandler] (debezium-oracleconnector-xxpdb1.eunetuat.eunet.oraclevcn.com-change-event-source-coordinator) Producer failure: io.debezium.text.ParsingException: DDL statement couldn't be parsed. Please open a Jira issue with the statement 'ALTER TABLE EXT_SIX LOCATION ('b3cc675b-a95b-b6e4-ed80-dd567c9e891c-3KSOe1Hz-20220206212138.csv');' mismatched input 'LOCATION' expecting {'ADD', 'ALLOCATE', 'CACHE', 'COALESCE', 'COLUMN', 'COMPRESS', 'DEALLOCATE', 'DISABLE', 'DROP', 'ENABLE', 'EXCHANGE', 'FILESYSTEM_LIKE_LOGGING', 'FLASHBACK', 'INITRANS', 'LOGGING', 'MAXTRANS', 'MERGE', 'MINIMIZE', 'MODIFY', 'MOVE', 'NOCACHE', 'NOCOMPRESS', 'NOLOGGING', 'NOMINIMIZE', 'NO', 'NOPARALLEL', 'PARALLEL', 'PCTFREE', 'PCTUSED', 'READ', 'RECORDS_PER_BLOCK', 'REKEY', 'RENAME', 'RESULT_CACHE', 'ROW', 'SET', 'SHRINK', 'SPLIT', 'STORAGE', 'TRUNCATE', 'UPGRADE', ';'} at io.debezium.antlr.ParsingErrorListener.syntaxError(ParsingErrorListener.java:43) at org.antlr.v4.runtime.ProxyErrorListener.syntaxError(ProxyErrorListener.java:41) at org.antlr.v4.runtime.Parser.notifyErrorListeners(Parser.java:544) at org.antlr.v4.runtime.DefaultErrorStrategy.reportInputMismatch(DefaultErrorStrategy.java:327) at org.antlr.v4.runtime.DefaultErrorStrategy.reportError(DefaultErrorStrategy.java:139) at io.debezium.ddl.parser.oracle.generated.PlSqlParser.alter_table(PlSqlParser.java) at io.debezium.ddl.parser.oracle.generated.PlSqlParser.unit_statement(PlSqlParser.java:2316) at io.debezium.ddl.parser.oracle.generated.PlSqlParser.sql_script(PlSqlParser.java:2007) at io.debezium.connector.oracle.antlr.OracleDdlParser.parseTree(OracleDdlParser.java:68) at io.debezium.connector.oracle.antlr.OracleDdlParser.parseTree(OracleDdlParser.java:32) at io.debezium.antlr.AntlrDdlParser.parse(AntlrDdlParser.java:82) at io.debezium.connector.oracle.antlr.OracleDdlParser.parse(OracleDdlParser.java:63) at io.debezium.connector.oracle.OracleSchemaChangeEventEmitter.emitSchemaChangeEvent(OracleSchemaChangeEventEmitter.java:81) at io.debezium.pipeline.EventDispatcher.dispatchSchemaChangeEvent(EventDispatcher.java:311) at io.debezium.connector.oracle.logminer.processor.AbstractLogMinerEventProcessor.handleSchemaChange(AbstractLogMinerEventProcessor.java:286) at io.debezium.connector.oracle.logminer.processor.memory.MemoryLogMinerEventProcessor.handleSchemaChange(MemoryLogMinerEventProcessor.java:347) at io.debezium.connector.oracle.logminer.processor.AbstractLogMinerEventProcessor.processRow(AbstractLogMinerEventProcessor.java:206) at io.debezium.connector.oracle.logminer.processor.AbstractLogMinerEventProcessor.processResults(AbstractLogMinerEventProcessor.java:178) at io.debezium.connector.oracle.logminer.processor.memory.MemoryLogMinerEventProcessor.process(MemoryLogMinerEventProcessor.java:134) at io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSource.execute(LogMinerStreamingChangeEventSource.java:169) at io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSource.execute(LogMinerStreamingChangeEventSource.java:58) at io.debezium.pipeline.ChangeEventSourceCoordinator.streamEvents(ChangeEventSourceCoordinator.java:166) at io.debezium.pipeline.ChangeEventSourceCoordinator.lambda$start$0(ChangeEventSourceCoordinator.java:127) at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515) at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264) at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128) at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) at java.base/java.lang.Thread.run(Thread.java:829) Caused by: org.antlr.v4.runtime.InputMismatchException at org.antlr.v4.runtime.DefaultErrorStrategy.sync(DefaultErrorStrategy.java:270) ... 23 more 2022-02-06 20:21:42,168 INFO [io.deb.con.ora.log.LogMinerStreamingChangeEventSource] (debezium-oracleconnector-xxpdb1.eunetuat.eunet.oraclevcn.com-change-event-source-coordinator) startScn=19703925442, endScn=19703925549 2022-02-06 20:21:42,168 INFO [io.deb.con.ora.log.LogMinerStreamingChangeEventSource] (debezium-oracleconnector-xxpdb1.eunetuat.eunet.oraclevcn.com-change-event-source-coordinator) Streaming metrics dump: OracleStreamingChangeEventSourceMetrics{currentScn=19703925549, oldestScn=-1, committedScn=19703925475, offsetScn=19703925442, logMinerQueryCount=50, totalProcessedRows=1213, totalCapturedDmlCount=0, totalDurationOfFetchingQuery=PT29.291625S, lastCapturedDmlCount=0, lastDurationOfFetchingQuery=PT0.558285S, maxCapturedDmlCount=0, maxDurationOfFetchingQuery=PT1.125265S, totalBatchProcessingDuration=PT34.515519S, lastBatchProcessingDuration=PT0.610405S, maxBatchProcessingThroughput=0, currentLogFileName=[+RECO/UAT_2/ONLINELOG/group_1.258.1084352793], minLogFilesMined=1, maxLogFilesMined=1, redoLogStatus=[+RECO/UAT_2/ONLINELOG/group_1.258.1084352793 | CURRENT, +RECO/UAT_2/ONLINELOG/group_3.259.1084352809 | INACTIVE, +RECO/UAT_2/ONLINELOG/group_2.257.1084352801 | INACTIVE], switchCounter=0, batchSize=20000, millisecondToSleepBetweenMiningQuery=3000, hoursToKeepTransaction=0, networkConnectionProblemsCounter0, batchSizeDefault=20000, batchSizeMin=1000, batchSizeMax=100000, sleepTimeDefault=1000, sleepTimeMin=0, sleepTimeMax=3000, sleepTimeIncrement=200, totalParseTime=PT0S, totalStartLogMiningSessionDuration=PT0.593643S, lastStartLogMiningSessionDuration=PT0.008906S, maxStartLogMiningSessionDuration=PT0.130534S, totalProcessTime=PT34.515519S, minBatchProcessTime=PT0.563418S, maxBatchProcessTime=PT4.137052S, totalResultSetNextTime=PT0.000916S, lagFromTheSource=DurationPT3.260117S, maxLagFromTheSourceDuration=PT26.984036S, minLagFromTheSourceDuration=PT0.775818S, lastCommitDuration=PT0.000007S, maxCommitDuration=PT0.001492S, activeTransactions=1, rolledBackTransactions=0, committedTransactions=602, abandonedTransactionIds=[], rolledbackTransactionIds=[], registeredDmlCount=0, committedDmlCount=0, errorCount=1, warningCount=0, scnFreezeCount=0, unparsableDdlCount=0, miningSessionUserGlobalAreaMemory=149160, miningSessionUserGlobalAreaMaxMemory=2105504, miningSessionProcessGlobalAreaMemory=149258232, miningSessionProcessGlobalAreaMaxMemory=149258232} 2022-02-06 20:21:42,169 INFO [io.deb.con.ora.log.LogMinerStreamingChangeEventSource] (debezium-oracleconnector-xxpdb1.eunetuat.eunet.oraclevcn.com-change-event-source-coordinator) Offsets: OracleOffsetContext [scn=19703925442] 2022-02-06 20:21:42,170 INFO [io.deb.pip.ChangeEventSourceCoordinator] (debezium-oracleconnector-xxpdb1.eunetuat.eunet.oraclevcn.com-change-event-source-coordinator) Finished streaming 2022-02-06 20:21:42,170 INFO [io.deb.pip.met.StreamingChangeEventSourceMetrics] (debezium-oracleconnector-xxpdb1.eunetuat.eunet.oraclevcn.com-change-event-source-coordinator) Connected metrics set to 'false' 2022-02-06 20:21:42,267 INFO [io.deb.con.com.BaseSourceTask] (pool-7-thread-1) Stopping down connector 2022-02-06 20:21:42,288 INFO [io.deb.jdb.JdbcConnection] (pool-8-thread-1) Connection gracefully closed 2022-02-06 20:21:42,289 INFO [org.apa.kaf.con.sto.FileOffsetBackingStore] (pool-7-thread-1) Stopped FileOffsetBackingStore 2022-02-06 20:21:42,290 INFO [io.deb.ser.ConnectorLifecycle] (pool-7-thread-1) Connector completed: success = 'false', message = 'Error while trying to run connector class 'io.debezium.connector.oracle.OracleConnector'', error = '{}': 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.logminer.LogMinerStreamingChangeEventSource.execute(LogMinerStreamingChangeEventSource.java:182) at io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSource.execute(LogMinerStreamingChangeEventSource.java:58) at io.debezium.pipeline.ChangeEventSourceCoordinator.streamEvents(ChangeEventSourceCoordinator.java:166) at io.debezium.pipeline.ChangeEventSourceCoordinator.lambda$start$0(ChangeEventSourceCoordinator.java:127) at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515) at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264) at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128) at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) at java.base/java.lang.Thread.run(Thread.java:829) Caused by: io.debezium.text.ParsingException: DDL statement couldn't be parsed. Please open a Jira issue with the statement 'ALTER TABLE EXT_SIX LOCATION ('b3cc675b-a95b-b6e4-ed80-dd567c9e891c-3KSOe1Hz-20220206212138.csv');' mismatched input 'LOCATION' expecting {'ADD', 'ALLOCATE', 'CACHE', 'COALESCE', 'COLUMN', 'COMPRESS', 'DEALLOCATE', 'DISABLE', 'DROP', 'ENABLE', 'EXCHANGE', 'FILESYSTEM_LIKE_LOGGING', 'FLASHBACK', 'INITRANS', 'LOGGING', 'MAXTRANS', 'MERGE', 'MINIMIZE', 'MODIFY', 'MOVE', 'NOCACHE', 'NOCOMPRESS', 'NOLOGGING', 'NOMINIMIZE', 'NO', 'NOPARALLEL', 'PARALLEL', 'PCTFREE', 'PCTUSED', 'READ', 'RECORDS_PER_BLOCK', 'REKEY', 'RENAME', 'RESULT_CACHE', 'ROW', 'SET', 'SHRINK', 'SPLIT', 'STORAGE', 'TRUNCATE', 'UPGRADE', ';'} at io.debezium.antlr.ParsingErrorListener.syntaxError(ParsingErrorListener.java:43) at org.antlr.v4.runtime.ProxyErrorListener.syntaxError(ProxyErrorListener.java:41) at org.antlr.v4.runtime.Parser.notifyErrorListeners(Parser.java:544) at org.antlr.v4.runtime.DefaultErrorStrategy.reportInputMismatch(DefaultErrorStrategy.java:327) at org.antlr.v4.runtime.DefaultErrorStrategy.reportError(DefaultErrorStrategy.java:139) at io.debezium.ddl.parser.oracle.generated.PlSqlParser.alter_table(PlSqlParser.java) at io.debezium.ddl.parser.oracle.generated.PlSqlParser.unit_statement(PlSqlParser.java:2316) at io.debezium.ddl.parser.oracle.generated.PlSqlParser.sql_script(PlSqlParser.java:2007) at io.debezium.connector.oracle.antlr.OracleDdlParser.parseTree(OracleDdlParser.java:68) at io.debezium.connector.oracle.antlr.OracleDdlParser.parseTree(OracleDdlParser.java:32) at io.debezium.antlr.AntlrDdlParser.parse(AntlrDdlParser.java:82) at io.debezium.connector.oracle.antlr.OracleDdlParser.parse(OracleDdlParser.java:63) at io.debezium.connector.oracle.OracleSchemaChangeEventEmitter.emitSchemaChangeEvent(OracleSchemaChangeEventEmitter.java:81) at io.debezium.pipeline.EventDispatcher.dispatchSchemaChangeEvent(EventDispatcher.java:311) at io.debezium.connector.oracle.logminer.processor.AbstractLogMinerEventProcessor.handleSchemaChange(AbstractLogMinerEventProcessor.java:286) at io.debezium.connector.oracle.logminer.processor.memory.MemoryLogMinerEventProcessor.handleSchemaChange(MemoryLogMinerEventProcessor.java:347) at io.debezium.connector.oracle.logminer.processor.AbstractLogMinerEventProcessor.processRow(AbstractLogMinerEventProcessor.java:206) at io.debezium.connector.oracle.logminer.processor.AbstractLogMinerEventProcessor.processResults(AbstractLogMinerEventProcessor.java:178) at io.debezium.connector.oracle.logminer.processor.memory.MemoryLogMinerEventProcessor.process(MemoryLogMinerEventProcessor.java:134) at io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSource.execute(LogMinerStreamingChangeEventSource.java:169) ... 8 more Caused by: org.antlr.v4.runtime.InputMismatchException at org.antlr.v4.runtime.DefaultErrorStrategy.sync(DefaultErrorStrategy.java:270) ... 23 more 2022-02-06 20:21:42,374 INFO [io.deb.ser.DebeziumServer] (main) Received request to stop the engine 2022-02-06 20:21:42,375 INFO [io.deb.emb.EmbeddedEngine] (main) Stopping the embedded engine 2022-02-06 20:21:42,390 INFO [io.quarkus] (main) debezium-server-dist stopped in 0.097s