flink.git
6 weeks ago[FLINK-27754][shell] Add stderr when singular flink-dist*.jar cannot be resolved... 19779/head
Rudi Kershaw [Fri, 13 May 2022 21:07:01 +0000 (22:07 +0100)] 
[FLINK-27754][shell] Add stderr when singular flink-dist*.jar cannot be resolved for config.sh.

6 weeks ago[FLINK-27751][build] Disable jboss repository 19721/head
Chesnay Schepler [Tue, 24 May 2022 08:12:01 +0000 (10:12 +0200)] 
[FLINK-27751][build] Disable jboss repository

6 weeks ago[FLINK-27219][sql-client] Print exception stack when get errors
Shengkai [Mon, 23 May 2022 11:40:04 +0000 (19:40 +0800)] 
[FLINK-27219][sql-client] Print exception stack when get errors

This closes #19796.

6 weeks ago[FLINK-27733][python] Rework on_timer output behind watermark bug fix
Juntao Hu [Sun, 22 May 2022 15:16:12 +0000 (23:16 +0800)] 
[FLINK-27733][python] Rework on_timer output behind watermark bug fix

This closes #19788.

6 weeks agoRevert "[FLINK-25188][python][build] Support m1 chip."
huangxingbo [Tue, 24 May 2022 01:57:40 +0000 (09:57 +0800)] 
Revert "[FLINK-25188][python][build] Support m1 chip."

This reverts commit 7e9be789

6 weeks ago[FLINK-25188][python][build] Support m1 chip.
Ada Wong [Tue, 18 Jan 2022 08:06:11 +0000 (16:06 +0800)] 
[FLINK-25188][python][build] Support m1 chip.

This closes #18769.

6 weeks ago[hotfix][tests] Fix command not found error in azure watchdog script
Paul Lam [Sat, 18 Sep 2021 08:39:27 +0000 (16:39 +0800)] 
[hotfix][tests] Fix command not found error in azure watchdog script

6 weeks ago[FLINK-27732][tests] Migrate flink-examples-table to JUnit5
Sergey Nuyanzin [Mon, 23 May 2022 09:50:43 +0000 (11:50 +0200)] 
[FLINK-27732][tests] Migrate flink-examples-table to JUnit5

6 weeks ago[hotfix][docs][connector/pulsar] Fix doc typo of setDeliveryGuarantee
Ada Wang [Mon, 23 May 2022 02:59:28 +0000 (10:59 +0800)] 
[hotfix][docs][connector/pulsar] Fix doc typo of setDeliveryGuarantee

6 weeks ago[hotfix][docs] Update java doc to use DataStream API instead of deprecated DataSet API
Jing Ge [Mon, 23 May 2022 08:12:09 +0000 (10:12 +0200)] 
[hotfix][docs] Update java doc to use DataStream API instead of deprecated DataSet API

This closes #19784.

6 weeks ago[FLINK-24735][sql-client] Catch Throwable rather than Exception in LocalExecutor...
Shengkai [Mon, 23 May 2022 07:57:31 +0000 (15:57 +0800)] 
[FLINK-24735][sql-client] Catch Throwable rather than Exception in LocalExecutor to avoid client crash

This closes #19773.

6 weeks ago[FLINK-27735][testinfrastructure] Update testcontainers dependency to v1.17.2
Sergey Nuyanzin [Sun, 22 May 2022 13:19:06 +0000 (15:19 +0200)] 
[FLINK-27735][testinfrastructure] Update testcontainers dependency to v1.17.2

6 weeks ago[FLINK-26043][runtime][security] Add periodic kerberos relogin to KerberosDelegationT...
gabor.g.somogyi [Mon, 14 Feb 2022 13:23:17 +0000 (14:23 +0100)] 
[FLINK-26043][runtime][security] Add periodic kerberos relogin to KerberosDelegationTokenManager
[FLINK-27605][tests] Updated Mockito version to 3.4.6 in order to use static method mocking

6 weeks ago[FLINK-27699][python][connector/pulsar] Support StopCursor.at_publish_time
Ada Wang [Thu, 19 May 2022 12:02:34 +0000 (20:02 +0800)] 
[FLINK-27699][python][connector/pulsar] Support StopCursor.at_publish_time

This closes #19771.

6 weeks ago[hotfix][python][connector/pulsar] Improve PulsarDeserializationSchema.flink_type_inf...
Dian Fu [Sat, 21 May 2022 09:46:17 +0000 (17:46 +0800)] 
[hotfix][python][connector/pulsar] Improve PulsarDeserializationSchema.flink_type_info set execution_config default to None

