[Feature][Connector-V2] add fluss Connector

[dyp12]

Purpose of this pull request

#8816 add fluss sink first

Does this PR introduce any user-facing change?

How was this patch tested?

Check list

• If any new Jar binary package adding in your PR, please add License Notice according
  New License Guide
• If necessary, please update the documentation to describe the new feature. https://github.com/apache/seatunnel/tree/dev/docs
• If necessary, please update incompatible-changes.md to describe the incompatibility caused by this PR.
• If you are contributing the connector code, please check that the following files are updated:
  1. Update plugin-mapping.properties and add new connector information in it
  2. Update the pom file of seatunnel-dist
  3. Add ci label in label-scope-conf
  4. Add e2e testcase in seatunnel-e2e
  5. Update connector plugin_config

[Copilot]

Pull request overview

This PR adds a new Fluss connector to SeaTunnel, implementing a sink connector to write data to Fluss, a streaming storage system. The implementation includes support for the timestamp_tz (TIMESTAMP_TZ) data type to handle timezone-aware timestamps.

Key changes:

• Adds Fluss sink connector with support for both upsert and append modes
• Implements JSON serialization/deserialization for OffsetDateTime (TIMESTAMP_TZ type)
• Provides E2E tests for single and multi-table scenarios

Reviewed changes

Copilot reviewed 17 out of 17 changed files in this pull request and generated 1 comment.

Show a summary per file

File	Description
seatunnel-formats/seatunnel-format-json/src/main/java/org/apache/seatunnel/format/json/RowToJsonConverters.java	Adds conversion support for TIMESTAMP_TZ to JSON using ISO_OFFSET_DATE_TIME formatter
seatunnel-formats/seatunnel-format-json/src/main/java/org/apache/seatunnel/format/json/JsonToRowConverters.java	Adds conversion support from JSON to OffsetDateTime for TIMESTAMP_TZ type
seatunnel-formats/seatunnel-format-json/src/test/java/org/apache/seatunnel/format/json/JsonRowDataSerDeSchemaTest.java	Adds test coverage for TIMESTAMP_TZ serialization/deserialization
seatunnel-connectors-v2/connector-fluss/src/main/java/org/apache/seatunnel/connectors/seatunnel/fluss/sink/FlussSinkWriter.java	Implements the core sink writer with type conversion logic including TIMESTAMP_TZ support
seatunnel-connectors-v2/connector-fluss/src/main/java/org/apache/seatunnel/connectors/seatunnel/fluss/sink/FlussSink.java	Main sink class implementing multi-table support
seatunnel-connectors-v2/connector-fluss/src/main/java/org/apache/seatunnel/connectors/seatunnel/fluss/sink/FlussSinkFactory.java	Factory class for creating Fluss sink instances
seatunnel-connectors-v2/connector-fluss/src/main/java/org/apache/seatunnel/connectors/seatunnel/fluss/config/FlussBaseOptions.java	Configuration options for Fluss connector
seatunnel-connectors-v2/connector-fluss/pom.xml	Maven dependencies for Fluss connector
seatunnel-e2e/seatunnel-connector-v2-e2e/connector-fluss-e2e/src/test/java/org/apache/seatunnel/e2e/connector/fluss/FlussSinkIT.java	E2E integration test for Fluss sink
seatunnel-e2e/seatunnel-connector-v2-e2e/connector-fluss-e2e/pom.xml	Maven dependencies for E2E tests
seatunnel-connectors-v2/pom.xml	Adds connector-fluss module
seatunnel-e2e/seatunnel-connector-v2-e2e/pom.xml	Adds connector-fluss-e2e module
seatunnel-dist/pom.xml	Includes connector-fluss in distribution
plugin-mapping.properties	Maps Fluss sink to connector-fluss module

---

💡 Add Copilot custom instructions for smarter, more guided reviews. Learn how to get started.

[davidzollo]

CI failed, please check

[davidzollo]

Please resolve conflicts.

[dyp12]

CI failed, please check

ci always fail，Could not find stored procedure 'master..xp_sqljdbc_xa_init_e

[zhangshenghang]

• Pull Request Labeler / Build (pull_request_target)

Retry the incorrect CI

[dyp12]

CI failed, please check

ci pass

[dyp12]

• Pull Request Labeler / Build (pull_request_target)

Retry the incorrect CI

thanks