[jira] [Created] (FLINK-6324) Refine state access methods in OperatorStateStore

Tzu-Li (Gordon) Tai created FLINK-6324: -- Summary: Refine state access methods in OperatorStateStore Key: FLINK-6324 URL: https://issues.apache.org/jira/browse/FLINK-6324 Project: Flink

Re: [DISCUSS] Code style / checkstyle

+1 to use earth rotation as the new standard time unit. Maybe more importantly, I'm absolutely in favor of merging it. On 18.04.2017 20:39, Aljoscha Krettek wrote: I rebased the PR [1] on current master. Is there any strong objection against merging this (minus the two last commits which

Re: Rescaling state

Hi, yes, right now this can only happen when a Job is stopped and restarted from a savepoint. In the future we might be able to do it without restarting but I think that is quite a ways in the future. Best, Aljoscha > On 18. Apr 2017, at 20:12, Vishnu Viswanath >

Re: [DISCUSS] Code style / checkstyle

I rebased the PR [1] on current master. Is there any strong objection against merging this (minus the two last commits which introduce curly-brace-style checking). If not, I would like to merge this after two earth rotations, i.e. after all the time zones have had some time to react. The

Rescaling state

Hi All, Regarding the scale up and down feature mentioned in this talk: https://www.youtube.com/watch?v=IHSMnlWXkZ4=PLDX4T_cnKjD2UC6wJr_wRbIvtlMtkc-n2=18 Can this only be done when restarting the job from a save point? Is there a case where the state is transferred over from one node to another

[jira] [Created] (FLINK-6323) Add new Sink interface with access to more meta data

Aljoscha Krettek created FLINK-6323: --- Summary: Add new Sink interface with access to more meta data Key: FLINK-6323 URL: https://issues.apache.org/jira/browse/FLINK-6323 Project: Flink

[jira] [Created] (FLINK-6322) Mesos task labels

Eron Wright created FLINK-6322: --- Summary: Mesos task labels Key: FLINK-6322 URL: https://issues.apache.org/jira/browse/FLINK-6322 Project: Flink Issue Type: Improvement Components:

[jira] [Created] (FLINK-6321) RocksDB state backend Checkpointing is not working with KeydCEP.

Shashank Agarwal created FLINK-6321: --- Summary: RocksDB state backend Checkpointing is not working with KeydCEP. Key: FLINK-6321 URL: https://issues.apache.org/jira/browse/FLINK-6321 Project: Flink

[jira] [Created] (FLINK-6320) Flakey JobManagerHAJobGraphRecoveryITCase

Nico Kruber created FLINK-6320: -- Summary: Flakey JobManagerHAJobGraphRecoveryITCase Key: FLINK-6320 URL: https://issues.apache.org/jira/browse/FLINK-6320 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-6319) Add timeout when shutting SystemProcessingTimeService down

Till Rohrmann created FLINK-6319: Summary: Add timeout when shutting SystemProcessingTimeService down Key: FLINK-6319 URL: https://issues.apache.org/jira/browse/FLINK-6319 Project: Flink

[jira] [Created] (FLINK-6318) NFA serialisation doesn't work with TypeSerializers that load classes

Aljoscha Krettek created FLINK-6318: --- Summary: NFA serialisation doesn't work with TypeSerializers that load classes Key: FLINK-6318 URL: https://issues.apache.org/jira/browse/FLINK-6318 Project:

[jira] [Created] (FLINK-6317) History server - wrong default directory

Lorenz Bühmann created FLINK-6317: - Summary: History server - wrong default directory Key: FLINK-6317 URL: https://issues.apache.org/jira/browse/FLINK-6317 Project: Flink Issue Type: Bug