[jira] [Created] (FLINK-4643) Average Clustering Coefficient

Greg Hogan created FLINK-4643: - Summary: Average Clustering Coefficient Key: FLINK-4643 URL: https://issues.apache.org/jira/browse/FLINK-4643 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-4644) Deprecate "flink.base.dir.path" from ConfigConstants

Maximilian Michels created FLINK-4644: - Summary: Deprecate "flink.base.dir.path" from ConfigConstants Key: FLINK-4644 URL: https://issues.apache.org/jira/browse/FLINK-4644 Project: Flink

[jira] [Created] (FLINK-4639) Make Calcite features more pluggable

Timo Walther created FLINK-4639: --- Summary: Make Calcite features more pluggable Key: FLINK-4639 URL: https://issues.apache.org/jira/browse/FLINK-4639 Project: Flink Issue Type: New Feature

Re: Gelly Library. Need an example

+1 for the either type solution :-) On Sat, Sep 17, 2016 at 10:49 AM, Martin Junghanns wrote: > Hi all, > > thanks for reporting the issue! I just looked into it. The > VertexGroupReduce outputs two semantically different tuples: one for each > vertex without the value

[jira] [Created] (FLINK-4638) Fix exception message for MemorySegment

Liwei Lin created FLINK-4638: Summary: Fix exception message for MemorySegment Key: FLINK-4638 URL: https://issues.apache.org/jira/browse/FLINK-4638 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-4640) Serialization of the initialValue of a Fold on WindowedStream fails

Fabian Hueske created FLINK-4640: Summary: Serialization of the initialValue of a Fold on WindowedStream fails Key: FLINK-4640 URL: https://issues.apache.org/jira/browse/FLINK-4640 Project: Flink

Re: Exception from in-progress implementation of Python API bulk iterations

Hello, I'll try to take a look this week. Regards, Chesnay On 20.09.2016 02:38, Geoffrey Mon wrote: Hello all, I have recently been working on adding bulk iterations to the Python API of Flink in order to facilitate a research project I am working on. The current changes can be seen in this

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

Hi, now you again see what I mentioned a while back: eviction based on processing time is not really well defined. I think we can completely get rid of "processing time eviction" because it can be replaced by something like this: DataStream input = ... DataStream withTimestamps =

Re: Assign issue

Hi Anton, I gave your JIRA account Contributor permissions. You can now assign Flink issues to yourself. You can start a discussion either on the dev mailing list (usually done for major changes and new features) or in the JIRA issue (preferred for minor improvements). Best, Fabian 2016-09-20

Assign issue

Hello everybody! I am novice in community, but I want to participate in community process. How I can assign https://issues.apache.org/jira/browse/FLINK-4564 to me and I would discuss it implementation?

[jira] [Created] (FLINK-4642) Remove unnecessary Guava dependency from flink-streaming-java

Stephan Ewen created FLINK-4642: --- Summary: Remove unnecessary Guava dependency from flink-streaming-java Key: FLINK-4642 URL: https://issues.apache.org/jira/browse/FLINK-4642 Project: Flink

[jira] [Created] (FLINK-4645) Hard to register Kryo Serializers due to generics

Stephan Ewen created FLINK-4645: --- Summary: Hard to register Kryo Serializers due to generics Key: FLINK-4645 URL: https://issues.apache.org/jira/browse/FLINK-4645 Project: Flink Issue Type:

Get Flink ExecutionGraph Programmatically

Hi All I am trying to get JOB accumulators. ( I am aware that I can get the accumulators through REST APIs as well, but i wanted to avoid JSON parsing). Looking at JobAccumulatorsHandler i am trying to get execution graph for currently running job. Following is my code: InetSocketAddress

[jira] [Created] (FLINK-4641) Support branching CEP patterns

Till Rohrmann created FLINK-4641: Summary: Support branching CEP patterns Key: FLINK-4641 URL: https://issues.apache.org/jira/browse/FLINK-4641 Project: Flink Issue Type: Improvement