Liu Jiangang

[FLINK-28548][Connectors / FileSystem] Fix the exception FileNotFoundException when the commit partition base path is not created

4

## What is the purpose of the change *The commit partition base path is not created when no data is sent which may cause FileNotFoundException. Just fix it.* ## Brief...

[FLINK-28208][Connectors/Hive] Set parallelism for map operator in class HiveTableSink's method createBatchSink

1

## What is the purpose of the change *Set parallelism for map operator in class HiveTableSink's method createBatchSink in order to keep consistent with HiveTableSink. If not so, the operators...

Fail to run "kubectl create -f examples/wordcount/flink-operator-custom-resource.yaml"

1

Error from server (NotFound): error when creating "examples/wordcount/flink-operator-custom-resource.yaml": namespaces "flink-operator" not found

This commit introduces a new feature that allows for dynamic index generation in the Elasticsearch connector. The index name can now be constructed by appending a suffix derived from a...

[FLINK-38371][Connectors / ElasticSearch] Add `sink.retry-on-conflicts` option to Elasticsearch Sink

1

This pull request introduces a new configuration option, sink.retry-on-conflicts, for the Elasticsearch table sink. This option allows users to specify the number of times to retry an update request when...

[FLINK-38372][Runtime / Metrics] Introduces whitelist to the flink-metrics-prometheus

1

## What is the purpose of the change *Allowing users to specify a whitelist of metrics to be exposed through the Prometheus reporter.* ## Brief change log - *Adding a...