[source-redshift] Timestamp Parse Failure

[crespire]

Connector Name

source-redshift

Connector Version

0.5.4

What step the error happened?

During the sync

Relevant information

We're looking at trying to import data during a sync but we are running into an issue on parsing a timestamp.

java.time.format.DateTimeParseException: Text '2026-03-11T17:05:58Z' could not be parsed, unparsed text found at index 19

This looks like text that should be parsable.

I'm also noticing that while our source data has the column as a timestamptz, Airbyte has detected the column as a string, which seems to be weird to me.

Relevant log output

2026-03-12 09:32:41 source ERROR i.a.c.i.b.AirbyteExceptionHandler(uncaughtException):64 Something went wrong in the connector. See the logs for more details. java.time.format.DateTimeParseException: Text '2026-03-11T17:05:58Z' could not be parsed, unparsed text found at index 19
	at java.base/java.time.format.DateTimeFormatter.parseResolved0(DateTimeFormatter.java:2111) ~[?:?]
	at java.base/java.time.format.DateTimeFormatter.parse(DateTimeFormatter.java:2010) ~[?:?]
	at java.base/java.time.LocalDateTime.parse(LocalDateTime.java:494) ~[?:?]
	at java.base/java.time.LocalDateTime.parse(LocalDateTime.java:479) ~[?:?]
	at io.airbyte.integrations.source.redshift.RedshiftSourceOperations.setTimestamp(RedshiftSourceOperations.java:57) ~[io.airbyte.airbyte-integrations.connectors-source-redshift.jar:?]
	at io.airbyte.cdk.db.jdbc.JdbcSourceOperations.setCursorField(JdbcSourceOperations.java:76) ~[airbyte-cdk-core-0.20.4.jar:?]
	at io.airbyte.cdk.db.jdbc.JdbcSourceOperations.setCursorField(JdbcSourceOperations.java:30) ~[airbyte-cdk-core-0.20.4.jar:?]
	at io.airbyte.cdk.integrations.source.jdbc.AbstractJdbcSource.getActualCursorRecordCount(AbstractJdbcSource.java:417) ~[airbyte-cdk-db-sources-0.20.4.jar:?]
	at io.airbyte.cdk.integrations.source.jdbc.AbstractJdbcSource.lambda$queryTableIncremental$18(AbstractJdbcSource.java:346) ~[airbyte-cdk-db-sources-0.20.4.jar:?]
	at io.airbyte.cdk.db.jdbc.StreamingJdbcDatabase.unsafeQuery(StreamingJdbcDatabase.java:66) ~[airbyte-cdk-core-0.20.4.jar:?]
	at io.airbyte.cdk.integrations.source.jdbc.AbstractJdbcSource.lambda$queryTableIncremental$19(AbstractJdbcSource.java:336) ~[airbyte-cdk-db-sources-0.20.4.jar:?]
	at io.airbyte.commons.util.LazyAutoCloseableIterator.computeNext(LazyAutoCloseableIterator.java:41) ~[airbyte-cdk-dependencies-0.20.4.jar:?]
	at com.google.common.collect.AbstractIterator.tryToComputeNext(AbstractIterator.java:145) ~[guava-33.0.0-jre.jar:?]
	at com.google.common.collect.AbstractIterator.hasNext(AbstractIterator.java:140) ~[guava-33.0.0-jre.jar:?]
	at com.google.common.collect.TransformedIterator.hasNext(TransformedIterator.java:46) ~[guava-33.0.0-jre.jar:?]
	at io.airbyte.commons.util.DefaultAutoCloseableIterator.computeNext(DefaultAutoCloseableIterator.java:42) ~[airbyte-cdk-dependencies-0.20.4.jar:?]
	at com.google.common.collect.AbstractIterator.tryToComputeNext(AbstractIterator.java:145) ~[guava-33.0.0-jre.jar:?]
	at com.google.common.collect.AbstractIterator.hasNext(AbstractIterator.java:140) ~[guava-33.0.0-jre.jar:?]
	at io.airbyte.cdk.integrations.source.relationaldb.StateDecoratingIterator.computeNext(StateDecoratingIterator.java:127) ~[airbyte-cdk-db-sources-0.20.4.jar:?]
	at io.airbyte.cdk.integrations.source.relationaldb.StateDecoratingIterator.computeNext(StateDecoratingIterator.java:22) ~[airbyte-cdk-db-sources-0.20.4.jar:?]
	at com.google.common.collect.AbstractIterator.tryToComputeNext(AbstractIterator.java:145) ~[guava-33.0.0-jre.jar:?]
	at com.google.common.collect.AbstractIterator.hasNext(AbstractIterator.java:140) ~[guava-33.0.0-jre.jar:?]
	at io.airbyte.commons.util.DefaultAutoCloseableIterator.computeNext(DefaultAutoCloseableIterator.java:42) ~[airbyte-cdk-dependencies-0.20.4.jar:?]
	at com.google.common.collect.AbstractIterator.tryToComputeNext(AbstractIterator.java:145) ~[guava-33.0.0-jre.jar:?]
	at com.google.common.collect.AbstractIterator.hasNext(AbstractIterator.java:140) ~[guava-33.0.0-jre.jar:?]
	at com.google.common.collect.TransformedIterator.hasNext(TransformedIterator.java:46) ~[guava-33.0.0-jre.jar:?]
	at io.airbyte.commons.util.DefaultAutoCloseableIterator.computeNext(DefaultAutoCloseableIterator.java:42) ~[airbyte-cdk-dependencies-0.20.4.jar:?]
	at com.google.common.collect.AbstractIterator.tryToComputeNext(AbstractIterator.java:145) ~[guava-33.0.0-jre.jar:?]
	at com.google.common.collect.AbstractIterator.hasNext(AbstractIterator.java:140) ~[guava-33.0.0-jre.jar:?]
	at io.airbyte.commons.util.CompositeIterator.computeNext(CompositeIterator.java:74) ~[airbyte-cdk-dependencies-0.20.4.jar:?]
	at com.google.common.collect.AbstractIterator.tryToComputeNext(AbstractIterator.java:145) ~[guava-33.0.0-jre.jar:?]
	at com.google.common.collect.AbstractIterator.hasNext(AbstractIterator.java:140) ~[guava-33.0.0-jre.jar:?]
	at io.airbyte.commons.util.DefaultAutoCloseableIterator.computeNext(DefaultAutoCloseableIterator.java:42) ~[airbyte-cdk-dependencies-0.20.4.jar:?]
	at com.google.common.collect.AbstractIterator.tryToComputeNext(AbstractIterator.java:145) ~[guava-33.0.0-jre.jar:?]
	at com.google.common.collect.AbstractIterator.hasNext(AbstractIterator.java:140) ~[guava-33.0.0-jre.jar:?]
	at java.base/java.util.Iterator.forEachRemaining(Iterator.java:132) ~[?:?]
	at io.airbyte.cdk.integrations.base.IntegrationRunner.produceMessages(IntegrationRunner.java:236) ~[airbyte-cdk-core-0.20.4.jar:?]
	at io.airbyte.cdk.integrations.base.IntegrationRunner.readSerial(IntegrationRunner.java:276) ~[airbyte-cdk-core-0.20.4.jar:?]
	at io.airbyte.cdk.integrations.base.IntegrationRunner.runInternal(IntegrationRunner.java:173) ~[airbyte-cdk-core-0.20.4.jar:?]
	at io.airbyte.cdk.integrations.base.IntegrationRunner.run(IntegrationRunner.java:125) ~[airbyte-cdk-core-0.20.4.jar:?]
	at io.airbyte.integrations.source.redshift.RedshiftSource.main(RedshiftSource.java:141) ~[io.airbyte.airbyte-integrations.connectors-source-redshift.jar:?]

