[jira] [Commented] (FLINK-1528) Add local clustering coefficient library method and example

2015-02-16 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1528?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14322906#comment-14322906 ] ASF GitHub Bot commented on FLINK-1528: --- Github user vasia commented on the pull

[jira] [Created] (FLINK-1557) Move WebFrontend out of JobManager Actor

2015-02-16 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-1557: --- Summary: Move WebFrontend out of JobManager Actor Key: FLINK-1557 URL: https://issues.apache.org/jira/browse/FLINK-1557 Project: Flink Issue Type: Improvement

[GitHub] flink pull request: [builds] Print Java process stack traces of st...

2015-02-16 Thread uce
Github user uce commented on the pull request: https://github.com/apache/flink/pull/389#issuecomment-74535643 Subsumed by #407. --- 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

[jira] [Commented] (FLINK-1514) [Gelly] Add a Gather-Sum-Apply iteration method

2015-02-16 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1514?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14323032#comment-14323032 ] ASF GitHub Bot commented on FLINK-1514: --- Github user balidani commented on a diff in

[GitHub] flink pull request: [FLINK-1528] Added local clustering coefficien...

2015-02-16 Thread vasia
Github user vasia commented on the pull request: https://github.com/apache/flink/pull/400#issuecomment-74527767 Right, so let me copy: The problem is here: ``` DataSetTuple2K, HashSetK neighborhoods = input.reduceOnEdges(new NeighborhoodEdgesFunctionK(),

[jira] [Created] (FLINK-1559) Normalize all Akka URLs to use IP addresses, not hostnames

2015-02-16 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-1559: --- Summary: Normalize all Akka URLs to use IP addresses, not hostnames Key: FLINK-1559 URL: https://issues.apache.org/jira/browse/FLINK-1559 Project: Flink Issue

[GitHub] flink pull request: [builds] Allow to upload build artifacts to S3

2015-02-16 Thread uce
GitHub user uce opened a pull request: https://github.com/apache/flink/pull/407 [builds] Allow to upload build artifacts to S3 This PR includes #389. Currently, logging of Travis builds is disabled as the log files are discarded after a build and stdout logging is limited

[GitHub] flink pull request: [builds] Print Java process stack traces of st...

2015-02-16 Thread uce
Github user uce closed the pull request at: https://github.com/apache/flink/pull/389 --- 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 enabled

[GitHub] flink pull request: [FLINK-1514][Gelly] Add a Gather-Sum-Apply ite...

2015-02-16 Thread balidani
Github user balidani commented on a diff in the pull request: https://github.com/apache/flink/pull/408#discussion_r24763748 --- Diff: flink-staging/flink-gelly/src/test/java/org/apache/flink/graph/test/GatherSumApplyITCase.java --- @@ -0,0 +1,212 @@ +/* + * Licensed to

[GitHub] flink pull request: [FLINK-1514][Gelly] Add a Gather-Sum-Apply ite...

2015-02-16 Thread balidani
GitHub user balidani opened a pull request: https://github.com/apache/flink/pull/408 [FLINK-1514][Gelly] Add a Gather-Sum-Apply iteration method You can merge this pull request into a Git repository by running: $ git pull https://github.com/balidani/flink gelly-gsa

[jira] [Commented] (FLINK-1514) [Gelly] Add a Gather-Sum-Apply iteration method

2015-02-16 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1514?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14323029#comment-14323029 ] ASF GitHub Bot commented on FLINK-1514: --- GitHub user balidani opened a pull request:

[jira] [Resolved] (FLINK-1454) CliFrontend blocks for 100 seconds when submitting to a non-existent JobManager

2015-02-16 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1454?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-1454. - Resolution: Fixed Fix Version/s: 0.9 Assignee: Stephan Ewen Fixed via

[GitHub] flink pull request: [FLINK-1454] [job client] Improve error handli...

2015-02-16 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/404#issuecomment-74563335 Manually merged in b941cf2d091bb38b9a45e1f2412136acae2b0f3f --- 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-1454) CliFrontend blocks for 100 seconds when submitting to a non-existent JobManager

