Re: Ongoing Projects in stratosphere
Hi I am interested in the following project also Flink Streaming (ongoing effort). My friend also wants to do these kind of projects. Can you tell us more about those mentioned projects. -- Thanks & Regards *Sana Sudheer*, 4th year Undergraduate (Dual Degree), Department of Computer Science & Engineering, IIT Madras. On Wed, Jul 16, 2014 at 10:29 AM, Sudheer Sana wrote: > Hi > > The following projects are interesting to me. > > Integration with Apache Mahout (ongoing effort) > > > Integration with Apache Tez (ongoing effort) > > > > -- Thanks & Regards > *Sana Sudheer*, > 4th year Undergraduate (Dual Degree), > Department of Computer Science & Engineering, > IIT Madras. > > > On Mon, Jul 14, 2014 at 8:52 PM, Sudheer Sana > wrote: > >> I will get back to you after reading about them >> > >
Re: Ongoing Projects in stratosphere
Hi The following projects are interesting to me. Integration with Apache Mahout (ongoing effort) Integration with Apache Tez (ongoing effort) -- Thanks & Regards *Sana Sudheer*, 4th year Undergraduate (Dual Degree), Department of Computer Science & Engineering, IIT Madras. On Mon, Jul 14, 2014 at 8:52 PM, Sudheer Sana wrote: > I will get back to you after reading about them >
Re: A wiki for Flink
On 14 Jul 2014, at 21:17, Robert Metzger wrote: > If we go for a ASF hosted wiki, we can choose between a moin wiki ( > http://moinmo.in/) and Confluence. > > We could write a little script that sends mails to the list on edits (the > APIs of GitHub would allow for that) > > I vote for using Confluence. +1
[jira] [Created] (FLINK-1027) CLI "run" command does not support flags
Alexander Alexandrov created FLINK-1027: --- Summary: CLI "run" command does not support flags Key: FLINK-1027 URL: https://issues.apache.org/jira/browse/FLINK-1027 Project: Flink Issue Type: Bug Components: JobManager Affects Versions: 0.6-incubating Reporter: Alexander Alexandrov Assignee: Alexander Alexandrov Priority: Trivial Fix For: 0.6-incubating When submitting a job from the CLI frontend, having flags as arguments is not possible. I would like my jar to be able to parse optional arguments formatted as "-a" or "--argument", e.g. flink run /path/to/logreg.jar --iterations 10 --alpha 0.2 /path/to/in /path/to/out If nobody objects I will submit a patch for that. -- This message was sent by Atlassian JIRA (v6.2#6252)
Re: KMeansIterative in master branch ?
Hi, I think its now just called "examples/flink-java-examples-*-KMeans.jar" (without the "Iterative"). There are some more issues with the kmeans example in the documentation, due to the project renaming. The example refers to the binaries of the 0.5.1 release, but due to some regex renaming, we changed the names to org.apache.flink and "flink-examples", .. and so on. We don't have a release with the new name out yet. If you are going to use the 0.5.1 (Stratosphere) release, I would suggest to use the documentation on the old website: http://stratosphere.eu/quickstart/example.html. There, the names should fit the old release. (Except for the KMeans vs KMeansIterative). I'm sorry that we have this mess right now. Once we have our first release within Apache, things will be better again. Best, Robert On Tue, Jul 15, 2014 at 10:49 AM, Liu, Raymond wrote: > I could not found the examples/flink-java-examples-*-KMeansIterative.jar > in the trunk code. Is that removed? If so, then the run_example_quickstart > doc need to be updated too. > > Best Regards, > Raymond Liu > >
KMeansIterative in master branch ?
I could not found the examples/flink-java-examples-*-KMeansIterative.jar in the trunk code. Is that removed? If so, then the run_example_quickstart doc need to be updated too. Best Regards, Raymond Liu
Re: Some notes from the first Flink Hangout
We shared the link to the hangout in this conversation thread. We should create a youtube channel for Flink (last time I used my personal one) and record it there tomorrow. Kostas On Mon, Jul 14, 2014 at 6:38 PM, Henry Saputra wrote: > +1 > > How was it done last time to get the hangout invite? > > On Monday, July 14, 2014, Robert Metzger wrote: > > > If we stick to our decision to do a bi-weekly hangout, the next one would > > be this Wednesday. > > Are we going again for 9am PST / 6pm CET ? > > > > Robert > > > > > > On Wed, Jul 2, 2014 at 7:12 PM, Márton Balassi > > > > wrote: > > > > > Thanks for the write-up, I do agree with the streaming notes. > > > > > > Cheers, > > > > > > Marton > > > > > > > > > On Wed, Jul 2, 2014 at 7:10 PM, Kostas Tzoumas < > > > kostas.tzou...@tu-berlin.de > > > > wrote: > > > > > > > Hi everyone, > > > > > > > > I tried to record the first hangout on youtube but we had several > > > problems > > > > with sound and video. Below are some rough notes. > > > > > > > > If you participated in the meeting, please feel free to add notes > > > > > > > > Kostas > > > > > > > > Website: > > > > > > > > > > > > - Documentation contains lots of broken links > > > > > > > > - Frontpage - remove Metor, color-coding of the stack, and features > > > > (do not include features) > > > > > > > > > > > > Streaming: > > > > -- > > > > > > > > - Low-latency streaming functionality and API > > > > > > > > - Move to the main repository > > > > - Down the road be able to mix APIs > > > > - Dependencies on current runtime refactoring > > > > > > > > - Add committers > > > > > > > > > > > > Intermediate datasets: > > > > -- > > > > > > > > - Switch to more pull-based mode with intermediate datasets as > > > > first-class citizens > > > > > > > > - Currently working on how to support pipelined channels with that > > > > > > > > > > > > Tez: > > > > > > > > > > > > - Replace code paths of Flink with Tez > > > > > > > > - Open questions related to incremental rollout and streaming > > > > > > > > > > > > Hadoop Compatibility: > > > > - > > > > > > > > - Report on progress by Artem > > > > > > > > > > > > Renaming: > > > > - > > > > > > > > - Possibility to start renaming of packages without legal approval > > > > > > > > - Will rename some parts of Java API > > > > > > > > > >
