Skip to content

Support Array type in Flink connector #1978

@platinumhamburg

Description

@platinumhamburg

Search before asking

  • I searched in the issues and found nothing similar.

Motivation

Enable Flink connector to read and write Array, NestedRow, and Map types for integration with Flink SQL and DataStream API.

Solution

  • Add type mapping between Flink types and Fluss complex types
  • Implement serialization/deserialization for complex types in Flink connector
  • Support complex types in both source and sink connectors
  • Add integration tests for Flink connector with complex types

Anything else?

No response

Willingness to contribute

  • I'm willing to submit a PR!

Metadata

Metadata

Assignees

No one assigned

    Labels

    No labels
    No labels
    No fields configured for Feature.

    Projects

    No projects

    Milestone

    Relationships

    None yet

    Development

    No branches or pull requests

    Issue actions