2015-02-16 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1454?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14323204#comment-14323204 ] ASF GitHub Bot commented on FLINK-1454: --- Github user StephanEwen commented on the

[GitHub] flink pull request: [FLINK-785] Chained AllReduce / AllGroupReduce...

2015-02-16 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/370#issuecomment-74565386 I think we should use the chained reducer from this pull request and drop the chained combiner change. --- If your project is set up for it, you can reply to this

[jira] [Commented] (FLINK-1542) Test case at BlobUtilsTest should not assume user could not create new item in root directory

2015-02-16 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1542?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14323147#comment-14323147 ] ASF GitHub Bot commented on FLINK-1542: --- Github user StephanEwen commented on the

[jira] [Commented] (FLINK-1557) Move WebFrontend out of JobManager Actor

2015-02-16 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1557?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14323218#comment-14323218 ] ASF GitHub Bot commented on FLINK-1557: --- GitHub user StephanEwen opened a pull

[jira] [Commented] (FLINK-1542) Test case at BlobUtilsTest should not assume user could not create new item in root directory

2015-02-16 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1542?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14323150#comment-14323150 ] ASF GitHub Bot commented on FLINK-1542: --- Github user hsaputra commented on the pull

[GitHub] flink pull request: [FLINK-1542] Test case at BlobUtilsTest should...

2015-02-16 Thread hsaputra
Github user hsaputra commented on the pull request: https://github.com/apache/flink/pull/396#issuecomment-74558015 Thanks for the review Ufuk and Stephan. Also thx for Stephan for merging it. --- If your project is set up for it, you can reply to this email and have your

[GitHub] flink pull request: [FLINK-1454] [job client] Improve error handli...

2015-02-16 Thread StephanEwen
Github user StephanEwen closed the pull request at: https://github.com/apache/flink/pull/404 --- 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-1542) Test case at BlobUtilsTest should not assume user could not create new item in root directory

2015-02-16 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1542?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14323208#comment-14323208 ] ASF GitHub Bot commented on FLINK-1542: --- Github user asfgit closed the pull request

[GitHub] flink pull request: [FLINK-1521] Chained operators respect reuse

2015-02-16 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/392#issuecomment-74565272 At this point, we also have to worry about efficiency and performance. This is also something that the user can easily mitigate in the UDF, at a fraction of the

[GitHub] flink pull request: [FLINK-1542] Test case at BlobUtilsTest should...

2015-02-16 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/396 --- 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-1454) CliFrontend blocks for 100 seconds when submitting to a non-existent JobManager

2015-02-16 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1454?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14323205#comment-14323205 ] ASF GitHub Bot commented on FLINK-1454: --- Github user StephanEwen closed the pull

[jira] [Resolved] (FLINK-1559) Normalize all Akka URLs to use IP addresses, not hostnames

2015-02-16 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1559?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-1559. - Resolution: Fixed Fixed via 2dcff4c122f37ca58a485e886fec9295fef0c832 Normalize all Akka URLs to

[GitHub] flink pull request: [FLINK-1542] Test case at BlobUtilsTest should...

2015-02-16 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/396#issuecomment-74556700 Looks good to me as well. Will merge it with the next batch... --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub

[GitHub] flink pull request: [FLINK-1466] Add HCatInputFormats to read from...

2015-02-16 Thread fhueske
GitHub user fhueske opened a pull request: https://github.com/apache/flink/pull/411 [FLINK-1466] Add HCatInputFormats to read from HCatalog tables. Right now the Flink-tuple mode is restricted to primitive types (no ARRAY, STRUCT, and MAP types) and the max Java/Scala tuple width.

[jira] [Commented] (FLINK-947) Add support for Named Datasets

2015-02-16 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-947?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14323372#comment-14323372 ] ASF GitHub Bot commented on FLINK-947: -- Github user mbalassi commented on the pull

[jira] [Commented] (FLINK-947) Add support for Named Datasets

2015-02-16 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-947?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14323370#comment-14323370 ] ASF GitHub Bot commented on FLINK-947: -- Github user mbalassi commented on a diff in

