flink.git
41 hours ago[FLINK-28143][runtime] Introduce BlocklistHandler. master
Lijie Wang [Mon, 27 Jun 2022 06:51:47 +0000 (14:51 +0800)] 
[FLINK-28143][runtime] Introduce BlocklistHandler.

This closes #20079.

44 hours ago[FLINK-28143][runtime] Introduce BlockListTracker.
lijiewang.wlj [Mon, 21 Mar 2022 03:54:48 +0000 (11:54 +0800)] 
[FLINK-28143][runtime] Introduce BlockListTracker.

44 hours ago[FLINK-28271][runtime] Add config options for speculative scheduler
Zhu Zhu [Tue, 28 Jun 2022 03:55:45 +0000 (11:55 +0800)] 
[FLINK-28271][runtime] Add config options for speculative scheduler

This closes #20087.

44 hours ago[FLINK-28134][runtime] Wait for all the executions to be terminated before finishing...
Zhu Zhu [Mon, 27 Jun 2022 06:59:01 +0000 (14:59 +0800)] 
[FLINK-28134][runtime] Wait for all the executions to be terminated before finishing a job

In speculative execution, it is possible that when all the execution vertices finish, some executions are still running. We need to waiting for all them to be terminated(canceled) before conducting job finalization.

44 hours ago[FLINK-28134][runtime] Rework TaskDeploymentDescriptorFactory to accept an execution...
Zhu Zhu [Thu, 23 Jun 2022 12:41:01 +0000 (20:41 +0800)] 
[FLINK-28134][runtime] Rework TaskDeploymentDescriptorFactory to accept an execution to deploy

This helps to decouple the task deployment from ExecutionVertex#getCurrentExecutionAttempt().

44 hours ago[FLINK-28134][runtime] Introduce SpeculativeExecutionJobVertex and SpeculativeExecuti...
Zhu Zhu [Thu, 23 Jun 2022 12:38:38 +0000 (20:38 +0800)] 
[FLINK-28134][runtime] Introduce SpeculativeExecutionJobVertex and SpeculativeExecutionVertex

This closes #20082.

47 hours ago[FLINK-28169][e2e-test/glue,kinesis] Re-enabled integration test that was failing...
Zichen Liu [Thu, 30 Jun 2022 13:30:02 +0000 (14:30 +0100)] 
[FLINK-28169][e2e-test/glue,kinesis] Re-enabled integration test that was failing due a shaded dependency test-jar requiring a transitive shaded test-jar being satisfied by a later unshaded dependency test-jar, changed so that unshaded dependency test-jar is loaded earlier in pom

2 days ago[FLINK-28140][python][docs] Improve the documentation by adding Python examples in...
Mingde Peng [Tue, 28 Jun 2022 01:31:05 +0000 (09:31 +0800)] 
[FLINK-28140][python][docs] Improve the documentation by adding Python examples in DataStream API Integration page

This closes #20121.

