[GitHub] incubator-flink pull request: Add DeltaPageRank example

2014-10-27 Thread StephanEwen
GitHub user StephanEwen opened a pull request: https://github.com/apache/incubator-flink/pull/166 Add DeltaPageRank example Illustrates a somewhat advanced use case for delta iterations. Runs self-contained. You can merge this pull request into a Git repository by running:

[jira] [Updated] (FLINK-1184) Streaming stateful computation support

2014-10-27 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-1184?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi updated FLINK-1184: -- Assignee: Gyula Fora (was: Márton Balassi) > Streaming stateful computation support > -

[GitHub] incubator-flink pull request: Remove unnecessary final modifier in...

2014-10-27 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/incubator-flink/pull/163 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the featur

[GitHub] incubator-flink pull request: Remove unnecessary final modifier in...

2014-10-27 Thread hsaputra
Github user hsaputra commented on the pull request: https://github.com/apache/incubator-flink/pull/163#issuecomment-60627135 Thx, will merge sometimes today --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project

[jira] [Commented] (FLINK-1186) Join key selection for nested Tuples is broken

2014-10-27 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1186?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14185360#comment-14185360 ] Robert Metzger commented on FLINK-1186: --- I'm trying to look into the issue in the ne

[jira] [Closed] (FLINK-1185) State interfaces for streaming checkpointing

2014-10-27 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-1185?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi closed FLINK-1185. - Resolution: Implemented Fix Version/s: 0.8-incubating Implemented in the following commit:

[jira] [Closed] (FLINK-1175) Add support for KeySelector and possibility to select more than one field for groupBy for streaming

2014-10-27 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-1175?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi closed FLINK-1175. - Resolution: Implemented Fix Version/s: 0.8-incubating Implemented in the following commit:

[jira] [Closed] (FLINK-1187) API support for registering persistent states

2014-10-27 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-1187?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi closed FLINK-1187. - Resolution: Implemented Implemented in the following commit: https://git-wip-us.apache.org/repos/

[jira] [Assigned] (FLINK-1161) Modify streaming api type extractor classes to allow java 8 lambdas

2014-10-27 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-1161?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi reassigned FLINK-1161: - Assignee: Márton Balassi > Modify streaming api type extractor classes to allow java 8 la

[jira] [Closed] (FLINK-1188) Streaming aggregations on array types

2014-10-27 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-1188?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi closed FLINK-1188. - Resolution: Implemented Fix Version/s: 0.8-incubating Resolved in the following commit: ht

[jira] [Closed] (FLINK-1178) Let ValueType and WritableType have preference over CaseClassType

2014-10-27 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1178?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-1178. Resolution: Fixed Fixed in https://github.com/apache/incubator-flink/commit/f2b8650e3968daf695af832

[jira] [Closed] (FLINK-1189) Temporal cross operator for streaming

2014-10-27 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-1189?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi closed FLINK-1189. - Resolution: Fixed Fix Version/s: 0.8-incubating The following commits addressed this issue:

[jira] [Commented] (FLINK-1178) Let ValueType and WritableType have preference over CaseClassType

2014-10-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1178?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14185299#comment-14185299 ] ASF GitHub Bot commented on FLINK-1178: --- Github user asfgit closed the pull request

[GitHub] incubator-flink pull request: [FLINK-1178] Changed type preference...

2014-10-27 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/incubator-flink/pull/162 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the featur

[jira] [Commented] (FLINK-1191) TypeAnalyzer MatchError when analyzing BitSet type with Scala API

2014-10-27 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1191?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14185275#comment-14185275 ] Aljoscha Krettek commented on FLINK-1191: - Yes, I was aware of the problem. Some s

[jira] [Assigned] (FLINK-1191) TypeAnalyzer MatchError when analyzing BitSet type with Scala API

2014-10-27 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1191?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-1191: --- Assignee: Aljoscha Krettek > TypeAnalyzer MatchError when analyzing BitSet type with

[jira] [Commented] (FLINK-1178) Let ValueType and WritableType have preference over CaseClassType

2014-10-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1178?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14185269#comment-14185269 ] ASF GitHub Bot commented on FLINK-1178: --- Github user tillrohrmann commented on the p

[GitHub] incubator-flink pull request: [FLINK-1178] Changed type preference...

2014-10-27 Thread tillrohrmann
Github user tillrohrmann commented on the pull request: https://github.com/apache/incubator-flink/pull/162#issuecomment-60616930 Ok, I'll merge --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have

[jira] [Commented] (FLINK-1027) CLI "run" command does not support flags

2014-10-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1027?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14185149#comment-14185149 ] ASF GitHub Bot commented on FLINK-1027: --- Github user StephanEwen commented on the pu

[GitHub] incubator-flink pull request: [FLINK-1027] ignore invalid commandl...

2014-10-27 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/incubator-flink/pull/161#issuecomment-60596192 How does that affect using the trailing parameters as program arguments? Right now, you can call ``` bin/flink run my_prog.jar parameter1 para