[jira] [Commented] (FLINK-1542) Test case at BlobUtilsTest should not assume user could not create new item in root directory

2015-02-16 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1542?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14322791#comment-14322791 ] ASF GitHub Bot commented on FLINK-1542: --- Github user uce commented on the pull

[jira] [Commented] (FLINK-1554) LocalFlinkMiniCluster cannot start multiple local TaskManagers

2015-02-16 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1554?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14322797#comment-14322797 ] ASF GitHub Bot commented on FLINK-1554: --- GitHub user tillrohrmann opened a pull

[GitHub] flink pull request: [FLINK-1454] [job client] Improve error handli...

2015-02-16 Thread StephanEwen
GitHub user StephanEwen opened a pull request: https://github.com/apache/flink/pull/404 [FLINK-1454] [job client] Improve error handling for failed connections between JobClient and JobManager - Decreases time until connection failure is discovered. - Improves error

[jira] [Commented] (FLINK-1549) Add proper exception handling for YarnJobManager

2015-02-16 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1549?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14322787#comment-14322787 ] ASF GitHub Bot commented on FLINK-1549: --- Github user mxm commented on the pull

[jira] [Created] (FLINK-1554) LocalFlinkMiniCluster cannot start multiple local TaskManagers

2015-02-16 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-1554: Summary: LocalFlinkMiniCluster cannot start multiple local TaskManagers Key: FLINK-1554 URL: https://issues.apache.org/jira/browse/FLINK-1554 Project: Flink

[jira] [Commented] (FLINK-1454) CliFrontend blocks for 100 seconds when submitting to a non-existent JobManager

2015-02-16 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1454?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14322803#comment-14322803 ] ASF GitHub Bot commented on FLINK-1454: --- GitHub user StephanEwen opened a pull

[GitHub] flink pull request: [FLINK-1231] Add test for streaming remote exe...

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

[GitHub] flink pull request: StreamWindow abstraction + modular window comp...

2015-02-16 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/395 --- 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] [Closed] (FLINK-1231) Add test for streaming remote execution

2015-02-16 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-1231?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi closed FLINK-1231. - Resolution: Fixed Implemented via 26ae979 Add test for streaming remote execution

[jira] [Closed] (FLINK-1539) Runtime context not initialized when running streaming PojoExample

2015-02-16 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-1539?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi closed FLINK-1539. - Resolution: Fixed Fixed via 4470207 Runtime context not initialized when running streaming

[jira] [Commented] (FLINK-1417) Automatically register nested types at Kryo

2015-02-16 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1417?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14322736#comment-14322736 ] ASF GitHub Bot commented on FLINK-1417: --- Github user aljoscha commented on a diff in

[GitHub] flink pull request: [FLINK-1417] Automatically register types with...

2015-02-16 Thread aljoscha
Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/393#discussion_r24749284 --- Diff: flink-core/src/main/java/org/apache/flink/api/common/ExecutionConfig.java --- @@ -292,7 +360,76 @@ public void registerKryoType(Class? type) {

[jira] [Commented] (FLINK-1542) Test case at BlobUtilsTest should not assume user could not create new item in root directory

2015-02-16 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1542?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14322699#comment-14322699 ] ASF GitHub Bot commented on FLINK-1542: --- Github user hsaputra commented on the pull

[GitHub] flink pull request: Fix standalone plan visualizer for 0.8 branch

2015-02-16 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/401 --- 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-1552) Allow secondary sorts in Vertex Centric Iteration