6 weeks ago[FLINK-27694][python][build] Move lint-python log location (#19768)
Ada Wang [Sat, 21 May 2022 09:32:55 +0000 (17:32 +0800)] 
[FLINK-27694][python][build] Move lint-python log location (#19768)

6 weeks ago[hotfix][python] Fix typo of lint-python (#19769)
Ada Wang [Sat, 21 May 2022 09:07:23 +0000 (17:07 +0800)] 
[hotfix][python] Fix typo of lint-python (#19769)

6 weeks ago[FLINK-27711][python][connector/pulsar] Fix the typo of the method name from set_topi...
Ada Wang [Fri, 20 May 2022 05:50:39 +0000 (13:50 +0800)] 
[FLINK-27711][python][connector/pulsar] Fix the typo of the method name from set_topics_pattern to set_topic_pattern

This closes #19774.

6 weeks ago[FLINK-26480][python] Support window_all in Python DataStream API
zhangjingcun [Wed, 18 May 2022 07:20:54 +0000 (15:20 +0800)] 
[FLINK-26480][python] Support window_all in Python DataStream API

This closes #19758.

6 weeks ago[FLINK-27490][table][tests] Migrate test to JUnit5 for flink-table-code-splitter
Sergey Nuyanzin [Wed, 4 May 2022 15:18:31 +0000 (17:18 +0200)] 
[FLINK-27490][table][tests] Migrate test to JUnit5 for flink-table-code-splitter

6 weeks ago[FLINK-17295][runtime] Refine tests to ensure the consistency of jobVertexId, subtask...
Zhu Zhu [Thu, 12 May 2022 08:32:34 +0000 (16:32 +0800)] 
[FLINK-17295][runtime] Refine tests to ensure the consistency of jobVertexId, subtaskIndex, attemptNumber and executionAttemptId

6 weeks ago[FLINK-17295][runtime] Remove unnecessary fields from Execution and ArchivedExecution
Zhu Zhu [Tue, 17 May 2022 08:08:32 +0000 (16:08 +0800)] 
[FLINK-17295][runtime] Remove unnecessary fields from Execution and ArchivedExecution

6 weeks ago[FLINK-17295][runtime] Remove unnecessary fields from TaskDeploymentDescriptor
Zhu Zhu [Fri, 13 May 2022 08:53:31 +0000 (16:53 +0800)] 
[FLINK-17295][runtime] Remove unnecessary fields from TaskDeploymentDescriptor

6 weeks ago[FLINK-17295][runtime] Simplify ExecutionVertexID retrieval in scheduler
Zhu Zhu [Fri, 13 May 2022 07:53:15 +0000 (15:53 +0800)] 
[FLINK-17295][runtime] Simplify ExecutionVertexID retrieval in scheduler

6 weeks ago[FLINK-17295][runtime] Rework MetricGroup methods to ensure param consistency
Zhu Zhu [Thu, 12 May 2022 09:38:43 +0000 (17:38 +0800)] 
[FLINK-17295][runtime] Rework MetricGroup methods to ensure param consistency

6 weeks ago[FLINK-17295][runtime] Refactor ExecutionAttemptID to consist of executionGraphId...
Zhu Zhu [Wed, 11 May 2022 13:39:29 +0000 (21:39 +0800)] 
[FLINK-17295][runtime] Refactor ExecutionAttemptID to consist of executionGraphId, executionVertexId and attemptNumber

6 weeks ago[FLINK-17295][runtime] Introduce ExecutionGraphID
Zhu Zhu [Wed, 18 May 2022 08:07:21 +0000 (16:07 +0800)] 
[FLINK-17295][runtime] Introduce ExecutionGraphID

6 weeks ago[hotfix][runtime] Add serialVersionUID to ExecutionVertexID
Zhu Zhu [Wed, 18 May 2022 08:10:45 +0000 (16:10 +0800)] 
[hotfix][runtime] Add serialVersionUID to ExecutionVertexID

6 weeks ago[FLINK-26788][core] Add cause when AbstractDeserializationSchema throw exception
Ran Tao [Fri, 25 Mar 2022 04:02:34 +0000 (12:02 +0800)] 
[FLINK-26788][core] Add cause when AbstractDeserializationSchema throw exception

This closes #19241.

6 weeks ago[FLINK-27672][tests][table] Migrate flink-table-common to JUnit5
Sergey Nuyanzin [Fri, 20 May 2022 08:07:34 +0000 (10:07 +0200)] 
[FLINK-27672][tests][table] Migrate flink-table-common to JUnit5

6 weeks ago[FLINK-27698][tests][table] Migrate flink-table-api-java-bridge to JUnit5
Sergey Nuyanzin [Thu, 19 May 2022 08:09:59 +0000 (10:09 +0200)] 
[FLINK-27698][tests][table] Migrate flink-table-api-java-bridge to JUnit5

6 weeks ago[FLINK-25950][runtime] Use idempotent delete for zk node
Jie Wang [Fri, 6 May 2022 15:46:33 +0000 (23:46 +0800)] 
[FLINK-25950][runtime] Use idempotent delete for zk node

This cleanup is made possible by upgrading the curator
dependency from 2.12 to 2.5.0.

6 weeks ago[FLINK-27174][connector/kafka] Fix checking of bootstrapServers when already provided...
zhangzhengqi3 [Tue, 3 May 2022 06:53:05 +0000 (14:53 +0800)] 
[FLINK-27174][connector/kafka] Fix checking of bootstrapServers when already provided in producer Properties

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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