You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@flink.apache.org by "liu (Jira)" <ji...@apache.org> on 2020/11/19 09:02:00 UTC

[jira] [Created] (FLINK-20238) flink-sql-connector-elasticsearch does not support Elasticsearch auth

liu created FLINK-20238:
---------------------------

             Summary: flink-sql-connector-elasticsearch  does not support Elasticsearch auth
                 Key: FLINK-20238
                 URL: https://issues.apache.org/jira/browse/FLINK-20238
             Project: Flink
          Issue Type: Wish
    Affects Versions: 1.11.2, 1.11.1
            Reporter: liu


Flink SQL> INSERT INTO cdc_enriched_orders
> SELECT o.*, p.name, p.description, s.shipment_id, s.origin, s.destination, s.is_arrived
> FROM cdc_orders AS o
> LEFT JOIN cdc_products AS p ON o.product_id = p.id
> LEFT JOIN cdc_shipments AS s ON o.order_id = s.order_id;
[INFO] Submitting SQL update statement to the cluster...
[ERROR] Could not execute SQL statement. Reason:
org.apache.flink.table.api.ValidationException: Unsupported options found for connector 'elasticsearch-7'.

Unsupported options:

password
username

Supported options:

connection.max-retry-timeout
connection.path-prefix
connector
document-id.key-delimiter
failure-handler
format
hosts
index
json.fail-on-missing-field
json.ignore-parse-errors
json.timestamp-format.standard
property-version
sink.bulk-flush.backoff.delay
sink.bulk-flush.backoff.max-retries
sink.bulk-flush.backoff.strategy
sink.bulk-flush.interval
sink.bulk-flush.max-actions
sink.bulk-flush.max-size
sink.flush-on-checkpoint



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