Brian Zhou

Allow inner class being parameter of `withTimestampAssigner` in Table API stream table source

3

**Problem description** Due to the serialization validation for `connectorProperties`, only `public` `static-inner/outer` class implements `AssignerWithTimeWindow` is supported as a parameter of `withTimestampAssigner` in Table API stream table source. We should...

**Problem description** Testcontainers can be used from inside a container, this is very useful for different CI scenarios like running everything in containers on Jenkins. When starting the Pravega container...

Support protobuf format in Pravega catalog

1

**Problem description** As Flink introduced the protobuf support in Flink 1.16.0, we can now support protobuf format in the Pravega catalog as well. **Problem location** Catalog **Suggestions for an improvement**...

**Problem description** There are some jackson usages in the code base, it is good to use the `JacksonMapperFactory` provided from the flink-core, this only affects the Flink 1.16 connector **Problem...

Documentation for auth/tls enabled settings unclear

1

**Problem description** The stream manager in python client has two flags to turn on the auth and tls, but it is not mentioned in the documentation or code comments, especially...

**Problem description** We can have a github.io website to host the document There is already mkdocs in the `documentation` folder. **Problem location** **Suggestions for an improvement**

**Problem description** Apache Flink is released in March https://flink.apache.org/2024/03/18/announcing-the-release-of-apache-flink-1.19/ We need to upgrade the connector to the latest version as well. We also need to replace all the deprecated usages...

Applying trial license after Elasticsearch creation causing cluster in a bad state

2

We have ECK operator 3.0.0 running with Elasticsearch 9.0.2. We create an `Elasticsearch` resource with a `StackConfigPolicy` which enables the oidc authentication in configs and also has some related secrets...