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
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:
Till Rohrmann created FLINK-8521:
Summary:
FlinkKafkaProducer011ITCase.testRunOutOfProducersInThePool timed out on Travis
Key: FLINK-8521
URL: https://issues.apache.org/jira/browse/FLINK-8521
(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
> 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
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
