[FLINK-20238] flink-sql-connector-elasticsearch does not support Elasticsearch auth

• Type: Improvement
• Status: Closed
• Priority: Major
• Resolution: Duplicate
• Affects Version/s: 1.11.1, 1.11.2
• Component/s: Connectors / ElasticSearch
• Assignee: Unassigned
• Reporter: liu
• Created: 19/Nov/20 09:01
• Updated: 13/Apr/21 20:30
• Resolved: 19/Nov/20 14:59

Description

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

Issue Links

• is duplicated by: FLINK-18361 Support username and password options for new Elasticsearch connector