diff --git a/connect/connect-jdbc-aws-redshift-sink/redshift-jdbc-sink.sh b/connect/connect-jdbc-aws-redshift-sink/redshift-jdbc-sink.sh index 6bb42a561..9c06eb208 100755 --- a/connect/connect-jdbc-aws-redshift-sink/redshift-jdbc-sink.sh +++ b/connect/connect-jdbc-aws-redshift-sink/redshift-jdbc-sink.sh @@ -4,6 +4,42 @@ set -e DIR="$( cd "$( dirname "${BASH_SOURCE[0]}" )" >/dev/null && pwd )" source ${DIR}/../../scripts/utils.sh +logwarn "WARN: This is not working, getting same issue as https://github.com/confluentinc/kafka-connect-jdbc/issues/1140" +exit 111 + +# [2023-10-26 15:54:29,575] ERROR [redshift-jdbc-sink|task-0] WorkerSinkTask{id=redshift-jdbc-sink-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:237) +# org.apache.kafka.connect.errors.ConnectException: Exiting WorkerSinkTask due to unrecoverable exception. +# at org.apache.kafka.connect.runtime.WorkerSinkTask.deliverMessages(WorkerSinkTask.java:628) +# at org.apache.kafka.connect.runtime.WorkerSinkTask.poll(WorkerSinkTask.java:340) +# at org.apache.kafka.connect.runtime.WorkerSinkTask.iteration(WorkerSinkTask.java:238) +# at org.apache.kafka.connect.runtime.WorkerSinkTask.execute(WorkerSinkTask.java:207) +# at org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:229) +# at org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:284) +# at org.apache.kafka.connect.runtime.isolation.Plugins.lambda$withClassLoader$1(Plugins.java:181) +# 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.apache.kafka.connect.errors.ConnectException: null (INT32) type doesn't have a mapping to the SQL database column type +# at io.confluent.connect.jdbc.dialect.GenericDatabaseDialect.getSqlType(GenericDatabaseDialect.java:1948) +# at io.confluent.connect.jdbc.dialect.GenericDatabaseDialect.writeColumnSpec(GenericDatabaseDialect.java:1864) +# at io.confluent.connect.jdbc.dialect.GenericDatabaseDialect.lambda$writeColumnsSpec$39(GenericDatabaseDialect.java:1853) +# at io.confluent.connect.jdbc.util.ExpressionBuilder.append(ExpressionBuilder.java:560) +# at io.confluent.connect.jdbc.util.ExpressionBuilder$BasicListBuilder.of(ExpressionBuilder.java:599) +# at io.confluent.connect.jdbc.dialect.GenericDatabaseDialect.writeColumnsSpec(GenericDatabaseDialect.java:1855) +# at io.confluent.connect.jdbc.dialect.GenericDatabaseDialect.buildCreateTableStatement(GenericDatabaseDialect.java:1772) +# at io.confluent.connect.jdbc.sink.DbStructure.create(DbStructure.java:121) +# at io.confluent.connect.jdbc.sink.DbStructure.createOrAmendIfNecessary(DbStructure.java:67) +# at io.confluent.connect.jdbc.sink.BufferedRecords.add(BufferedRecords.java:122) +# at io.confluent.connect.jdbc.sink.JdbcDbWriter.write(JdbcDbWriter.java:74) +# at io.confluent.connect.jdbc.sink.JdbcSinkTask.put(JdbcSinkTask.java:90) +# at org.apache.kafka.connect.runtime.WorkerSinkTask.deliverMessages(WorkerSinkTask.java:593) +# ... 11 more + +# string +# org.apache.kafka.connect.errors.ConnectException: null (STRING) type doesn't have a mapping to the SQL database column type + if [ ! -f ${PWD}/redshift-jdbc42-2.1.0.17/redshift-jdbc42-2.1.0.17.jar ] then mkdir -p redshift-jdbc42-2.1.0.17