[jira] [Created] (FLINK-2506) HBase table that is distributed over more than 1 region server

Lydia Ickler created FLINK-2506: --- Summary: HBase table that is distributed over more than 1 region server Key: FLINK-2506 URL: https://issues.apache.org/jira/browse/FLINK-2506 Project: Flink I

[ANNOUNCE] Apache Mahout 0.11.0 Release

The Apache Mahout PMC is pleased to announce the release of Mahout 0.11.0. Mahout's goal is to create an environment for quickly creating machine learning applications that scale and run on the highest performance parallel computation engines available. Mahout comprises an interactive environmen

[jira] [Created] (FLINK-2505) HDFSTest failure: VM crash

Sachin Goel created FLINK-2505: -- Summary: HDFSTest failure: VM crash Key: FLINK-2505 URL: https://issues.apache.org/jira/browse/FLINK-2505 Project: Flink Issue Type: Bug Reporter: Sa

Re: Parameter Server for Flink

Hi Stephan I opened a PR for a version integrated with the flink runtime itself [which is a lot more evolved than the branch I mentioned on this thread :') ]. https://github.com/apache/flink/pull/1003 I was more inclined towards an integrated implementation and finished it over the weekend. The mai

Re: Failing test in Gelly

I think the YARN problem is as before, but with a longer timeout. Before, when after 60 seconds the expected output did not come, the tests aborted. The timeout is now 180 seconds, which is probably so long that the deadlock detector (5 minutes no output) kicks in. In any case, there is something

Re: Failing test in Gelly

May be an issue with the embedded YARN mini cluster... On Mon, Aug 10, 2015 at 8:37 PM, Stephan Ewen wrote: > I think the YARN problem is as before, but with a longer timeout. > > Before, when after 60 seconds the expected output did not come, the tests > aborted. > The timeout is now 180 second

Re: Some problems about Flink applications

It would also help if you could paste the entire POM file of your project. Maybe something is amiss with the dependencies, or the scopes? On Sat, Aug 8, 2015 at 7:27 PM, Matthias J. Sax < mj...@informatik.hu-berlin.de> wrote: > Hi Huang, > > about Storm compatibility. Did you double check, that t

Re: Parameter Server for Flink

Very interesting addition, Sachin! I cc-ed Nam-Luc Tran, who recently opened a pull request with a draft for SSP iterations in Flink, which usually work closely together with a parameter server. I think that a parameter server is an orthogonal piece to Flink, and should be decoupled from the runt

Re: New Flink Runtime Monitor Dashboard

I have a pending fix that uses a linguist git attribute to mark the directory with generated files as "vendored", which excludes it. On Tue, Jul 28, 2015 at 9:25 PM, Stephan Ewen wrote: > Good idea! > > On Mon, Jul 27, 2015 at 10:31 AM, Maximilian Michels > wrote: > >> We could open a pull requ

[jira] [Created] (FLINK-2504) ExternalSortLargeRecordsITCase.testSortWithLongAndShortRecordsMixed failed spuriously

Till Rohrmann created FLINK-2504: Summary: ExternalSortLargeRecordsITCase.testSortWithLongAndShortRecordsMixed failed spuriously Key: FLINK-2504 URL: https://issues.apache.org/jira/browse/FLINK-2504

[jira] [Created] (FLINK-2503) Inconsistencies in FileInputFormat hierarchy

Flavio Pompermaier created FLINK-2503: - Summary: Inconsistencies in FileInputFormat hierarchy Key: FLINK-2503 URL: https://issues.apache.org/jira/browse/FLINK-2503 Project: Flink Issue Ty

[Proposal] Addition to Gelly

Hey, Before actually opening a PR, I wanted to hear your opinion. So, here goes nothing :). I'd like to add the core of my master thesis to Gelly. That is, a series of operators that take a skewed graph, split its high degree vertices into subvertices and redistribute the edges accordingly (thus