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

This closes #20079.

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

3 months 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.

3 months 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.

3 months 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().

3 months 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.

3 months 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

3 months 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.

3 months 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)

3 months 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.

3 months 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.

3 months 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

3 months 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

3 months 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.

3 months 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.

3 months 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.

3 months 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.

3 months 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

3 months 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)

3 months 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.

3 months 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

3 months 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

3 months 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

3 months 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 months 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 months 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 months 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 months 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 months 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 months 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 months 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 months 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 months 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 months 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 months 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 months 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.

3 months 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

3 months 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.

3 months 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.

3 months 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

3 months 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

3 months 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.

3 months 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

3 months 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

3 months 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.

3 months 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

3 months 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)

3 months 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

3 months 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).

3 months 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.

3 months 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.

3 months 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

3 months 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

3 months 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.

3 months 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.

3 months 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.

3 months 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)

3 months 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

3 months 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

3 months 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.

3 months 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.

3 months 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.

3 months 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

3 months 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

3 months 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

3 months 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.

3 months 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

3 months 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

3 months 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>
3 months 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

3 months 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

3 months 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)

3 months 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

3 months 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

3 months 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)

3 months 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+.

3 months 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

3 months 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`

3 months 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

3 months 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.

3 months 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

3 months 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

3 months 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

3 months 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

3 months 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

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

3 months 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

3 months 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

3 months 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

3 months 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.

3 months 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.

3 months 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

3 months 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

3 months 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

3 months 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.

3 months 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

3 months 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

3 months 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.

3 months 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)

3 months 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.