Feifan Wang created FLINK-24159:
---
Summary: document of entropy injection may mislead users
Key: FLINK-24159
URL: https://issues.apache.org/jira/browse/FLINK-24159
Project: Flink
Issue Type: Imp
+ team
On Fri, Sep 3, 2021 at 9:37 AM zhihao wang wrote:
> We backfill from two sources for two different reasons.
>
> 1. We write the outputs into a TEMP Kafka first to allow the v2 job to
> cold-start. The events accumulated in TEMP Kafka need to find a way to
> redirect to the final sink. A s
We backfill from two sources for two different reasons.
1. We write the outputs into a TEMP Kafka first to allow the v2 job to
cold-start. The events accumulated in TEMP Kafka need to find a way to
redirect to the final sink. A simple way is to just move the events in TEMP
Kafka into the final sin
Yangze Guo created FLINK-24161:
--
Summary: Can not stop the job with savepoint while a task is
finishing
Key: FLINK-24161
URL: https://issues.apache.org/jira/browse/FLINK-24161
Project: Flink
Is
Xintong Song created FLINK-24160:
Summary: PartiallyFinishedSourcesITCase fails due to 'Size of the
state is larger than the maximum permitted memory-backed state.'
Key: FLINK-24160
URL: https://issues.apache.org/
Xintong Song created FLINK-24162:
Summary: PartiallyFinishedSourcesITCase fails due to assertion
error in DrainingValidator.validateOperatorLifecycle
Key: FLINK-24162
URL: https://issues.apache.org/jira/browse/FLI
Xintong Song created FLINK-24163:
Summary: PartiallyFinishedSourcesITCase fails due to timeout
Key: FLINK-24163
URL: https://issues.apache.org/jira/browse/FLINK-24163
Project: Flink
Issue Typ