2015-02-16 Thread Vasia Kalavri (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1552?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14322766#comment-14322766 ] Vasia Kalavri commented on FLINK-1552: -- This would be very useful to have! Would you

[jira] [Commented] (FLINK-1417) Automatically register nested types at Kryo

2015-02-16 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1417?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14322743#comment-14322743 ] ASF GitHub Bot commented on FLINK-1417: --- Github user aljoscha commented on the pull

[jira] [Created] (FLINK-1560) Add ITCases for streaming examples

2015-02-16 Thread JIRA
Márton Balassi created FLINK-1560: - Summary: Add ITCases for streaming examples Key: FLINK-1560 URL: https://issues.apache.org/jira/browse/FLINK-1560 Project: Flink Issue Type: Test

[jira] [Created] (FLINK-1555) Add utility to log the serializers of composite types

2015-02-16 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-1555: - Summary: Add utility to log the serializers of composite types Key: FLINK-1555 URL: https://issues.apache.org/jira/browse/FLINK-1555 Project: Flink Issue

[GitHub] flink pull request: [FLINK-947] Add a declarative expression API

2015-02-16 Thread aljoscha
GitHub user aljoscha opened a pull request: https://github.com/apache/flink/pull/405 [FLINK-947] Add a declarative expression API This one is quite big. So you should check out the documentation, skaldic, examples and test cases to see how the API works. You can merge this pull

[jira] [Created] (FLINK-1556) JobClient does not wait until a job failed completely if submission exception

2015-02-16 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-1556: Summary: JobClient does not wait until a job failed completely if submission exception Key: FLINK-1556 URL: https://issues.apache.org/jira/browse/FLINK-1556 Project:

[GitHub] flink pull request: [FLINK-1515]Splitted runVertexCentricIteration...

2015-02-16 Thread vasia
Github user vasia commented on the pull request: https://github.com/apache/flink/pull/402#issuecomment-74525590 Hi @martinkiefer! Thanks a lot for this pull request! The change looks good :) I was only thinking that it would be nice to have an example that demonstrates

[jira] [Commented] (FLINK-1515) [Gelly] Enable access to aggregators and broadcast sets in vertex-centric iteration

2015-02-16 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1515?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14322886#comment-14322886 ] ASF GitHub Bot commented on FLINK-1515: --- Github user vasia commented on the pull

[jira] [Commented] (FLINK-1528) Add local clustering coefficient library method and example

2015-02-16 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1528?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14322649#comment-14322649 ] ASF GitHub Bot commented on FLINK-1528: --- Github user vasia commented on the pull

[GitHub] flink pull request: [FLINK-1231] Add test for streaming remote exe...

2015-02-16 Thread mbalassi
Github user mbalassi commented on the pull request: https://github.com/apache/flink/pull/303#issuecomment-74480487 Sorry for the late reply. Thanks for the great PR, I wanted to merge it for quite some time. It turns out that this test is redundant given the 6bec228 I've pushed last

[jira] [Commented] (FLINK-1231) Add test for streaming remote execution

2015-02-16 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1231?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14322565#comment-14322565 ] ASF GitHub Bot commented on FLINK-1231: --- Github user mbalassi commented on the pull

[GitHub] flink pull request: StreamWindow abstraction + modular window comp...

2015-02-16 Thread mbalassi
Github user mbalassi commented on a diff in the pull request: https://github.com/apache/flink/pull/395#discussion_r24737233 --- Diff: docs/streaming_guide.md --- @@ -383,9 +389,40 @@ dataStream.groupBy(groupingField).window(Count.of(100)).every(…).max(field); This

[GitHub] flink pull request: StreamWindow abstraction + modular window comp...

2015-02-16 Thread mbalassi
Github user mbalassi commented on a diff in the pull request: https://github.com/apache/flink/pull/395#discussion_r24737330 --- Diff: docs/streaming_guide.md --- @@ -857,7 +895,7 @@ After installing Docker an image can be pulled for each connector. Containers ca For the

[jira] [Closed] (FLINK-1551) Fix History view of JobManager web interface

2015-02-16 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1551?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-1551. Resolution: Fixed Fixed via 055f6dc3eb8705dbbfb04e44965a85cbfc0b10db Fix History view of

[jira] [Created] (FLINK-1553) Kafka connectors rework

2015-02-16 Thread JIRA
Gábor Hermann created FLINK-1553: Summary: Kafka connectors rework Key: FLINK-1553 URL: https://issues.apache.org/jira/browse/FLINK-1553 Project: Flink Issue Type: Bug Components: