`org.postgresql.util.PSQLException` should cause the task to fail

[yeikel]

I am currently seeing the following error in the logs :

[2023-12-08 14:33:07,008] ERROR [event-log\|task-0] Failed to run query for table TimestampIncrementingTableQuerier{table=null, query='SELECT * FROM (SELECT * FROM event and action_layer_tx='service' AND event_status_tx='COMPLETED_SUCCESS') as elv1', topicPrefix='topic', incrementingColumn='', timestampColumns=[create_epoch_ts]}: {} (io.confluent.connect.jdbc.source.JdbcSourceTask:386)
  | org.postgresql.util.PSQLException: ERROR: syntax error at or near "and"
  | Position: 46
  | at org.postgresql.core.v3.QueryExecutorImpl.receiveErrorResponse(QueryExecutorImpl.java:2676)
  | at org.postgresql.core.v3.QueryExecutorImpl.processResults(QueryExecutorImpl.java:2366)
  | at org.postgresql.core.v3.QueryExecutorImpl.execute(QueryExecutorImpl.java:356)
  | at org.postgresql.jdbc.PgStatement.executeInternal(PgStatement.java:496)
  | at org.postgresql.jdbc.PgStatement.execute(PgStatement.java:413)
  | at org.postgresql.jdbc.PgPreparedStatement.executeWithFlags(PgPreparedStatement.java:190)
 

But the task is still active. I was only able to find out that something is wrong because I checked the logs manually. This should not be necessary

Sample configuration :

{
    "connector.class": "io.confluent.connect.jdbc.JdbcSourceConnector",
    "timestamp.column.name": "create_epoch_ts",
    "connection.password": "redacted",
    "tasks.max": "1",
    "query": "SELECT * FROM (SELECT * FROM event and action_layer_tx='service' AND event_status_tx='COMPLETED_SUCCESS') as elv1",
    "connection.attempts": "10",
    "batch.max.rows": "100",
    "connection.backoff.ms": "1000",
    "mode": "timestamp",
    "topic.prefix": "redacted",
    "connection.user": "redacted",
    "db.timezone": "America/Denver",
    "poll.interval.ms": "100",
    "name": "test",
    "errors.tolerance": "none",
    "connection.url": "jdbc:postgresql://redacted:5432/redacted"
}

In this case, my query was invalid, but I should think that the task should fail rather than to just log it and keep the task active