Chesnay Schepler created FLINK-21386:
Summary: FromElements ignores returns()
Key: FLINK-21386
URL: https://issues.apache.org/jira/browse/FLINK-21386
Project: Flink
Issue Type: Bug
That's an interesting idea.
I guess we can decouple the actual state cleanup delegation from the
correctness issues. I don't see any reason why it can't be implemented
without changing notifications (for FLIP-158, however, we'll probably have
to ask "random" TMs because FLIP-158 adds state
Leonid Ilyevsky created FLINK-21385:
---
Summary: AvroDeserializationSchema corrupted after getting invalid
data
Key: FLINK-21385
URL: https://issues.apache.org/jira/browse/FLINK-21385
Project: Flink
Seth Wiesman created FLINK-21384:
Summary: Automatically copy maven dependencies to clipboard on
click
Key: FLINK-21384
URL: https://issues.apache.org/jira/browse/FLINK-21384
Project: Flink
Hi everyone,
Please review and vote on the release candidate #1 for the version 1.12.2,
as follows:
[ ] +1, Approve the release
[ ] -1, Do not approve the release (please provide specific comments)
The complete staging area is available for your review, which includes:
* JIRA release notes [1],
Till Rohrmann created FLINK-21383:
-
Summary: Docker image does not play well together with ConfigMap
based flink-conf.yamls
Key: FLINK-21383
URL: https://issues.apache.org/jira/browse/FLINK-21383
Till Rohrmann created FLINK-21382:
-
Summary: Standalone K8s documentation does not explain usage of
standby JobManagers
Key: FLINK-21382
URL: https://issues.apache.org/jira/browse/FLINK-21382
Till Rohrmann created FLINK-21381:
-
Summary: Kubernetes HA documentation does not state required
service account and role
Key: FLINK-21381
URL: https://issues.apache.org/jira/browse/FLINK-21381
Chesnay Schepler created FLINK-21380:
Summary: Restarting/Canceling/Failing expose globally-terminal EG
Key: FLINK-21380
URL: https://issues.apache.org/jira/browse/FLINK-21380
Project: Flink
Well deserved! Congrats Roman!
Best,
Yuan
On Tue, Feb 16, 2021 at 5:10 PM Guowei Ma wrote:
> Congratulations Roman!
> Best,
> Guowei
>
>
> On Thu, Feb 11, 2021 at 3:37 PM Yun Tang wrote:
>
> > Congratulations, Roman!
> >
> > Today is also the beginning of Chinese Spring Festival holiday, at
Congratulations Roman!
Best,
Guowei
On Thu, Feb 11, 2021 at 3:37 PM Yun Tang wrote:
> Congratulations, Roman!
>
> Today is also the beginning of Chinese Spring Festival holiday, at which
> we Chinese celebrate across the world for the next lunar new year, and also
> very happy to have you on
Dawid Wysakowicz created FLINK-21379:
Summary: Elasticsearch (v6.3.1) sink end-to-end test fails on azure
Key: FLINK-21379
URL: https://issues.apache.org/jira/browse/FLINK-21379
Project: Flink
Thanks for clarifying.
Concerning the JM aborted checkpoints and state handles: I was thinking
about it the other day as well and was considering an approach like that:
The core idea is to move the cleanup from JM to TM. That solves two issues:
(1) The StateBackends / DSTL delete the artifacts
Thanks Yun for the detailed explanation.
A simple supplementary explanation about the sink case: Maybe we could use
`OperatorCoordinator` to avoid sending the element to the downstream
operator.
But I agree we could not limit the users not to emit records in the
`notiyCheckpointComplete`.
Best,
14 matches
Mail list logo
