flink

flink copied to clipboard

[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...

Myracle

[FLINK-27399][Connector/Pulsar] Change initial consuming position setting logic for better handle the checkpoint.

5

## What is the purpose of the change ## Brief change log This task modifies the `flink-connector-pulsar` module, adds some new mechanisms to set the initial consuming position. - Change...

syhily

[FLINK-28932][Table/SQL] Use Builder#withConfiguration instead of deprecated EnvironmentSettings#fromConfiguration

1

## What is the purpose of the change The PR makes use of `Builder#withConfiguration(Configuration)` instead of deprecated `org.apache.flink.table.api.EnvironmentSettings#fromConfiguration` ## Brief change log `flink-table/flink-sql-gateway/src/main/java/org/apache/flink/table/gateway/service/context/SessionContext.java` ## Verifying this change This change is...

snuyanzin

[FLINK-28861][table] Make UID generation behavior configurable and plan-only by default

1

## What is the purpose of the change This PR fixes two critical bugs in the stream operator UID generation of Table API. 1) Not deterministic UID: Due to changes...

twalthr

[hotfix][doc]Fixed the problem that the Checkpoint document directory…

2

## What is the purpose of the change I found that there is one place in the Chinese documentation of Checkpoint that cannot be jumped correctly.And i fixed it. ##...

meng1222

[FLINK-28893][table] Add built-in conv function.

2

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

liuyongvs

[WIP] [FLINK-28773][hive] Fix HiveTableSink failed to report statistic to hive metastore

1

## What is the purpose of the change To fix the issue that HiveTableSInk fails to report [statistic](https://cwiki.apache.org/confluence/display/hive/statsdev) to Hive metastore. ## Brief change log - When commit non-partition table/partition,...

luoyuxia

[FLINK-28929][table] Add built-in datediff function.

2

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

liuyongvs

[FLINK-28924][docs-zh] Translate "LIMIT clause" page into Chinese.

2

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

liuzhuang2017

[FLINK-28817] NullPointerException in HybridSource when restoring from checkpoint

2

## What is the purpose of the change This pull request fix NullPointerException in HybridSource when restoring from checkpoint. After the recovery action is triggered, only the source with sourceIndex...

zhongqishang