Distributed Data Frame (DFF) Support

Hi, Is it possible to support DFF (http://ddf.io/) in Flink? Suminda -- View this message in context: http://apache-flink-incubator-mailing-list-archive.1008284.n3.nabble.com/Distributed-Data-Frame-DFF-Support-tp2892.html Sent from the Apache Flink (Incubator) Mailing List archive. mailing li

Need some help to implement the outer join operator

Hi, I am trying to pick up the outer join operator. However, as Fabian mentioned to me, that this task would require to touch many different components of the system, it would be a challenge job for me. Therefore I would need some help:-) I might need to walk through some features like Compiler

Re: Flink Streaming Hangout

The hangout was not recorded, so I'm providing a short write-up on the issues and decisions. The discussion was 2 hours long, so please feel free to add the important statements I have missed. The initial ideas are listed on the project wiki as Flink Streaming roadmap. [1] The hangout yielded the

Re: Flink Streaming Hangout

Related to Zeppelin [1], looks like it is sponsored/ developed by a company in Korea [2] that has nothing to do with football unfortunately (I thought they were the same team that does http://www.nfl.com/stats/statslab), I was kinda disappointed at the beginning =P But anyway seemed like integrati

[jira] [Created] (FLINK-1323) Implement memory management profiles

Márton Balassi created FLINK-1323: - Summary: Implement memory management profiles Key: FLINK-1323 URL: https://issues.apache.org/jira/browse/FLINK-1323 Project: Flink Issue Type: Improvement

Re: Flink Streaming Hangout

Thanks for arranging the hangout Gyula, sorry I have to miss the it. I will help review the proposed doc in the wiki and add comments/questions as they come up. - Henry On Fri, Dec 12, 2014 at 3:22 AM, Gyula Fóra wrote: > Hey All, > > I have created a google hangout for today's Streaming discus

[jira] [Created] (FLINK-1322) Scala API does not respect WriteMode set by configuration

Till Rohrmann created FLINK-1322: Summary: Scala API does not respect WriteMode set by configuration Key: FLINK-1322 URL: https://issues.apache.org/jira/browse/FLINK-1322 Project: Flink Issue

Fwd: Enhance Flink's monitoring capabilities

I have created an issue for the related dataflow statistics tracking feature here: https://issues.apache.org/jira/browse/FLINK-1297 FLINK-456 seems to have some overlap with what I described. I suggest to either have three separate issues or at least work on resolving FLINK-1297 and FLINK-456 in

Re: Forking off the 0.8 release branch.

On Wed, Dec 10, 2014 at 7:35 PM, Stephan Ewen wrote: > > -- > Important Pull Requests to merge: > -- > > [FLINK-1287] LocalizableSplitAssigner prefers splits with less degrees of > freedom > > [FLINK-1305] [FLI

Flink Streaming Hangout

Hey All, I have created a google hangout for today's Streaming discussion: https://plus.google.com/hangouts/_/gws3f77u5fee5euehtw7zwob2qa As we have agreed we will start today at 17:30 CET / 08:30 PST and I think we'll be around for those who can only join later as well. Please find the topics h