flink.git
2 months ago[FLINK-27676][python] Fix on_timer output behind triggering watermark
Juntao Hu [Wed, 18 May 2022 09:14:49 +0000 (17:14 +0800)] 
[FLINK-27676][python] Fix on_timer output behind triggering watermark

This closes #19765.

2 months ago[FLINK-27185][connector] Convert connector-cassandra module to assertj
Alexander Preuß [Fri, 6 May 2022 09:07:53 +0000 (11:07 +0200)] 
[FLINK-27185][connector] Convert connector-cassandra module to assertj

Co-authored-by: slinkydeveloper <francescoguard@gmail.com>
2 months ago[FLINK-27680][Connector][Pulsar] Disable PulsarSinkITCase and PulsarSourceITCase...
MartijnVisser [Wed, 18 May 2022 12:48:23 +0000 (14:48 +0200)] 
[FLINK-27680][Connector][Pulsar] Disable PulsarSinkITCase and PulsarSourceITCase on JDK 11 since Pulsar doesn't support JDK 11 fully

2 months ago[FLINK-27682][tests] Migrate ComparatorTestBase to JUnit5
Sergey Nuyanzin [Wed, 18 May 2022 09:50:53 +0000 (11:50 +0200)] 
[FLINK-27682][tests] Migrate ComparatorTestBase to JUnit5

2 months ago[FLINK-27340][python][tests] Migrate flink-python to JUnit5
Sergey Nuyanzin [Thu, 19 May 2022 08:03:43 +0000 (10:03 +0200)] 
[FLINK-27340][python][tests] Migrate flink-python to JUnit5

2 months ago[FLINK-25795][python][connector/pulsar] Support pulsar sink connector in PyFlink...
Ada Wang [Mon, 9 May 2022 07:28:07 +0000 (15:28 +0800)] 
[FLINK-25795][python][connector/pulsar] Support pulsar sink connector in PyFlink DataStream API

This closes #19682.

2 months ago[FLINK-27185][connector] Convert connector-base module to assertj
Alexander Preuß [Fri, 6 May 2022 09:07:06 +0000 (11:07 +0200)] 
[FLINK-27185][connector] Convert connector-base module to assertj

Co-authored-by: slinkydeveloper <francescoguard@gmail.com>
2 months ago[FLINK-27185][connector] Convert connector-hive module to assertj
Alexander Preuß [Fri, 6 May 2022 09:09:59 +0000 (11:09 +0200)] 
[FLINK-27185][connector] Convert connector-hive module to assertj

Co-authored-by: slinkydeveloper <francescoguard@gmail.com>
2 months ago[FLINK-27185][connector] Convert connector-elasticsearch modules to assertj
Alexander Preuß [Fri, 6 May 2022 09:09:27 +0000 (11:09 +0200)] 
[FLINK-27185][connector] Convert connector-elasticsearch modules to assertj

Co-authored-by: slinkydeveloper <francescoguard@gmail.com>
2 months ago[FLINK-27607][tests] Migrate module flink-connector-files to JUnit5
Sergey Nuyanzin [Wed, 18 May 2022 08:54:01 +0000 (10:54 +0200)] 
[FLINK-27607][tests] Migrate module flink-connector-files to JUnit5

2 months ago[FLINK-27673][table][tests] Migrate flink-table-api-scala to JUnit5
Sergey Nuyanzin [Wed, 18 May 2022 07:42:44 +0000 (09:42 +0200)] 
[FLINK-27673][table][tests] Migrate flink-table-api-scala to JUnit5

2 months ago[FLINK-27669][tests] Migrate flink-file-sink-common to JUnit5
Sergey Nuyanzin [Wed, 18 May 2022 07:39:45 +0000 (09:39 +0200)] 
[FLINK-27669][tests] Migrate flink-file-sink-common to JUnit5

2 months ago[FLINK-27561][aws][tests] Migrate connector-aws-base to JUnit5
Sergey Nuyanzin [Wed, 18 May 2022 07:21:25 +0000 (09:21 +0200)] 
[FLINK-27561][aws][tests] Migrate connector-aws-base to JUnit5

2 months ago[hotfix][python] Fix lint-python typo 19755/head 19757/head
Ada Wang [Tue, 17 May 2022 11:23:56 +0000 (19:23 +0800)] 
[hotfix][python] Fix lint-python typo

