I fear that I have to give another -1.
The reason is that in the current RC Flink fails when spilling partitions
of the MutableHashTable when performing a join operation with many records
which are also large in size. Thus, effectively the join operation is
broken.
The underlying problem is that
Till Rohrmann created FLINK-2964:
Summary: MutableHashTable fails when spilling partitions without
overflow segments
Key: FLINK-2964
URL: https://issues.apache.org/jira/browse/FLINK-2964
Project: Flin
Ted Yu created FLINK-2963:
-
Summary: Dependence on SerializationUtils#deserialize() should be
avoided
Key: FLINK-2963
URL: https://issues.apache.org/jira/browse/FLINK-2963
Project: Flink
Issue Type:
Hi Johannes,
that's the way to do it, IMO.
Cheers, Fabian
2015-11-03 22:39 GMT+01:00 Kirschnick, Johannes <
johannes.kirschn...@tu-berlin.de>:
> Hi List,
>
> I am stuck on a simple problem and though somebody might point me into the
> right direction.
>
> Basically I’m trying to
>
>
> -
Hi List,
I am stuck on a simple problem and though somebody might point me into the
right direction.
Basically I’m trying to
- Get a measure of my dataset, say the average of some field
- Filter all items which fall below the threshold
I’m currently using just a straight fo
The problem with having many different graph model in gelly is that it
might get quite confusing for a user.
Maybe this can be fixed with good documentation so that its clear how each
model works and what its benefits are (and maybe when its better to use it
over a different model).
On Tue, Nov 3,
Hi Andre,
Thanks for reaching out to the Flink community!
I am not sure your analysis is based on correct assumptions about Flink's
delta iterations.
Flink's delta iterations do support
- working and solution sets of different types
- worksets that grow and shrink or are completely replaced in ea
I also think a Giraph-like model could be added, but we shouldn't remove
Spargel in favour of it!
On Tue, Nov 3, 2015 at 2:35 AM, Stephan Ewen wrote:
> When creating the original version of Spargel I was pretty much thinking in
> GSA terms, more than in Pregel terms. There are some fundamental
>
Ufuk Celebi created FLINK-2962:
--
Summary: Cluster startup script refers to unused variable
Key: FLINK-2962
URL: https://issues.apache.org/jira/browse/FLINK-2962
Project: Flink
Issue Type: Improv
Hi,
according to the feedback I got so far, I have three open PRs for the
webpage and docu now. I summarize this, because I want to merge all of
them at once (to avoid rebuilding the webpage multiple times).
Additionally, I want to apply one more change (see below).
1) adding third-party (externa
Sorry for redundant post ...
Hi all,
We are working on an implementation of Frequent Subgraph Mining using
Flink. At that, the "too few memory segments error" prevents the most
promising solution. The problem is not specific for graphs, but all
iterative problems where
- working and solution se
Hi all,
We are working on an implementation of Frequent Subgraph Mining using
Flink. At that, the "too few memory segments error" prevents the most
promising solution. The problem is not specific for graphs, but all
iterative problems where
- working and solution sets contain data of different t
Timo Walther created FLINK-2961:
---
Summary: Add support for basic type Date in Table API
Key: FLINK-2961
URL: https://issues.apache.org/jira/browse/FLINK-2961
Project: Flink
Issue Type: Improvem
Thanks for the detailed explanation Stephan!
Seeing Spargel as a Gather-Scatter model makes much more sense :)
I think we should be more careful not to present it as a "Pregel
equivalent" to avoid confusion of users coming from systems like Giraph.
Maybe I could put together a comparison table Pre
Maximilian Michels created FLINK-2960:
-
Summary: Communicate with JobManager through YARN proxy
Key: FLINK-2960
URL: https://issues.apache.org/jira/browse/FLINK-2960
Project: Flink
Issue
I tried out Spargel during my work with Spotify and have implemented
several algorithms using it. In all implementations I ended up storing
additional Data and Flags on the Vertex to carry them over from one UDF to
the next one. It definitely makes the code harder to write and maintain.
I wonder h
Here is the testing document:
https://docs.google.com/document/d/1BYtis1Xg2Z9UpeV5UuH2kB6DnisnneOB19L1YBIw4Zs/edit
On Tue, Nov 3, 2015 at 12:24 PM, Maximilian Michels wrote:
> Please vote on releasing the following candidate as Apache Flink version
> 0.10.0:
>
> The commit to be voted on:
> 347c
Please vote on releasing the following candidate as Apache Flink version
0.10.0:
The commit to be voted on:
347c2b00d4c32da118460a8da0a417f752f9177e
Branch:
release-0.10.0-rc5 (see
https://git1-us-west.apache.org/repos/asf/flink/?p=flink.git)
The release artifacts to be voted on can be found at:
Ufuk Celebi created FLINK-2959:
--
Summary: Remove number of execution retries configuration from
Environment
Key: FLINK-2959
URL: https://issues.apache.org/jira/browse/FLINK-2959
Project: Flink
Ufuk Celebi created FLINK-2958:
--
Summary: StreamingJobGraphGenerator sets hard coded number
execution retry
Key: FLINK-2958
URL: https://issues.apache.org/jira/browse/FLINK-2958
Project: Flink
Maximilian Michels created FLINK-2957:
-
Summary: Make cancel button look less like a label
Key: FLINK-2957
URL: https://issues.apache.org/jira/browse/FLINK-2957
Project: Flink
Issue Type:
21 matches
Mail list logo