flink

flink copied to clipboard

[FLINK-28860] Fix CacheITCase

3

## What is the purpose of the change The PR address the two problems that cause CacheITCase to fail randomly. - Cache consumption in stream mode should recompute the result...

Sxnan

[FLINK-24718][avro] update AVRO dependency to latest version

14

## What is the purpose of the change * Update AVRO dependency to the latest version (Continuing on the work of https://github.com/apache/flink/pull/17623) ## Brief change log - Updated org.apache.avro:avro:1.10.0 to...

RyanSkraba

[FLINK-28908][python] Coder for LIST type is incorrectly chosen

1

## What is the purpose of the change This PR fixes incorrect coder for deserializing `Types.LIST` data from Java. This needs to be cherry-picked to release-1.14 too. ## Verifying this...

Vancior

[FLINK-27570][runtime] Fix checkFailureCounter in CheckpointFailureManager for finalize failure

42

## What is the purpose of the change This pull request is related to [FLINK-27570](https://issues.apache.org/jira/browse/FLINK-27570). When checkpoints are stored on `CheckpointCoordinator` using the `FileSystemCheckpointStorage`, `initializeBaseLocationsForCheckpoint` may failed to initialize `sharedStateDirectory`...

JesseAtSZ

[FLINK-28773][hive] Fix Hive sink not write a success file after finish writing in batch mode

2

## What is the purpose of the change Allow to write a success file after finish for Hive sink in batch mode ## Brief change log Allow PartitionLoader to use...

Tartarus0zm

[FLINK-28910][Connectors/hbase]Fix potential data deletion while updating HBase rows

10

## What is the purpose of the change https://issues.apache.org/jira/browse/FLINK-28910 ## Brief change log - *Add reduce when hbase connector process mutation. ## Verifying this change CI passed ## Does this...

ganlute

[FLINK-26771][Hive] Fix incomparable exception between boolean type and numeric type in Hive dialect

2

## What is the purpose of the change To make Hive dialect support comparing boolean type with numeric/string type. ## Brief change log - When it invovles with comparsion betwen...

luoyuxia

[FLINK-28905][hive] Fix HiveCatalog can't get statistic for Hive timestamp partition column

3

## What is the purpose of the change To fix the issue that HiveCatalog can't get statistic for Hive timestamp partition column ## Brief change log Change `TIMESTAMP_WITH_LOCAL_TIME_ZONE` to `TIMESTAMP_WITHOUT_TIME_ZONE`...

luoyuxia

[hotfix][docs] Fix some formatting errors in Chinese documents.

2

## What is the purpose of the change - **In english document:**  - **In chinese document:**  ## Brief change log - Fix some formatting errors in Chinese documents....

liuzhuang2017

[WIP][FLINK-26372][runtime][state] Allow to configure Changelog Storage per program

1

``` Because different changelog implementations might have different options, the configuration is passed as a (serialized) string map. To extract the relevant KV-pairs (and not pass the whole configuration), Changelog...

rkhachatryan