Stack Trace: java.time.format.DateTimeParseException: Text '2026-03-11T17:05:58Z' could not be parsed, unparsed text found at index 19
	at java.base/java.time.format.DateTimeFormatter.parseResolved0(DateTimeFormatter.java:2111)
	at java.base/java.time.format.DateTimeFormatter.parse(DateTimeFormatter.java:2010)
	at java.base/java.time.LocalDateTime.parse(LocalDateTime.java:494)
	at java.base/java.time.LocalDateTime.parse(LocalDateTime.java:479)
	at io.airbyte.integrations.source.redshift.RedshiftSourceOperations.setTimestamp(RedshiftSourceOperations.java:57)
	at io.airbyte.cdk.db.jdbc.JdbcSourceOperations.setCursorField(JdbcSourceOperations.java:76)
	at io.airbyte.cdk.db.jdbc.JdbcSourceOperations.setCursorField(JdbcSourceOperations.java:30)
	at io.airbyte.cdk.integrations.source.jdbc.AbstractJdbcSource.getActualCursorRecordCount(AbstractJdbcSource.java:417)
	at io.airbyte.cdk.integrations.source.jdbc.AbstractJdbcSource.lambda$queryTableIncremental$18(AbstractJdbcSource.java:346)
	at io.airbyte.cdk.db.jdbc.StreamingJdbcDatabase.unsafeQuery(StreamingJdbcDatabase.java:66)
	at io.airbyte.cdk.integrations.source.jdbc.AbstractJdbcSource.lambda$queryTableIncremental$19(AbstractJdbcSource.java:336)
	at io.airbyte.commons.util.LazyAutoCloseableIterator.computeNext(LazyAutoCloseableIterator.java:41)
	at com.google.common.collect.AbstractIterator.tryToComputeNext(AbstractIterator.java:145)
	at com.google.common.collect.AbstractIterator.hasNext(AbstractIterator.java:140)
	at com.google.common.collect.TransformedIterator.hasNext(TransformedIterator.java:46)
	at io.airbyte.commons.util.DefaultAutoCloseableIterator.computeNext(DefaultAutoCloseableIterator.java:42)
	at com.google.common.collect.AbstractIterator.tryToComputeNext(AbstractIterator.java:145)
	at com.google.common.collect.AbstractIterator.hasNext(AbstractIterator.java:140)
	at io.airbyte.cdk.integrations.source.relationaldb.StateDecoratingIterator.computeNext(StateDecoratingIterator.java:127)
	at io.airbyte.cdk.integrations.source.relationaldb.StateDecoratingIterator.computeNext(StateDecoratingIterator.java:22)
	at com.google.common.collect.AbstractIterator.tryToComputeNext(AbstractIterator.java:145)
	at com.google.common.collect.AbstractIterator.hasNext(AbstractIterator.java:140)
	at io.airbyte.commons.util.DefaultAutoCloseableIterator.computeNext(DefaultAutoCloseableIterator.java:42)
	at com.google.common.collect.AbstractIterator.tryToComputeNext(AbstractIterator.java:145)
	at com.google.common.collect.AbstractIterator.hasNext(AbstractIterator.java:140)
	at com.google.common.collect.TransformedIterator.hasNext(TransformedIterator.java:46)
	at io.airbyte.commons.util.DefaultAutoCloseableIterator.computeNext(DefaultAutoCloseableIterator.java:42)
	at com.google.common.collect.AbstractIterator.tryToComputeNext(AbstractIterator.java:145)
	at com.google.common.collect.AbstractIterator.hasNext(AbstractIterator.java:140)
	at io.airbyte.commons.util.CompositeIterator.computeNext(CompositeIterator.java:74)
	at com.google.common.collect.AbstractIterator.tryToComputeNext(AbstractIterator.java:145)
	at com.google.common.collect.AbstractIterator.hasNext(AbstractIterator.java:140)
	at io.airbyte.commons.util.DefaultAutoCloseableIterator.computeNext(DefaultAutoCloseableIterator.java:42)
	at com.google.common.collect.AbstractIterator.tryToComputeNext(AbstractIterator.java:145)
	at com.google.common.collect.AbstractIterator.hasNext(AbstractIterator.java:140)
	at java.base/java.util.Iterator.forEachRemaining(Iterator.java:132)
	at io.airbyte.cdk.integrations.base.IntegrationRunner.produceMessages(IntegrationRunner.java:236)
	at io.airbyte.cdk.integrations.base.IntegrationRunner.readSerial(IntegrationRunner.java:276)
	at io.airbyte.cdk.integrations.base.IntegrationRunner.runInternal(IntegrationRunner.java:173)
	at io.airbyte.cdk.integrations.base.IntegrationRunner.run(IntegrationRunner.java:125)
	at io.airbyte.integrations.source.redshift.RedshiftSource.main(RedshiftSource.java:141)
