Hello folks, I am using <Flink Elasticsearch> (`el...
# troubleshooting
s
Hello folks, I am using Flink Elasticsearch (
elasticsearch-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:
Copy code
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