flink

flink copied to clipboard

[Flink 14101][Connectors][Jdbc] SQL Server dialect

12

## What is the purpose of the change Support Microsoft SQL Server in JDBC connector ## Brief change log - Added SqlServerDialect and corresponding helper class ## Verifying this change...

qingwei91

[FLINK-25371] Include data port as part of the host info for subtask detail panel on Web UI

2

## What is the purpose of the change Help user locate the container where a task is running on from Web UI by including port in the host info on...

X-czh

[FLINK-27857][hive] HiveSource supports filter push down for orc format

1

## What is the purpose of the change Make hive source support filter push down for orc format ## Brief change log - Make HiveTableSource implement `SupportsFilterPushDown` - Pass the...

luoyuxia

[FLINK-28842][Connector/Kafka] Add client.id.prefix for the KafkaSink

3

## What is the purpose of the change Adding a way to configure `client.id.prefix` for the KafkaSink, which, internally, configures `client.id` for the KafkaProducer. This implementation essentially copies the implementation...

sap1ens

[FLINK-28837][chinese-translation] Translate "Hybrid Source" page of …

2

## What is the purpose of the change *Translate "Hybrid Source" page of "DataStream Connectors" into Chinese* ## Brief change log *Translate "Hybrid Source" page of "DataStream Connectors" into Chinese*...

JasonLeeCoding

Just for CI

4

Just for CI, please ignore

1996fanrui

Just for test : output buffer aligned to uc

3

Just for test

1996fanrui

Bump postgresql from 42.3.3 to 42.4.1 in /flink-connectors/flink-connector-jdbc

1

Bumps [postgresql](https://github.com/pgjdbc/pgjdbc) from 42.3.3 to 42.4.1. Release notes Sourced from postgresql's releases. 42.4.0 What's Changed Enhancement: Made TimestampUtils.utcTz static and renamed to UTC_TIMEZONE by @​svendiedrichsen in pgjdbc/pgjdbc#2519 fix: return correct...

dependabot[bot]

[FLINK-28475] [Connector/kafka] stopping offset can be 0

4

## What is the purpose of the change Stopping offset can be 0.When we make a zero stopping offset empty,it would be serialized to NO_STOPPING_OFFSET, which it is not expected....

leozhangsr

fix version for supporting add file

1

## What is the purpose of the change *(For example: This pull request makes task deployment go through the blob server, rather than through RPC. That way we avoid re-transferring...

luoyuxia