[
https://issues.apache.org/jira/browse/FLINK-18093?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17127853#comment-17127853
]
Shengkai Fang edited comment on FLINK-18093 at 6/8/20, 3:48 AM:
----------------------------------------------------------------
Currently we have cases: Kafka2AppendEs, Kafka2DynamicIndexEs and
Kafka2UpsertEs.
The goal of Kafka2AppendEs is to test whether we can write to elasticsearch
using streaming append mode and batch mode and we also add datatype test such
as ARRAY.
The goal of Kafka2DynamicIndexEs is to test whether we can write to
elasticsearch using dynamic index.
The goal of Kafka2UpsertEs is to test whether we can write to elasticsearch
using streaming upsert mode.
Of course, every case has two versions: the old connector property keys and new
connector property keys.
was (Author: fsk119):
Currently we have cases: Kafka2AppendEs, Kafka2DynamicIndexEs and
Kafka2UpsertEs.
The goal of Kafka2AppendEs is to test whether we can write to elasticsearch
using streaming append mode and batch mode and we also add datatype test such
as ARRAY.
The goal of Kafka2DynamicIndexEs is to test whether we can write to
elasticsearch using dynamic index.
The goal of Kafka2UpsertEs is to test whether we can write to elasticsearch
using streaming upsert mode.
Of course, every case has two version: the old connector property keys and new
connector property keys.
> E2E tests manually for Elasticsearch Sink
> -----------------------------------------
>
> Key: FLINK-18093
> URL: https://issues.apache.org/jira/browse/FLINK-18093
> Project: Flink
> Issue Type: Sub-task
> Components: Connectors / ElasticSearch, Tests
> Reporter: Jark Wu
> Assignee: Shengkai Fang
> Priority: Blocker
> Fix For: 1.11.0
>
>
> - test Kafka 2 ES with insert-only query
> - test Kafka 2 ES with upsert query
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
