Re: Unable to serialize exception running KafkaWindowedWordCountExample

@Max: Thanks for your quick fix, this serializable exception has been solved. However, it reported another one: 16/03/17 20:14:23 INFO flink.FlinkPipelineRunner: PipelineOptions.filesToStage was not specified. Defaulting to files from the classpath: will stage 158 files. Enable logging at DEBUG lev

Re: [PROPOSAL] MultiLineIO

Hi Peter, Echoing Eugene's and JB's thoughts -- we'd love a PR! I also wanted to say: we've hit you with a lot of recommendations in this email thread. If you have any questions, you can ask us here -- but we'll of course be happy to answer them during code review as well. Do not feel like meetin

Re: Capability Matrix

Looks great! I think it's the best way to give a clear picture of capabilities for users and runner developers. And as always, Love the colours ;) On Fri, Mar 18, 2016 at 3:33 PM Kostas Kloudas wrote: > Great to have an overview of the available > runners and a comprehensible visualization of >

Draft Contribution Guide

Hi Beamers! We've started a draft for the Beam contribution guide. Please take a look and provide feedback. Once things settle, we'll get this moved over on to the Beam website. Frances

Re: Draft Contribution Guide

Thanks Frances, This document is helpful for newbies like myself. Will follow these steps over this weekend. On Thu, Mar 17, 2016 at 2:19 PM, Frances Perry wrote: > Hi Beamers! > > We've started a draft > < > https://docs.google.com/document/d/1syFyfqIsGOYDE_Hn3ZkRd8a6ylcc64Kud9YtrGHgU0E/comme

Re: Jenkins build became unstable: beam_MavenVerify #14

We've applied the change (local to the workspace) to both Jenkins projects - hopefully this will fix. We'll keep an eye out for breakages related to this. On Thu, Mar 17, 2016 at 10:29 AM, Davor Bonaci wrote: > Adding Jason explicitly. This is somewhat expected. > > Thanks Andreas. > > On Thu, M

Re: Capability Matrix

Great to have an overview of the available runners and a comprehensible visualization of the features each one supports! Kostas > On Mar 18, 2016, at 11:32 AM, Maximilian Michels wrote: > > Well done. The matrix provides a good basis for improving the existing > runners. Moreover, new backend