flink.git
9 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)

9 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

9 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).

9 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.

9 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.

10 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

10 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

10 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.

10 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.

12 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.

12 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)

12 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

13 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

13 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.

13 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.

13 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.

13 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

13 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

13 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

13 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.

2 weeks 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

2 weeks 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

2 weeks 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>
2 weeks 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

2 weeks 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

2 weeks 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)

2 weeks 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

2 weeks 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

2 weeks 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)

2 weeks 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+.

2 weeks 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

2 weeks 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`

2 weeks 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

2 weeks 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.

2 weeks 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

2 weeks 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

2 weeks 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

2 weeks 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

2 weeks 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

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

2 weeks 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

2 weeks 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

2 weeks 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

2 weeks 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.

2 weeks 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.

2 weeks 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

2 weeks 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

2 weeks 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

2 weeks 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.

2 weeks 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

2 weeks 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

2 weeks 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.

2 weeks 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)

2 weeks 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.

2 weeks ago[FLINK-27523][runtime] Runtime supports producing and consuming cached intermediate...
sxnan [Wed, 25 May 2022 02:55:41 +0000 (10:55 +0800)] 
[FLINK-27523][runtime] Runtime supports producing and consuming cached intermediate results

This closes #19653.

2 weeks ago[FLINK-28114][python] Fix the issue that the Python client interpreter could not...
Dian Fu [Sun, 19 Jun 2022 14:47:58 +0000 (22:47 +0800)] 
[FLINK-28114][python] Fix the issue that the Python client interpreter could not point to an archive file in distributed file system

2 weeks ago[FLINK-28060][Connector/Kafka] Updated Kafka Clients to 3.1.1 to resolve the issue...
Martijn Visser [Fri, 17 Jun 2022 16:56:14 +0000 (18:56 +0200)] 
[FLINK-28060][Connector/Kafka] Updated Kafka Clients to 3.1.1 to resolve the issue where Flink is unable to commit its offset back to Kafka in case of Kafka Broker becoming unavailable. This should be resolved when the broker comes back up, but due to KAFKA-13563 that doesn't work. Since that fix has only become available with Kafka Clients 3.1.1, this commit updates the Kafka Clients dependency from 2.8.4 to 3.1.1.

No interfaces needed to be adjusted.

It was necessary to change some of our Bash e2e tests since they still relied on the Zookeeper parameter which has been removed in this version.
The other necessary change was adjusting the KafkaConsumerTestBase class since the level of exception is changed in the new Kafka Clients so exception.getCause().getMessage()  throws an NPE in the test case.

2 weeks ago[FLINK-20765][table-planner] Fix ScalarOperatorGens doesn't set proper nullability...
yuxia Luo [Fri, 17 Jun 2022 11:37:18 +0000 (19:37 +0800)] 
[FLINK-20765][table-planner] Fix ScalarOperatorGens doesn't set proper nullability for result type of generated expressions

This closes #19851

2 weeks ago[FLINK-22920][formats] Fix guava version conflict between calcite and hadoop componen...
Jia Liu [Fri, 17 Jun 2022 11:21:00 +0000 (19:21 +0800)] 
[FLINK-22920][formats] Fix guava version conflict between calcite and hadoop component. (#19965)

2 weeks ago[FLINK-28007][bugfix/connectors] Migrated Kinesis Firehose & Streams sink tests to...
Zichen Liu [Fri, 10 Jun 2022 17:47:15 +0000 (18:47 +0100)] 
[FLINK-28007][bugfix/connectors] Migrated Kinesis Firehose & Streams sink tests to using synchronous http clients..

2 weeks ago[FLINK-28095][oss] Replace commons-io IOUtils dependency
Chesnay Schepler [Thu, 16 Jun 2022 10:14:13 +0000 (12:14 +0200)] 
[FLINK-28095][oss] Replace commons-io IOUtils dependency

2 weeks ago[FLINK-18887][python][connector/elasticsearch] Add ElasticSearch connector for Python...
Ada Wong [Fri, 31 Dec 2021 09:40:19 +0000 (17:40 +0800)] 
[FLINK-18887][python][connector/elasticsearch] Add ElasticSearch connector for Python DataStream API

This closes #19732.

2 weeks ago[FLINK-27006][table] Support SingleValueAggFunction for CHAR data type
yuxia Luo [Fri, 17 Jun 2022 06:20:38 +0000 (14:20 +0800)] 
[FLINK-27006][table] Support SingleValueAggFunction for CHAR data type

This closes #19338

2 weeks ago[FLINK-27985][table-planner] Introduce FlinkRecomputeStatisticsProgram to compute...
godfreyhe [Thu, 16 Jun 2022 03:39:37 +0000 (11:39 +0800)] 
[FLINK-27985][table-planner] Introduce FlinkRecomputeStatisticsProgram to compute statistics after filter push and partition pruning

This closes #19939

2 weeks ago[FLINK-27987][connector/file] Let FileSystemTableSource extend from SupportsStatistic...
godfreyhe [Thu, 16 Jun 2022 03:39:19 +0000 (11:39 +0800)] 
[FLINK-27987][connector/file] Let FileSystemTableSource extend from SupportsStatisticReport

This closes #19939

2 weeks ago[FLINK-27984][table-common] Introduce FileBasedStatisticsReportableInputFormat interface
godfreyhe [Sun, 12 Jun 2022 08:59:36 +0000 (16:59 +0800)] 
[FLINK-27984][table-common] Introduce FileBasedStatisticsReportableInputFormat interface

This closes #19939

2 weeks ago[FLINK-27983][table-common] Introduce SupportsStatisticsReport interface
godfreyhe [Sun, 12 Jun 2022 08:22:18 +0000 (16:22 +0800)] 
[FLINK-27983][table-common] Introduce SupportsStatisticsReport interface

This closes #19939

2 weeks ago[FLINK-27932][python] Introduce WatermarkStrategy.no_watermarks and WatermarkStrategy...
Juntao Hu [Tue, 7 Jun 2022 08:21:03 +0000 (16:21 +0800)] 
[FLINK-27932][python] Introduce WatermarkStrategy.no_watermarks and WatermarkStrategy.no_watermarks to align with Java API

This closes #19896.

2 weeks ago[FLINK-26941][cep] Support Pattern end with notFollowedBy in case time constraint...
mayue.fight [Thu, 31 Mar 2022 06:53:29 +0000 (14:53 +0800)] 
[FLINK-26941][cep] Support Pattern end with notFollowedBy in case time constraint is defined

This closes #19295.

3 weeks ago[FLINK-27881][Connector/Pulsar] Never return null for PulsarMessageBuilder.
Yufan Sheng [Wed, 15 Jun 2022 22:27:49 +0000 (06:27 +0800)] 
[FLINK-27881][Connector/Pulsar] Never return null for PulsarMessageBuilder.

3 weeks ago[FLINK-28004][ci] Reduce heap memory consumption by 25%
Chesnay Schepler [Wed, 8 Jun 2022 12:09:59 +0000 (14:09 +0200)] 
[FLINK-28004][ci] Reduce heap memory consumption by 25%

3 weeks ago[FLINK-26824][cassandra] Upgrade driver to 3.11.2
Etienne Chauchot [Thu, 16 Jun 2022 09:01:50 +0000 (11:01 +0200)] 
[FLINK-26824][cassandra] Upgrade driver to 3.11.2

3 weeks ago[FLINK-28019][table] fix error when retract a staled record if state ttl enabled...
lincoln lee [Thu, 16 Jun 2022 06:53:12 +0000 (14:53 +0800)] 
[FLINK-28019][table] fix error when retract a staled record if state ttl enabled in RetractableTopNFunction

This closes #19942

3 weeks ago[FLINK-27762][connector/kafka] Catch WakeupException and retry KafkaConsumer invocati...
Qingsheng Ren [Wed, 15 Jun 2022 12:36:06 +0000 (20:36 +0800)] 
[FLINK-27762][connector/kafka] Catch WakeupException and retry KafkaConsumer invocations in split assignment

This closes #19828.

3 weeks ago[FLINK-28052][tests] Remove RunFailedJobListener
Chesnay Schepler [Tue, 14 Jun 2022 11:58:10 +0000 (13:58 +0200)] 
[FLINK-28052][tests] Remove RunFailedJobListener

The RunFailedJobListener had rather obscure semantics.
It considered a job to be terminal after it was restarted. This is awfully specific to a particular test case.
A cleaner approach is to just cancel the job and wait for it to terminate.

Additionally it considered a job as running purely based on the job status, whereas, in particular when checkpointing is involved, waiting for the tasks to be submitted is a better measure.
In fact, testExceptionHistoryWithTaskFailureFromStopWithSavepoint was a broken since a savepoint was never triggered, as not all tasks were running.

3 weeks ago[hotfix][tests] Always respond to task cancellation requests
Chesnay Schepler [Tue, 14 Jun 2022 11:49:19 +0000 (13:49 +0200)] 
[hotfix][tests] Always respond to task cancellation requests

The previous cancel setup doesn't make sense if you aren't aware that one of the tests forces a restart.
We now immediately respond to any task cancellation request instead.

3 weeks ago[hotfix][tests] Remove magic number
Chesnay Schepler [Tue, 14 Jun 2022 11:46:53 +0000 (13:46 +0200)] 
[hotfix][tests] Remove magic number

3 weeks ago[hotfix][tests] Streamline SubmissionBufferingTaskManagerGateway
Chesnay Schepler [Tue, 14 Jun 2022 11:42:11 +0000 (13:42 +0200)] 
[hotfix][tests] Streamline SubmissionBufferingTaskManagerGateway

3 weeks ago[FLINK-28006][tests] Run prod architecture tests in 1 JVM
Chesnay Schepler [Fri, 10 Jun 2022 13:28:06 +0000 (15:28 +0200)] 
[FLINK-28006][tests] Run prod architecture tests in 1 JVM

3 weeks ago[hotfix][build] Introduce property for common surefire arg line
Chesnay Schepler [Fri, 10 Jun 2022 13:27:31 +0000 (15:27 +0200)] 
[hotfix][build] Introduce property for common surefire arg line

3 weeks ago[FLINK-28005][tests] Reduce network memory in UnalignedCheckpointTestBase
Chesnay Schepler [Tue, 14 Jun 2022 11:30:35 +0000 (13:30 +0200)] 
[FLINK-28005][tests] Reduce network memory in UnalignedCheckpointTestBase

3 weeks ago[hotfix][tests] Avoid hard-coded class name
Chesnay Schepler [Tue, 14 Jun 2022 11:25:45 +0000 (13:25 +0200)] 
[hotfix][tests] Avoid hard-coded class name

3 weeks ago[FLINK-27965][table-planner] Fix EXPLAIN PLAN produces wrong query schema for insert...
Jane Chan [Wed, 15 Jun 2022 06:50:10 +0000 (14:50 +0800)] 
[FLINK-27965][table-planner] Fix EXPLAIN PLAN produces wrong query schema for insert clause with static partition

This closes #19940

3 weeks ago[FLINK-27819][rest][docs] Use proper operationIds
Chesnay Schepler [Wed, 15 Jun 2022 06:35:08 +0000 (08:35 +0200)] 
[FLINK-27819][rest][docs] Use proper operationIds

3 weeks ago[FLINK-28018][core] correct the start index for creating empty splits in BinaryInputF...
zhouli [Tue, 14 Jun 2022 07:40:46 +0000 (15:40 +0800)] 
[FLINK-28018][core] correct the start index for creating empty splits in BinaryInputFormat#createInputSplits

3 weeks ago[hotfix] Rework BinaryInputFormatTest to be based on AssertJ
zhouli [Tue, 14 Jun 2022 07:35:39 +0000 (15:35 +0800)] 
[hotfix] Rework BinaryInputFormatTest to be based on AssertJ

3 weeks ago[FLINK-24960][yarn-tests] change order of statements to avoid race condition
Niklas Semmler [Tue, 31 May 2022 11:26:47 +0000 (13:26 +0200)] 
[FLINK-24960][yarn-tests] change order of statements to avoid race condition

3 weeks ago[hotfix][docs] Improve HA_MODE description
Chesnay Schepler [Mon, 13 Jun 2022 13:04:10 +0000 (15:04 +0200)] 
[hotfix][docs] Improve HA_MODE description

3 weeks ago[FLINK:27808][ha] Allow "kubernetes" as HA_MODE
Chesnay Schepler [Fri, 27 May 2022 07:58:37 +0000 (09:58 +0200)] 
[FLINK:27808][ha] Allow "kubernetes" as HA_MODE

3 weeks ago[FLINK-27895][hive][ci] Enable nightly Hive 3.x tests
luoyuxia [Tue, 14 Jun 2022 08:34:45 +0000 (16:34 +0800)] 
[FLINK-27895][hive][ci] Enable nightly Hive 3.x tests

3 weeks ago[FLINK-27999][hive] Fix Hive3 issues
luoyuxia [Tue, 14 Jun 2022 08:28:57 +0000 (16:28 +0800)] 
[FLINK-27999][hive] Fix Hive3 issues

- VirtualColumn.VIRTUAL_COLUMN_NAMES has a different type in hive2 vs hive3, causing NoSuchFieldErrors since our code is only compiled against hive2
- HiveConf is a singleton that is modified in various ways; adds a band-aid to resolve some issues

3 weeks ago[FLINK-24995][tests] Migrate tests to ConsoleReporter#finish
Chesnay Schepler [Wed, 1 Dec 2021 11:16:17 +0000 (12:16 +0100)] 
[FLINK-24995][tests] Migrate tests to ConsoleReporter#finish

'ConsoleReporter#finish' behaves just like '#printSummary', but is also supported in later versions.
Additionally, we now fail the test if the compiler reported any warnings/errors, as without it the summary business didn't provide a benefit in the first place.

3 weeks ago[hotfix] Cleanup EnumValueSerializerCompatibilityTest
Chesnay Schepler [Wed, 1 Dec 2021 11:11:27 +0000 (12:11 +0100)] 
[hotfix] Cleanup EnumValueSerializerCompatibilityTest

- 'in' variable was unused
- 'out' variable was unnecessary because the reporter by default prints to stderr anyway, and there isn't a real benefit in using stdout

3 weeks ago[FLINK-27041][connector/kafka] Catch IllegalStateException in KafkaPartitionSplitRead...
Qingsheng Ren [Tue, 14 Jun 2022 07:33:21 +0000 (15:33 +0800)] 
[FLINK-27041][connector/kafka] Catch IllegalStateException in KafkaPartitionSplitReader.fetch() to handle no valid partition case

This closes #19456.

3 weeks ago[FLINK-27658][runtime] SafetyNetWrapperClassLoader expose addURL method to allow...
fengli [Wed, 1 Jun 2022 08:04:44 +0000 (16:04 +0800)] 
[FLINK-27658][runtime] SafetyNetWrapperClassLoader expose addURL method to allow registering jar dynamically

3 weeks ago[Hotfix] fix typos
littleeleventhwolf [Sat, 11 Jun 2022 04:57:09 +0000 (12:57 +0800)] 
[Hotfix] fix typos

3 weeks ago[hotfix][fault-tolerance][docs] Corrected typo in state page
mans2singh [Tue, 7 Jun 2022 22:59:35 +0000 (18:59 -0400)] 
[hotfix][fault-tolerance][docs] Corrected typo in state page

3 weeks ago[hotfix][network] Fix the typo about subpartition
fanrui [Sat, 28 May 2022 09:23:40 +0000 (17:23 +0800)] 
[hotfix][network] Fix the typo about subpartition

3 weeks ago[FLINK-27171][runtime][security] Add periodic kerberos delegation token obtain possib...
Gabor Somogyi [Mon, 23 May 2022 08:03:54 +0000 (10:03 +0200)] 
[FLINK-27171][runtime][security] Add periodic kerberos delegation token obtain possibility to DelegationTokenManager

3 weeks ago[hotfix][docs-zh] Add missing the flame_graphs.md file to debugging.
liuzhuang2017 [Thu, 26 May 2022 00:24:54 +0000 (08:24 +0800)] 
[hotfix][docs-zh] Add missing the flame_graphs.md file to debugging.