[jira] [Commented] (FLINK-1178) Let ValueType and WritableType have preference over CaseClassType

2014-10-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1178?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14185147#comment-14185147 ] ASF GitHub Bot commented on FLINK-1178: --- Github user StephanEwen commented on the pu

[jira] [Commented] (FLINK-1194) Wrong manifest entries and compiler configuration in Java Quickstarts

2014-10-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1194?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14185145#comment-14185145 ] ASF GitHub Bot commented on FLINK-1194: --- GitHub user StephanEwen opened a pull reque

[GitHub] incubator-flink pull request: [FLINK-1178] Changed type preference...

2014-10-27 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/incubator-flink/pull/162#issuecomment-60595832 Good catch. Looks good to merge... --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. I

[GitHub] incubator-flink pull request: Remove unnecessary final modifier in...

2014-10-27 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/incubator-flink/pull/163#issuecomment-60595788 Looks good --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this

[GitHub] incubator-flink pull request: [FLINK-1194] Fix Java quickstart arc...

2014-10-27 Thread StephanEwen
GitHub user StephanEwen opened a pull request: https://github.com/apache/incubator-flink/pull/165 [FLINK-1194] Fix Java quickstart archetype POM file Fixes the quickstart archetype for java: - sets correct main class attribute in jar - sets correct main class attribute in

[jira] [Created] (FLINK-1194) Wrong manifest entries and compiler configuration in Java Quickstarts

2014-10-27 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-1194: --- Summary: Wrong manifest entries and compiler configuration in Java Quickstarts Key: FLINK-1194 URL: https://issues.apache.org/jira/browse/FLINK-1194 Project: Flink

[jira] [Created] (FLINK-1193) InvalidTypesException for Array[Array[Tuple2[Int, Double]]]

2014-10-27 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-1193: Summary: InvalidTypesException for Array[Array[Tuple2[Int, Double]]] Key: FLINK-1193 URL: https://issues.apache.org/jira/browse/FLINK-1193 Project: Flink Is

[jira] [Created] (FLINK-1192) Streaming source fault tolerance

2014-10-27 Thread JIRA
Márton Balassi created FLINK-1192: - Summary: Streaming source fault tolerance Key: FLINK-1192 URL: https://issues.apache.org/jira/browse/FLINK-1192 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-1191) TypeAnalyzer MatchError when analyzing BitSet type with Scala API

2014-10-27 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-1191: Summary: TypeAnalyzer MatchError when analyzing BitSet type with Scala API Key: FLINK-1191 URL: https://issues.apache.org/jira/browse/FLINK-1191 Project: Flink

[jira] [Created] (FLINK-1190) Enhanced windowing semantics

2014-10-27 Thread JIRA
Márton Balassi created FLINK-1190: - Summary: Enhanced windowing semantics Key: FLINK-1190 URL: https://issues.apache.org/jira/browse/FLINK-1190 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-1189) Temporal cross operator for streaming

2014-10-27 Thread JIRA
Márton Balassi created FLINK-1189: - Summary: Temporal cross operator for streaming Key: FLINK-1189 URL: https://issues.apache.org/jira/browse/FLINK-1189 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-1188) Streaming aggregations on array types

2014-10-27 Thread JIRA
Márton Balassi created FLINK-1188: - Summary: Streaming aggregations on array types Key: FLINK-1188 URL: https://issues.apache.org/jira/browse/FLINK-1188 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-1187) API support for registering persistent states

2014-10-27 Thread JIRA
Márton Balassi created FLINK-1187: - Summary: API support for registering persistent states Key: FLINK-1187 URL: https://issues.apache.org/jira/browse/FLINK-1187 Project: Flink Issue Type: Sub

[jira] [Created] (FLINK-1186) Join key selection for nested Tuples is broken

2014-10-27 Thread Robert Waury (JIRA)
Robert Waury created FLINK-1186: --- Summary: Join key selection for nested Tuples is broken Key: FLINK-1186 URL: https://issues.apache.org/jira/browse/FLINK-1186 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-1185) State interfaces for streaming checkpointing

2014-10-27 Thread JIRA
Márton Balassi created FLINK-1185: - Summary: State interfaces for streaming checkpointing Key: FLINK-1185 URL: https://issues.apache.org/jira/browse/FLINK-1185 Project: Flink Issue Type: Sub-

[jira] [Updated] (FLINK-1186) Join key selection for nested Tuples is broken

2014-10-27 Thread Robert Waury (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1186?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Waury updated FLINK-1186: Attachment: KeySelectionBug.java > Join key selection for nested Tuples is broken >

[jira] [Created] (FLINK-1184) Streaming stateful computation support

2014-10-27 Thread JIRA
Márton Balassi created FLINK-1184: - Summary: Streaming stateful computation support Key: FLINK-1184 URL: https://issues.apache.org/jira/browse/FLINK-1184 Project: Flink Issue Type: Improvemen