[jira] [Created] (FLINK-37427) incorrect NPE message in StandaloneHaServices constructor
LuJiang created FLINK-37427:
---
Summary: incorrect NPE message in StandaloneHaServices constructor
Key: FLINK-37427
URL: https://issues.apache.org/jira/browse/FLINK-37427
Project: Flink
Issue Type: Improvement
Components: Runtime / RPC
Affects Versions: 1.20.0
Environment: * flink: 1.20.0
Reporter: LuJiang
The constructor of
org.apache.flink.runtime.highavailability.nonha.standalone.StandaloneHaServices
currently uses the variable name clusterRestEndpointAddress instead of the
string literal "clusterRestEndpointAddress" in the checkNotNull validation for
the third parameter. This leads to ambiguous NullPointerException messages
(e.g., NullPointerException: null).
```java
public StandaloneHaServices(
String resourceManagerAddress,
String dispatcherAddress,
String clusterRestEndpointAddress) {
this.resourceManagerAddress =
checkNotNull(resourceManagerAddress, "resourceManagerAddress");
this.dispatcherAddress = checkNotNull(dispatcherAddress,
"dispatcherAddress");
this.clusterRestEndpointAddress =
checkNotNull(clusterRestEndpointAddress,
clusterRestEndpointAddress);
}
```
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
[jira] [Created] (FLINK-37424) Using JDK17 for the binary convenience release
Weijie Guo created FLINK-37424: -- Summary: Using JDK17 for the binary convenience release Key: FLINK-37424 URL: https://issues.apache.org/jira/browse/FLINK-37424 Project: Flink Issue Type: Bug Components: Release System Affects Versions: 2.0.0 Reporter: Weijie Guo Assignee: Weijie Guo Fix For: 2.0.0 -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Created] (FLINK-37423) Add support for PTFs in Table API
Timo Walther created FLINK-37423: Summary: Add support for PTFs in Table API Key: FLINK-37423 URL: https://issues.apache.org/jira/browse/FLINK-37423 Project: Flink Issue Type: Sub-task Components: Table SQL / API Reporter: Timo Walther Assignee: Timo Walther Add API endpoints to use PTFs in Table API. As documented in FLIP-440: https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=298781093#FLIP440:UserdefinedSQLoperators/ProcessTableFunction(PTF)-UsageofPTFsinTableAPI -- This message was sent by Atlassian Jira (v8.20.10#820010)
[SUMMARY] Flink 2.0 Release Sync 03/05/2025
Hi devs, Here's a summary of today's release sync. - All cross-team verification work are completed - There are 2 remaining blockers, both have PRs in review and are expected to be resolved by weekend - Release announcement PR opened [1] - We plan to start building RC1 this weekend and open a Vote next Monday Unless anything unexpected happens that needs to be discussed, we will cancel the subsequent release syncs. Best, Xintong [1] https://github.com/apache/flink-web/pull/777
[ANNOUNCE] Apache Flink Kubernetes Operator 1.11.0 released
Hi All! The Apache Flink community is very happy to announce the release of Apache Flink Kubernetes Operator 1.11.0. The Flink Kubernetes Operator allows users to manage their Apache Flink applications and their lifecycle through native k8s tooling like kubectl. Release blogpost: https://flink.apache.org/2025/03/03/apache-flink-kubernetes-operator-1.11.0-release-announcement/ The release is available for download at: https://flink.apache.org/downloads.html Maven artifacts for Flink Kubernetes Operator can be found at: https://search.maven.org/artifact/org.apache.flink/flink-kubernetes-operator Official Docker image for Flink Kubernetes Operator can be found at: https://hub.docker.com/r/apache/flink-kubernetes-operator Release notes: https://issues.apache.org/jira/secure/ReleaseNote.jspa?projectId=12315522&version=12355186 We would like to thank all contributors of the Apache Flink community who made this release possible! Regards, Gyula Fora
[jira] [Created] (FLINK-37426) FLIP-481: Introduce Event Reporting
Piotr Nowojski created FLINK-37426: -- Summary: FLIP-481: Introduce Event Reporting Key: FLINK-37426 URL: https://issues.apache.org/jira/browse/FLINK-37426 Project: Flink Issue Type: Improvement Components: Runtime / Metrics Affects Versions: 2.0.0 Reporter: Piotr Nowojski Fix For: 2.1.0 https://cwiki.apache.org/confluence/display/FLINK/FLIP-481%3A+Introduce+Event+Reporting -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Created] (FLINK-37425) Sanity check before ForSt cache created
Zakelly Lan created FLINK-37425: --- Summary: Sanity check before ForSt cache created Key: FLINK-37425 URL: https://issues.apache.org/jira/browse/FLINK-37425 Project: Flink Issue Type: Bug Affects Versions: 2.0.0 Reporter: Zakelly Lan Assignee: Zakelly Lan Fix For: 2.0.0 There is a chance that the space based cache limit policy in ForStStateBackend could not work on the specified cache path, resulting in the whole cache fail to store anything. This should be fixed. -- This message was sent by Atlassian Jira (v8.20.10#820010)
