yangjunhan [Tue, 22 Feb 2022 03:20:30 +0000 (11:20 +0800)]
[FLINK-26206][runtime-web] add service layer abstraction and refactor config service
Hangxiang Yu [Thu, 28 Apr 2022 03:58:18 +0000 (11:58 +0800)]
[hotfix][docs] Fix the wrong display of totalNumberOfCheckpoints in metric.md
Hangxiang Yu [Thu, 28 Apr 2022 01:45:42 +0000 (09:45 +0800)]
[FLINK-25470][changelog] Expose more metrics of ChangelogStateBackend and materialization
Ada Wang [Thu, 12 May 2022 11:00:32 +0000 (19:00 +0800)]
[FLINK-27421][python] Bundle test utility classes (#19700)
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.
Alexander Fedulov [Thu, 12 May 2022 09:10:10 +0000 (11:10 +0200)]
[hotfix][connector][elasticsearch] Reduce testutils log level (#19707)
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.
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.
fredia [Mon, 18 Apr 2022 03:19:01 +0000 (11:19 +0800)]
FLINK-27260][Runtime/Web] Expose changelog configurations in web ui
fredia [Fri, 15 Apr 2022 08:00:27 +0000 (16:00 +0800)]
[FLINK-27260][Runtime/REST] Expose changelog configurations in Rest API
CPS794 [Thu, 7 Apr 2022 10:25:17 +0000 (18:25 +0800)]
[hotfix][docs]correct configuration key "taskmanager.network.detailed-metrics" in metrics document
Hongbo Miao [Thu, 21 Apr 2022 19:08:07 +0000 (12:08 -0700)]
[hotfix][docs] fix "parameters"
Alexander Preuß [Mon, 9 May 2022 13:19:06 +0000 (15:19 +0200)]
[hotfix][connectors/kafka] Fix spelling of setDeliveryGuarantee method
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
Lijie Wang [Tue, 10 May 2022 11:06:36 +0000 (19:06 +0800)]
[FLINK-27563][docs] Fix yarn doc page display error.
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
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
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>
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>
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
Fabian Paul [Thu, 5 May 2022 07:32:48 +0000 (09:32 +0200)]
[FLINK-27487][kafka] Only forward measurable Kafka metrics and ignore others
liliwei [Mon, 15 Nov 2021 15:08:21 +0000 (23:08 +0800)]
[hotfix] Fix comment typos in AsyncIOExample
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.
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.
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
Aitozi [Mon, 14 Feb 2022 06:49:03 +0000 (14:49 +0800)]
[hotfix]Remove unused variable in KubernetesEntrypointUtils
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.
Marios Trivyzas [Mon, 28 Mar 2022 18:06:48 +0000 (21:06 +0300)]
[hotfix][table][tests] Clean-up tests and update to assertJ
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.
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
liuzhuang2017 [Sat, 7 May 2022 08:09:35 +0000 (16:09 +0800)]
[hotfix][docs] Fix the formatting errors of some Chinese documents.
Fabian Paul [Tue, 3 May 2022 12:26:28 +0000 (14:26 +0200)]
[FLINK-27480][kafka] Explain possible metrics InstanceAlreadyExistsException in docs
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.
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.
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>
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
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
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
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
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
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
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
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
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
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
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
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
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
愚鲤 [Wed, 4 May 2022 03:52:32 +0000 (11:52 +0800)]
[FLINK-27461][Kubernetes] Add option to set userAgent for kubeclient
This closes #19630.
Jing Ge [Fri, 6 May 2022 11:52:06 +0000 (13:52 +0200)]
[FLINK-27476][tests] Add dedicated import option for selecting production code
liuzhuang2017 [Fri, 6 May 2022 06:14:35 +0000 (14:14 +0800)]
[hotfix][docs] Fix the inaccessible huawei cloud link.
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.
liuzhuang2017 [Thu, 21 Apr 2022 09:18:22 +0000 (17:18 +0800)]
[hotfix][docs-zh] Delete redundant English content in Chinese documents.
snuyanzin [Mon, 8 Nov 2021 09:51:37 +0000 (10:51 +0100)]
[FLINK-24820][docs] Wrong description in documentation for IS DISTINCT FROM
Yun Gao [Fri, 6 May 2022 10:45:46 +0000 (18:45 +0800)]
[release] Change the stable doc versions
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
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.
wangfeifan [Sun, 1 May 2022 13:19:38 +0000 (21:19 +0800)]
[FLINK-26052][docs-zh] Document savepoint format
Chesnay Schepler [Mon, 2 May 2022 09:59:00 +0000 (11:59 +0200)]
[FLINK-27477][yarn][tests] Drop flink-yarn test-jar
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
Chesnay Schepler [Thu, 5 May 2022 19:11:28 +0000 (21:11 +0200)]
[hotfix][ci] Update libssl download link
Fabian Paul [Wed, 4 May 2022 09:29:08 +0000 (11:29 +0200)]
[FLINK-27486][tests] Fix archunit test violations in connector-base module
Fabian Paul [Wed, 4 May 2022 08:57:55 +0000 (10:57 +0200)]
[FLINK-27486][hybrid] Make hybrid source building blocks as PublicEvolving
Fabian Paul [Wed, 4 May 2022 08:50:49 +0000 (10:50 +0200)]
[FLINK-27486][core] Mark documentation formatting tools as PublicEvolving
Chesnay Schepler [Thu, 5 May 2022 10:23:32 +0000 (12:23 +0200)]
[hotfix][k8s][tests] Fix import
Chesnay Schepler [Thu, 5 May 2022 07:46:33 +0000 (09:46 +0200)]
[hotfix][metrics] Ignore compatibility warnings for Metric#getMetricType
The change is source-compatible.
Yun Gao [Thu, 5 May 2022 06:47:13 +0000 (14:47 +0800)]
Update japicmp configuration for 1.15.0
Joe Moser [Tue, 26 Apr 2022 09:47:16 +0000 (11:47 +0200)]
release notes for the 1.15 release
snuyanzin [Tue, 26 Oct 2021 16:39:53 +0000 (18:39 +0200)]
[FLINK-24766] Ceiling/flooring dates to day returns wrong results. This includes handling millis for timestamps. This closes #17677
Thomas Weise [Tue, 3 May 2022 04:50:18 +0000 (21:50 -0700)]
[FLINK-27465] Handle conversion of negative long to timestamp in AvroRowDeserializationSchema
MartijnVisser [Wed, 4 May 2022 13:24:51 +0000 (15:24 +0200)]
[FLINK-27442][Formats][Avro Confluent] Add Confluent repo to module flink-sql-avro-confluent-registry
Roc Marshal [Wed, 4 May 2022 12:27:29 +0000 (20:27 +0800)]
[FLINK-26496][yarn][tests] Migrate tests to JUnit5
Sergey Nuyanzin [Fri, 22 Apr 2022 12:30:51 +0000 (14:30 +0200)]
[hotfix][docs] Fix class name in docs for ExecutionEnvironment class
MartijnVisser [Wed, 4 May 2022 10:30:39 +0000 (12:30 +0200)]
[FLINK-27485][docs] Fix documentation build pipeline Fix the documentation build pipeline by 1) using a different Git command (which is supported by the installed Git version on the Docker image) and 2) upgrading Hugo and making sure that this is added to the PATH (#19632)
- use compatible command to get the current git branch
- put hugo onto PATH
Timo Walther [Mon, 25 Apr 2022 07:39:29 +0000 (09:39 +0200)]
[FLINK-27368][table-planner] Trim casts from character string to numeric
This closes #19565.
Chesnay Schepler [Tue, 3 May 2022 10:13:47 +0000 (12:13 +0200)]
[FLINK-27470][state][tests] Migrate test to JUnit5
Chesnay Schepler [Tue, 3 May 2022 08:12:32 +0000 (10:12 +0200)]
[hotfix][json][tests] Fix location of services directory
BiGsuw [Tue, 3 May 2022 08:10:17 +0000 (16:10 +0800)]
[FLINK-27352][json][tests] Migrate flink-json to JUnit5
Alexander Fedulov [Wed, 20 Apr 2022 10:16:35 +0000 (12:16 +0200)]
[FLINK-27066][tests][connectors/elasticsearch] Remove bash-based E2E Elasticsearch tests
Alexander Fedulov [Tue, 5 Apr 2022 19:18:19 +0000 (21:18 +0200)]
[FLINK-27066][tests][connectors/elasticsearch] Reintroduce e2e tests in ES as Java tests.
TODO: switch off logging
Ferenc Csaky [Mon, 2 May 2022 19:57:07 +0000 (21:57 +0200)]
[FLINK-27441][webfrontend] fix "nzScroll" calculations
Co-authored-by: Ferenc Csaky <fcsaky@cloudera.com>
MartijnVisser [Tue, 26 Apr 2022 10:45:35 +0000 (12:45 +0200)]
[FLINK-27394][Documentation] Document how you can add externally hosted documentation in a virtual filemounted system that's only known to Hugo, using Hugo Modules.
MartijnVisser [Mon, 25 Apr 2022 11:35:51 +0000 (13:35 +0200)]
[FLINK-27394][Documentation][Buildsystem] Update build pipeline to get latest documentation from external connector repository
MartijnVisser [Mon, 25 Apr 2022 11:20:06 +0000 (13:20 +0200)]
[FLINK-27394][Documentation] Remove existing Elasticsearch documentation since it has been moved to apache/flink-connector-elasticsearch
MartijnVisser [Mon, 25 Apr 2022 11:19:40 +0000 (13:19 +0200)]
[FLINK-27394][Documentation] Document how you can add externally hosted documentation in a virtual filemounted system that's only known to Hugo, using Hugo Modules.
Zhu Zhu [Sat, 30 Apr 2022 08:15:04 +0000 (16:15 +0800)]
[FLINK-27460][runtime] Remove unused notifyPartitionDataAvailable process
Chesnay Schepler [Fri, 29 Apr 2022 10:03:38 +0000 (12:03 +0200)]
[FLINK-27454][tests] Remove inheritance from TestBaseUtils
Chesnay Schepler [Fri, 29 Apr 2022 10:02:59 +0000 (12:02 +0200)]
[FLINK-27454][tests] Explicitly import TestBaseUtils
Chesnay Schepler [Fri, 29 Apr 2022 16:12:43 +0000 (18:12 +0200)]
[FLINK-27459][tests] Reset context environment
Timo Walther [Tue, 19 Apr 2022 12:08:01 +0000 (14:08 +0200)]
[FLINK-26947][table] Add ARRAY_CONTAINS function
This closes #19543.
Timo Walther [Tue, 12 Apr 2022 07:06:16 +0000 (09:06 +0200)]
[FLINK-22857][table] Support evaluating expressions in SpecializedFunction
Timo Walther [Wed, 13 Apr 2022 08:09:35 +0000 (10:09 +0200)]
[FLINK-22857][table-common] Expose more RuntimeContext functionalities in FunctionContext
Timo Walther [Mon, 11 Apr 2022 15:39:35 +0000 (17:39 +0200)]
[FLINK-22857][table-planner] Simplify DefaultSqlExprToRexConverterFactory to RexFactory
Timo Walther [Thu, 14 Apr 2022 07:08:39 +0000 (09:08 +0200)]
[hotfix][table] Simplify code in ParserImpl and FunctionLookup
Timo Walther [Fri, 8 Apr 2022 16:08:51 +0000 (18:08 +0200)]
[hotfix][table-planner] Simplify PlannerContext signatures related to CatalogManager
Timo Walther [Fri, 8 Apr 2022 15:34:55 +0000 (17:34 +0200)]
[hotfix][table-planner] Remove TableConfig as member variable in PlannerContext
Chesnay Schepler [Fri, 29 Apr 2022 09:38:29 +0000 (11:38 +0200)]
[FLINK-27453][tests] Cleanup TestBaseUtils
Chesnay Schepler [Fri, 29 Apr 2022 13:18:57 +0000 (15:18 +0200)]
[FLINK-27452][tests] Move TestBaseUtils#getFromHttp to WebFrontendITCase
Roman Khachatryan [Fri, 18 Feb 2022 09:35:01 +0000 (10:35 +0100)]
[FLINK-26154][tests] Improve logging in SavepointFormatITCase
Ben Augarten [Wed, 27 Apr 2022 20:45:12 +0000 (13:45 -0700)]
[FLINK-27420] Recreate metric groups for each new RM to avoid metric loss
This closes #19607