2 days ago[FLINK-28288][table][python] Support decode and encode in Table API (#20098)
Luning (Lucas) Wang [Fri, 1 Jul 2022 05:15:44 +0000 (13:15 +0800)] 
[FLINK-28288][table][python] Support decode and encode in Table API (#20098)

2 days ago[FLINK-28323][python][kafka] Support KafkaSource in PyFlink
Juntao Hu [Thu, 30 Jun 2022 08:40:25 +0000 (16:40 +0800)] 
[FLINK-28323][python][kafka] Support KafkaSource in PyFlink

This closes #20113.

2 days ago[FLINK-28142][runtime] Enrich TaskExecutorRegistration with node information
Lijie Wang [Tue, 28 Jun 2022 14:55:43 +0000 (22:55 +0800)] 
[FLINK-28142][runtime] Enrich TaskExecutorRegistration with node information

This closes #20056.

2 days ago[FLINK-28142][runtime] Enrich TaskManagerLocation with node information
Lijie Wang [Tue, 28 Jun 2022 14:53:50 +0000 (22:53 +0800)] 
[FLINK-28142][runtime] Enrich TaskManagerLocation with node information

2 days ago[hotfix][runtime][tests] Migrate TaskManagerLocationTest, TaskExecutorToResourceManag...
Lijie Wang [Wed, 22 Jun 2022 12:05:19 +0000 (20:05 +0800)] 
[hotfix][runtime][tests] Migrate TaskManagerLocationTest, TaskExecutorToResourceManagerConnectionTest and TaskManagerRunnerConfigurationTest to JUnit5

2 days ago[FLINK-28136][runtime] Implement ExecutionTimeBasedSlowTaskDetector
hongli [Sat, 25 Jun 2022 09:05:26 +0000 (17:05 +0800)] 
[FLINK-28136][runtime] Implement ExecutionTimeBasedSlowTaskDetector

This closes #20072.

2 days ago[FLINK-28135][runtime] Introduce SlowTaskDetector
hongli [Thu, 23 Jun 2022 03:04:00 +0000 (11:04 +0800)] 
[FLINK-28135][runtime] Introduce SlowTaskDetector

This closes #20054.

2 days ago[FLINK-28309][rest] Introduce metrics of the duration that a task stays in each status
Yangze Guo [Tue, 24 May 2022 03:25:17 +0000 (11:25 +0800)] 
[FLINK-28309][rest] Introduce metrics of the duration that a task stays in each status

This closes #20111.

2 days ago[FLINK-28308] Introduce metrics of the accumulated time that a running task is busy...
Yangze Guo [Mon, 23 May 2022 08:50:37 +0000 (16:50 +0800)] 
[FLINK-28308] Introduce metrics of the accumulated time that a running task is busy / idle / back-pressured

This closes #20110.

2 days ago[hotfix][rest] Remove the stale items in rest_v1_dispatcher
Yangze Guo [Thu, 30 Jun 2022 06:30:38 +0000 (14:30 +0800)] 
[hotfix][rest] Remove the stale items in rest_v1_dispatcher

2 days ago[FLINK-26361][hive] Create LogicalFilter with CorrelationId to fix failed to rewrite...
yuxia Luo [Fri, 1 Jul 2022 02:29:26 +0000 (10:29 +0800)] 
[FLINK-26361][hive] Create LogicalFilter with CorrelationId to fix failed to rewrite subquery in hive dialect (#18920)

2 days ago[FLINK-28182][python][avro] Support Avro generic record decoder in PyFlink
Juntao Hu [Tue, 21 Jun 2022 13:05:42 +0000 (21:05 +0800)] 
[FLINK-28182][python][avro] Support Avro generic record decoder in PyFlink

This closes #20040.

2 days ago[FLINK-25872][state] Support restore from non-changelog checkpoint with changelog...
fredia [Tue, 17 May 2022 10:39:51 +0000 (18:39 +0800)] 
[FLINK-25872][state] Support restore from non-changelog checkpoint with changelog enabled in CLAIM mode

2 days agoRevert "[FLINK-26079][state/changelog] Disallow recovery from non-changelog checkpoints"
fredia [Tue, 12 Apr 2022 16:11:43 +0000 (00:11 +0800)] 
Revert "[FLINK-26079][state/changelog] Disallow recovery from non-changelog checkpoints"

This reverts commit 6fc4bad2

2 days ago[FLINK-27031][runtime] Assign even empty old state to the task if the upstream has...
Anton Kalashnikov [Wed, 11 May 2022 16:21:27 +0000 (18:21 +0200)] 
[FLINK-27031][runtime] Assign even empty old state to the task if the upstream has output states since the task should be prepared to filter these old incoming states from upstream

2 days ago[FLINK-28290][sql-gateway] Set lastAccessTime when create the Session Object (#20107)
Shengkai [Thu, 30 Jun 2022 12:05:26 +0000 (20:05 +0800)] 
[FLINK-28290][sql-gateway] Set lastAccessTime when create the Session Object (#20107)

3 days ago[FLINK-27906][runtime] Introduce HsDataIndex.
Weijie Guo [Tue, 21 Jun 2022 05:40:16 +0000 (13:40 +0800)] 
[FLINK-27906][runtime] Introduce HsDataIndex.

This closes #20031

3 days ago[hotfix] Add Extension META-INF for flink-runtime module to support junit5.
Weijie Guo [Tue, 21 Jun 2022 05:38:27 +0000 (13:38 +0800)] 
[hotfix] Add Extension META-INF for flink-runtime module to support junit5.

3 days ago[hotfix][docs] Remove a unuseful space
Ada Wang [Tue, 28 Jun 2022 11:31:47 +0000 (19:31 +0800)] 
[hotfix][docs] Remove a unuseful space

3 days ago[FLINK-28213][runtime] StreamExecutionEnvironment configure method support override...
fengli [Thu, 23 Jun 2022 06:40:04 +0000 (14:40 +0800)] 
[FLINK-28213][runtime] StreamExecutionEnvironment configure method support override pipeline.jars option

This closes #20057.

3 days ago[FLINK-28259][flink-parquet] Bump protoc version to 3.21.2 for proper ARM support
Robert Metzger [Mon, 27 Jun 2022 08:25:45 +0000 (10:25 +0200)] 
[FLINK-28259][flink-parquet] Bump protoc version to 3.21.2 for proper ARM support

3 days ago[FLINK-28047][api] Deprecate StreamExecutionEnvironment#readFile()/readTextFile(...
Alexander Fedulov [Wed, 22 Jun 2022 14:59:08 +0000 (16:59 +0200)] 
[FLINK-28047][api] Deprecate StreamExecutionEnvironment#readFile()/readTextFile() methods

3 days ago[FLINK-28080][runtime] Introduce MutableURLClassLoader as parent class of FlinkUserCl...
fengli [Fri, 17 Jun 2022 09:04:52 +0000 (17:04 +0800)] 
[FLINK-28080][runtime] Introduce MutableURLClassLoader as parent class of FlinkUserClassLoader and SafetyNetWrapperClassLoader

3 days ago[FLINK-27586][python] Support non-keyed co-broadcast processing in PyFlink
Juntao Hu [Fri, 20 May 2022 10:40:11 +0000 (18:40 +0800)] 
[FLINK-27586][python] Support non-keyed co-broadcast processing in PyFlink

This closes #19878.

3 days ago[FLINK-28269][Kubernetes] Install cri-dockerd and crictl so that we can continue...
MartijnVisser [Wed, 29 Jun 2022 09:39:19 +0000 (11:39 +0200)] 
[FLINK-28269][Kubernetes] Install cri-dockerd and crictl so that we can continue to use Kubernetes 1.24+ and the `none` driver, since Kubernetes 1.24 has dropped support for Dockershim.

3 days ago[FLINK-27789][network] Disable overdraft buffer for LegacySource
fanrui [Wed, 29 Jun 2022 03:35:58 +0000 (11:35 +0800)] 
[FLINK-27789][network] Disable overdraft buffer for LegacySource

3 days ago[hotfix] Fix the generic of RecordWriter
fanrui [Wed, 29 Jun 2022 03:35:08 +0000 (11:35 +0800)] 
[hotfix] Fix the generic of RecordWriter

3 days ago[FLINK-28043][formats][parquet] Fix "Invalid lambda deserialization" in AvroParquetRe...
Juntao Hu [Tue, 14 Jun 2022 10:00:44 +0000 (18:00 +0800)] 
[FLINK-28043][formats][parquet] Fix "Invalid lambda deserialization" in AvroParquetReaders

This closes #19956.

4 days ago[FLINK-19869][connectors/jdbc] Add support for postgres UUID type
Bobby Richard [Tue, 28 Jun 2022 01:19:07 +0000 (21:19 -0400)] 
[FLINK-19869][connectors/jdbc] Add support for postgres UUID type

4 days ago[FLINK-27964][python] Support Cassandra connector in Python DataStream API
Mingde Peng [Fri, 10 Jun 2022 01:15:18 +0000 (09:15 +0800)] 
[FLINK-27964][python] Support Cassandra connector in Python DataStream API

This closes #19945.

4 days ago[FLINK-28092][table] Support ASCII and CHR built-in function in the Table API
Ada Wang [Thu, 16 Jun 2022 09:24:21 +0000 (17:24 +0800)] 
[FLINK-28092][table] Support ASCII and CHR built-in function in the Table API

This closes #19988.

4 days ago[FLINK-28263][TPCDS][Tests] Clean-up generated data folder by TPCDS test
MartijnVisser [Tue, 28 Jun 2022 08:48:06 +0000 (10:48 +0200)] 
[FLINK-28263][TPCDS][Tests] Clean-up generated data folder by TPCDS test

4 days ago[hotfix][docs] Remove redundant "." from sample code
nieyingping [Wed, 22 Jun 2022 06:11:13 +0000 (14:11 +0800)] 
[hotfix][docs] Remove redundant "." from sample code

4 days ago[FLINK-28173][formats] Specify guava version explicitly in flink-orc and flink-parquet.
liujia10 [Sat, 25 Jun 2022 14:50:02 +0000 (22:50 +0800)] 
[FLINK-28173][formats] Specify guava version explicitly in flink-orc and flink-parquet.

4 days ago[FLINK-27116][hive] Support read Hive table partitioned by decimal type
luoyuxia [Thu, 7 Apr 2022 10:13:53 +0000 (18:13 +0800)] 
[FLINK-27116][hive] Support read Hive table partitioned by decimal type

This closes #19388

4 days ago[FLINK-23995][hive] Fix bug of table name parser when using Hive dialect
yuxia Luo [Thu, 26 Aug 2021 11:59:08 +0000 (19:59 +0800)] 
[FLINK-23995][hive] Fix bug of table name parser when using Hive dialect

This closes #16999

5 days ago[FLINK-27392][cep] CEP Pattern supports definition of the maximum time gap between...
SteNicholas [Fri, 17 Jun 2022 02:20:11 +0000 (10:20 +0800)] 
[FLINK-27392][cep] CEP Pattern supports definition of the maximum time gap between events

This closes #20029.

5 days ago[FLINK-27304][hive] Calcite's varbinary type should be converted to Hive's binary...
luoyuxia [Sun, 24 Apr 2022 11:45:38 +0000 (19:45 +0800)] 
[FLINK-27304][hive] Calcite's varbinary type should be converted to Hive's binary type.

This closes #19562

5 days ago[hotfix][docs] Add a chinese doc of first_value/last_value in the Table API (#20088)
LuNing (Lucas) Wang [Tue, 28 Jun 2022 08:42:36 +0000 (16:42 +0800)] 
[hotfix][docs] Add a chinese doc of first_value/last_value in the Table API (#20088)

5 days ago[FLINK-28036][hive] HiveInspectors should use correct writable type to create Constan...
luoyuxia [Tue, 14 Jun 2022 04:02:09 +0000 (12:02 +0800)] 
[FLINK-28036][hive] HiveInspectors should use correct writable type to create ConstantObjectInspector

This closes #19949

5 days ago[FLINK-28217] Bumps [mysql-connector-java](https://github.com/mysql/mysql-connector...
dependabot[bot] [Wed, 22 Jun 2022 13:01:30 +0000 (13:01 +0000)] 
[FLINK-28217] Bumps [mysql-connector-java](https://github.com/mysql/mysql-connector-j) from 8.0.27 to 8.0.29.

Flink doesn't bundle this dependency but only uses it for testing. Bumping this dependency will also address false positives for CVE-2022-21363 (direct vulnerability) and CVE-2021-22569 (vulnerability from included dependency).

5 days ago[FLINK-28195][python] Fix the build wheels
huangxingbo [Tue, 28 Jun 2022 01:59:31 +0000 (09:59 +0800)] 
[FLINK-28195][python] Fix the build wheels

This closes #20085.

5 days ago[FLINK-28258][runtime] Introduce ExecutionHistory to host historical executions for...
Zhu Zhu [Mon, 27 Jun 2022 05:52:09 +0000 (13:52 +0800)] 
[FLINK-28258][runtime] Introduce ExecutionHistory to host historical executions for each execution vertex

This closes #20080.

5 days ago[FLINK-25097][table-planner] Fix bug in inner join when the filter condition is boole...
zhengyunhong.zyh [Thu, 14 Apr 2022 09:04:41 +0000 (17:04 +0800)] 
[FLINK-25097][table-planner] Fix bug in inner join when the filter condition is boolean type

This closes #19579

5 days ago[FLINK-26762][docs-zh] Translate the doc of overdraft buffers
fanrui [Sun, 26 Jun 2022 08:40:38 +0000 (16:40 +0800)] 
[FLINK-26762][docs-zh] Translate the doc of overdraft buffers

6 days ago[hotfix][runtime] Cleanup for the temporary fix of FLINK-13063 which is completely...
lincoln.lil [Wed, 15 Jun 2022 02:52:45 +0000 (10:52 +0800)] 
[hotfix][runtime] Cleanup for the temporary fix of FLINK-13063 which is completely solved by FLINK-16219

1. In FLINK-13063 the chaining strategy of AsyncWaitOperatorFactory is HEAD, AsyncWaitOperatorTest#addAsyncOperatorLegacyChained is for manually setting it to ALWAYS,
and now it is no long needed since FLINK-16219 change the chaining strategy of AsyncWaitOperatorFactory to ALWAYS.

2. test case rename: testStateSnapshotAndRestoreWithObjectReused -> testObjectReused
because the case does not contain the snapshot and restore logic in it.

This closes #19961.

6 days ago[FLINK-28195][python] Annotate Python3.6 as deprecated in PyFlink 1.16
huangxingbo [Mon, 27 Jun 2022 06:16:47 +0000 (14:16 +0800)] 
[FLINK-28195][python] Annotate Python3.6 as deprecated in PyFlink 1.16

This closes #20078.

7 days ago[FLINK-16078] [docs-zh] Translate "Tuning Checkpoints and Large State".
JustDoDT [Mon, 18 Apr 2022 05:57:50 +0000 (13:57 +0800)] 
[FLINK-16078] [docs-zh] Translate "Tuning Checkpoints and Large State".

Co-authored-by: Jun He <xuehaijuxian@gmail.com>
This closes #19503.

8 days ago[FLINK-28226][python] Limit grpcio<1.47 (#20058)
HuangXingBo [Sat, 25 Jun 2022 02:00:16 +0000 (10:00 +0800)] 
[FLINK-28226][python] Limit grpcio<1.47 (#20058)

8 days ago[FLINK-28169] Disabling Flaky GlueSchemaRegistryJsonKinesisITCase test to unblock...
Ahmed Hamdy [Fri, 24 Jun 2022 08:40:55 +0000 (09:40 +0100)] 
[FLINK-28169] Disabling Flaky  GlueSchemaRegistryJsonKinesisITCase test to unblock build CI

8 days ago[FLINK-28239][table] Add commons-math3 to owner classpath
Chesnay Schepler [Fri, 24 Jun 2022 07:23:01 +0000 (09:23 +0200)] 
[FLINK-28239][table] Add commons-math3 to owner classpath

8 days ago[FLINK-27794][connectors/jdbc] Fix the wrong primary key for MysqlCatalog when there...
dusukang [Fri, 24 Jun 2022 12:03:45 +0000 (20:03 +0800)] 
[FLINK-27794][connectors/jdbc] Fix the wrong primary key for MysqlCatalog when there are tables with same name in different databases

This closes ##20025.

8 days ago[FLINK-28193][runtime] Enable to identify whether a job vertex contains source/sink...
zhuzhu.zz [Wed, 23 Mar 2022 08:33:48 +0000 (16:33 +0800)] 
[FLINK-28193][runtime] Enable to identify whether a job vertex contains source/sink operators

This closes #20043.

9 days ago[FLINK-28133][runtime] Rework DefaultScheduler to directly deploy executions
Zhu Zhu [Fri, 10 Jun 2022 07:33:51 +0000 (15:33 +0800)] 
[FLINK-28133][runtime] Rework DefaultScheduler to directly deploy executions

This closes #20039.

9 days ago[FLINK-27933][coordination][tests] Force serialization applies to return value
Chesnay Schepler [Tue, 7 Jun 2022 08:51:08 +0000 (10:51 +0200)] 
[FLINK-27933][coordination][tests] Force serialization applies to return value

9 days ago[FLINK-27933][coordination] Fix/document RPC serializability violations
Chesnay Schepler [Wed, 15 Jun 2022 11:23:20 +0000 (13:23 +0200)] 
[FLINK-27933][coordination] Fix/document RPC serializability violations

- allow tests to opt-out of serializability force
- never force serialization in AkkaRpcActorOversizedResponseMessageTest, because it affected the payload size
- DispatcherTest no longer relies on retrieving the same object instance via RPC
- ResourceManager#requestTaskExecutorThreadInfoGateway is just not serializable; see FLINK-27954
- ClassLoaderITCase wrongly assumed that serialization occurs

9 days ago[FLINK-27933][coordination] OperationResult is serializable
Chesnay Schepler [Tue, 7 Jun 2022 14:11:17 +0000 (16:11 +0200)] 
[FLINK-27933][coordination] OperationResult is serializable

9 days ago[hotfix][tests] Clarify interface
Chesnay Schepler [Wed, 15 Jun 2022 11:23:07 +0000 (13:23 +0200)] 
[hotfix][tests] Clarify interface

These 2 methods were never used via the gateway, but are called directly on the instance.
This was misleading because I couldn't figure out why the serialization didn't fail for these methods.

9 days ago[FLINK-27466][jdbc][docs] Clarify metaspace leak fix
Chesnay Schepler [Thu, 23 Jun 2022 11:37:57 +0000 (13:37 +0200)] 
[FLINK-27466][jdbc][docs] Clarify metaspace leak fix

10 days ago[FLINK-28175][ci] Improve license checker output
Chesnay Schepler [Tue, 21 Jun 2022 10:10:08 +0000 (12:10 +0200)] 
[FLINK-28175][ci] Improve license checker output

10 days ago[FLINK-27290][docs-zh] Translate the "Data Type" section of "Data Types" in to Chinese.
Chengkai Yang [Tue, 14 Jun 2022 15:34:28 +0000 (23:34 +0800)] 
[FLINK-27290][docs-zh] Translate the "Data Type" section of "Data Types" in to Chinese.

Co-authored-by: LuNing Wang <rsl4@foxmail.com>
10 days ago[hotfix][table-api-java][javadoc]fix and unified the example JavaDoc for most DSL...
coderap [Sun, 12 Jun 2022 15:50:11 +0000 (23:50 +0800)] 
[hotfix][table-api-java][javadoc]fix and unified the example JavaDoc for most DSL methods of Table class

10 days ago[FLINK-27926][Docs] Translating the `Upgrading Applications and Flink versions` page...
饶紫轩 [Tue, 7 Jun 2022 03:21:07 +0000 (11:21 +0800)] 
[FLINK-27926][Docs] Translating the `Upgrading Applications and Flink versions` page to Chiinese

10 days ago[FLINK-27865][docs] Add example for configuring SASL and SSL in Kafka DataStream...
Qingsheng Ren [Thu, 23 Jun 2022 02:58:50 +0000 (10:58 +0800)] 
[FLINK-27865][docs] Add example for configuring SASL and SSL in Kafka DataStream and SQL connector (#19904)

10 days ago[FLINK-27766][sql-gateway] Introduce the OperationManager for the SqlGatewayService
Shengkai [Wed, 22 Jun 2022 12:21:54 +0000 (20:21 +0800)] 
[FLINK-27766][sql-gateway] Introduce the OperationManager for the SqlGatewayService

10 days ago[FLINK-27766][sql-gateway] Introduce the basic components for the SqlGatewayService
Shengkai [Wed, 22 Jun 2022 11:43:54 +0000 (19:43 +0800)] 
[FLINK-27766][sql-gateway] Introduce the basic components for the SqlGatewayService

10 days ago[FLINK-28194][python] Remove avro sql jar workaround (#20045)
Chesnay Schepler [Thu, 23 Jun 2022 01:06:23 +0000 (03:06 +0200)] 
[FLINK-28194][python] Remove avro sql jar workaround (#20045)

10 days ago[FLINK-28196][build] Rename hadoop.version property
Chesnay Schepler [Tue, 21 Jun 2022 09:23:30 +0000 (11:23 +0200)] 
[FLINK-28196][build] Rename hadoop.version property

Prevent conflicts with the hadoop.version property in the Hadoop parent pom, when using Maven 3.8.5+.

10 days ago[FLINK-28112][filesystems] Fix error message when directly supported file system...
gabor.g.somogyi [Fri, 17 Jun 2022 14:35:34 +0000 (16:35 +0200)] 
[FLINK-28112][filesystems] Fix error message when directly supported file system not able to be handled

10 days ago[hotfix][javadoc] Misprint in javadoc at QuadFunction.java
Sergey Nuyanzin [Tue, 15 Feb 2022 12:46:37 +0000 (13:46 +0100)] 
[hotfix][javadoc] Misprint in javadoc at QuadFunction.java

`@oaram` => `@param`

11 days ago[hotfix][legal] Correct module name in NOTICE
Chesnay Schepler [Tue, 21 Jun 2022 09:33:02 +0000 (11:33 +0200)] 
[hotfix][legal] Correct module name in NOTICE

11 days ago[hotfix][docs] Fix the Intellij key nouns.
liuzhuang2017 [Wed, 15 Jun 2022 09:22:47 +0000 (17:22 +0800)] 
[hotfix][docs] Fix the Intellij key nouns.

11 days ago[hotfix][ci] Update libssl download link
MartijnVisser [Wed, 22 Jun 2022 09:25:26 +0000 (11:25 +0200)] 
[hotfix][ci] Update libssl download link

11 days ago[hotfix][docs] Fix the inaccessible documentation link
liuzhuang2017 [Wed, 22 Jun 2022 09:25:19 +0000 (17:25 +0800)] 
[hotfix][docs] Fix the inaccessible documentation link

11 days ago[FLINK-27667][yarn-tests] Stabilize flaky YARN integration tests
Ferenc Csaky [Mon, 20 Jun 2022 14:41:05 +0000 (16:41 +0200)] 
[FLINK-27667][yarn-tests] Stabilize flaky YARN integration tests

11 days ago[FLINK-27972][tests] Forbid multiple state transitions
Chesnay Schepler [Wed, 15 Jun 2022 09:30:20 +0000 (11:30 +0200)] 
[FLINK-27972][tests] Forbid multiple state transitions

11 days ago[FLINK-27972][coordination] Wait until savepoint operation is complete
Chesnay Schepler [Wed, 15 Jun 2022 10:40:32 +0000 (12:40 +0200)] 
[FLINK-27972][coordination] Wait until savepoint operation is complete

11 days ago[hotfix][tests] Cleanup StopWithSavepointTest
Chesnay Schepler [Wed, 15 Jun 2022 08:46:57 +0000 (10:46 +0200)] 
[hotfix][tests] Cleanup StopWithSavepointTest

11 days agofixup! fixup! [FLINK-26762][docs] Document overdraft buffers 20047/head
Piotr Nowojski [Tue, 21 Jun 2022 15:12:07 +0000 (17:12 +0200)] 
fixup! fixup! [FLINK-26762][docs] Document overdraft buffers

11 days agofixup! [FLINK-26762][docs] Document overdraft buffers
Piotr Nowojski [Tue, 21 Jun 2022 12:30:14 +0000 (14:30 +0200)] 
fixup! [FLINK-26762][docs] Document overdraft buffers

11 days ago[FLINK-26762][docs] Document overdraft buffers
Piotr Nowojski [Tue, 21 Jun 2022 08:14:09 +0000 (10:14 +0200)] 
[FLINK-26762][docs] Document overdraft buffers

11 days ago[FLINK-28044][runtime][security] Make hadoop filesystems configuration available...
gabor.g.somogyi [Tue, 14 Jun 2022 10:11:01 +0000 (12:11 +0200)] 
[FLINK-28044][runtime][security] Make hadoop filesystems configuration available to all deployment targets

This closes #19953.

11 days ago[FLINK-28077][checkpoint] Allow buffers to be discarded asynchronously
1996fanrui [Tue, 21 Jun 2022 12:23:47 +0000 (20:23 +0800)] 
[FLINK-28077][checkpoint] Allow buffers to be discarded asynchronously

The dataFuture may never be completed, so waiting for that might cause the task to get stuck.

We now chain the cleanup to the dataFuture instead; if it is complete it will run immediately, otherwise it _may_ run at a later point if the future ever completes.
The latter is a safeguard against potential buffer leaks.

12 days ago[hotfix] Removed foul language. This closes #18722
Nie yingping [Tue, 21 Jun 2022 09:47:55 +0000 (17:47 +0800)] 
[hotfix] Removed foul language. This closes #18722

[hotfix] Removed foul language. This closes #18722

12 days ago[FLINK-26762][network] Add the overdraft buffer in ResultPartition
fanrui [Tue, 31 May 2022 08:03:02 +0000 (16:03 +0800)] 
[FLINK-26762][network] Add the overdraft buffer in ResultPartition

12 days ago[FLINK-28147][Python] Update httplib2 to at least 0.19.0 to address CVE-2021-21240
Martijn Visser [Mon, 20 Jun 2022 11:14:41 +0000 (13:14 +0200)] 
[FLINK-28147][Python] Update httplib2 to at least 0.19.0 to address CVE-2021-21240

12 days ago[FLINK-28002][python] Fixes the issue that add_jars doesn't work on JDK11
huangxingbo [Mon, 13 Jun 2022 13:06:32 +0000 (21:06 +0800)] 
[FLINK-28002][python] Fixes the issue that add_jars doesn't work on JDK11

This closes #19947.

13 days ago[FLINK-28105][Tests] test the copied object in GlobFilePathFilterTest#testGlobFilterS...
zhouli [Mon, 20 Jun 2022 01:44:04 +0000 (09:44 +0800)] 
[FLINK-28105][Tests] test the copied object in GlobFilePathFilterTest#testGlobFilterSerializable

13 days ago[hotfix] Rework GlobFilePathFilterTest to be based on AssertJ & JUnit5
zhouli [Mon, 20 Jun 2022 01:43:23 +0000 (09:43 +0800)] 
[hotfix] Rework GlobFilePathFilterTest to be based on AssertJ & JUnit5

13 days ago[FLINK-27159][table] Support firstValue/lastValue in the Table API
shuiqiangchen [Tue, 14 Jun 2022 12:17:29 +0000 (20:17 +0800)] 
[FLINK-27159][table] Support firstValue/lastValue in the Table API

This closes #19958.

13 days ago[FLINK-27861][table] Introduce ResourceManager to manage JAR resources (#19859)
Ron [Mon, 20 Jun 2022 05:49:10 +0000 (13:49 +0800)] 
[FLINK-27861][table] Introduce ResourceManager to manage JAR resources (#19859)

13 days ago[FLINK-28107][python][connector/elasticsearch] Support id of document is null
Ada Wang [Fri, 17 Jun 2022 08:49:09 +0000 (16:49 +0800)] 
[FLINK-28107][python][connector/elasticsearch] Support id of document is null

This closes #20002.