Versions Compared

Old Version 6

changes.mady.by.user Andriy Redko

Saved on

compared with

New Version Current

changes.mady.by.user Chesnay Schepler

Saved on

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.

Status

...

Page properties


Discussion threadhttps://lists.apache.org/thread/j5gywt7hoo8gr3myxh1ctdxdjlq92hcf

JIRA:  Image RemovedFLINK-25756 - Dedicated Opensearch connectors

...

Vote threadhttps://lists.apache.org/thread/57sj2zzrrcohk77mczrzcth7wsvrjrqk
JIRA

Jira
serverASF JIRA
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
keyFLINK-25756

Release1.17


Please keep the discussion on the mailing list rather than commenting on the wiki (wiki discussions get unwieldy fast).

...

  • Integrate with Flink Sink API (FLIP-143)
  • Integrate with Flink new Source API (FLIP-27)
  • Build upon Flink New DynamicTableSink and DynamicTableSinkFactory interfaces (FLIP-95)
  • Sink streaming results with checkpointing enabled (at-least-once delivery semantics)
  • Integrate with Table API

The Opensearch connectors are largely based on already existing Elasticsearch connectors (more specifically, Elasticsearch 7 flavor) and APIs-wise provide the identical feature set.

Proposed Changes

We propose to introduce dedicated Opensearch connectors (for 1.x and 2.x release lines) in Flink, based on existing Elasticsearch 7 connectors (https://nightlies.apache.org/flink/flink-docs-release-1.14/docs/connectors/datastream/elasticsearch/).

...