2 months ago[FLINK-24433][Connector][Elasticsearch] Disable Elasticsearch disk allocation decider...
MartijnVisser [Tue, 17 May 2022 14:23:32 +0000 (16:23 +0200)] 
[FLINK-24433][Connector][Elasticsearch] Disable Elasticsearch disk allocation decider. Elasticsearch by default goes into read-only mode when the disk usage is above 85%. On the Azure E2E tests, this is quite common.

We therefore disable the entire disk allocation decider, as documented on https://www.elastic.co/guide/en/elasticsearch/reference/6.2/disk-allocator.html

2 months ago [FLINK-27662][tests] Migrate TypeInformationTestBase to JUnit5
Sergey Nuyanzin [Tue, 17 May 2022 07:36:44 +0000 (09:36 +0200)] 
 [FLINK-27662][tests] Migrate TypeInformationTestBase to JUnit5

2 months ago[hotfix][akka][docs] Replace LocalRpcInvocation with RpcInvocation
cphe [Fri, 22 Mar 2019 06:53:08 +0000 (14:53 +0800)] 
[hotfix][akka][docs] Replace LocalRpcInvocation with RpcInvocation

This closes #8033.

2 months ago[hotfix][elasticsearch] Fix typo
Ada Wang [Tue, 17 May 2022 07:38:43 +0000 (15:38 +0800)] 
[hotfix][elasticsearch] Fix typo

2 months ago[FLINK-27059][compress][tests] Migrate tests to JUnit5
Ryan Skraba [Tue, 17 May 2022 07:26:13 +0000 (09:26 +0200)] 
[FLINK-27059][compress][tests] Migrate tests to JUnit5

2 months ago[FLINK-25543][yarn][tests] Migrate tests to JUnit5
Roc Marshal [Tue, 17 May 2022 07:22:00 +0000 (15:22 +0800)] 
[FLINK-25543][yarn][tests] Migrate tests to JUnit5

2 months ago[FLINK-27433][tests] Store RocksDB logs in its database folder for e2e tests
Yun Tang [Tue, 17 May 2022 07:19:42 +0000 (15:19 +0800)] 
[FLINK-27433][tests] Store RocksDB logs in its database folder for e2e tests

2 months ago[FLINK-27567][aws][tests] Migrate connector-aws-kinesis-streams to JUnit5
Sergey Nuyanzin [Tue, 17 May 2022 07:09:12 +0000 (09:09 +0200)] 
[FLINK-27567][aws][tests] Migrate connector-aws-kinesis-streams to JUnit5

2 months ago[FLINK-27501][tests] Migrate SerializerTestBase to JUnit5
Chesnay Schepler [Tue, 17 May 2022 07:06:57 +0000 (09:06 +0200)] 
[FLINK-27501][tests] Migrate SerializerTestBase to JUnit5

2 months ago[FLINK-26909][Client/Job Submission] Allow to set parallelism to be -1 from Cli
liujiangang [Thu, 5 May 2022 13:55:23 +0000 (21:55 +0800)] 
[FLINK-26909][Client/Job Submission] Allow to set parallelism to be -1 from Cli

This closes #19651.

