flink

flink copied to clipboard

[FLINK-27014][hive] Fix exception when select null literal in subquery for Hive dialect

1

## What is the purpose of the change To fix the exception when select null literal in subquery for Hive dialect ## Brief change log - Consider Hive's void type...

luoyuxia

[FLINK-27017][hive] Fix divide by zero exception in Hive dialect

1

## What is the purpose of the change To fix the divide by zero exception in Hive dialect ## Brief change log when the operand is `/`, make it call...

luoyuxia

[FLINK-27375][hive] Fix exception when no order keys exists in over() in Hive Dialect

1

## What is the purpose of the change To fix the exception thrown when no order keys exists in over() in Hive dialects. ## Brief change log Rewrite `over()` to...

luoyuxia

[FLINK-27015][hive] Fix exception for casting timestamp to decimal in Hive dialect

1

## What is the purpose of the change Support insert timestamp type to decimal type in Hive dialect. ## Brief change log - Add a custome udf `flink_hive_to_decimal` to convert...

luoyuxia

[FLINK-26505][hive] Fix IndexOutOfBoundsException for non equality condition exists in left semi join in Hive dialect

2

## What is the purpose of the change The pr is try to fix the `IndexOutOfBoundsException` that when there's only `1 = 1` in semi join cluster like the sql:...

luoyuxia

[FLINK-27805][Connectors/ORC] bump orc version to 1.7.5

11

## What is the purpose of the change In order to use new features (zstd compression, column encryption etc.) in 1.6.x and 1.7.x. [Release Notes](https://orc.apache.org/news/releases/) ## Brief change log -...

liujiawinds

[FLINK-28814][Connectors][JDBC] Update org.postgresql:postgresql to 42.4.1

2

## What is the purpose of the change This a simple update of postgres jdbc driver to cope with CVE-2022-31197 https://github.com/pgjdbc/pgjdbc/security/advisories/GHSA-r38f-c4h4-hqq2 ## Brief change log pom file ## Verifying this...

snuyanzin

[FLINK-28751][Table SQL/Runtime] Optimize the performance of the json…

5

… functions ## What is the purpose of the change This PR is meant to improve the performance of the built in json functions. The default `LRUCache` used in the...

Aitozi

[FLINK-28853][connector-base] Add FLIP-217 support for watermark alignment of source splits

1

## What is the purpose of the change * The change implements FLIP-217 (https://cwiki.apache.org/confluence/display/FLINK/FLIP-217+Support+watermark+alignment+of+source+splits) to support watermark alignment of source splits. ## Brief change log * Revised `SplitFetcher` threading model...

smattheis

[FLINK-24640][table] CEIL, FLOOR built-in functions for Timestamp should res…

5

## What is the purpose of the change The PR makes `org.apache.flink.table.utils.DateTimeUtils#timestampCeil` and `org.apache.flink.table.utils.DateTimeUtils#timestampFloor` respecting DST ## Verifying this change There is `org.apache.flink.table.utils.DateTimeUtilsTest` introduced ## Does this pull request potentially...

snuyanzin