2026-03-12 09:32:51 replication-orchestrator ERROR Source process exited with non-zero exit code 1
2026-03-12 09:32:51 replication-orchestrator ERROR SourceReader error:

Contribute

• Yes, I want to contribute

---

Internal Tracking: https://github.com/airbytehq/oncall/issues/11631

[octavia-bot]

AI Triage Starting...

Thank you for opening this issue! I'm an AI assistant that will do an initial review and may:

• Ask clarifying questions if needed
• Suggest relevant documentation or workarounds
• Flag this for internal visibility

Note: Community issues are reviewed on a best-effort basis and do not have a guaranteed response time. For additional help:

• Join the Airbyte Community Slack to connect with other users and community members
• If you're an Airbyte Cloud customer, you can open a support ticket or contact your account representative, referencing this issue URL

View playbook

• 🔗 Session URL: https://app.devin.ai/sessions/50c8d6195d8b407b9f29b5cf54bb1ae7

✅ Devin AI session created successfully!

[devin-ai-integration]

Hi Simmon Li (@crespire), thank you for reporting this issue!

I was able to trace the root cause of this bug in the source code.

Technical Analysis

The error occurs in RedshiftSourceOperations.setTimestamp(), which is called when setting cursor field values for incremental syncs.

The method uses LocalDateTime.parse(value) to parse the timestamp string. However, LocalDateTime.parse() only accepts timestamps without timezone information (e.g., 2026-03-11T17:05:58). Your value 2026-03-11T17:05:58Z includes the Z (UTC) timezone suffix at index 19, which causes the DateTimeParseException.

This is a confirmed bug — the connector's copyToJsonField method already has special handling for timestamptz columns (converting them with timezone awareness), but the corresponding setTimestamp method used for cursor comparison does not account for timezone suffixes in the serialized value.

Your observation that the timestamptz column is detected as string by Airbyte may be a related secondary issue in schema discovery.

Workaround: If possible, you may be able to use a different cursor column that is not of type timestamptz (e.g., an integer ID or plain timestamp without timezone) to unblock your incremental syncs while this is being addressed.

I have escalated this to the internal team for investigation: https://github.com/airbytehq/oncall/issues/11631

---

Need more help? Join Airbyte Community Slack for peer support, or if you're a Cloud customer, open a support ticket referencing this URL.

[crespire]

I should add that this error only happens if we set the cursor to this column, so it does seem like there's something wrong with cursor parsing.