flink

flink copied to clipboard

[FLINK-28800][network] HsFileDataManager should avoid busy-loop when fileReader has not data to read

1

## What is the purpose of the change *When fileReader has no data to read, for example, most of the data is consumed from memory. HsFileDataManager will encounter busy-loop problem,...

reswqa

[kinesis][glue] Updating AWS SDK dependencies to latest versions

3

## What is the purpose of the change - Updating AWS SDK dependencies to latest versions to pull recent bug fixes and add support for new AWS regions. - Removing...

dannycranmer

[FLINK-27856][flink-kubernetes]solve the NPE error of no spec field in taskmanager pod template.

6

## What is the purpose of the change This pull request fix the NPE error of TM pod template file without spec field. ## Brief change log Add validation for...

Grypse

[FLINK-28750][Hive]The field comment for hive ddl has logic error

2

## What is the purpose of the change The field comment is lost when using hive parser. There are som logic error for parsering hive sql ```java "set table.sql-dialect=hive;\n" +...

hehuiyuan

[FLINK-28639][Runtime/Checkpointing] Preserve consistency of events from subtask to OC

10

## What is the purpose of the change This PR is a continuation of #20275, further guaranteeing the consistency of operator events sent from subtasks to their coordinators. A coordinator...

yunfengzhou-hub

[FLINK-28922][docs-zh] Translate "ORDER BY clause" page into Chinese.

2

## What is the purpose of the change - Translate "ORDER BY clause" page into Chinese: https://nightlies.apache.org/flink/flink-docs-master/zh/docs/dev/table/sql/queries/orderby/. - The markdown file is located in "docs/content.zh/docs/dev/table/sql/queries/orderby.md". - Details See [FLINK-28922](https://issues.apache.org/jira/browse/FLINK-28922) for...

liuzhuang2017

[FLINK-28919][table] Add built-in generate_series function.

1

## What is the purpose of the change *Add built-in generate_series function.*

liuyongvs

[FLINK-28916][e2e] Add e2e test for create function using jar syntax

2

## What is the purpose of the change Add e2e test for create function using jar syntax that using remote hdfs jar ## Brief change log - *Add e2e test...

lsyldliu

[FLINK-28010][state] Use deleteRange to optimize the clear method of RocksDBMapState.

6

## What is the purpose of the change This pull request will use `deleteRange` to optimize the `clear` method of `RocksDBMapState`. ## Brief change log Replace RocksDB's `Iterator` with `deleteRange`....

liming30

[FLINK-28858][docs] Add document to describe join hints for batch sql

1

## What is the purpose of the change This pr is aims to add document for introduce join hints for batch sql. ## Brief change log - Adding join hints...

swuferhong