zhijiang created FLINK-8523:
---
Summary: Stop assigning floating buffers for blocked input
channels in exactly-once mode
Key: FLINK-8523
URL: https://issues.apache.org/jira/browse/FLINK-8523
Project: Flink
>
>
> What do you mean by checkpoint “assignments”? The assignment from
> shard-to-source is only fixed within a single execution of the job. We only
> checkpoint the progress of each shard in the state.
> Given that we support plugging in custom shard assignment hashing, then
> the assignment coul
Kostas Kloudas created FLINK-8522:
-
Summary: DefaultOperatorStateBackend writes data in checkpoint
that is never read.
Key: FLINK-8522
URL: https://issues.apache.org/jira/browse/FLINK-8522
Project: Fl
Till Rohrmann created FLINK-8521:
Summary:
FlinkKafkaProducer011ITCase.testRunOutOfProducersInThePool timed out on Travis
Key: FLINK-8521
URL: https://issues.apache.org/jira/browse/FLINK-8521
Project:
(Sorry, I accidentally sent out my un-finished reply too early. Here’s the full
reply.)
> Isn't the issue that some shard assignments may not have been checkpointed
> and so may end up in different subtasks when they are re-discovered?
That is part of the problem, yes. For example, it would al
> Isn't the issue that some shard assignments may not have been checkpointed
> and so may end up in different subtasks when they are re-discovered?
That is part of the problem, yes. For example, it would also be problematic for
shard discovery.
If the assignment is non-deterministic, a source s
Till Rohrmann created FLINK-8520:
Summary: CassandraConnectorITCase.testCassandraTableSink unstable
on Travis
Key: FLINK-8520
URL: https://issues.apache.org/jira/browse/FLINK-8520
Project: Flink
