Re: Quickstart build - Fat Jar is empty

2015-04-13 Thread Henry Saputra
Sounds good, thx Robert! On Monday, April 13, 2015, Robert Metzger 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 > > wrote: > > > Ah thanks. I assume this need to

[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: doc

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 wrote: > Ah thanks. I assume this need to be tagged for 0.8.2 release? > > On Monday, April 13, 2015, Robert Metzger wrote: > > > Its

[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 Type

Re: Flink 0.9.0-milestone1 released

2015-04-13 Thread Henry Saputra
Woot! Great news! On Monday, April 13, 2015, Kostas Tzoumas 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 > - Gelly, Flink'

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 wrote: > Its this one: https://issues.apache.org/jira/browse/FLINK-1342 > > On Mon, Apr 13, 2015 at 6:52 AM, Henry Saputra > > wrote: > > > Robert, Which one is the Jira to fix the QuickStart

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

2015-04-13 Thread Robert Metzger
Hi, no need to supply us with the code. Its a known issue that has been fixed in 0.9-milestone1. If you can easily upgrade to 0.9-milestone1, that's the way to go. Otherwise, you can set the version in your poms to 0.8-SNAPSHOT and you should get a version with the fix (through Apache's Snapshot

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 http://mvnrepository.com/artifact/org.bdgenomics.bdg-for

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

2015-04-13 Thread Stephan Ewen
Hi! Thanks you for reporting this. The Apache mailing lists do not support attachments, unfortunately. To help us fix this, can you upload the attachment (screenshot) somewhere and post a link here? Thanks, Stephan On Mon, Apr 13, 2015 at 6:25 PM, Filip Łęczycki wrote: > Hi > > I have an iss

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 http://mvnrepository.com/artifact/org.bdgenomics.bdg-for

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 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, Kostas Tzoumas wro

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 wrote: > We are very excited to announce Flink 0.9.0-milestone1, a preview release > to give users early acc

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 scikit

[jira] [Created] (FLINK-1882) Remove RemoteCollectorOutputFormat

2015-04-13 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-1882: --- Summary: Remove RemoteCollectorOutputFormat Key: FLINK-1882 URL: https://issues.apache.org/jira/browse/FLINK-1882 Project: Flink Issue Type: Bug Comp

[jira] [Created] (FLINK-1881) want link explain Table API Java in flink and what is important

2015-04-13 Thread hagersaleh (JIRA)
hagersaleh created FLINK-1881: - Summary: want link explain Table API Java in flink and what is important Key: FLINK-1881 URL: https://issues.apache.org/jira/browse/FLINK-1881 Project: Flink Issu

[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 Affe

[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: Dis

[jira] [Created] (FLINK-1878) Add mode to Environments to deactivate sysout printing

2015-04-13 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-1878: --- Summary: Add mode to Environments to deactivate sysout printing Key: FLINK-1878 URL: https://issues.apache.org/jira/browse/FLINK-1878 Project: Flink Issue Type

Re: [QUESTION] Scala Table API syntax

2015-04-13 Thread Maximilian Michels
Hadn't thought about that but it makes perfect sense. Very handy. On Mon, Apr 13, 2015 at 12:02 PM, Aljoscha Krettek wrote: > @Till: Correct > > On Mon, Apr 13, 2015 at 10:52 AM, Till Rohrmann > wrote: > > IMO the symbol notation makes it slightly easier to write Table API > > expressions, beca

[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: Te

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 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 only give > you a syn

[jira] [Created] (FLINK-1876) Refactor StreamGraph to be node centric

2015-04-13 Thread Gyula Fora (JIRA)
Gyula Fora created FLINK-1876: - Summary: Refactor StreamGraph to be node centric Key: FLINK-1876 URL: https://issues.apache.org/jira/browse/FLINK-1876 Project: Flink Issue Type: Bug Com

Re: [QUESTION] Scala Table API syntax

2015-04-13 Thread Till Rohrmann
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 only give you a syntax error upon compilation, right? On Mon, Apr 13, 2015 at 10:42 AM, Maximilian

Re: [QUESTION] Scala Table API syntax

2015-04-13 Thread Maximilian Michels
'Symbol is actually syntactic sugar for Symbol("Symbol") which is part of the Scala standard library. It is a core feature of Scala which IMO is perfectly fine to use. I'm not sure whether it makes the expression much easier to read but it is a neat feature already in place. @Stephan: As far as I

[jira] [Created] (FLINK-1875) Add figure to documentation describing

2015-04-13 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-1875: - Summary: Add figure to documentation describing Key: FLINK-1875 URL: https://issues.apache.org/jira/browse/FLINK-1875 Project: Flink Issue Type: Improveme

[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: Tas

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 wrote: > Thanks for bringing up this discussion. > > I'm very much in favor of splitting up the connectors into separate maven > modules. > The transitive dependen

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 wrote: > Robert, Which one is the Jira to fix the QuickStart fat jar issue? > > On Friday, April 10, 2015, Robert Metzger wrote: > > > We actually have 7 fixes for 0.8.2: > > > > > http