Implementing multi-field "sum" function [FLINK-4029]

Hi, I would like to implement a multi-field "sum" function[1], but I am not sure what would be the best way to approach it. Should I add a new method to the DataStream class or would it be better to add it to a specialized stream? Should it be based on existing operators/streams, or should I imple

Re: Assigning an issue to self on JIRA

Hi, I am new to Flink myself, but I don't think there is any issues with assigning issues to yourself. Best regards, Ivan. On Sun, 14 Aug 2016 at 21:48 Sunny T wrote: > Hi, > > I would like to contribute to Apache Flink. And I have chosen this minor > bug to work on: FLINK-4309 >

Re: Assigning an issue to self on JIRA

> for me to be able to edit the JIRA item? > > Thanks, > Sunny > > On Sun, Aug 14, 2016 at 2:37 PM, Ivan Mushketyk > wrote: > > > Hi, > > > > I am new to Flink myself, but I don't think there is any issues with > > assigning issues to yourse

Re: Jenkins and Travis CI failing

Hi, Some Flink tests are flaky and fail on some platforms, so failures may have nothing to do with your changes. Since your build passes on most platforms, I would assume that the code is fine, but it is up to someone more experienced in Flink to decide. Flink community is working towards improvin

[DISCUSS] Python API for Fllink libraries

Hi Flink developers, It seems to me that Flink has two important "selling points": 1. It has Java, Scala and Python APIs 2. I has a number of useful libraries (ML, Gelly, CEP, and Table) But as far as I understand, currently users cannot use any of these libraries using a Python API. It seems to

Re: [DISCUSS] Python API for Fllink libraries

s. > Especially so since ML, CEP and Table are afaik still in heavy development. > > If anything, before thinking about porting the libraries to python it > would make more sense to implement a python streaming API. > Or maybe /finish/ porting the DataSet API... > > Regards

[DISCUSS] [FLINK-3950] Meter interface

Hi, I was working on the creating new Meter metric type, but I need some input to define a proper interface for it. Initial idea developed in this pull request [1] was to follow Dropwizard's meter interface, but zentol suggested that we may need a different interface for Flink use-cases. The issue

[DISCUSS][FLINK-3414] Scala API for CEP's pattern definition

Hi, Currently CEP supports API for pattern definition, but it is very similar to the Java one. Using Scala we could achieve much more concise API. In JIRA comment for this task I've described a proposal for how this API could look like: [1] Could you please review it and write your comments? Be

[DISCUSS] Automated code quality check in Flink

Hi! Flink uses Travis and Jenkis to check if new PR passes unit tests, but there are other tools that can automatically check code quality like: https://www.codacy.com/ https://codeclimate.com/ These tools promise to track test coverage, check code style, detect code duplication and so on. Since

Re: build error

Hi Ameet, This seems like a possible JVM bug. Could you try to build Flink using OracleJDK instead? Best regards, Ivan. On Thu, 15 Sep 2016 at 12:30 Ameet BD wrote: > Hi All, > > I am trying to build latest Flink code from github.com by running command > > $ git clone https://github.com/apache

Re: build error

license". > The file rat.txt is attached. > > Please tell me what could be going wrong. I am using Ubuntu 14.04, Maven > 3.0.5 and Oracle JDK 8. > Regards, > Ameet > > On Thu, Sep 15, 2016 at 5:45 PM, Ivan Mushketyk > wrote: > >> Hi Ameet, >> >>

Flink CEP development is stalling

Hi Flink devs, Roughly half a year ago I implemented several PRs for Flink-CEP[1][2][3] but since then there were no progress with the reviews. What is frustrating about this situation is that Flink customers are asking for features in these PRs. For example customers commented on [1] and [2] aski

Re: Flink CEP development is stalling

this applies only to committers) to commit the PRs. I can try to reach out to other committers to make them aware of the CEP library. Cheers, Till On Thu, Jan 12, 2017 at 9:15 AM, wrote: > +1 > > I have some clientes interested in CEP features > > El 11/1/17 16:23, "Ivan Mus

Re: Flink CEP development is stalling

dig into it. I used to work in IoT so event processing is a close topic for me. Dmitry. On Fri, 13 Jan 2017 at 14:58, Ivan Mushketyk wrote: > Hi Till, > > Thank you for your reply. > > I wonder if the following will work. > What if you can find a Flink committer/committers that

Re: Flink CEP development is stalling

roject. > Main contributors overloaded and simple fixes frequently are staying as PR > without merge. > > You can see how amount of open PR increasing over time. > > Thanks, > Alexey Diomin > > > 2017-01-15 17:18 GMT+04:00 Ivan Mushketyk : > > > Hi Dmitry, > >

Re: Flink CEP development is stalling

