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

3 months ago[hotfix][metrics] Ignore compatibility warnings for Metric#getMetricType
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.

3 months agoUpdate japicmp configuration for 1.15.0
Yun Gao [Thu, 5 May 2022 06:47:13 +0000 (14:47 +0800)] 
Update japicmp configuration for 1.15.0

3 months agorelease notes for the 1.15 release
Joe Moser [Tue, 26 Apr 2022 09:47:16 +0000 (11:47 +0200)] 
release notes for the 1.15 release

3 months ago[FLINK-24766] Ceiling/flooring dates to day returns wrong results. This includes...
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

3 months ago[FLINK-27465] Handle conversion of negative long to timestamp in AvroRowDeserializati...
Thomas Weise [Tue, 3 May 2022 04:50:18 +0000 (21:50 -0700)] 
[FLINK-27465] Handle conversion of negative long to timestamp in AvroRowDeserializationSchema

3 months ago[FLINK-27442][Formats][Avro Confluent] Add Confluent repo to module flink-sql-avro...
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

3 months ago[FLINK-26496][yarn][tests] Migrate tests to JUnit5
Roc Marshal [Wed, 4 May 2022 12:27:29 +0000 (20:27 +0800)] 
[FLINK-26496][yarn][tests] Migrate tests to JUnit5

3 months ago[hotfix][docs] Fix class name in docs for ExecutionEnvironment class
Sergey Nuyanzin [Fri, 22 Apr 2022 12:30:51 +0000 (14:30 +0200)] 
[hotfix][docs] Fix class name in docs for ExecutionEnvironment class

3 months ago[FLINK-27485][docs] Fix documentation build pipeline Fix the documentation build...
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

3 months ago[FLINK-27368][table-planner] Trim casts from character string to numeric
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.

3 months ago[FLINK-27470][state][tests] Migrate test to JUnit5
Chesnay Schepler [Tue, 3 May 2022 10:13:47 +0000 (12:13 +0200)] 
[FLINK-27470][state][tests] Migrate test to JUnit5

3 months ago[hotfix][json][tests] Fix location of services directory
Chesnay Schepler [Tue, 3 May 2022 08:12:32 +0000 (10:12 +0200)] 
[hotfix][json][tests] Fix location of services directory

3 months ago[FLINK-27352][json][tests] Migrate flink-json to JUnit5
BiGsuw [Tue, 3 May 2022 08:10:17 +0000 (16:10 +0800)] 
[FLINK-27352][json][tests] Migrate flink-json to JUnit5

3 months ago[FLINK-27066][tests][connectors/elasticsearch] Remove bash-based E2E Elasticsearch...
Alexander Fedulov [Wed, 20 Apr 2022 10:16:35 +0000 (12:16 +0200)] 
[FLINK-27066][tests][connectors/elasticsearch] Remove bash-based E2E Elasticsearch tests

3 months ago[FLINK-27066][tests][connectors/elasticsearch] Reintroduce e2e tests in ES as Java...
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

3 months ago[FLINK-27441][webfrontend] fix "nzScroll" calculations
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>
3 months ago[FLINK-27394][Documentation] Document how you can add externally hosted documentation...
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.

3 months ago[FLINK-27394][Documentation][Buildsystem] Update build pipeline to get latest documen...
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

3 months ago[FLINK-27394][Documentation] Remove existing Elasticsearch documentation since it...
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

3 months ago[FLINK-27394][Documentation] Document how you can add externally hosted documentation...
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.

3 months ago[FLINK-27460][runtime] Remove unused notifyPartitionDataAvailable process
Zhu Zhu [Sat, 30 Apr 2022 08:15:04 +0000 (16:15 +0800)] 
[FLINK-27460][runtime] Remove unused notifyPartitionDataAvailable process

3 months ago[FLINK-27454][tests] Remove inheritance from TestBaseUtils
Chesnay Schepler [Fri, 29 Apr 2022 10:03:38 +0000 (12:03 +0200)] 
[FLINK-27454][tests] Remove inheritance from TestBaseUtils

