Ted Yu created FLINK-3392:
-
Summary: Unprotected access to elements in
ClosableBlockingQueue#size()
Key: FLINK-3392
URL: https://issues.apache.org/jira/browse/FLINK-3392
Project: Flink
Issue Type: B
Hi,
In Flink it is possible to have different backends for operator state. I
am wondering what the best approach for different state backends would be.
Let's assume the backend is a database server. The following questions
arise:
- Should the database server be started manually by the user or c
Sebastian Klemke created FLINK-3391:
---
Summary: Typo in SavepointITCase
Key: FLINK-3391
URL: https://issues.apache.org/jira/browse/FLINK-3391
Project: Flink
Issue Type: Bug
Repor
Sebastian Klemke created FLINK-3390:
---
Summary: Savepoint resume is not retried
Key: FLINK-3390
URL: https://issues.apache.org/jira/browse/FLINK-3390
Project: Flink
Issue Type: Bug
Stephan Ewen created FLINK-3389:
---
Summary: Add Pre-defined Options settings for RocksDB State backend
Key: FLINK-3389
URL: https://issues.apache.org/jira/browse/FLINK-3389
Project: Flink
Issue
Maximilian Michels created FLINK-3388:
-
Summary: Expose task accumulators via JMX
Key: FLINK-3388
URL: https://issues.apache.org/jira/browse/FLINK-3388
Project: Flink
Issue Type: Sub-task
Stephan Ewen created FLINK-3387:
---
Summary: Replace all ByteArrayOutputStream and DataOutputStream
use in State Backends by DataOutputSerializer
Key: FLINK-3387
URL: https://issues.apache.org/jira/browse/FLINK-3387
Gyula Fora created FLINK-3386:
-
Summary: Kafka consumers should not necessarily fail on expiring
data
Key: FLINK-3386
URL: https://issues.apache.org/jira/browse/FLINK-3386
Project: Flink
Issue T
big +1 on reworking the timestamp extractor. There were too many users
stumbling across this. I also misunderstood it when trying it out the first
time.
On Tue, Feb 9, 2016 at 4:54 PM, Stephan Ewen wrote:
> Hi everyone!
>
> There are two remaining issues right now pending for 1.0 that will cause
