flink-connector-elasticsearch

flink-connector-elasticsearch copied to clipboard

Support multiple updates on a single document in ES8 client

1

The ability to perform multiple updates on a single Elasticsearch document was available in the ES7 client but is currently not supported in the ES8 client.This PR introduces this feature...

TerminaCoder

[FLINK-37831] V3.1 do not retry failed index operations

1

When using flink-connector-elasticsearch8 ver. 3.1.0-1.20 with flink ver. 1.20.1, the retry of failed index operations has two problems: 1. the isRetryable method is testing error.getCause() which is null in case...

thbay

[FLINK-37830] V3.1 restore checkpoint arraylist NPE

2

When using flink-connector-elasticsearch8 ver. 3.1.0-1.20 with flink ver. 1.20.1, restore checkpoint state in the connector fails the NullPointerException for ArrayList: ` 2025-05-12 08:14:09 com.esotericsoftware.kryo.KryoException: java.lang.NullPointerException Serialization trace: _children (com.fasterxml.jackson.databind.node.ArrayNode) _children...

thbay