That should involve how to deal with projects like the > CEP library, and also with the sheer size of the project and code base in > general. > > Greetings, > Stephan > > > On Sun, Jan 15, 2017 at 11:28 PM, Ivan Mushketyk > > wrote: > > > Hi Alexey, > > &

[jira] [Created] (FLINK-4440) Make API for edge/vertex creation less verbose

Ivan Mushketyk created FLINK-4440: - Summary: Make API for edge/vertex creation less verbose Key: FLINK-4440 URL: https://issues.apache.org/jira/browse/FLINK-4440 Project: Flink Issue Type

[jira] [Created] (FLINK-4521) Fix "Submit new Job" panel in development mode

Ivan Mushketyk created FLINK-4521: - Summary: Fix "Submit new Job" panel in development mode Key: FLINK-4521 URL: https://issues.apache.org/jira/browse/FLINK-4521 Project: Flink

[jira] [Created] (FLINK-8314) Add support for Kinesis Firehose

Ivan Mushketyk created FLINK-8314: - Summary: Add support for Kinesis Firehose Key: FLINK-8314 URL: https://issues.apache.org/jira/browse/FLINK-8314 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-8315) Use AWSCredentialsProvider to get AWS credentials

Ivan Mushketyk created FLINK-8315: - Summary: Use AWSCredentialsProvider to get AWS credentials Key: FLINK-8315 URL: https://issues.apache.org/jira/browse/FLINK-8315 Project: Flink Issue Type

[jira] [Created] (FLINK-4646) Add BipartiteGraph class

Ivan Mushketyk created FLINK-4646: - Summary: Add BipartiteGraph class Key: FLINK-4646 URL: https://issues.apache.org/jira/browse/FLINK-4646 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-4647) Implement BipartiteGraph reader

Ivan Mushketyk created FLINK-4647: - Summary: Implement BipartiteGraph reader Key: FLINK-4647 URL: https://issues.apache.org/jira/browse/FLINK-4647 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-4648) Implement bipartite graph generators

Ivan Mushketyk created FLINK-4648: - Summary: Implement bipartite graph generators Key: FLINK-4648 URL: https://issues.apache.org/jira/browse/FLINK-4648 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-4649) Implement bipartite graph metrics

Ivan Mushketyk created FLINK-4649: - Summary: Implement bipartite graph metrics Key: FLINK-4649 URL: https://issues.apache.org/jira/browse/FLINK-4649 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-5104) Implement BipartiteGraph validator

Ivan Mushketyk created FLINK-5104: - Summary: Implement BipartiteGraph validator Key: FLINK-5104 URL: https://issues.apache.org/jira/browse/FLINK-5104 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-5242) Implement Scala API for BipartiteGraph

Ivan Mushketyk created FLINK-5242: - Summary: Implement Scala API for BipartiteGraph Key: FLINK-5242 URL: https://issues.apache.org/jira/browse/FLINK-5242 Project: Flink Issue Type: New

[jira] [Created] (FLINK-5243) Implement an example for BipartiteGraph

Ivan Mushketyk created FLINK-5243: - Summary: Implement an example for BipartiteGraph Key: FLINK-5243 URL: https://issues.apache.org/jira/browse/FLINK-5243 Project: Flink Issue Type: New

[jira] [Created] (FLINK-5244) Implement methods for BipartiteGraph transformations

Ivan Mushketyk created FLINK-5244: - Summary: Implement methods for BipartiteGraph transformations Key: FLINK-5244 URL: https://issues.apache.org/jira/browse/FLINK-5244 Project: Flink Issue

[jira] [Created] (FLINK-5245) Add support for BipartiteGraph mutations

Ivan Mushketyk created FLINK-5245: - Summary: Add support for BipartiteGraph mutations Key: FLINK-5245 URL: https://issues.apache.org/jira/browse/FLINK-5245 Project: Flink Issue Type

[jira] [Created] (FLINK-5311) Write user documentation for BipartiteGraph

Ivan Mushketyk created FLINK-5311: - Summary: Write user documentation for BipartiteGraph Key: FLINK-5311 URL: https://issues.apache.org/jira/browse/FLINK-5311 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-5349) Fix code sample for Twitter connector

Ivan Mushketyk created FLINK-5349: - Summary: Fix code sample for Twitter connector Key: FLINK-5349 URL: https://issues.apache.org/jira/browse/FLINK-5349 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-5360) Fix arguments names in WindowedStream

Ivan Mushketyk created FLINK-5360: - Summary: Fix arguments names in WindowedStream Key: FLINK-5360 URL: https://issues.apache.org/jira/browse/FLINK-5360 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-5362) Implement methods to access BipartiteGraph properties

Ivan Mushketyk created FLINK-5362: - Summary: Implement methods to access BipartiteGraph properties Key: FLINK-5362 URL: https://issues.apache.org/jira/browse/FLINK-5362 Project: Flink Issue