[ 
https://issues.apache.org/jira/browse/FLINK-16788?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

zhisheng updated FLINK-16788:
-----------------------------
    Comment: was deleted

(was: Hi Jark

If you need to enable authentication, you need install xpack plugin. The
new ElasticSearch version(6.8 above) includes xpack by default[1]. Previous
versions required install xpack plugins[2].

I have personally tested each version of ElasticSearch(5/6/7) and it work
fine.  Yeah, it is possible to verify it in integration test.

[1](
https://www.elastic.co/guide/en/elasticsearch/reference/current/setup-xpack.html
)

[2](
https://www.elastic.co/guide/en/elasticsearch/reference/6.8/setup-xpack.html
)

Jark Wu (Jira) <[email protected]> 于2020年3月26日周四 下午5:40写道:

)

> ElasticSearch Connector SQL DDL add optional config (eg: 
> enable-auth/username/password)
> ---------------------------------------------------------------------------------------
>
>                 Key: FLINK-16788
>                 URL: https://issues.apache.org/jira/browse/FLINK-16788
>             Project: Flink
>          Issue Type: Improvement
>          Components: Connectors / ElasticSearch, Table SQL / API
>    Affects Versions: 1.10.0
>            Reporter: zhisheng
>            Priority: Major
>             Fix For: 1.11.0
>
>
> In a production environment, accessing elasticsearch usually requires 
> authentication, and requires a username and password to access it, but the 
> current version of SQL DDL does not support users to configure these 
> parameters.
>  
> I have improve it in our company, and we use it as follows:
>  
> CREATE TABLE user_behavior_es (
>     user_idBIGINT,
>     item_id BIGINT
> ) WITH (
>     'connector.type'='elasticsearch',
>     'connector.version'='7',
>     'connector.hosts'='http://localhost:9200',
>     'connector.index'='user_behavior_es',
>     'connector.document-type'='user_behavior_es',
>     'connector.enable-auth'='true',
>     'connector.username'='zhisheng',
>     'connector.password'='123456',
>     'format.type'='json',
>     'update-mode'='append',
>     'connector.bulk-flush.max-actions'='10'
> )



--
This message was sent by Atlassian Jira
(v8.3.4#803005)

Reply via email to