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

[ https://issues.apache.org/jira/browse/FLINK-2008?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14545111#comment-14545111 ] Robert Metzger commented on FLINK-2008: --- {{brokerFailureTest()}} has been fixed in

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

Github user uce commented on a diff in the pull request: https://github.com/apache/flink/pull/664#discussion_r30391422 --- Diff: docs/apis/best_practices.md --- @@ -0,0 +1,155 @@ +--- +title: Best Practices +--- +!-- +Licensed to the Apache Software Foundation

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

[ https://issues.apache.org/jira/browse/FLINK-1525?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14545121#comment-14545121 ] ASF GitHub Bot commented on FLINK-1525: --- Github user uce commented on a diff in the

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

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

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

[ https://issues.apache.org/jira/browse/FLINK-1977?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14545161#comment-14545161 ] ASF GitHub Bot commented on FLINK-1977: --- Github user mbalassi commented on the pull

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

[ https://issues.apache.org/jira/browse/FLINK-1962?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14545102#comment-14545102 ] PJ Van Aeken commented on FLINK-1962: - Don't worry about it. I'm just glad we got it

[jira] [Commented] (FLINK-2012) addVertices, addEdges, removeVertices, removeEdges methods

[ https://issues.apache.org/jira/browse/FLINK-2012?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14545100#comment-14545100 ] ASF GitHub Bot commented on FLINK-2012: --- Github user andralungu commented on the

[GitHub] flink pull request: [FLINK-2008] Fix broker failure test case

Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/675#issuecomment-102302334 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 feature

[GitHub] flink pull request: Pluggable state backend support for checkpoint...

Github user mbalassi commented on the pull request: https://github.com/apache/flink/pull/676#issuecomment-102306832 Changes look good to me. Some documentation should be added on the behaviour and maybe a iscussion on the dev list would be also nice on how to proceed, like

[jira] [Created] (FLINK-2017) Add predefinde required parameters to ParameterTool

Robert Metzger created FLINK-2017: - Summary: Add predefinde required parameters to ParameterTool Key: FLINK-2017 URL: https://issues.apache.org/jira/browse/FLINK-2017 Project: Flink Issue

[GitHub] flink pull request: [FLINK-2012][gelly] Added methods to remove/ad...

Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/678#issuecomment-102299465 Looks good (+1 for updating the docs and having tests ;) ) --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as

[jira] [Commented] (FLINK-2012) addVertices, addEdges, removeVertices, removeEdges methods

[ https://issues.apache.org/jira/browse/FLINK-2012?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14545091#comment-14545091 ] ASF GitHub Bot commented on FLINK-2012: --- Github user rmetzger commented on a diff in

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

[ https://issues.apache.org/jira/browse/FLINK-1976?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14545104#comment-14545104 ] ASF GitHub Bot commented on FLINK-1976: --- Github user fhueske commented on the pull

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

[ https://issues.apache.org/jira/browse/FLINK-2008?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14545103#comment-14545103 ] ASF GitHub Bot commented on FLINK-2008: --- Github user rmetzger commented on the pull

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

Github user fhueske commented on the pull request: https://github.com/apache/flink/pull/663#issuecomment-102302338 Thanks for pinging. 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. If your project

[jira] [Created] (FLINK-2018) Add ParameterUtil.fromGenericOptionsParser() for compatibility to Hadoop's argument parser

Robert Metzger created FLINK-2018: - Summary: Add ParameterUtil.fromGenericOptionsParser() for compatibility to Hadoop's argument parser Key: FLINK-2018 URL: https://issues.apache.org/jira/browse/FLINK-2018

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

[ https://issues.apache.org/jira/browse/FLINK-1525?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14545127#comment-14545127 ] ASF GitHub Bot commented on FLINK-1525: --- Github user uce commented on a diff in the

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

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 +--- +!-- +Licensed to the Apache Software

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

[ https://issues.apache.org/jira/browse/FLINK-1525?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14545145#comment-14545145 ] ASF GitHub Bot commented on FLINK-1525: --- Github user rmetzger commented on a diff in

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

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

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

[ https://issues.apache.org/jira/browse/FLINK-2008?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14545207#comment-14545207 ] Robert Metzger commented on FLINK-2008: --- Another kafka test failure:

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

[ https://issues.apache.org/jira/browse/FLINK-1525?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14545130#comment-14545130 ] ASF GitHub Bot commented on FLINK-1525: --- Github user uce commented on the pull

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

Github user uce commented on the pull request: https://github.com/apache/flink/pull/664#issuecomment-102312636 Thanks for the docs update! Very nice idea with the best practices page. +1 --- If your project is set up for it, you can reply to this email and have your reply appear on

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

Github user rmetzger commented on a diff in the pull request: https://github.com/apache/flink/pull/664#discussion_r30392111 --- Diff: docs/apis/programming_guide.md --- @@ -665,6 +667,18 @@ DataSetInteger result = in.partitionByHash(0) /td /tr tr +

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

[ https://issues.apache.org/jira/browse/FLINK-1525?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14545134#comment-14545134 ] ASF GitHub Bot commented on FLINK-1525: --- Github user rmetzger commented on a diff in

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

[ https://issues.apache.org/jira/browse/FLINK-1962?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14545210#comment-14545210 ] Aljoscha Krettek commented on FLINK-1962: - Which are the syntactic sugar lines? Do

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

[ https://issues.apache.org/jira/browse/FLINK-1525?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14545125#comment-14545125 ] ASF GitHub Bot commented on FLINK-1525: --- Github user uce commented on a diff in the

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

Github user uce commented on a diff in the pull request: https://github.com/apache/flink/pull/664#discussion_r30391587 --- Diff: docs/apis/best_practices.md --- @@ -0,0 +1,155 @@ +--- +title: Best Practices +--- +!-- +Licensed to the Apache Software Foundation

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

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

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

[ https://issues.apache.org/jira/browse/FLINK-1525?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14545146#comment-14545146 ] ASF GitHub Bot commented on FLINK-1525: --- Github user rmetzger commented on the pull

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

[ https://issues.apache.org/jira/browse/FLINK-1976?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14545150#comment-14545150 ] ASF GitHub Bot commented on FLINK-1976: --- Github user asfgit closed the pull request

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

[ https://issues.apache.org/jira/browse/FLINK-1977?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14545196#comment-14545196 ] ASF GitHub Bot commented on FLINK-1977: --- Github user aljoscha commented on the pull

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

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:

[jira] [Commented] (FLINK-2012) addVertices, addEdges, removeVertices, removeEdges methods

[ https://issues.apache.org/jira/browse/FLINK-2012?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14545059#comment-14545059 ] ASF GitHub Bot commented on FLINK-2012: --- GitHub user andralungu opened a pull

[GitHub] flink pull request: [FLINK-2012][gelly] Added methods to remove/ad...

GitHub user andralungu opened a pull request: https://github.com/apache/flink/pull/678 [FLINK-2012][gelly] Added methods to remove/add multiple edges/vertices This pull request provides methods for adding/deleting more than one vertex/edge at a time. The addEdges method is

[GitHub] flink pull request: [FLINK-2012][gelly] Added methods to remove/ad...

Github user rmetzger commented on a diff in the pull request: https://github.com/apache/flink/pull/678#discussion_r30390037 --- Diff: flink-staging/flink-gelly/src/test/java/org/apache/flink/graph/test/operations/GraphMutationsITCase.java --- @@ -271,4 +605,31 @@ public void

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

Github user rmetzger commented on a diff in the pull request: https://github.com/apache/flink/pull/664#discussion_r30391280 --- Diff: flink-java/src/test/java/org/apache/flink/api/java/utils/ParameterToolTest.java --- @@ -0,0 +1,220 @@ +/* + * Licensed to the Apache

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

[ https://issues.apache.org/jira/browse/FLINK-1525?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14545119#comment-14545119 ] ASF GitHub Bot commented on FLINK-1525: --- Github user rmetzger commented on a diff in

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

[ https://issues.apache.org/jira/browse/FLINK-1525?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14545129#comment-14545129 ] ASF GitHub Bot commented on FLINK-1525: --- Github user uce commented on a diff in the

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

Github user uce commented on a diff in the pull request: https://github.com/apache/flink/pull/664#discussion_r30391850 --- Diff: docs/apis/best_practices.md --- @@ -0,0 +1,155 @@ +--- +title: Best Practices +--- +!-- +Licensed to the Apache Software Foundation

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

Github user rmetzger commented on a diff in the pull request: https://github.com/apache/flink/pull/664#discussion_r30392280 --- Diff: flink-runtime/src/main/resources/log4j.properties --- @@ -18,7 +18,7 @@ # Convenience file for local debugging of the

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

[ https://issues.apache.org/jira/browse/FLINK-1962?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14545170#comment-14545170 ] PJ Van Aeken commented on FLINK-1962: - I spoke a little bit too soon. The syntactic

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

[ https://issues.apache.org/jira/browse/FLINK-1525?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14545185#comment-14545185 ] ASF GitHub Bot commented on FLINK-1525: --- Github user aljoscha commented on the pull

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

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

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

[ https://issues.apache.org/jira/browse/FLINK-1525?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14545140#comment-14545140 ] ASF GitHub Bot commented on FLINK-1525: --- Github user rmetzger commented on a diff in

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

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] [Resolved] (FLINK-1976) Add ForwardedFields* hints for the optimizer

[ 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-1977) Rework Stream Operators to always be push based

[ https://issues.apache.org/jira/browse/FLINK-1977?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14545159#comment-14545159 ] ASF GitHub Bot commented on FLINK-1977: --- Github user mbalassi commented on the pull

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

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

[GitHub] flink pull request: [FLINK-2012][gelly] Added methods to remove/ad...

Github user andralungu commented on the pull request: https://github.com/apache/flink/pull/678#issuecomment-102301712 Well that was embarrassing ^^. Excellent catch @rmetzger! The code was written yesterday evening during a plane ride; My tests found a bug and I basically put that

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

[ https://issues.apache.org/jira/browse/FLINK-2008?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14545110#comment-14545110 ] ASF GitHub Bot commented on FLINK-2008: --- Github user asfgit closed the pull request

[GitHub] flink pull request: [FLINK-2008] Fix broker failure test case

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/675 --- 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

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

[ https://issues.apache.org/jira/browse/FLINK-1525?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14545120#comment-14545120 ] ASF GitHub Bot commented on FLINK-1525: --- Github user uce commented on a diff in the

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

Github user uce commented on a diff in the pull request: https://github.com/apache/flink/pull/664#discussion_r30391338 --- Diff: flink-runtime/src/main/resources/log4j.properties --- @@ -18,7 +18,7 @@ # Convenience file for local debugging of the

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

Github user uce commented on a diff in the pull request: https://github.com/apache/flink/pull/664#discussion_r30391736 --- Diff: docs/apis/programming_guide.md --- @@ -665,6 +667,18 @@ DataSetInteger result = in.partitionByHash(0) /td /tr tr +

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

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

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

[ https://issues.apache.org/jira/browse/FLINK-1975?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14545165#comment-14545165 ] ASF GitHub Bot commented on FLINK-1975: --- Github user fhueske commented on the pull

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

[ https://issues.apache.org/jira/browse/FLINK-1711?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14545200#comment-14545200 ] ASF GitHub Bot commented on FLINK-1711: --- Github user aljoscha commented on the pull

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

[ https://issues.apache.org/jira/browse/FLINK-1975?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14545265#comment-14545265 ] ASF GitHub Bot commented on FLINK-1975: --- Github user vasia commented on the pull

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

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

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

[ https://issues.apache.org/jira/browse/FLINK-1523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14545293#comment-14545293 ] ASF GitHub Bot commented on FLINK-1523: --- Github user vasia commented on the pull

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

[ https://issues.apache.org/jira/browse/FLINK-1942?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14545354#comment-14545354 ] ASF GitHub Bot commented on FLINK-1942: --- Github user vasia commented on the pull

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

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

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

[ 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

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

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

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

[ https://issues.apache.org/jira/browse/FLINK-1525?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14545401#comment-14545401 ] ASF GitHub Bot commented on FLINK-1525: --- Github user asfgit closed the pull request

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

[ https://issues.apache.org/jira/browse/FLINK-1523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14545430#comment-14545430 ] ASF GitHub Bot commented on FLINK-1523: --- Github user andralungu commented on the

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

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

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

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] [Commented] (FLINK-1962) Add Gelly Scala API

[ https://issues.apache.org/jira/browse/FLINK-1962?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14545348#comment-14545348 ] Aljoscha Krettek commented on FLINK-1962: - Oh my, the gift that keeps on giving.

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

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

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

[ https://issues.apache.org/jira/browse/FLINK-1523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14545365#comment-14545365 ] ASF GitHub Bot commented on FLINK-1523: --- Github user andralungu closed the pull

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

[ https://issues.apache.org/jira/browse/FLINK-1990?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=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...

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

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

[ https://issues.apache.org/jira/browse/FLINK-2019?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14545395#comment-14545395 ] ASF GitHub Bot commented on FLINK-2019: --- GitHub user rmetzger opened a pull request:

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

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:

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

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

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

[ https://issues.apache.org/jira/browse/FLINK-1525?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14545399#comment-14545399 ] ASF GitHub Bot commented on FLINK-1525: --- Github user rmetzger commented on the pull

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

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

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

[ 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] [Closed] (FLINK-1711) Replace all usages off commons.Validate with guava.check

[ 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

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

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

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

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

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

[ https://issues.apache.org/jira/browse/FLINK-1962?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14545434#comment-14545434 ] PJ Van Aeken commented on FLINK-1962: - So the fix works for the syntactic sugar. I

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

[ 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

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

[ https://issues.apache.org/jira/browse/FLINK-1962?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14545490#comment-14545490 ] Aljoscha Krettek commented on FLINK-1962: - I'm afraid it's the most elegant

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

[ https://issues.apache.org/jira/browse/FLINK-1962?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14545492#comment-14545492 ] Aljoscha Krettek commented on FLINK-1962: - This is the issue I filed:

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

[ https://issues.apache.org/jira/browse/FLINK-1830?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14545537#comment-14545537 ] Stefan Bunk commented on FLINK-1830: This did not happen again, so I cannot provide

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

[ 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

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

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

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

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

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

[ 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

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

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

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

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:

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

[ https://issues.apache.org/jira/browse/FLINK-1975?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14545646#comment-14545646 ] ASF GitHub Bot commented on FLINK-1975: --- Github user asfgit closed the pull request

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

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

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

[ 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] [Resolved] (FLINK-2019) Grouping by Joda DateTime field fails with Kryo exception

[ 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

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

[ https://issues.apache.org/jira/browse/FLINK-2019?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14545648#comment-14545648 ] ASF GitHub Bot commented on FLINK-2019: --- Github user asfgit closed the pull request

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

[ 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

  1   2   >