Dear Team,
I see that the connector version referred to is elasticsearch-3.1.0. But I
am not sure from where can I get sample code using this artifact and how to
download this artifact.
Any help is appreciated.
Thanks,
Tauseef
On Tue, 18 Jun 2024 at 18:55, Tauseef Janvekar
wrote:
> Dear
参考这个案例试试：
CREATE TEMPORARY TABLE datagen_source (
a INT,
b BIGINT,
c STRING,
`proc_time` AS PROCTIME()
) WITH (
'connector'='datagen'
);
CREATE TEMPORARY TABLE hbase_dim (
rowkey INT,
family1 ROW,
family2 ROW,
family3 ROW
) WITH (
'connector'='cloudhbase',
'table-name'='',
Hi,
I'm currently working with the ElasticsearchSink class in the Flink
Elasticsearch connector. I noticed that in the createBulkProcessor method,
setConcurrentRequests(0) is used, which makes the flush() operation blocking.
From my understanding, it seems that even if we set
