flink

flink copied to clipboard

[FLINK-38477][runtime] Add FINISHED watermark status to support proper watermark aggregation

2

## What is the purpose of the change This PR fixes a watermark aggregation bug that can cause zero output from time-based operators (e.g., IntervalJoin) when some upstream subtasks finish...

weiqingy

[hotfix] Fix typos

1

Just fix some typos

zcoo

[FLINK-34015] fix setting execution.savepoint.ignore-unclaimed-state …

1

…does not take effect when passing this parameter by dynamic properties ## What is the purpose of the change fix setting execution.savepoint.ignore-unclaimed-state does not take effect when passing this parameter...

xiangforever2014

FLINK-38449: Makes error message for fractional values for MemorySize explicit

1

## What is the purpose of the change Currently for a fractional value for memory size, like 1.5g, the exception message is generated from failing to parse the string ".5g"....

navinvishy

[FLINK-38468][flink-table-planner] When the coalesce parameter contains a function, convert it to case when

2

Optimize RemoveUnreachableCoalesceArgumentsRule rule，when including functions, it will fall back to case when [FLINK-38468](https://issues.apache.org/jira/browse/FLINK-38468)

ChengJie1053

[FLINK-38418][python] Support pickling Instants when collecting TIMESTAMP_LTZ types in PyFlink

1

## What is the purpose of the change Currently, when trying to `collect` a `TIMESTAMP_LTZ` value in PyFlink, you get a pickling error: ``` py4j.protocol.Py4JJavaError: An error occurred while calling...

autophagy

[hotfix] [docs] Fix Typo in Stateful Stream Processing introduction

1

Pactum7

[docs] Typo fix

1

Adjusting type in variable to match that of descriptor

gunnarmorling

[FLINK-36808][table-planner] Fix LookupJoin bug when used with filterable table source

5

## What is the purpose of the change - Fix bug in LookupJoin that occurs when used together with filterable (that support filter pushdown) table and union all ### Brief...

morazow

[FLINK-37722] Eliminate redundant field initialization of PojoSerializer

3

## What is the purpose of the change Perf: eliminate redundant field initialization of PojoSerializer. ## Brief change log Currently, PojoSerializer will first create a new POJO instance and initialize...

X-czh