Source-postgres case sensitive column issue. "updatedat" vs "users.updatedAt"

[prateekmukhedkar]

Connector Name

source-postgres

Connector Version

3.1.0

What step the error happened?

During the sync

Revelant information

Postgres 3.1.0 sync is failing with on one cloud user (job link)

"stacktrace" : "java.lang.RuntimeException: org.postgresql.util.PSQLException: ERROR: column \"updatedat\" does not exist\n Hint: Perhaps you meant to reference the column \"users.updatedAt\".\n Position: 10\n\tat io.airbyte.integrations.source.postgres.PostgresQueryUtils.lambda$getCursorBasedSyncStatusForStreams$4(PostgresQueryUtils.java:178)\n\tat java.base/java.lang.Iterable.forEach(Iterable.java:75)\n\tat io.airbyte.integrations.source.postgres.PostgresQueryUtils.getCursorBasedSyncStatusForStreams(PostgresQueryUtils.java:143)\n\tat io.airbyte.integrations.source.postgres.PostgresSource.getIncrementalIterators(PostgresSource.java:530)\n\tat io.airbyte.integrations.source.postgres.PostgresSource.getIncrementalIterators(PostgresSource.java:127)\n\tat io.airbyte.integrations.source.relationaldb.AbstractDbSource.read(AbstractDbSource.java:161)\n\tat io.airbyte.integrations.base.ssh.SshWrappedSource.read(SshWrappedSource.java:74)\n\tat io.airbyte.integrations.base.spec_modification.SpecModifyingSource.read(SpecModifyingSource.java:49)\n\tat io.airbyte.integrations.base.IntegrationRunner.runInternal(IntegrationRunner.java:139)\n\tat io.airbyte.integrations.base.IntegrationRunner.run(IntegrationRunner.java:99)\n\tat io.airbyte.integrations.source.postgres_strict_encrypt.PostgresSourceStrictEncrypt.main(PostgresSourceStrictEncrypt.java:70)\nCaused by: org.postgresql.util.PSQLException: ERROR: column \"updatedat\" does not exist\n Hint: Perhaps you meant to reference the column \"users.updatedAt\".\n Position: 10\n\tat org.postgresql.core.v3.QueryExecutorImpl.receiveErrorResponse(QueryExecutorImpl.java:2676)\n\tat org.postgresql.core.v3.QueryExecutorImpl.processResults(QueryExecutorImpl.java:2366)\n\tat org.postgresql.core.v3.QueryExecutorImpl.execute(QueryExecutorImpl.java:356)\n\tat org.postgresql.jdbc.PgStatement.executeInternal(PgStatement.java:496)\n\tat org.postgresql.jdbc.PgStatement.execute(PgStatement.java:413)\n\tat org.postgresql.jdbc.PgPreparedStatement.executeWithFlags(PgPreparedStatement.java:190)\n\tat org.postgresql.jdbc.PgPreparedStatement.executeQuery(PgPreparedStatement.java:134)\n\tat com.zaxxer.hikari.pool.ProxyPreparedStatement.executeQuery(ProxyPreparedStatement.java:52)\n\tat com.zaxxer.hikari.pool.HikariProxyPreparedStatement.executeQuery(HikariProxyPreparedStatement.java)\n\tat io.airbyte.integrations.source.postgres.PostgresQueryUtils.lambda$getCursorBasedSyncStatusForStreams$2(PostgresQueryUtils.java:161)\n\tat io.airbyte.db.jdbc.DefaultJdbcDatabase.bufferedResultSetQuery(DefaultJdbcDatabase.java:55)\n\tat io.airbyte.integrations.source.postgres.PostgresQueryUtils.lambda$getCursorBasedSyncStatusForStreams$4(PostgresQueryUtils.java:161)\n\t... 10 more\n",

Relevant log output

No response

Contribute

• Yes, I want to contribute