[jira] [Reopened] (FLINK-2027) Flink website does not provide link to source repo

2015-05-15 Thread Henry Saputra (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2027?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Henry Saputra reopened FLINK-2027: -- Re-open this one to add link for easy access to source repo information. > Flink website does not p

[jira] [Closed] (FLINK-2027) Flink website does not provide link to source repo

2015-05-15 Thread Henry Saputra (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2027?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Henry Saputra closed FLINK-2027. Resolution: Not A Problem > Flink website does not provide link to source repo > ---

[jira] [Commented] (FLINK-2027) Flink website does not provide link to source repo

2015-05-15 Thread Henry Saputra (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2027?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14546583#comment-14546583 ] Henry Saputra commented on FLINK-2027: -- [~s...@apache.org], the main Apache source re

[jira] [Commented] (FLINK-2029) DOAP has disappeared

2015-05-15 Thread Henry Saputra (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2029?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14546582#comment-14546582 ] Henry Saputra commented on FLINK-2029: -- [~uce], could you help take a look at this? P

[jira] [Updated] (FLINK-2029) DOAP has disappeared

2015-05-15 Thread Henry Saputra (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2029?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Henry Saputra updated FLINK-2029: - Assignee: Ufuk Celebi > DOAP has disappeared > > > Key: FLINK

[jira] [Commented] (FLINK-2026) Error message in count() only jobs

2015-05-15 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2026?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14546572#comment-14546572 ] Aljoscha Krettek commented on FLINK-2026: - You are calling execute() on the enviro

[jira] [Created] (FLINK-2029) DOAP has disappeared

2015-05-15 Thread Sebb (JIRA)
Sebb created FLINK-2029: --- Summary: DOAP has disappeared Key: FLINK-2029 URL: https://issues.apache.org/jira/browse/FLINK-2029 Project: Flink Issue Type: Bug Reporter: Sebb The DOAP was pr

[jira] [Created] (FLINK-2028) Download pages must not link to snapshots

2015-05-15 Thread Sebb (JIRA)
Sebb created FLINK-2028: --- Summary: Download pages must not link to snapshots Key: FLINK-2028 URL: https://issues.apache.org/jira/browse/FLINK-2028 Project: Flink Issue Type: Bug Reporter: S

[jira] [Created] (FLINK-2027) Flink website does not provide link to source repo

2015-05-15 Thread Sebb (JIRA)
Sebb created FLINK-2027: --- Summary: Flink website does not provide link to source repo Key: FLINK-2027 URL: https://issues.apache.org/jira/browse/FLINK-2027 Project: Flink Issue Type: Bug Re

[GitHub] flink pull request: Wrap very long line in FlatMapOperator class

2015-05-15 Thread hsaputra
GitHub user hsaputra opened a pull request: https://github.com/apache/flink/pull/683 Wrap very long line in FlatMapOperator class As previous discussions before, we do not restrict max chars per line for Java code, but this one just way too long compare to others that I just think

[jira] [Commented] (FLINK-2013) Create generalized linear model framework

2015-05-15 Thread Theodore Vasiloudis (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2013?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14546115#comment-14546115 ] Theodore Vasiloudis commented on FLINK-2013: I've started working on this, bas

[jira] [Comment Edited] (FLINK-1985) Streaming does not correctly forward ExecutionConfig to runtime

2015-05-15 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1985?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14545842#comment-14545842 ] Matthias J. Sax edited comment on FLINK-1985 at 5/15/15 8:15 PM: ---

[jira] [Created] (FLINK-2026) Error message in count() only jobs

2015-05-15 Thread Sebastian Schelter (JIRA)
Sebastian Schelter created FLINK-2026: - Summary: Error message in count() only jobs Key: FLINK-2026 URL: https://issues.apache.org/jira/browse/FLINK-2026 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-2025) Support booleans in CSV reader

2015-05-15 Thread Sebastian Schelter (JIRA)
Sebastian Schelter created FLINK-2025: - Summary: Support booleans in CSV reader Key: FLINK-2025 URL: https://issues.apache.org/jira/browse/FLINK-2025 Project: Flink Issue Type: New Featur

[jira] [Commented] (FLINK-1985) Streaming does not correctly forward ExecutionConfig to runtime

2015-05-15 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1985?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14546029#comment-14546029 ] Matthias J. Sax commented on FLINK-1985: Hi again. I forgot to add, that I discove

[jira] [Commented] (FLINK-1985) Streaming does not correctly forward ExecutionConfig to runtime

2015-05-15 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1985?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14545993#comment-14545993 ] Matthias J. Sax commented on FLINK-1985: Hi, I also added a JUnit test for this. I

[jira] [Closed] (FLINK-1990) Uppercase "AS" keyword not allowed in select expression

2015-05-15 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1990?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-1990. --- Fixed in https://github.com/apache/flink/commit/6dd241d3bb7b0d057c04187bc114313f9c9e1937 > Upper

[jira] [Commented] (FLINK-1990) Uppercase "AS" keyword not allowed in select expression

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

[GitHub] flink pull request: [FLINK-1990] [staging table] Support upper cas...

2015-05-15 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/667 --- 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 feature is enabl

[GitHub] flink pull request: [Flink-1985] Streaming does not correctly forw...

2015-05-15 Thread mjsax
GitHub user mjsax opened a pull request: https://github.com/apache/flink/pull/682 [Flink-1985] Streaming does not correctly forward ExecutionConfig to runtime added ExecutionConfig serialization for streaming jobs closes #1985 You can merge this pull request into a Git repositor

[jira] [Commented] (FLINK-1985) Streaming does not correctly forward ExecutionConfig to runtime

2015-05-15 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1985?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14545842#comment-14545842 ] Matthias J. Sax commented on FLINK-1985: Hi, I prepared a fix for it. Just opened

[jira] [Commented] (FLINK-1711) Replace all usages off commons.Validate with guava.check

2015-05-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1711?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14545746#comment-14545746 ] ASF GitHub Bot commented on FLINK-1711: --- Github user aljoscha commented on the pull

[GitHub] flink pull request: [FLINK-1711] - Converted all usages of Commons...

2015-05-15 Thread aljoscha
Github user aljoscha commented on the pull request: https://github.com/apache/flink/pull/673#issuecomment-102452915 That's because I rebased your commit which changes the signature of the commit. But if you look here https://github.com/apache/flink/commits/master you can see that your

[jira] [Commented] (FLINK-1711) Replace all usages off commons.Validate with guava.check

2015-05-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1711?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14545699#comment-14545699 ] ASF GitHub Bot commented on FLINK-1711: --- Github user lokeshrajaram commented on the

[GitHub] flink pull request: [FLINK-1711] - Converted all usages of Commons...

2015-05-15 Thread lokeshrajaram
Github user lokeshrajaram commented on the pull request: https://github.com/apache/flink/pull/673#issuecomment-102445184 Thanks @aljoscha .I notice above it says "This pull request is closed, but the lokeshrajaram:all_guava branch has unmerged commits." Is there anything more needs to

[jira] [Updated] (FLINK-2024) Table API mentioned only in Batch in documentation site

2015-05-15 Thread Henry Saputra (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2024?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Henry Saputra updated FLINK-2024: - Description: The documentation image for http://ci.apache.org/projects/flink/flink-docs-master/fi

[jira] [Updated] (FLINK-2024) Table API mentioned only in Batch in documentation site

2015-05-15 Thread Henry Saputra (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2024?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Henry Saputra updated FLINK-2024: - Summary: Table API mentioned only in Batch in documentation site (was: Table API mentioned twice

[jira] [Updated] (FLINK-2024) Table API mentioned only in Batch in documentation site

2015-05-15 Thread Henry Saputra (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2024?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Henry Saputra updated FLINK-2024: - Component/s: (was: Project Website) Documentation > Table API mentioned only

[GitHub] flink pull request: [FLINK-2019] Use a properly instantiated Kryo ...

2015-05-15 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/679 --- 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 feature is enabl

[jira] [Created] (FLINK-2024) Table API mentioned twice in the small stack image in the Flink homepage

2015-05-15 Thread Henry Saputra (JIRA)
Henry Saputra created FLINK-2024: Summary: Table API mentioned twice in the small stack image in the Flink homepage Key: FLINK-2024 URL: https://issues.apache.org/jira/browse/FLINK-2024 Project: Flink

[GitHub] flink pull request: implement a simple session management

2015-05-15 Thread mxm
GitHub user mxm opened a pull request: https://github.com/apache/flink/pull/681 implement a simple session management This pull request implements a rudimentary session management. Together with the backtracking #640, this will enable users to successively submit jobs to the cluste

[jira] [Resolved] (FLINK-1975) Graph getUndirected improvement

2015-05-15 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1975?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske resolved FLINK-1975. -- Resolution: Fixed Fix Version/s: 0.9 Fixed with beb7f31227766cfa17691525ccc666d105d442da

[jira] [Resolved] (FLINK-2019) Grouping by Joda DateTime field fails with Kryo exception

2015-05-15 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2019?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-2019. --- Resolution: Fixed Fix Version/s: 0.9 Fixed in http://git-wip-us.apache.org/repos/asf/fl

[jira] [Commented] (FLINK-2019) Grouping by Joda DateTime field fails with Kryo exception

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

[jira] [Commented] (FLINK-1975) Graph getUndirected improvement

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

[GitHub] flink pull request: [FLINK-1975][gelly] Graph getUndirected improv...

2015-05-15 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/653 --- 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 feature is enabl

[jira] [Commented] (FLINK-1830) java.io.IOException: Network stream corrupted

2015-05-15 Thread Stefan Bunk (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1830?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14545537#comment-14545537 ] Stefan Bunk commented on FLINK-1830: This did not happen again, so I cannot provide lo

[jira] [Commented] (FLINK-1962) Add Gelly Scala API

2015-05-15 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1962?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14545492#comment-14545492 ] Aljoscha Krettek commented on FLINK-1962: - This is the issue I filed: https://issu

[jira] [Commented] (FLINK-1962) Add Gelly Scala API

2015-05-15 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1962?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14545490#comment-14545490 ] Aljoscha Krettek commented on FLINK-1962: - I'm afraid it's the most elegant soluti

[jira] [Created] (FLINK-2023) TypeExtractor does not work for (some) Scala Classes

2015-05-15 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-2023: --- Summary: TypeExtractor does not work for (some) Scala Classes Key: FLINK-2023 URL: https://issues.apache.org/jira/browse/FLINK-2023 Project: Flink Issu

[jira] [Closed] (FLINK-1711) Replace all usages off commons.Validate with guava.check

2015-05-15 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1711?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-1711. --- Resolution: Fixed Fixed in https://github.com/apache/flink/commit/f950def569f20e2009a9c216d51

[jira] [Commented] (FLINK-1711) Replace all usages off commons.Validate with guava.check

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

[GitHub] flink pull request: [FLINK-1711] - Converted all usages of Commons...

2015-05-15 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/673 --- 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 feature is enabl

[jira] [Commented] (FLINK-1962) Add Gelly Scala API

2015-05-15 Thread PJ Van Aeken (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1962?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14545434#comment-14545434 ] PJ Van Aeken commented on FLINK-1962: - So the fix works for the syntactic sugar. I als

[jira] [Reopened] (FLINK-2006) TaskManagerTest.testRunJobWithForwardChannel:432 expected: but was:

2015-05-15 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2006?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reopened FLINK-2006: --- 9da2f1f725473f1242067acb546607888e3a5015 did not resolve the issue. We had another case on master

[jira] [Commented] (FLINK-1523) Vertex-centric iteration extensions

2015-05-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14545430#comment-14545430 ] ASF GitHub Bot commented on FLINK-1523: --- Github user andralungu commented on the pul

[GitHub] flink pull request: [FLINK-1523] vertex-centric iteration extensio...

2015-05-15 Thread andralungu
Github user andralungu commented on the pull request: https://github.com/apache/flink/pull/680#issuecomment-102387218 Uhhh this looks incredibly clean now :)) +1 to merge --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as wel

[jira] [Commented] (FLINK-1523) Vertex-centric iteration extensions

2015-05-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14545420#comment-14545420 ] ASF GitHub Bot commented on FLINK-1523: --- GitHub user vasia opened a pull request:

[GitHub] flink pull request: [FLINK-1523] vertex-centric iteration extensio...

2015-05-15 Thread vasia
GitHub user vasia opened a pull request: https://github.com/apache/flink/pull/680 [FLINK-1523] vertex-centric iteration extensions This PR builds on top of @andralungu's work in #537. The vertex-centric iteration is extended with the following options: - set the messagin

[jira] [Created] (FLINK-2022) log4j.properties are not in quickstart projects

2015-05-15 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-2022: - Summary: log4j.properties are not in quickstart projects Key: FLINK-2022 URL: https://issues.apache.org/jira/browse/FLINK-2022 Project: Flink Issue Type: B

[jira] [Updated] (FLINK-2000) Add SQL-style aggregations for Table API

2015-05-15 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2000?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-2000: Component/s: Table API > Add SQL-style aggregations for Table API >

[jira] [Updated] (FLINK-1990) Uppercase "AS" keyword not allowed in select expression

2015-05-15 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1990?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-1990: Assignee: Cheng Hao (was: Aljoscha Krettek) > Uppercase "AS" keyword not allowed in select

[jira] [Updated] (FLINK-2017) Add predefined required parameters to ParameterTool

2015-05-15 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2017?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-2017: -- Summary: Add predefined required parameters to ParameterTool (was: Add predefinde required para

[jira] [Created] (FLINK-2021) Rework examples to use new ParameterTool

2015-05-15 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-2021: - Summary: Rework examples to use new ParameterTool Key: FLINK-2021 URL: https://issues.apache.org/jira/browse/FLINK-2021 Project: Flink Issue Type: Improvem

[jira] [Resolved] (FLINK-1525) Provide utils to pass -D parameters to UDFs

2015-05-15 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1525?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-1525. --- Resolution: Fixed Fix Version/s: 0.9 Merged in http://git-wip-us.apache.org/repos/asf/f

[GitHub] flink pull request: [FLINK-1525]Introduction of a small input para...

2015-05-15 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/664 --- 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 feature is enabl

[jira] [Commented] (FLINK-1525) Provide utils to pass -D parameters to UDFs

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

[jira] [Commented] (FLINK-1525) Provide utils to pass -D parameters to UDFs

2015-05-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1525?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14545399#comment-14545399 ] ASF GitHub Bot commented on FLINK-1525: --- Github user rmetzger commented on the pull

[GitHub] flink pull request: [FLINK-1525]Introduction of a small input para...

2015-05-15 Thread rmetzger
Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/664#issuecomment-102383548 Okay .. merging --- 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 featur

[jira] [Commented] (FLINK-2019) Grouping by Joda DateTime field fails with Kryo exception

2015-05-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2019?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14545395#comment-14545395 ] ASF GitHub Bot commented on FLINK-2019: --- GitHub user rmetzger opened a pull request:

[GitHub] flink pull request: [FLINK-2019] Use a properly instantiated Kryo ...

2015-05-15 Thread rmetzger
GitHub user rmetzger opened a pull request: https://github.com/apache/flink/pull/679 [FLINK-2019] Use a properly instantiated Kryo in the GenericTypeComparator I'll merge this once travis is green. You can merge this pull request into a Git repository by running: $ git pull htt

[GitHub] flink pull request: [gelly][Refactoring] Removed example string

2015-05-15 Thread andralungu
Github user andralungu commented on the pull request: https://github.com/apache/flink/pull/625#issuecomment-102376105 If you don't like the example string at the end, then we can go for sol (b) --- If your project is set up for it, you can reply to this email and have your reply appea

[jira] [Commented] (FLINK-1523) Vertex-centric iteration extensions

2015-05-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14545365#comment-14545365 ] ASF GitHub Bot commented on FLINK-1523: --- Github user andralungu closed the pull requ

[GitHub] flink pull request: [FLINK-1523][gelly] Vertex centric iteration e...

2015-05-15 Thread andralungu
Github user andralungu closed the pull request at: https://github.com/apache/flink/pull/537 --- 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 feature is e

[jira] [Commented] (FLINK-1990) Uppercase "AS" keyword not allowed in select expression

2015-05-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1990?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14545357#comment-14545357 ] ASF GitHub Bot commented on FLINK-1990: --- Github user aljoscha commented on the pull

[GitHub] flink pull request: [FLINK-1990] [staging table] Support upper cas...

2015-05-15 Thread aljoscha
Github user aljoscha commented on the pull request: https://github.com/apache/flink/pull/667#issuecomment-102374728 I'm running my own tests on travis and then I'll merge it. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well

[GitHub] flink pull request: [FLINK-1942][gelly] GSA Iteration Configuratio...

2015-05-15 Thread vasia
Github user vasia commented on the pull request: https://github.com/apache/flink/pull/635#issuecomment-102374179 This looks good! Thanks for the update @andralungu! Will merge :) --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub

[jira] [Commented] (FLINK-1942) Add configuration options to Gelly-GSA

2015-05-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1942?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14545354#comment-14545354 ] ASF GitHub Bot commented on FLINK-1942: --- Github user vasia commented on the pull req

[jira] [Commented] (FLINK-1962) Add Gelly Scala API

2015-05-15 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1962?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14545348#comment-14545348 ] Aljoscha Krettek commented on FLINK-1962: - Oh my, the gift that keeps on giving. N

[GitHub] flink pull request: [gelly][Refactoring] Removed example string

2015-05-15 Thread vasia
Github user vasia commented on the pull request: https://github.com/apache/flink/pull/625#issuecomment-102373199 Hi @andralungu, regarding `EdgeWithLongIdNullValueParser`: good catch, let's remove it then. As for the renaming, I would like the examples naming to be con

[jira] [Commented] (FLINK-1523) Vertex-centric iteration extensions

2015-05-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14545293#comment-14545293 ] ASF GitHub Bot commented on FLINK-1523: --- Github user vasia commented on the pull req

[GitHub] flink pull request: [FLINK-1523][gelly] Vertex centric iteration e...

2015-05-15 Thread vasia
Github user vasia commented on the pull request: https://github.com/apache/flink/pull/537#issuecomment-102366422 Hey @andralungu! Thanks a lot for looking into this! Can you please close this PR and I'll open a new one with the latest changes. Regarding returning -1 if the

[jira] [Commented] (FLINK-1975) Graph getUndirected improvement

2015-05-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1975?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14545265#comment-14545265 ] ASF GitHub Bot commented on FLINK-1975: --- Github user vasia commented on the pull req

[GitHub] flink pull request: [FLINK-1975][gelly] Graph getUndirected improv...

2015-05-15 Thread vasia
Github user vasia commented on the pull request: https://github.com/apache/flink/pull/653#issuecomment-102356828 No objections! Please go ahead @fhueske, thanks a lot ^^ --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If

[jira] [Created] (FLINK-2020) Table API JoinITCase fails non-deterministically

2015-05-15 Thread Fabian Hueske (JIRA)
Fabian Hueske created FLINK-2020: Summary: Table API JoinITCase fails non-deterministically Key: FLINK-2020 URL: https://issues.apache.org/jira/browse/FLINK-2020 Project: Flink Issue Type: Bu

[jira] [Commented] (FLINK-1962) Add Gelly Scala API

2015-05-15 Thread PJ Van Aeken (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1962?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14545217#comment-14545217 ] PJ Van Aeken commented on FLINK-1962: - https://github.com/PieterJanVanAeken/flink/blob

[jira] [Commented] (FLINK-1962) Add Gelly Scala API

2015-05-15 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1962?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14545210#comment-14545210 ] Aljoscha Krettek commented on FLINK-1962: - Which are the syntactic sugar lines? Do

[jira] [Commented] (FLINK-2008) PersistentKafkaSource is sometimes emitting tuples multiple times

2015-05-15 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2008?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14545207#comment-14545207 ] Robert Metzger commented on FLINK-2008: --- Another kafka test failure: https://travis-

[jira] [Commented] (FLINK-1711) Replace all usages off commons.Validate with guava.check

2015-05-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1711?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14545200#comment-14545200 ] ASF GitHub Bot commented on FLINK-1711: --- Github user aljoscha commented on the pull

[GitHub] flink pull request: [FLINK-1711] - Converted all usages of Commons...

2015-05-15 Thread aljoscha
Github user aljoscha commented on the pull request: https://github.com/apache/flink/pull/673#issuecomment-102337633 I'm running a last check on travis on my branch. Then I'm merging this. Thanks for your work! --- If your project is set up for it, you can reply to this email and hav

[GitHub] flink pull request: [FLINK-1977] Rework Stream Operators to always...

2015-05-15 Thread aljoscha
Github user aljoscha commented on the pull request: https://github.com/apache/flink/pull/659#issuecomment-10246 Yes, I was aware of that new test. :smile: The PollingSourceFunction I didn't implement because I think this is orthogonal to this work. For the operators, I thi

[jira] [Commented] (FLINK-1977) Rework Stream Operators to always be push based

2015-05-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1977?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14545196#comment-14545196 ] ASF GitHub Bot commented on FLINK-1977: --- Github user aljoscha commented on the pull

[GitHub] flink pull request: [FLINK-1525]Introduction of a small input para...

2015-05-15 Thread aljoscha
Github user aljoscha commented on the pull request: https://github.com/apache/flink/pull/664#issuecomment-102327285 +1 --- 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 an

[jira] [Commented] (FLINK-1525) Provide utils to pass -D parameters to UDFs

2015-05-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1525?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14545185#comment-14545185 ] ASF GitHub Bot commented on FLINK-1525: --- Github user aljoscha commented on the pull

[jira] [Created] (FLINK-2019) Grouping by Joda DateTime field fails with Kryo exception

2015-05-15 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-2019: - Summary: Grouping by Joda DateTime field fails with Kryo exception Key: FLINK-2019 URL: https://issues.apache.org/jira/browse/FLINK-2019 Project: Flink Iss

[jira] [Commented] (FLINK-1962) Add Gelly Scala API

2015-05-15 Thread PJ Van Aeken (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1962?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14545170#comment-14545170 ] PJ Van Aeken commented on FLINK-1962: - I spoke a little bit too soon. The syntactic su

[GitHub] flink pull request: [FLINK-1975][gelly] Graph getUndirected improv...

2015-05-15 Thread fhueske
Github user fhueske commented on the pull request: https://github.com/apache/flink/pull/653#issuecomment-102320473 LGTM @vasia Any objections against merging this? --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If yo

[jira] [Commented] (FLINK-1975) Graph getUndirected improvement

2015-05-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1975?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14545165#comment-14545165 ] ASF GitHub Bot commented on FLINK-1975: --- Github user fhueske commented on the pull r

[jira] [Commented] (FLINK-1977) Rework Stream Operators to always be push based

2015-05-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1977?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14545161#comment-14545161 ] ASF GitHub Bot commented on FLINK-1977: --- Github user mbalassi commented on the pull

[GitHub] flink pull request: [FLINK-1977] Rework Stream Operators to always...

2015-05-15 Thread mbalassi
Github user mbalassi commented on the pull request: https://github.com/apache/flink/pull/659#issuecomment-102320172 Oh, and when rebasing to the current master please pay attention to 4786b56. --- If your project is set up for it, you can reply to this email and have your reply appear

[GitHub] flink pull request: [FLINK-1977] Rework Stream Operators to always...

2015-05-15 Thread mbalassi
Github user mbalassi commented on the pull request: https://github.com/apache/flink/pull/659#issuecomment-102319519 A couple of comments: * As I see you do not introduce the PollingSourceFunction, this leads to the following point :) * I would have the Flume package

[jira] [Commented] (FLINK-1977) Rework Stream Operators to always be push based

2015-05-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1977?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14545159#comment-14545159 ] ASF GitHub Bot commented on FLINK-1977: --- Github user mbalassi commented on the pull

[jira] [Resolved] (FLINK-1976) Add ForwardedFields* hints for the optimizer

2015-05-15 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1976?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske resolved FLINK-1976. -- Resolution: Fixed Fix Version/s: 0.9 Fixed with a35c7201e010ee34629a7fbd9ffcd9b149fe5f93

[jira] [Commented] (FLINK-1976) Add ForwardedFields* hints for the optimizer

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

[GitHub] flink pull request: [FLINK-1976][gelly] Added ForwardedFields Anno...

2015-05-15 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/663 --- 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 feature is enabl

[jira] [Commented] (FLINK-1525) Provide utils to pass -D parameters to UDFs

2015-05-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1525?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14545140#comment-14545140 ] ASF GitHub Bot commented on FLINK-1525: --- Github user rmetzger commented on a diff in

[GitHub] flink pull request: [FLINK-1525]Introduction of a small input para...

2015-05-15 Thread rmetzger
Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/664#issuecomment-102315511 Thanks for the review Henry and Ufuk! I addressed your concerns and updated the PR. I rebased the PR to the current master and filed two JIRAs for missing fe

[jira] [Commented] (FLINK-1525) Provide utils to pass -D parameters to UDFs

2015-05-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1525?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14545146#comment-14545146 ] ASF GitHub Bot commented on FLINK-1525: --- Github user rmetzger commented on the pull

[GitHub] flink pull request: [FLINK-1525]Introduction of a small input para...

2015-05-15 Thread rmetzger
Github user rmetzger commented on a diff in the pull request: https://github.com/apache/flink/pull/664#discussion_r30392459 --- Diff: docs/apis/best_practices.md --- @@ -0,0 +1,155 @@ +--- +title: "Best Practices" +--- + + + + + +This page contain

[jira] [Commented] (FLINK-1525) Provide utils to pass -D parameters to UDFs

2015-05-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1525?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14545145#comment-14545145 ] ASF GitHub Bot commented on FLINK-1525: --- Github user rmetzger commented on a diff in

  1   2   >