3 months ago[FLINK-27454][tests] Explicitly import TestBaseUtils
Chesnay Schepler [Fri, 29 Apr 2022 10:02:59 +0000 (12:02 +0200)] 
[FLINK-27454][tests] Explicitly import TestBaseUtils

3 months ago[FLINK-27459][tests] Reset context environment
Chesnay Schepler [Fri, 29 Apr 2022 16:12:43 +0000 (18:12 +0200)] 
[FLINK-27459][tests] Reset context environment

3 months ago[FLINK-26947][table] Add ARRAY_CONTAINS function
Timo Walther [Tue, 19 Apr 2022 12:08:01 +0000 (14:08 +0200)] 
[FLINK-26947][table] Add ARRAY_CONTAINS function

This closes #19543.

3 months ago[FLINK-22857][table] Support evaluating expressions in SpecializedFunction
Timo Walther [Tue, 12 Apr 2022 07:06:16 +0000 (09:06 +0200)] 
[FLINK-22857][table] Support evaluating expressions in SpecializedFunction

3 months ago[FLINK-22857][table-common] Expose more RuntimeContext functionalities in FunctionContext
Timo Walther [Wed, 13 Apr 2022 08:09:35 +0000 (10:09 +0200)] 
[FLINK-22857][table-common] Expose more RuntimeContext functionalities in FunctionContext

3 months ago[FLINK-22857][table-planner] Simplify DefaultSqlExprToRexConverterFactory to RexFactory
Timo Walther [Mon, 11 Apr 2022 15:39:35 +0000 (17:39 +0200)] 
[FLINK-22857][table-planner] Simplify DefaultSqlExprToRexConverterFactory to RexFactory

3 months ago[hotfix][table] Simplify code in ParserImpl and FunctionLookup
Timo Walther [Thu, 14 Apr 2022 07:08:39 +0000 (09:08 +0200)] 
[hotfix][table] Simplify code in ParserImpl and FunctionLookup

3 months ago[hotfix][table-planner] Simplify PlannerContext signatures related to CatalogManager
Timo Walther [Fri, 8 Apr 2022 16:08:51 +0000 (18:08 +0200)] 
[hotfix][table-planner] Simplify PlannerContext signatures related to CatalogManager

3 months ago[hotfix][table-planner] Remove TableConfig as member variable in PlannerContext
Timo Walther [Fri, 8 Apr 2022 15:34:55 +0000 (17:34 +0200)] 
[hotfix][table-planner] Remove TableConfig as member variable in PlannerContext

3 months ago[FLINK-27453][tests] Cleanup TestBaseUtils
Chesnay Schepler [Fri, 29 Apr 2022 09:38:29 +0000 (11:38 +0200)] 
[FLINK-27453][tests] Cleanup TestBaseUtils

3 months ago[FLINK-27452][tests] Move TestBaseUtils#getFromHttp to WebFrontendITCase
Chesnay Schepler [Fri, 29 Apr 2022 13:18:57 +0000 (15:18 +0200)] 
[FLINK-27452][tests] Move TestBaseUtils#getFromHttp to WebFrontendITCase

3 months ago[FLINK-26154][tests] Improve logging in SavepointFormatITCase
Roman Khachatryan [Fri, 18 Feb 2022 09:35:01 +0000 (10:35 +0100)] 
[FLINK-26154][tests] Improve logging in SavepointFormatITCase

3 months ago[FLINK-27420] Recreate metric groups for each new RM to avoid metric loss
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

3 months ago[FLINK-27367][table-planner] Support cast int to date in legacy cast behavior (#19585)
Ron [Fri, 29 Apr 2022 07:31:16 +0000 (15:31 +0800)] 
[FLINK-27367][table-planner] Support cast int to date in legacy cast behavior (#19585)

3 months ago[hotfix][runtime][test] Adds additional test for when the JobManagerRunner result...
Matthias Pohl [Tue, 26 Apr 2022 11:25:01 +0000 (13:25 +0200)] 
[hotfix][runtime][test] Adds additional test for when the JobManagerRunner result completes exceptionally

Additionally, I moved the test's documentation into the
production code because it makes more sense to have the
reasoning over there.