Skip to content

Conversation

@priyanshu-ctds
Copy link
Collaborator

Fix

fixes #195

Types of changes

  • Bug fix (non-breaking change which fixes an issue)
  • New feature (non-breaking change which adds functionality)
  • Breaking change (fix or feature that would cause existing functionality to change)
  • I have read the CONTRIBUTING document.
  • My code follows the code style of this project.
  • My change requires a change to the documentation.
  • I have updated the documentation accordingly.
  • I have added tests to cover my changes.
  • All new and existing tests passed.

Description

The Pull request fixes the connector issue, in which Cassandra CDC (Change Data Capture) Source Connector encounters a ClassCastException when processing data from tables that contain collection columns (list, map, or set) storing timestamp values.

What's added/changed

  • Custom Marshalling method for collection fields in AbstractNativeConverter, which checks for Instant type data and converts that to long data.
  • Integrated the new marshaling methods with collection columns (list, map, or set) converters.

Checklist:

  • My code follows the style guidelines of this project.
  • I have performed a self-review of my own code.
  • I have commented my code, particularly in hard-to-understand areas.
  • I have made corresponding changes to the documentation.
  • My changes generate no new warnings.
  • Any dependent changes have been merged and published in downstream modules.

…ction value marshaling

(cherry picked from commit e84e9d7)
…tion value marshaling with null safety and custom mapping

(cherry picked from commit eb05e8a)
@srinath-ctds srinath-ctds merged commit aa12550 into master Jul 29, 2025
71 of 72 checks passed
@srinath-ctds srinath-ctds deleted the pr_196 branch July 29, 2025 05:27
Copy link

@sandeep-ctds sandeep-ctds left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

LGTM!!

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

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

[Connnector] Cassandra CDC Connector Fails with ClassCastException for Timestamp Values in Collection Columns

5 participants