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
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
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
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
Rep
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 i
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: Bug
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
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
Comp
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
Is
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
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 14
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?
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 = input.assignTimes
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
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 G
+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 (null) and one tuple repre
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
17 matches
Mail list logo
