Re: [DISCUSS][FLIP-4] Enhance Window Evictor in Flink

2016-10-31 Thread Vishnu Viswanath
Hi, I have created a pull request for this: https://github.com/apache/flink/pull/2736 Regards, Vishnu On Tue, Oct 18, 2016 at 3:34 AM, Aljoscha Krettek wrote: > Hi, > yes, I think it's fine if we keep it in the same package as the Evictor. > StreamRecord is more of an internal class that shoul

[jira] [Created] (FLINK-4988) Elasticsearch 5.x support

2016-10-31 Thread Mike Dias (JIRA)
Mike Dias created FLINK-4988: Summary: Elasticsearch 5.x support Key: FLINK-4988 URL: https://issues.apache.org/jira/browse/FLINK-4988 Project: Flink Issue Type: New Feature Reporter:

[jira] [Created] (FLINK-4987) Harden slot pool logic

2016-10-31 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-4987: Summary: Harden slot pool logic Key: FLINK-4987 URL: https://issues.apache.org/jira/browse/FLINK-4987 Project: Flink Issue Type: Sub-task Reporte

[jira] [Created] (FLINK-4986) Harden JobMaster logic

2016-10-31 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-4986: Summary: Harden JobMaster logic Key: FLINK-4986 URL: https://issues.apache.org/jira/browse/FLINK-4986 Project: Flink Issue Type: Sub-task Component

[jira] [Created] (FLINK-4985) Report Declined/Canceled Checkpoints to Checkpoint Coordinator

2016-10-31 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-4985: --- Summary: Report Declined/Canceled Checkpoints to Checkpoint Coordinator Key: FLINK-4985 URL: https://issues.apache.org/jira/browse/FLINK-4985 Project: Flink I

[jira] [Created] (FLINK-4984) Add Cancellation Barriers to BarrierTracker and BarrierBuffer

2016-10-31 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-4984: --- Summary: Add Cancellation Barriers to BarrierTracker and BarrierBuffer Key: FLINK-4984 URL: https://issues.apache.org/jira/browse/FLINK-4984 Project: Flink Is

[jira] [Created] (FLINK-4982) quickstart example: Can't see the output

2016-10-31 Thread JIRA
Mischa Krüger created FLINK-4982: Summary: quickstart example: Can't see the output Key: FLINK-4982 URL: https://issues.apache.org/jira/browse/FLINK-4982 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-4983) Web UI: Add favicon

2016-10-31 Thread JIRA
Mischa Krüger created FLINK-4983: Summary: Web UI: Add favicon Key: FLINK-4983 URL: https://issues.apache.org/jira/browse/FLINK-4983 Project: Flink Issue Type: Improvement Component

[jira] [Created] (FLINK-4981) Job Plan view: Not very readable and informative

2016-10-31 Thread JIRA
Mischa Krüger created FLINK-4981: Summary: Job Plan view: Not very readable and informative Key: FLINK-4981 URL: https://issues.apache.org/jira/browse/FLINK-4981 Project: Flink Issue Type: Im

[jira] [Created] (FLINK-4980) Include example source code in Flink binary distribution

2016-10-31 Thread Jamie Grier (JIRA)
Jamie Grier created FLINK-4980: -- Summary: Include example source code in Flink binary distribution Key: FLINK-4980 URL: https://issues.apache.org/jira/browse/FLINK-4980 Project: Flink Issue Type

[jira] [Created] (FLINK-4979) Submit Job view: Replace checkboxes for job entry with a link on the job name

2016-10-31 Thread JIRA
Mischa Krüger created FLINK-4979: Summary: Submit Job view: Replace checkboxes for job entry with a link on the job name Key: FLINK-4979 URL: https://issues.apache.org/jira/browse/FLINK-4979 Project:

[jira] [Created] (FLINK-4978) Present dropdown list with possible entry points for job

2016-10-31 Thread JIRA
Mischa Krüger created FLINK-4978: Summary: Present dropdown list with possible entry points for job Key: FLINK-4978 URL: https://issues.apache.org/jira/browse/FLINK-4978 Project: Flink Issue

[jira] [Created] (FLINK-4977) Enum serialization does not work properly

2016-10-31 Thread Sean Winard (JIRA)
Sean Winard created FLINK-4977: -- Summary: Enum serialization does not work properly Key: FLINK-4977 URL: https://issues.apache.org/jira/browse/FLINK-4977 Project: Flink Issue Type: Bug Affec

[jira] [Created] (FLINK-4976) Add a way to abort in flight checkpoints

2016-10-31 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-4976: --- Summary: Add a way to abort in flight checkpoints Key: FLINK-4976 URL: https://issues.apache.org/jira/browse/FLINK-4976 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-4974) RescalingITCase.testSavepointRescalingInPartitionedOperatorState unstable

2016-10-31 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-4974: - Summary: RescalingITCase.testSavepointRescalingInPartitionedOperatorState unstable Key: FLINK-4974 URL: https://issues.apache.org/jira/browse/FLINK-4974 Project: Fl

[jira] [Created] (FLINK-4975) Add a limit for how much data may be buffered during checkpoint alignment

2016-10-31 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-4975: --- Summary: Add a limit for how much data may be buffered during checkpoint alignment Key: FLINK-4975 URL: https://issues.apache.org/jira/browse/FLINK-4975 Project: Flink

[jira] [Created] (FLINK-4973) Flakey Yarn tests due to recently added latency marker

2016-10-31 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-4973: Summary: Flakey Yarn tests due to recently added latency marker Key: FLINK-4973 URL: https://issues.apache.org/jira/browse/FLINK-4973 Project: Flink Issue Ty

[jira] [Created] (FLINK-4972) CoordinatorShutdownTestrelies on race for success

2016-10-31 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-4972: --- Summary: CoordinatorShutdownTestrelies on race for success Key: FLINK-4972 URL: https://issues.apache.org/jira/browse/FLINK-4972 Project: Flink Issue T

Re: Why checkpointing is synchronized with data processing?

2016-10-31 Thread Stephan Ewen
Hi! Checkpoints do not really hold data processing. The only synchronous call is to create a "state snapshot". Some state backends implement that synchronously (like the FsStateBackend) some asynchronously (RocksDBStateBackend). It depends on the state backend how much is synchronous (blocking) v

[jira] [Created] (FLINK-4971) Unify Stream Sinks and OutputFormats

2016-10-31 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-4971: --- Summary: Unify Stream Sinks and OutputFormats Key: FLINK-4971 URL: https://issues.apache.org/jira/browse/FLINK-4971 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-4970) Parameterize vertex value for SSSP

2016-10-31 Thread Greg Hogan (JIRA)
Greg Hogan created FLINK-4970: - Summary: Parameterize vertex value for SSSP Key: FLINK-4970 URL: https://issues.apache.org/jira/browse/FLINK-4970 Project: Flink Issue Type: Improvement

Re: [DISCUSS] FLIP-13: Consistent Processing with Loops

2016-10-31 Thread Paris Carbone
Hey Stephan, Thanks for looking into it! +1 for breaking this up, will do that. I can see your point and maybe it makes sense to introduce part of scoping to incorporate support for nested loops (otherwise it can’t work). Let us think about this a bit. We will share another draft for a more det

[jira] [Created] (FLINK-4969) TypeInfoParser needs to be extended to parse the java.sql.* types into the corresponding TypeInfos.

2016-10-31 Thread radu (JIRA)
radu created FLINK-4969: --- Summary: TypeInfoParser needs to be extended to parse the java.sql.* types into the corresponding TypeInfos. Key: FLINK-4969 URL: https://issues.apache.org/jira/browse/FLINK-4969 Proje