Major Streaming refactoring

2015-04-13 Thread Gyula Fóra
Dear All, Today I did a major refactoring of some streaming components, with a lot of class renamings and some package restructuring. https://github.com/apache/flink/pull/594 1. I refactored the internal representation of the Streaming topologies (StreamGraph) to a more straightforward and less

Re: Quickstart build - Fat Jar is empty

2015-04-13 Thread Robert Metzger
I tagged it to affect 0.8.x. I'll backport the fix to 0.8, then we can mark it as fixed for that release as well. On Mon, Apr 13, 2015 at 7:17 PM, Henry Saputra henry.sapu...@gmail.com wrote: Ah thanks. I assume this need to be tagged for 0.8.2 release? On Monday, April 13, 2015, Robert

[jira] [Created] (FLINK-1884) Outdated Spargel docs

2015-04-13 Thread Vasia Kalavri (JIRA)
Vasia Kalavri created FLINK-1884: Summary: Outdated Spargel docs Key: FLINK-1884 URL: https://issues.apache.org/jira/browse/FLINK-1884 Project: Flink Issue Type: Bug Components:

Re: Quickstart build - Fat Jar is empty

2015-04-13 Thread Henry Saputra
Sounds good, thx Robert! On Monday, April 13, 2015, Robert Metzger rmetz...@apache.org wrote: I tagged it to affect 0.8.x. I'll backport the fix to 0.8, then we can mark it as fixed for that release as well. On Mon, Apr 13, 2015 at 7:17 PM, Henry Saputra henry.sapu...@gmail.com

Re: Flink 0.9.0-milestone1 released

2015-04-13 Thread Henry Saputra
Woot! Great news! On Monday, April 13, 2015, Kostas Tzoumas ktzou...@apache.org wrote: We are very excited to announce Flink 0.9.0-milestone1, a preview release to give users early access to some Flink 0.9.0 features, including: - A Table API for SQL-like queries embedded in Java and Scala

Re: Quickstart build - Fat Jar is empty

2015-04-13 Thread Henry Saputra
Ah thanks. I assume this need to be tagged for 0.8.2 release? On Monday, April 13, 2015, Robert Metzger rmetz...@apache.org wrote: Its this one: https://issues.apache.org/jira/browse/FLINK-1342 On Mon, Apr 13, 2015 at 6:52 AM, Henry Saputra henry.sapu...@gmail.com javascript:; wrote:

[jira] [Created] (FLINK-1883) Add Min Vertex ID Propagation Library Method and Example

2015-04-13 Thread Andra Lungu (JIRA)
Andra Lungu created FLINK-1883: -- Summary: Add Min Vertex ID Propagation Library Method and Example Key: FLINK-1883 URL: https://issues.apache.org/jira/browse/FLINK-1883 Project: Flink Issue

Re: [DISCUSS] Break up streaming connectors into subprojects

2015-04-13 Thread Robert Metzger
I filed a JIRA to address the issue: https://issues.apache.org/jira/browse/FLINK-1874 On Thu, Apr 9, 2015 at 4:08 PM, Robert Metzger rmetz...@apache.org wrote: Thanks for bringing up this discussion. I'm very much in favor of splitting up the connectors into separate maven modules. The

Re: Quickstart build - Fat Jar is empty

2015-04-13 Thread Robert Metzger
Its this one: https://issues.apache.org/jira/browse/FLINK-1342 On Mon, Apr 13, 2015 at 6:52 AM, Henry Saputra henry.sapu...@gmail.com wrote: Robert, Which one is the Jira to fix the QuickStart fat jar issue? On Friday, April 10, 2015, Robert Metzger rmetz...@apache.org wrote: We actually

[jira] [Created] (FLINK-1874) Break up streaming connectors into submodules

2015-04-13 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-1874: - Summary: Break up streaming connectors into submodules Key: FLINK-1874 URL: https://issues.apache.org/jira/browse/FLINK-1874 Project: Flink Issue Type:

[jira] [Created] (FLINK-1879) Simplify JobClient

2015-04-13 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-1879: --- Summary: Simplify JobClient Key: FLINK-1879 URL: https://issues.apache.org/jira/browse/FLINK-1879 Project: Flink Issue Type: Sub-task Components:

Re: [QUESTION] Scala Table API syntax

2015-04-13 Thread Aljoscha Krettek
@Till: Correct On Mon, Apr 13, 2015 at 10:52 AM, Till Rohrmann trohrm...@apache.org wrote: IMO the symbol notation makes it slightly easier to write Table API expressions, because the IDE can assist you in what operations are supported by the expression DSL whereas the string notation will

[jira] [Created] (FLINK-1877) Stalled Flink on Tez build

2015-04-13 Thread Ufuk Celebi (JIRA)
Ufuk Celebi created FLINK-1877: -- Summary: Stalled Flink on Tez build Key: FLINK-1877 URL: https://issues.apache.org/jira/browse/FLINK-1877 Project: Flink Issue Type: Bug Components:

[jira] [Created] (FLINK-1880) TaskManagerTest fails spuriously

2015-04-13 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-1880: --- Summary: TaskManagerTest fails spuriously Key: FLINK-1880 URL: https://issues.apache.org/jira/browse/FLINK-1880 Project: Flink Issue Type: Bug

Flink - Avro - AvroTypeInfo issue - Index out of bounds exception

2015-04-13 Thread Filip Łęczycki
Hi I have an issue while running the following line while usig flink v 0.8.1 (: val asdf = new AvroTypeInfo[AlignmentRecord](classOf[AlignmentRecord]) Alignment record belongs to the package : org.bdgenomics.formats.avro.AlignmentRecord

Flink 0.9.0-milestone1 released

2015-04-13 Thread Kostas Tzoumas
We are very excited to announce Flink 0.9.0-milestone1, a preview release to give users early access to some Flink 0.9.0 features, including: - A Table API for SQL-like queries embedded in Java and Scala - Gelly, Flink's graph processing API - A Machine Learning library on Flink inspired by

Re: Flink 0.9.0-milestone1 released

2015-04-13 Thread Kostas Tzoumas
should be fixed now thanks! On Mon, Apr 13, 2015 at 5:48 PM, Vasiliki Kalavri vasilikikala...@gmail.com wrote: Awesome job everyone! Just one thing, the release download link in the announcement post is broken :-) Looking forward to 0.9.0 ^^ Cheers, -V. On 13 April 2015 at 18:10,

Re: Flink 0.9.0-milestone1 released

2015-04-13 Thread Vasiliki Kalavri
Awesome job everyone! Just one thing, the release download link in the announcement post is broken :-) Looking forward to 0.9.0 ^^ Cheers, -V. On 13 April 2015 at 18:10, Kostas Tzoumas ktzou...@apache.org wrote: We are very excited to announce Flink 0.9.0-milestone1, a preview release to