Soumya Ghosh
04/19/2023, 6:54 AMelasticsearch-7 ) table connector and exploring the below configurations mentioned in document.
• connection.request-timeout
• connection.timeout
• socket.timeout
When I use above connector options in Flink table DDL, I’m getting error that above options are not supported. Is there a specific way to utilize these configs?
Error:
Caused by: org.apache.flink.table.api.ValidationException: Unsupported options found for 'elasticsearch-7'.
Unsupported options:
connection.request-timeout
connection.timeout
socket.timeout
Supported options:
connection.path-prefix
connector
document-id.key-delimiter
failure-handler
format
hosts
index
json.encode.decimal-as-plain-number
json.fail-on-missing-field
json.ignore-parse-errors
json.map-null-key.literal
json.map-null-key.mode
json.timestamp-format.standard
password
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
username
at org.apache.flink.table.factories.FactoryUtil.validateUnconsumedKeys(FactoryUtil.java:631)
at org.apache.flink.table.factories.FactoryUtil$FactoryHelper.validate(FactoryUtil.java:923)
at org.apache.flink.streaming.connectors.elasticsearch.table.Elasticsearch7DynamicSinkFactory.createDynamicTableSink(Elasticsearch7DynamicSinkFactory.java:93)
at org.apache.flink.table.factories.FactoryUtil.createDynamicTableSink(FactoryUtil.java:266)
... 18 more