2 months ago[hotfix][table] Add objectReuse parameter for AsyncLookupJoinITCase. (#19728)
lincoln lee [Tue, 17 May 2022 02:14:54 +0000 (10:14 +0800)] 
[hotfix][table] Add objectReuse parameter for AsyncLookupJoinITCase. (#19728)

2 months ago[FLINK-27649][connectors/elasticsearch] Remove slf4 dependency causing unwanted log...
Alexander Preuß [Mon, 16 May 2022 14:14:38 +0000 (16:14 +0200)] 
[FLINK-27649][connectors/elasticsearch] Remove slf4 dependency causing unwanted log output

2 months ago[FLINK-24433][Tests][Buildsystem] Remove additional pre-installed packages to clean...
MartijnVisser [Mon, 16 May 2022 09:17:40 +0000 (11:17 +0200)] 
[FLINK-24433][Tests][Buildsystem] Remove additional pre-installed packages to clean up more diskspace before starting the E2E tests. Also removing the line that removes `^ghc-8.*` since that doesn't exist anymore on the machines.

3 months ago[FLINK-27566][aws][tests] Migrate aws-kinesis-firehose to JUnit5
Sergey Nuyanzin [Mon, 16 May 2022 12:54:16 +0000 (14:54 +0200)] 
[FLINK-27566][aws][tests] Migrate aws-kinesis-firehose to JUnit5

3 months ago[FLINK-27323][table][tests] Migrate table-api-java to JUnit5
Sergey Nuyanzin [Mon, 16 May 2022 11:47:34 +0000 (13:47 +0200)] 
[FLINK-27323][table][tests] Migrate table-api-java to JUnit5

3 months ago[FLINK-17232][k8s] Disable the implicit behavior to use the Service externalIP as...
愚鲤 [Sun, 15 May 2022 04:22:17 +0000 (12:22 +0800)] 
[FLINK-17232][k8s] Disable the implicit behavior to use the Service externalIP as the address of the Endpoint

3 months ago[FLINK-24433][Tests][Buildsystem] Turn off debug logging for all end-to-end tests...
MartijnVisser [Fri, 13 May 2022 06:50:34 +0000 (08:50 +0200)] 
[FLINK-24433][Tests][Buildsystem] Turn off debug logging for all end-to-end tests to avoid flooding the disk space

3 months ago[FLINK-27271][python] Expose GroupWindow to users
Dian Fu [Thu, 12 May 2022 07:48:19 +0000 (15:48 +0800)] 
[FLINK-27271][python] Expose GroupWindow to users

3 months ago[FLINK-27564][python] Separate different connectors into separate packages
Dian Fu [Thu, 12 May 2022 15:11:50 +0000 (23:11 +0800)] 
[FLINK-27564][python] Separate different connectors into separate packages

This closes #19711.

3 months ago[FLINK-27185][formats] Convert format modules to assertj
slinkydeveloper [Mon, 11 Apr 2022 12:56:48 +0000 (14:56 +0200)] 
[FLINK-27185][formats] Convert format modules to assertj

Co-authored-by: slinkydeveloper <francescoguard@gmail.com>
3 months ago[FLINK-27271][python] Introduce Globalwindows window allocator
zhangjingcun [Wed, 11 May 2022 02:22:32 +0000 (10:22 +0800)] 
[FLINK-27271][python] Introduce Globalwindows window allocator

This closes #19696.

3 months ago[FLINK-26206][runtime-web] add service layer abstraction and refactor config service 19740/head
yangjunhan [Tue, 22 Feb 2022 03:20:30 +0000 (11:20 +0800)] 
[FLINK-26206][runtime-web] add service layer abstraction and refactor config service

3 months ago[hotfix][docs] Fix the wrong display of totalNumberOfCheckpoints in metric.md
Hangxiang Yu [Thu, 28 Apr 2022 03:58:18 +0000 (11:58 +0800)] 
[hotfix][docs] Fix the wrong display of totalNumberOfCheckpoints in metric.md

3 months ago[FLINK-25470][changelog] Expose more metrics of ChangelogStateBackend and materialization
Hangxiang Yu [Thu, 28 Apr 2022 01:45:42 +0000 (09:45 +0800)] 
[FLINK-25470][changelog] Expose more metrics of ChangelogStateBackend and materialization

3 months ago[FLINK-27421][python] Bundle test utility classes (#19700)
Ada Wang [Thu, 12 May 2022 11:00:32 +0000 (19:00 +0800)] 
[FLINK-27421][python] Bundle test utility classes (#19700)

3 months ago[FLINK-27560][python] Refactor SimpleStateRequestHandler to support both keyed state...
Juntao Hu [Tue, 10 May 2022 07:58:32 +0000 (15:58 +0800)] 
[FLINK-27560][python] Refactor SimpleStateRequestHandler to support both keyed state and operator state

This closes #19687.

3 months ago[hotfix][connector][elasticsearch] Reduce testutils log level (#19707)
Alexander Fedulov [Thu, 12 May 2022 09:10:10 +0000 (11:10 +0200)] 
[hotfix][connector][elasticsearch] Reduce testutils log level (#19707)

3 months ago[FLINK-27297][python] Add get_execution_environment method with configuration argument.
Ada Wang [Tue, 10 May 2022 10:01:10 +0000 (18:01 +0800)] 
[FLINK-27297][python] Add get_execution_environment method with configuration argument.

This closes #19685.

3 months ago[hotfix][table] avoid NPE and add more UTs. Remove System.out.println() call.
Jing Ge [Wed, 11 May 2022 13:15:21 +0000 (15:15 +0200)] 
[hotfix][table] avoid NPE and add more UTs. Remove System.out.println() call.

This closes #19699.

3 months agoFLINK-27260][Runtime/Web] Expose changelog configurations in web ui
fredia [Mon, 18 Apr 2022 03:19:01 +0000 (11:19 +0800)] 
FLINK-27260][Runtime/Web] Expose changelog configurations in web ui

3 months ago[FLINK-27260][Runtime/REST] Expose changelog configurations in Rest API
fredia [Fri, 15 Apr 2022 08:00:27 +0000 (16:00 +0800)] 
[FLINK-27260][Runtime/REST] Expose changelog configurations in Rest API

3 months ago[hotfix][docs]correct configuration key "taskmanager.network.detailed-metrics" in...
CPS794 [Thu, 7 Apr 2022 10:25:17 +0000 (18:25 +0800)] 
[hotfix][docs]correct configuration key "taskmanager.network.detailed-metrics" in metrics document

3 months ago[hotfix][docs] fix "parameters"
Hongbo Miao [Thu, 21 Apr 2022 19:08:07 +0000 (12:08 -0700)] 
[hotfix][docs] fix "parameters"

3 months ago[hotfix][connectors/kafka] Fix spelling of setDeliveryGuarantee method
Alexander Preuß [Mon, 9 May 2022 13:19:06 +0000 (15:19 +0200)] 
[hotfix][connectors/kafka] Fix spelling of setDeliveryGuarantee method

3 months ago[hotfix][doc] Extensible unified Sink uses new metric to capture outgoing records
Jing Ge [Fri, 6 May 2022 13:10:03 +0000 (15:10 +0200)] 
[hotfix][doc] Extensible unified Sink uses new metric to capture outgoing records

3 months ago[FLINK-27563][docs] Fix yarn doc page display error.
Lijie Wang [Tue, 10 May 2022 11:06:36 +0000 (19:06 +0800)] 
[FLINK-27563][docs] Fix yarn doc page display error.

3 months ago[FLINK-27048][test] Add ArchUnit rule that connectors should only depend on public API
Alexander Preuß [Tue, 5 Apr 2022 10:14:18 +0000 (12:14 +0200)] 
[FLINK-27048][test] Add ArchUnit rule that connectors should only depend on public API

3 months ago[FLINK-27450][hive] Upgrade default hive version to fix Hive SessionState initializat...
Tartarus0zm [Wed, 11 May 2022 03:36:59 +0000 (11:36 +0800)] 
[FLINK-27450][hive] Upgrade default hive version to fix Hive SessionState initialization issue with jdk11

3 months ago[FLINK-27565][runtime-web] Bump minimist from 1.2.5 to 1.2.6 in /flink-runtime-web...
dependabot[bot] [Sun, 17 Apr 2022 19:55:32 +0000 (19:55 +0000)] 
[FLINK-27565][runtime-web] Bump minimist from 1.2.5 to 1.2.6 in /flink-runtime-web/web-dashboard. This closes #19501

Bumps [minimist](https://github.com/substack/minimist) from 1.2.5 to 1.2.6.
- [Release notes](https://github.com/substack/minimist/releases)
- [Commits](https://github.com/substack/minimist/compare/1.2.5...1.2.6)

---
updated-dependencies:
- dependency-name: minimist
  dependency-type: indirect
...

Signed-off-by: dependabot[bot] <support@github.com>
3 months ago[FLINK-27255] [flink-avro] flink-avro does not support ser/de of large avro schema...
Haizhou Zhao [Tue, 10 May 2022 23:18:38 +0000 (16:18 -0700)] 
[FLINK-27255] [flink-avro] flink-avro does not support ser/de of large avro schema (#19645)

Co-authored-by: Haizhou Zhao <haizhou_zhao@apple.com>
3 months ago[hotfix][docs-zh] Fix two inaccessible links. (#19678)
liuzhuang2017 [Tue, 10 May 2022 13:50:10 +0000 (21:50 +0800)] 
[hotfix][docs-zh] Fix two inaccessible links. (#19678)

* [hotfix][docs-zh] Fix two inaccessible links to the Iterations documentation. This fixes #19678

3 months ago[FLINK-27487][kafka] Only forward measurable Kafka metrics and ignore others
Fabian Paul [Thu, 5 May 2022 07:32:48 +0000 (09:32 +0200)] 
[FLINK-27487][kafka] Only forward measurable Kafka metrics and ignore others

3 months ago[hotfix] Fix comment typos in AsyncIOExample
liliwei [Mon, 15 Nov 2021 15:08:21 +0000 (23:08 +0800)] 
[hotfix] Fix comment typos in AsyncIOExample

3 months ago[FLINK-26588][docs] Translate the new CAST documentation to Chinese 19756/head
Chengkai Yang [Tue, 10 May 2022 02:25:27 +0000 (10:25 +0800)] 
[FLINK-26588][docs] Translate the new CAST documentation to Chinese

This closes #19498.

3 months ago[FLINK-26112][k8s]Port getRestEndpoint method to the specific service type subclass
Aitozi [Mon, 14 Feb 2022 15:22:25 +0000 (23:22 +0800)] 
[FLINK-26112][k8s]Port getRestEndpoint method to the specific service type subclass

This closes #18762.

3 months ago[Flink-26112][k8s]Refactor the FlinkKubeClient interface to deal with service name...
Aitozi [Mon, 14 Feb 2022 07:56:14 +0000 (15:56 +0800)] 
[Flink-26112][k8s]Refactor the FlinkKubeClient interface to deal with service name directly

3 months ago[hotfix]Remove unused variable in KubernetesEntrypointUtils
Aitozi [Mon, 14 Feb 2022 06:49:03 +0000 (14:49 +0800)] 
[hotfix]Remove unused variable in KubernetesEntrypointUtils

3 months ago[hotfix][table][tests] Replace ExpectedException with assertJ
Marios Trivyzas [Mon, 28 Mar 2022 18:07:21 +0000 (21:07 +0300)] 
[hotfix][table][tests] Replace ExpectedException with assertJ

Replace deprecated ExpectedException with assertJ's
`assertThatThrownBy` and improve certain assertions by asserting
the Exception class or the Exception message where missing.

This closes #19262.

3 months ago[hotfix][table][tests] Clean-up tests and update to assertJ
Marios Trivyzas [Mon, 28 Mar 2022 18:06:48 +0000 (21:06 +0300)] 
[hotfix][table][tests] Clean-up tests and update to assertJ

3 months ago[hotfix][table-planner][tests] Remove configuration for default legacy-cast-behaviour
Marios Trivyzas [Mon, 28 Mar 2022 09:41:09 +0000 (12:41 +0300)] 
[hotfix][table-planner][tests] Remove configuration for default legacy-cast-behaviour

Since `table.exec.legacy-cast-behaviour` is disabled by default, there
is no need to explicitely set it in the configuration of the Cast
related IT tests.

Call `super.getConfiguration()` to inherit the configuration set in the
superclass and add/override with more config options in the subclass.

3 months ago[hotfix][docs] Mention changes of "RuntimeContext#getMetricGroup" in 1.14 release...
Lijie Wang [Mon, 9 May 2022 06:38:37 +0000 (14:38 +0800)] 
[hotfix][docs] Mention changes of "RuntimeContext#getMetricGroup" in 1.14 release notes.

This closes #19676

3 months ago[hotfix][docs] Fix the formatting errors of some Chinese documents.
liuzhuang2017 [Sat, 7 May 2022 08:09:35 +0000 (16:09 +0800)] 
[hotfix][docs] Fix the formatting errors of some Chinese documents.

3 months ago[FLINK-27480][kafka] Explain possible metrics InstanceAlreadyExistsException in docs
Fabian Paul [Tue, 3 May 2022 12:26:28 +0000 (14:26 +0200)] 
[FLINK-27480][kafka] Explain possible metrics InstanceAlreadyExistsException in docs

3 months ago[hotfix][docs-zh] Add known issues with Pulsar client under Java 11 to Chinese docume...
zhuanshenbsj1 [Mon, 18 Apr 2022 16:00:47 +0000 (00:00 +0800)] 
[hotfix][docs-zh] Add known issues with Pulsar client under Java 11 to Chinese documentation.

3 months ago[FLINK-27545][python][examples] Update the example in PyFlink shell
Dian Fu [Mon, 9 May 2022 02:37:42 +0000 (10:37 +0800)] 
[FLINK-27545][python][examples] Update the example in PyFlink shell

This closes #19673.

3 months ago[hotfix][doc] fix the mismatch result in Window Join example (#19665)
TennyZhuang [Sun, 8 May 2022 12:45:01 +0000 (20:45 +0800)] 
[hotfix][doc] fix the mismatch result in Window Join example (#19665)

Signed-off-by: TennyZhuang <zty0826@gmail.com>
3 months ago[release] Upgrade current version to 1.15 for StatefulJobWBroadcastStateMigrationITCa...
Yun Gao [Sat, 7 May 2022 16:37:57 +0000 (00:37 +0800)] 
[release] Upgrade current version to 1.15 for StatefulJobWBroadcastStateMigrationITCase and create snapshots

3 months ago[release] Upgrade current version to 1.15 for StatefulJobSavepointMigrationITCase...
Yun Gao [Sat, 7 May 2022 16:33:49 +0000 (00:33 +0800)] 
[release] Upgrade current version to 1.15 for StatefulJobSavepointMigrationITCase and create snapshots

3 months ago[release] Upgrade current version to 1.15 for AbstractOperatorRestoreTestBase and...
Yun Gao [Sat, 7 May 2022 16:31:14 +0000 (00:31 +0800)] 
[release] Upgrade current version to 1.15 for AbstractOperatorRestoreTestBase and create snapshots

3 months ago[release] Upgrade current version to 1.15 for TypeSerializerSnapshotMigrationITCase...
Yun Gao [Sat, 7 May 2022 10:59:55 +0000 (18:59 +0800)] 
[release] Upgrade current version to 1.15 for TypeSerializerSnapshotMigrationITCase and create snapshots

3 months ago[release] Upgrade current version to 1.15 for StatefulJobWBroadcastStateMigrationITCa...
Yun Gao [Sat, 7 May 2022 10:58:34 +0000 (18:58 +0800)] 
[release] Upgrade current version to 1.15 for StatefulJobWBroadcastStateMigrationITCase and create snapshots

3 months ago[release] Upgrade current version to 1.15 for StatefulJobSnapshotMigrationITCase...
Yun Gao [Sat, 7 May 2022 10:39:09 +0000 (18:39 +0800)] 
[release] Upgrade current version to 1.15 for StatefulJobSnapshotMigrationITCase and create snapshots

3 months ago[release] Upgrade current version to 1.15 for WindowOperatorMigrationTest and create...
Yun Gao [Sat, 7 May 2022 10:23:16 +0000 (18:23 +0800)] 
[release] Upgrade current version to 1.15 for WindowOperatorMigrationTest and create snapshots

3 months ago[release] Upgrade current version to 1.15 for CEPMigrationTest and create snapshots
Yun Gao [Sat, 7 May 2022 10:20:29 +0000 (18:20 +0800)] 
[release] Upgrade current version to 1.15 for CEPMigrationTest and create snapshots

3 months ago[release] Upgrade current version to 1.15 for ContinuousFileProcessingMigrationTest...
Yun Gao [Sat, 7 May 2022 10:15:35 +0000 (18:15 +0800)] 
[release] Upgrade current version to 1.15 for ContinuousFileProcessingMigrationTest and create snapshots

3 months ago[release] Upgrade current version to 1.15 for FlinkKinesisConsumerMigrationTest and...
Yun Gao [Sat, 7 May 2022 06:10:56 +0000 (14:10 +0800)] 
[release] Upgrade current version to 1.15 for FlinkKinesisConsumerMigrationTest and create snapshots

3 months ago[release] Upgrade current version to 1.15 for FlinkKafkaProducerMigrationTest and...
Yun Gao [Sat, 7 May 2022 06:07:27 +0000 (14:07 +0800)] 
[release] Upgrade current version to 1.15 for FlinkKafkaProducerMigrationTest and create snapshots

3 months ago[release] Upgrade current version to 1.15 for FlinkKafkaConsumerBaseMigrationTest...
Yun Gao [Sat, 7 May 2022 04:11:13 +0000 (12:11 +0800)] 
[release] Upgrade current version to 1.15 for FlinkKafkaConsumerBaseMigrationTest and create snapshots

3 months ago[release] Upgrade current version to 1.15 for TypeSerializerUpgradeTestBase and creat...
Yun Gao [Sat, 7 May 2022 04:06:39 +0000 (12:06 +0800)] 
[release] Upgrade current version to 1.15 for TypeSerializerUpgradeTestBase and create snapshots

3 months ago[FLINK-27461][Kubernetes] Add option to set userAgent for kubeclient
愚鲤 [Wed, 4 May 2022 03:52:32 +0000 (11:52 +0800)] 
[FLINK-27461][Kubernetes] Add option to set userAgent for kubeclient

This closes #19630.

3 months ago[FLINK-27476][tests] Add dedicated import option for selecting production code
Jing Ge [Fri, 6 May 2022 11:52:06 +0000 (13:52 +0200)] 
[FLINK-27476][tests] Add dedicated import option for selecting production code

3 months ago[hotfix][docs] Fix the inaccessible huawei cloud link.
liuzhuang2017 [Fri, 6 May 2022 06:14:35 +0000 (14:14 +0800)] 
[hotfix][docs] Fix the inaccessible huawei cloud  link.

3 months ago[FLINK-27533][coordination][tests] Remove retry attempt limit
Chesnay Schepler [Fri, 6 May 2022 11:48:11 +0000 (13:48 +0200)] 
[FLINK-27533][coordination][tests] Remove retry attempt limit

The test could fail if the polling loop ran too quickly or if the timing was just right that it always missed the restarting state.
Remove the limit and just wait for as long as needed.

3 months ago[hotfix][docs-zh] Delete redundant English content in Chinese documents.
liuzhuang2017 [Thu, 21 Apr 2022 09:18:22 +0000 (17:18 +0800)] 
[hotfix][docs-zh] Delete redundant English content in Chinese documents.

3 months ago[FLINK-24820][docs] Wrong description in documentation for IS DISTINCT FROM
snuyanzin [Mon, 8 Nov 2021 09:51:37 +0000 (10:51 +0100)] 
[FLINK-24820][docs] Wrong description in documentation for IS DISTINCT FROM

3 months ago[release] Change the stable doc versions
Yun Gao [Fri, 6 May 2022 10:45:46 +0000 (18:45 +0800)] 
[release] Change the stable doc versions

3 months ago[FLINK-25970][core] Add type of original exception to the detailMessage of Serialized...
Wencong Liu [Wed, 27 Apr 2022 15:11:03 +0000 (23:11 +0800)] 
[FLINK-25970][core] Add type of original exception to the detailMessage of SerializedThrowable.

This closes #19615

3 months ago[FLINK-27469][yarn][tests] Drop CliFrontendRunWithYarnTest
Chesnay Schepler [Mon, 2 May 2022 09:52:45 +0000 (11:52 +0200)] 
[FLINK-27469][yarn][tests] Drop CliFrontendRunWithYarnTest

The detached/parallelism options aren't handled by the yarn session CLI.
See CliFrontendParser#getProgramSpecificOptions.

3 months ago[FLINK-26052][docs-zh] Document savepoint format
wangfeifan [Sun, 1 May 2022 13:19:38 +0000 (21:19 +0800)] 
[FLINK-26052][docs-zh] Document savepoint format

3 months ago[FLINK-27477][yarn][tests] Drop flink-yarn test-jar
Chesnay Schepler [Mon, 2 May 2022 09:59:00 +0000 (11:59 +0200)] 
[FLINK-27477][yarn][tests] Drop flink-yarn test-jar

3 months ago[release] Add 1.15 docs link to the list of previous versions
Yun Gao [Fri, 6 May 2022 02:24:37 +0000 (10:24 +0800)] 
[release] Add 1.15 docs link to the list of previous versions

3 months ago[hotfix][ci] Update libssl download link
Chesnay Schepler [Thu, 5 May 2022 19:11:28 +0000 (21:11 +0200)] 
[hotfix][ci] Update libssl download link

3 months ago[FLINK-27486][tests] Fix archunit test violations in connector-base module
Fabian Paul [Wed, 4 May 2022 09:29:08 +0000 (11:29 +0200)] 
[FLINK-27486][tests] Fix archunit test violations in connector-base module

3 months ago[FLINK-27486][hybrid] Make hybrid source building blocks as PublicEvolving
Fabian Paul [Wed, 4 May 2022 08:57:55 +0000 (10:57 +0200)] 
[FLINK-27486][hybrid] Make hybrid source building blocks as PublicEvolving

3 months ago[FLINK-27486][core] Mark documentation formatting tools as PublicEvolving
Fabian Paul [Wed, 4 May 2022 08:50:49 +0000 (10:50 +0200)] 
[FLINK-27486][core] Mark documentation formatting tools as PublicEvolving

3 months ago[hotfix][k8s][tests] Fix import
Chesnay Schepler [Thu, 5 May 2022 10:23:32 +0000 (12:23 +0200)] 
[hotfix][k8s][tests] Fix import