Details
-
Bug
-
Resolution: Done
-
Major
-
1.4.0.Alpha2
-
None
-
False
-
False
-
Undefined
-
- Add connector to database with table having '$' in name of any column.
- Connector fails.
Description
Connector fails when using '$' sign in column name with stacktrace:
[2020-12-11 13:52:07,270] ERROR WorkerSourceTask{id=TWCMS_Inhouse_TEST-0} Task threw an uncaught and unrecoverable exception (org.apache.kafka.connect.runtime.WorkerTask:179) org.apache.kafka.connect.errors.ConnectException: Tolerance exceeded in error handler at org.apache.kafka.connect.runtime.errors.RetryWithToleranceOperator.execAndHandleError(RetryWithToleranceOperator.java:178) at org.apache.kafka.connect.runtime.errors.RetryWithToleranceOperator.execute(RetryWithToleranceOperator.java:104) at org.apache.kafka.connect.runtime.WorkerSourceTask.convertTransformedRecord(WorkerSourceTask.java:287) at org.apache.kafka.connect.runtime.WorkerSourceTask.sendRecords(WorkerSourceTask.java:316) at org.apache.kafka.connect.runtime.WorkerSourceTask.execute(WorkerSourceTask.java:240) at org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:177) at org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:227) at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) at java.util.concurrent.FutureTask.run(FutureTask.java:266) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) at java.lang.Thread.run(Thread.java:748) Caused by: org.apache.avro.SchemaParseException: Illegal character in: UP$OWNERID at org.apache.avro.Schema.validateName(Schema.java:1532) at org.apache.avro.Schema.access$400(Schema.java:87) at org.apache.avro.Schema$Field.<init>(Schema.java:520) at org.apache.avro.Schema$Field.<init>(Schema.java:559) at io.confluent.connect.avro.AvroData.addAvroRecordField(AvroData.java:1041) at io.confluent.connect.avro.AvroData.fromConnectSchema(AvroData.java:900) at io.confluent.connect.avro.AvroData.fromConnectSchema(AvroData.java:732) at io.confluent.connect.avro.AvroData.fromConnectSchema(AvroData.java:726) at io.confluent.connect.avro.AvroData.fromConnectData(AvroData.java:365) at io.confluent.connect.avro.AvroConverter.fromConnectData(AvroConverter.java:80) at org.apache.kafka.connect.storage.Converter.fromConnectData(Converter.java:62) at org.apache.kafka.connect.runtime.WorkerSourceTask.lambda$convertTransformedRecord$1(WorkerSourceTask.java:287) at org.apache.kafka.connect.runtime.errors.RetryWithToleranceOperator.execAndRetry(RetryWithToleranceOperator.java:128) at org.apache.kafka.connect.runtime.errors.RetryWithToleranceOperator.execAndHandleError(RetryWithToleranceOperator.java:162) ... 11 more [2020-12-11 13:52:07,271] ERROR WorkerSourceTask{id=TWCMS_Inhouse_TEST-0} Task is being killed and will not recover until manually restarted (org.apache.kafka.connect.runtime.WorkerTask:180) [2020-12-11 13:52:07,271] INFO Stopping down connector (io.debezium.connector.common.BaseSourceTask:192)