flink

flink copied to clipboard

[FLINK-27660][table] add table api for registering function with resource

9

## What is the purpose of the change Add table api for registering function with remote resource, so that we the advance function creation can be supported in DDL. ##...

HuangZhenQiu

[FLINK-28139][docs] Add documentation for speculative execution

1

## What is the purpose of the change This PR adds documentation for speculative execution.

zhuzhurk

[FLINK-25284][Table SQL / API] Add proportion of null values to generate with datagen

6

## What is the purpose of the change The PR allows to specify the proportion of null values to generate with DataGen per field, like ``` CREATE TABLE Orders (...

snuyanzin

[FLINK-28815][docs] Translate the Real Time Reporting with the Table API page into Chinese

1

## What is the purpose of the change Improve the docs in chinese. ## Brief change log - **Translate the "Real Time Reporting with the Table API" page into Chinese**...

Mrzyxing

[FLINK-17488] Now JdbcConnectionOptions supports autoCommit control

3

- Now JdbcConnectionOptions supports autoCommit control Default behaviour hasn't changed. - Added logging information to be able to track batches ## What is the purpose of the change *(For example:...

pavel-hp

[FLINK-28870][Connector/Pulsar] Improve the Pulsar source performance when meeting small data source

1

## What is the purpose of the change When using Pulsar Source to consume data, if the data rate is small, e.g. 2 msg/s, there will be long periods of...

syhily

[FLINK-28595][Connectors/kafka] KafkaSource should not read metadata of unmatched regex topics

13

## What is the purpose of the change *KafkaSource should not read metadata of unmatched regex topics, Optimize the logic for filtering topics* ## Brief change log *The filter logic...

JasonLeeCoding

[Flink 16024][Connector][JDBC] Support FilterPushdown

12

## What is the purpose of the change Implement Filter Pushdown in JDBC Connector Source, this is an optimization that will avoid scanning the whole table into Flink when we...

qingwei91

[FLINK-28825][k8s] Add K8S pod scheduler into Kubernetes options

2

We introduce 3 options for supporting specify the K8S pod scheduler name. ## What is the purpose of the change *(For example: This pull request makes task deployment go through...

bzhaoopenstack

Field-level lineage inference

1

This pr introduces an explainLineage function to get field-level lineage relationship about Flink SQL task. For example, ``` create table src (a String,b String, c String) with ( 'connector' =...

wangqinghuan