Zakelly Lan created FLINK-32090:
---
Summary: Python API for enabling and configuring file merging
snapshot
Key: FLINK-32090
URL: https://issues.apache.org/jira/browse/FLINK-32090
Project: Flink
Zakelly Lan created FLINK-32091:
---
Summary: Add necessary metrics for file-merging
Key: FLINK-32091
URL: https://issues.apache.org/jira/browse/FLINK-32091
Project: Flink
Issue Type: Sub-task
Zakelly Lan created FLINK-32089:
---
Summary: Do fast copy in best-effort during first checkpoint after
restoration
Key: FLINK-32089
URL: https://issues.apache.org/jira/browse/FLINK-32089
Project: Flink
Zakelly Lan created FLINK-32092:
---
Summary: Integrate snapshot file-merging with existing IT cases
Key: FLINK-32092
URL: https://issues.apache.org/jira/browse/FLINK-32092
Project: Flink
Issue
Zakelly Lan created FLINK-32087:
---
Summary: Space amplification statistics of file merging
Key: FLINK-32087
URL: https://issues.apache.org/jira/browse/FLINK-32087
Project: Flink
Issue Type:
Zakelly Lan created FLINK-32088:
---
Summary: Re-uploading in state file-merging for space
amplification control
Key: FLINK-32088
URL: https://issues.apache.org/jira/browse/FLINK-32088
Project: Flink
Zakelly Lan created FLINK-32086:
---
Summary: Cleanup non-reported managed directory on exit of TM
Key: FLINK-32086
URL: https://issues.apache.org/jira/browse/FLINK-32086
Project: Flink
Issue
Zakelly Lan created FLINK-32084:
---
Summary: Migrate current file merging of channel state into the
file merging framework
Key: FLINK-32084
URL: https://issues.apache.org/jira/browse/FLINK-32084
Project:
Zakelly Lan created FLINK-32085:
---
Summary: Implement and migrate batch uploading in changelog files
into the file merging framework
Key: FLINK-32085
URL: https://issues.apache.org/jira/browse/FLINK-32085
Zakelly Lan created FLINK-32083:
---
Summary: Chinese translation of documentation of checkpoint
file-merging
Key: FLINK-32083
URL: https://issues.apache.org/jira/browse/FLINK-32083
Project: Flink
Zakelly Lan created FLINK-32082:
---
Summary: Documentation of checkpoint file-merging
Key: FLINK-32082
URL: https://issues.apache.org/jira/browse/FLINK-32082
Project: Flink
Issue Type: Sub-task
Zakelly Lan created FLINK-32080:
---
Summary: Restoration of FileMergingSnapshotManager
Key: FLINK-32080
URL: https://issues.apache.org/jira/browse/FLINK-32080
Project: Flink
Issue Type: Sub-task
Zakelly Lan created FLINK-32081:
---
Summary: Compatibility between file-merging on and off across job
runs
Key: FLINK-32081
URL: https://issues.apache.org/jira/browse/FLINK-32081
Project: Flink
Zakelly Lan created FLINK-32079:
---
Summary: Read/write checkpoint metadata of merged files
Key: FLINK-32079
URL: https://issues.apache.org/jira/browse/FLINK-32079
Project: Flink
Issue Type:
Zakelly Lan created FLINK-32078:
---
Summary: Implement private state file merging
Key: FLINK-32078
URL: https://issues.apache.org/jira/browse/FLINK-32078
Project: Flink
Issue Type: Sub-task
Zakelly Lan created FLINK-32077:
---
Summary: Implement shared state file merging
Key: FLINK-32077
URL: https://issues.apache.org/jira/browse/FLINK-32077
Project: Flink
Issue Type: Sub-task
Zakelly Lan created FLINK-32076:
---
Summary: Add file pool for concurrent file reusing
Key: FLINK-32076
URL: https://issues.apache.org/jira/browse/FLINK-32076
Project: Flink
Issue Type: Sub-task
Zakelly Lan created FLINK-32075:
---
Summary: Delete merged files on checkpoint abort
Key: FLINK-32075
URL: https://issues.apache.org/jira/browse/FLINK-32075
Project: Flink
Issue Type: Sub-task
Zakelly Lan created FLINK-32074:
---
Summary: Support file merging across checkpoints
Key: FLINK-32074
URL: https://issues.apache.org/jira/browse/FLINK-32074
Project: Flink
Issue Type: Sub-task
Zakelly Lan created FLINK-32072:
---
Summary: Create and wire FileMergingSnapshotManager with
TaskManagerServices
Key: FLINK-32072
URL: https://issues.apache.org/jira/browse/FLINK-32072
Project: Flink
Zakelly Lan created FLINK-32073:
---
Summary: Implement file merging in snapshot
Key: FLINK-32073
URL: https://issues.apache.org/jira/browse/FLINK-32073
Project: Flink
Issue Type: Sub-task
Zakelly Lan created FLINK-32070:
---
Summary: FLIP-306 Unified File Merging Mechanism for Checkpoints
Key: FLINK-32070
URL: https://issues.apache.org/jira/browse/FLINK-32070
Project: Flink
Issue
Zakelly Lan created FLINK-32071:
---
Summary: Implement the snapshot manager for merged checkpoint
files in TM
Key: FLINK-32071
URL: https://issues.apache.org/jira/browse/FLINK-32071
Project: Flink
Hi everyone,
Happy to announce that FLIP-306[1] has been approved!
According to the vote thread[2], there are 7 approving votes, out of
which 5 are binding:
* Yanfei Lei
* Yuan Mei (binding)
* Hangxiang Yu
* Rui Fan (binding)
* Yu Li (binding)
* Yun Tang (binding)
* Piotr Nowojski (binding)
And
Chesnay, thank you for all your hard work on this!
David
On Fri, May 12, 2023 at 4:03 PM Chesnay Schepler wrote:
>
>
> What happened?
>
> I have just merged the last commits to properly support Maven 3.3+ on
> the Flink master branch.
>
> mvnw and CI have been updated to use Maven 3.8.6.
Thanks for the FLIP, Archit.
+1 from me as well. This would be very useful for us and others in the
community given the same issue was raised earlier as well.
Regards
Venkata krishnan
On Fri, May 12, 2023 at 4:03 PM Becket Qin wrote:
> Thanks for the FLIP, Archit.
>
> The motivation sounds
Thanks for the FLIP, Archit.
The motivation sounds reasonable and it looks like a straightforward
proposal. +1 from me.
Thanks,
Jiangjie (Becket) Qin
On Fri, May 12, 2023 at 1:30 AM Archit Goyal
wrote:
> Hi all,
>
> I am opening this thread to discuss the proposal to support Yarn ACLs to
>
Successfully built and deployed the bundle from the
flink-kubernetes-operator-1.5.0-rc2
Steps:
Create a fresh KinD cluster (v0.18.0 go1.20.2 linux/amd64)
wget
https://dist.apache.org/repos/dist/dev/flink/flink-kubernetes-operator-1.5.0-rc2/flink-kubernetes-operator-1.5.0-src.tgz
tar xzvf
Thank you so much Wencong Liu, that fixed it!!!
Sent with Proton Mail secure email.
--- Original Message ---
On Thursday, May 11th, 2023 at 11:11 PM, Wencong Liu
wrote:
>
>
> Hi Brandon Wright,
>
>
> I think you could try the following actions in IntelliJ IDE:
> First, execute
Hi Everyone,
Please review and vote on the release candidate #2 for the version 1.5.0 of
Apache Flink Kubernetes Operator,
as follows:
[ ] +1, Approve the release
[ ] -1, Do not approve the release (please provide specific comments)
**Release Overview**
As an overview, the release consists of
Aleksandr Iushmanov created FLINK-32069:
---
Summary: jobClient.getJobStatus() can return status RUNNING for
finished insert operation
Key: FLINK-32069
URL: https://issues.apache.org/jira/browse/FLINK-32069
What happened?
I have just merged the last commits to properly support Maven 3.3+ on
the Flink master branch.
mvnw and CI have been updated to use Maven 3.8.6.
What does this mean for me?
* You can now use Maven versions beyond 3.2.5 (duh).
o Most versions should work, but
leishuiyu created FLINK-32068:
-
Summary: flink-connector-jdbc support clickhouse
Key: FLINK-32068
URL: https://issues.apache.org/jira/browse/FLINK-32068
Project: Flink
Issue Type: New Feature
Hi all!
I am closing this vote now in light of the above mentioned blocker issue:
https://issues.apache.org/jira/browse/FLINK-32067
The fix is on the way, I will create another RC later today.
Cheers,
Gyula
On Fri, May 12, 2023 at 10:20 AM Gyula Fóra wrote:
> The error only happens in cases
Gyula Fora created FLINK-32067:
--
Summary: When no pod template configured, an invalid null pod
template is configured
Key: FLINK-32067
URL: https://issues.apache.org/jira/browse/FLINK-32067
Project:
The error only happens in cases when a podTemplate is not defined. The
checkpointing/HA examples run well.
Adding a simple (dummy) podtemplate to the basic.yaml makes it work:
podTemplate:
spec:
containers:
- name: flink-main-container
I suspect it could be related to some
Thanks all for the feedback.
I'd like to provide some status updates for transparency.
As previously discussed, we have assembled the release management team and
have been discussing how to push things forward. We'd like to split this
into several separate tracks, and prepare some draft
Wencong Liu created FLINK-32066:
---
Summary: Flink Ci service on Azure stops responding to pull
requests
Key: FLINK-32066
URL: https://issues.apache.org/jira/browse/FLINK-32066
Project: Flink
Very strange, I also get an error when running the examples from the RC.
It's different but could be related:
Caused by: io.fabric8.kubernetes.client.KubernetesClientException: Failure
executing: POST at: https://10.96.0.1/api/v1/namespaces/default/pods.
Message: PodList in version "v1" cannot be
Hi Jim and Ted,
Thanks for the quick response. For Openshift issue I would assume that
adding the RBAC suggested here [1] would solve the problem, it seems fine
to me.
For the missing taskmanager could you please share the relevant logs from
your jobmanager pod that is already show running?
Seems missing taskmanager pod. I tried the following:
kubectl create -f
https://github.com/jetstack/cert-manager/releases/download/v1.8.2/cert-manager.yaml
helm install 1.5rc1
Spongebob created FLINK-32065:
-
Summary: Got NoSuchFileException when initialize source function.
Key: FLINK-32065
URL: https://issues.apache.org/jira/browse/FLINK-32065
Project: Flink
Issue
42 matches
Mail list logo
