[jira] [Created] (FLINK-4902) Flink Task Chain not getting input in a distributed manner

2016-10-24 Thread Sajeev Ramakrishnan (JIRA)
Sajeev Ramakrishnan created FLINK-4902: -- Summary: Flink Task Chain not getting input in a distributed manner Key: FLINK-4902 URL: https://issues.apache.org/jira/browse/FLINK-4902 Project: Flink

[jira] [Created] (FLINK-4901) Build DCOS Docker image

2016-10-24 Thread Eron Wright (JIRA)
Eron Wright created FLINK-4901: --- Summary: Build DCOS Docker image Key: FLINK-4901 URL: https://issues.apache.org/jira/browse/FLINK-4901 Project: Flink Issue Type: Sub-task Reporter

[jira] [Created] (FLINK-4900) Implement Docker image support

2016-10-24 Thread Eron Wright (JIRA)
Eron Wright created FLINK-4900: --- Summary: Implement Docker image support Key: FLINK-4900 URL: https://issues.apache.org/jira/browse/FLINK-4900 Project: Flink Issue Type: Sub-task R

[jira] [Created] (FLINK-4899) Implement DCOS package

2016-10-24 Thread Eron Wright (JIRA)
Eron Wright created FLINK-4899: --- Summary: Implement DCOS package Key: FLINK-4899 URL: https://issues.apache.org/jira/browse/FLINK-4899 Project: Flink Issue Type: Sub-task Reporter:

[jira] [Created] (FLINK-4898) Refactor HTTP handlers and Netty server/client

2016-10-24 Thread Eron Wright (JIRA)
Eron Wright created FLINK-4898: --- Summary: Refactor HTTP handlers and Netty server/client Key: FLINK-4898 URL: https://issues.apache.org/jira/browse/FLINK-4898 Project: Flink Issue Type: Sub-ta

[jira] [Created] (FLINK-4897) Implement Dispatcher

2016-10-24 Thread Eron Wright (JIRA)
Eron Wright created FLINK-4897: --- Summary: Implement Dispatcher Key: FLINK-4897 URL: https://issues.apache.org/jira/browse/FLINK-4897 Project: Flink Issue Type: New Feature Components

[jira] [Created] (FLINK-4896) PageRank algorithm for directed graphs

2016-10-24 Thread Greg Hogan (JIRA)
Greg Hogan created FLINK-4896: - Summary: PageRank algorithm for directed graphs Key: FLINK-4896 URL: https://issues.apache.org/jira/browse/FLINK-4896 Project: Flink Issue Type: New Feature

[DISCUSS] Releasing Flink 1.1.4

2016-10-24 Thread Ufuk Celebi
Hey all, I would like to start the discussion for kicking off the next bug fix release, Flink 1.1.4. What do you think about aiming for a RC by end of this week? Users reported some instabilities/inconveniences that would be good to fix. Personally, I would like to backport the following fixes:

Re: [DISCUSS] Drop Hadoop 1 support with Flink 1.2

2016-10-24 Thread Robert Metzger
Thanks alot for the feedback on the issue. It seems that everybody agrees to drop Hadoop 1 support in Flink. I don't think we need to vote on the issue. I've filed a JIRA for the task: https://issues.apache.org/jira/browse/FLINK-4895 Maybe I'll find time to work on it next week. On Fri, Oct 14,

[jira] [Created] (FLINK-4895) Drop support for Hadoop 1

2016-10-24 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-4895: - Summary: Drop support for Hadoop 1 Key: FLINK-4895 URL: https://issues.apache.org/jira/browse/FLINK-4895 Project: Flink Issue Type: Task Componen

Re: [FLINK-3035] Redis as State Backend

2016-10-24 Thread Aljoscha Krettek
Hi, regarding RocksDB, yes this is possible because RocksDB is essentially only used as an out-of-core hash table. When checkpointing we write everything from RocksDB to HDFS. When restoring we repopulate an empty local RocksDB instance from the data in HDFS. Cheers, Aljoscha On Fri, 21 Oct 2016

Re: [FLINK-4832] Count/Sum 0 elements

2016-10-24 Thread Aljoscha Krettek
Hi Anton, executeOnCollection() is only meant for executing Flink Jobs in the local machine without bringing up a local (or actual) Flink cluster. So solving the problem there does not really solve the problem. The underlying problem is this: in a Map-Reduce world the way to count elements of type

[jira] [Created] (FLINK-4894) Don't block on buffer request after broadcastEvent

2016-10-24 Thread Ufuk Celebi (JIRA)
Ufuk Celebi created FLINK-4894: -- Summary: Don't block on buffer request after broadcastEvent Key: FLINK-4894 URL: https://issues.apache.org/jira/browse/FLINK-4894 Project: Flink Issue Type: Imp

[jira] [Created] (FLINK-4893) Use single RecordSerializer per RecordWriter

2016-10-24 Thread Ufuk Celebi (JIRA)
Ufuk Celebi created FLINK-4893: -- Summary: Use single RecordSerializer per RecordWriter Key: FLINK-4893 URL: https://issues.apache.org/jira/browse/FLINK-4893 Project: Flink Issue Type: Improvemen

[jira] [Created] (FLINK-4892) Snapshot TimerService using Key-Grouped State

2016-10-24 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-4892: --- Summary: Snapshot TimerService using Key-Grouped State Key: FLINK-4892 URL: https://issues.apache.org/jira/browse/FLINK-4892 Project: Flink Issue Type:

[jira] [Created] (FLINK-4891) Remove flink-contrib/flink-operator-stats

2016-10-24 Thread Ufuk Celebi (JIRA)
Ufuk Celebi created FLINK-4891: -- Summary: Remove flink-contrib/flink-operator-stats Key: FLINK-4891 URL: https://issues.apache.org/jira/browse/FLINK-4891 Project: Flink Issue Type: Task

Re: Removing flink-contrib/flink-operator-stats

2016-10-24 Thread Ufuk Celebi
I'll go ahead and remove it today. On Thu, Oct 20, 2016 at 8:21 PM, Stephan Ewen wrote: > +1 for removing it > > - It seems quite unstable (is responsible for almost all build failures > right now) > - It is not integrated with the metric system. Having more metrics is > desirable, but is a s

[jira] [Created] (FLINK-4890) FileInputFormatTest#testExcludeFiles fails on Windows OS

2016-10-24 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-4890: --- Summary: FileInputFormatTest#testExcludeFiles fails on Windows OS Key: FLINK-4890 URL: https://issues.apache.org/jira/browse/FLINK-4890 Project: Flink