Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Encountering this error between Postgre & Snowflake: org.apache.kafka.connect.errors.DataException: Invalid Java object for schema with type STRING: class java.lang.Long for field: "created_at" #52083

Open
FraPaoletti98 opened this issue Jan 22, 2025 · 0 comments

Comments

@FraPaoletti98
Copy link

FraPaoletti98 commented Jan 22, 2025

Topic

I'm encountering this error:
org.apache.kafka.connect.errors.DataException: Invalid Java object for schema with type STRING: class java.lang.Long for field: "created_at"

on only one table out of 50 of my db.
I have set up a connection between Posgre and Snowflake with the CDC option. I launched a full refresh of all tables and it succeeded. I tried to remove this table and everything also works, so i do not understand why it happens :(
I'm using the latest versions of connectors for both source and destination & the Airbyte version is 1.2.0.

Relevant information

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Projects
None yet
Development

No branches or pull requests

2 participants