twosom

implementation equals and hashCode of FlinkOrderedListState

2

**Please** add a meaningful description for your change here fixed #31724 This PR Contains implementation `equals` and `hashCode` of `FlinkOrderedListState` ------------------------ Thank you for your contribution! Follow this checklist to...

[Feature Request]: Implement equals, hashCode in FlinkRunner's OrderedListState.

1

### What would you like to happen? FlinkRunner's OrderedListState (i.e. FlinkOrderedListState) does not have an implementation of equals, hashCode, unlike other States in FlinkRunner. Before starting to write tests for...

[Feature Request]: Add OrderedListState test in StateInternalsTest

1

### What would you like to happen? As the number of state operators in Apache Beam grows, we need to update the existing StateInternalsTest. Currently, tests exist for ValueState, BagState,...

[FLINK-35870] Change DEFAULT_KAFKA_TRANSACTION_TIMEOUT in KafkaSinkBuilder

1

change `DEFAULT_KAFKA_TRANSACTION_TIMEOUT` in `KafkaSinkBuilder` class. The default value is 15 minutes, as shown in the official Kakfa documentation. So I changed it from 1 hour to 15 minutes and added...

added methods for support ValueProvider in `MqttIO`

3

**Please** add a meaningful description for your change here fixes #19378 This PR contains thease changes - add `ValueProvider` methods for `MqttIO.ConnectionConfiguration` ------------------------ Thank you for your contribution! Follow this...

[FLINK-36029] Add @Nullable Annotation to ValueState's Value Method Return Type

1

## What is the purpose of the change The `ValueState#value` description says that null can be returned, but the method does not have the `@Nullable` annotation. So it seems reasonable...

[Feature][Integration][Java] add ElasticsearchVectorStore in Java

2

Linked issue: #321 ### Purpose of change This PR implements the Java version of Vector Store functionality for Flink Agents, following the design proposal in #143. This implementation enables RAG...

### Search before asking - [x] I searched in the [issues](https://github.com/apache/flink-agents/issues) and found nothing similar. ### Description Following the design proposal in #143, we need to implement Java version of...