[GitHub] flink pull request: [FLINK-1641] Make projection operator chainabl...

GitHub user ggevay opened a pull request: https://github.com/apache/flink/pull/489 [FLINK-1641] Make projection operator chainable. I tested this by adding a dummy project to the WordCount example, by adding .project(0, 1).types(String.class, Integer.class) to line 70.

[jira] [Commented] (FLINK-1641) Make projection operator chainable

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

[GitHub] flink pull request: [FLINK-1688] Socket client sink added

Github user mxm commented on a diff in the pull request: https://github.com/apache/flink/pull/484#discussion_r26483463 --- Diff: flink-staging/flink-streaming/flink-streaming-connectors/src/main/java/org/apache/flink/streaming/connectors/socket/SocketClientSink.java --- @@ -0,0

[GitHub] flink pull request: [FLINK-1342] Fix filtering of usercode from qu...

Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/486#issuecomment-81682932 Looks good to me. --- 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] [Commented] (FLINK-1342) Quickstart's assembly can possibly filter out user's code

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

[jira] [Commented] (FLINK-1633) Add getTriplets() Gelly method

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

[jira] [Commented] (FLINK-1633) Add getTriplets() Gelly method

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

[GitHub] flink pull request: [FLINK-1633][gelly] Added getTriplets() method...

Github user vasia commented on a diff in the pull request: https://github.com/apache/flink/pull/452#discussion_r26487206 --- Diff: flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/example/EuclideanGraphExample.java --- @@ -0,0 +1,231 @@ +/* + * Licensed to

[jira] [Commented] (FLINK-1688) Add socket sink

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

[jira] [Commented] (FLINK-1633) Add getTriplets() Gelly method

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

[jira] [Commented] (FLINK-1520) Read edges and vertices from CSV files

[ https://issues.apache.org/jira/browse/FLINK-1520?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14363270#comment-14363270 ] Vasia Kalavri commented on FLINK-1520: -- Hi [~cebe]! Are you working on this? If

[jira] [Commented] (FLINK-1633) Add getTriplets() Gelly method

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

[GitHub] flink pull request: [FLINK-1342] Fix filtering of usercode from qu...

GitHub user rmetzger opened a pull request: https://github.com/apache/flink/pull/486 [FLINK-1342] Fix filtering of usercode from quickstart With this change, we'll not just exclude everything from the org.apache.flink groupid. This has caused many troubles to users because

[jira] [Assigned] (FLINK-1699) Co-task sometimes returns null

[ https://issues.apache.org/jira/browse/FLINK-1699?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gábor Hermann reassigned FLINK-1699: Assignee: Gábor Hermann Co-task sometimes returns null --

[GitHub] flink pull request: [FLINK-1688] Socket client sink added

Github user mxm commented on the pull request: https://github.com/apache/flink/pull/484#issuecomment-81665515 Thanks for the pull request. Could you add some javadoc to the class and add an entry in the Flink website docs [1]? [1]

[GitHub] flink pull request: [FLINK-1633][gelly] Added getTriplets() method...

Github user andralungu commented on a diff in the pull request: https://github.com/apache/flink/pull/452#discussion_r26487168 --- Diff: flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/example/EuclideanGraphExample.java --- @@ -0,0 +1,231 @@ +/* + * Licensed

[GitHub] flink pull request: [FLINK-1633][gelly] Added getTriplets() method...

Github user vasia commented on a diff in the pull request: https://github.com/apache/flink/pull/452#discussion_r26487008 --- Diff: flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/example/EuclideanGraphExample.java --- @@ -0,0 +1,231 @@ +/* + * Licensed to

[jira] [Commented] (FLINK-1633) Add getTriplets() Gelly method

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

[jira] [Commented] (FLINK-1633) Add getTriplets() Gelly method

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

[jira] [Commented] (FLINK-1688) Add socket sink

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

[GitHub] flink pull request: [FLINK-1688] Socket client sink added

Github user mxm commented on a diff in the pull request: https://github.com/apache/flink/pull/484#discussion_r26483484 --- Diff: flink-staging/flink-streaming/flink-streaming-connectors/src/main/java/org/apache/flink/streaming/connectors/socket/SocketClientSink.java --- @@ -0,0

[GitHub] flink pull request: [FLINK-1688] Socket client sink added

Github user mxm commented on a diff in the pull request: https://github.com/apache/flink/pull/484#discussion_r26483479 --- Diff: flink-staging/flink-streaming/flink-streaming-connectors/src/main/java/org/apache/flink/streaming/connectors/socket/SocketClientSink.java --- @@ -0,0

[jira] [Commented] (FLINK-1688) Add socket sink

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

[jira] [Commented] (FLINK-1633) Add getTriplets() Gelly method

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

[GitHub] flink pull request: [FLINK-1633][gelly] Added getTriplets() method...

Github user vasia commented on a diff in the pull request: https://github.com/apache/flink/pull/452#discussion_r26486364 --- Diff: flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/example/EuclideanGraphExample.java --- @@ -0,0 +1,231 @@ +/* + * Licensed to

[jira] [Commented] (FLINK-1633) Add getTriplets() Gelly method

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

[GitHub] flink pull request: [FLINK-1633][gelly] Added getTriplets() method...

Github user vasia commented on a diff in the pull request: https://github.com/apache/flink/pull/452#discussion_r26487167 --- Diff: flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/example/EuclideanGraphExample.java --- @@ -0,0 +1,231 @@ +/* + * Licensed to

[jira] [Commented] (FLINK-1688) Add socket sink

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

[jira] [Commented] (FLINK-1342) Quickstart's assembly can possibly filter out user's code

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

[jira] [Commented] (FLINK-1633) Add getTriplets() Gelly method

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

[GitHub] flink pull request: [FLINK-1633][gelly] Added getTriplets() method...

Github user vasia commented on a diff in the pull request: https://github.com/apache/flink/pull/452#discussion_r26486381 --- Diff: flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/example/EuclideanGraphExample.java --- @@ -0,0 +1,231 @@ +/* + * Licensed to

[jira] [Commented] (FLINK-1633) Add getTriplets() Gelly method

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

[jira] [Commented] (FLINK-1540) JobManagerFailsITCase Startup timed out on travis

[ https://issues.apache.org/jira/browse/FLINK-1540?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14362993#comment-14362993 ] Stephan Ewen commented on FLINK-1540: - I think it was also an issue of the earlier

[jira] [Commented] (FLINK-1618) Add parallel time discretisation for time-window transformations

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

[jira] [Created] (FLINK-1706) Add disk spilling to BarrierBuffer

Gyula Fora created FLINK-1706: - Summary: Add disk spilling to BarrierBuffer Key: FLINK-1706 URL: https://issues.apache.org/jira/browse/FLINK-1706 Project: Flink Issue Type: Improvement

[GitHub] flink pull request: [FLINK-1622][java-api][scala-api] add a GroupC...

Github user mxm commented on a diff in the pull request: https://github.com/apache/flink/pull/466#discussion_r26471022 --- Diff: flink-compiler/src/main/java/org/apache/flink/compiler/operators/GroupCombineProperties.java --- @@ -0,0 +1,112 @@ +/* + * Licensed to the

[jira] [Commented] (FLINK-1534) GSoC project: Distributed pattern matching over Flink streaming

[ https://issues.apache.org/jira/browse/FLINK-1534?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14363009#comment-14363009 ] Márton Balassi commented on FLINK-1534: --- Hey, FilterFunctions unfortunately operate

[jira] [Commented] (FLINK-1699) Co-task sometimes returns null

[ https://issues.apache.org/jira/browse/FLINK-1699?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14363049#comment-14363049 ] Gábor Hermann commented on FLINK-1699: -- This was probably caused by using static

[GitHub] flink pull request: Add support for building Flink with Scala 2.11

Github user aalexandrov commented on the pull request: https://github.com/apache/flink/pull/477#issuecomment-8159 H... now it passes. This is weird... --- 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

[jira] [Commented] (FLINK-1622) Add GroupReducePartial Operator

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

[jira] [Resolved] (FLINK-1691) Inprove CountCollectITCase

[ https://issues.apache.org/jira/browse/FLINK-1691?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-1691. - Resolution: Fixed Assignee: Stephan Ewen (was: Maximilian Michels) Fixed via

[GitHub] flink pull request: [FLINK-1618] [streaming] Parallel time reduce

GitHub user gyfora opened a pull request: https://github.com/apache/flink/pull/485 [FLINK-1618] [streaming] Parallel time reduce This commit introduces a new critical feature for the windowing api, which allows parallel discretization and reduce over Time windows. You can merge

[jira] [Commented] (FLINK-1540) JobManagerFailsITCase Startup timed out on travis

[ https://issues.apache.org/jira/browse/FLINK-1540?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14362985#comment-14362985 ] Ufuk Celebi commented on FLINK-1540: Is this resolved? JobManagerFailsITCase Startup

[jira] [Assigned] (FLINK-1707) Add an Affinity Propagation Library Method

[ https://issues.apache.org/jira/browse/FLINK-1707?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] joey reassigned FLINK-1707: --- Assignee: joey Add an Affinity Propagation Library Method --

[jira] [Assigned] (FLINK-1687) Streaming file source/sink API is not in sync with the batch API

[ https://issues.apache.org/jira/browse/FLINK-1687?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Péter Szabó reassigned FLINK-1687: -- Assignee: Péter Szabó Streaming file source/sink API is not in sync with the batch API

[jira] [Created] (FLINK-1709) Add support for programs with higher-than-slot parallelism

Ufuk Celebi created FLINK-1709: -- Summary: Add support for programs with higher-than-slot parallelism Key: FLINK-1709 URL: https://issues.apache.org/jira/browse/FLINK-1709 Project: Flink Issue

[GitHub] flink pull request: Cleanup of low level Kafka consumer (Persisten...

Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/474#issuecomment-81792049 There are no tests for the Kafka connectors. The code is not working. I've fixed an issue with the classloading already:

[jira] [Commented] (FLINK-1622) Add GroupReducePartial Operator

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

[GitHub] flink pull request: [FLINK-1622][java-api][scala-api] add a GroupC...

Github user hsaputra commented on the pull request: https://github.com/apache/flink/pull/466#issuecomment-81777035 HI @mxm, appreciate the ACK. Just trying to keep up all informed with more code coming in. It is harder to read other people code and flow so was just trying to ease

[jira] [Created] (FLINK-1710) Expression API Tests take very long

Stephan Ewen created FLINK-1710: --- Summary: Expression API Tests take very long Key: FLINK-1710 URL: https://issues.apache.org/jira/browse/FLINK-1710 Project: Flink Issue Type: Bug

[jira] [Assigned] (FLINK-1679) Document how degree of parallelism / parallelism / slots are connected to each other

[ https://issues.apache.org/jira/browse/FLINK-1679?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels reassigned FLINK-1679: - Assignee: Maximilian Michels (was: Ufuk Celebi) Document how degree of

[jira] [Commented] (FLINK-1632) Use DataSet's count() and collect() to simplify Gelly methods

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

[GitHub] flink pull request: [FLINK-1632][gelly] Deleted GraphUtils

Github user vasia commented on the pull request: https://github.com/apache/flink/pull/462#issuecomment-81756505 Thanks for the revision @andralungu! This makes the Gelly methods you changed much more user-friendly. Since, count() and collect() are just used to return a single

[GitHub] flink pull request: [FLINK-1695] Kick off of Flink's machine learn...

Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/479#discussion_r26506880 --- Diff: docs/ml/alternating_least_squares.md --- @@ -0,0 +1,157 @@ +--- +mathjax: include +title: Alternating Least Squares +---

[jira] [Commented] (FLINK-1695) Create machine learning library

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

[jira] [Commented] (FLINK-1695) Create machine learning library

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

[jira] [Commented] (FLINK-1695) Create machine learning library

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

[jira] [Commented] (FLINK-1679) Document how degree of parallelism / parallelism / slots are connected to each other

[ https://issues.apache.org/jira/browse/FLINK-1679?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14363550#comment-14363550 ] Maximilian Michels commented on FLINK-1679: --- I would be up for setting the

[GitHub] flink pull request: Cleanup of low level Kafka consumer (Persisten...

Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/474#issuecomment-81813382 I think we should add a integration test with a local kafka cluster: https://github.com/sakserv/hadoop-mini-clusters --- If your project is set up for it, you can reply

[GitHub] flink pull request: [FLINK-1695] Kick off of Flink's machine learn...

Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/479#discussion_r26506950 --- Diff: docs/ml/alternating_least_squares.md --- @@ -0,0 +1,157 @@ +--- +mathjax: include +title: Alternating Least Squares +---

[jira] [Commented] (FLINK-1679) Document how degree of parallelism / parallelism / slots are connected to each other

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

[jira] [Commented] (FLINK-1615) Introduces a new InputFormat for Tweets

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

[GitHub] flink pull request: [FLINK-1615] [java api] SimpleTweetInputFormat

Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/442#issuecomment-81837584 Have a look at the build server logs. They still complain about unapproved license headers. --- If your project is set up for it, you can reply to this email and

[jira] [Commented] (FLINK-1695) Create machine learning library

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

[GitHub] flink pull request: [FLINK-1695] Kick off of Flink's machine learn...

Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/479#discussion_r26507028 --- Diff: docs/ml/polynomial_base_feature_mapper.md --- @@ -0,0 +1,91 @@ +--- +mathjax: include +title: Polynomial Base Feature Mapper

[jira] [Commented] (FLINK-1695) Create machine learning library

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

[jira] [Commented] (FLINK-1695) Create machine learning library

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

[GitHub] flink pull request: [FLINK-1671] Add different execution modes to ...

GitHub user StephanEwen opened a pull request: https://github.com/apache/flink/pull/487 [FLINK-1671] Add different execution modes to APIs and optimizer. This allows users to specify how programs should be executed: - PIPELINED: Uses pipelining for shuffling, except where the

[GitHub] flink pull request: [FLINK-1679] rename degree of parallelism to p...

GitHub user mxm opened a pull request: https://github.com/apache/flink/pull/488 [FLINK-1679] rename degree of parallelism to parallelism extend documentation about parallelism You can merge this pull request into a Git repository by running: $ git pull

[jira] [Resolved] (FLINK-1370) Build website automatically

[ https://issues.apache.org/jira/browse/FLINK-1370?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels resolved FLINK-1370. --- Resolution: Implemented Build website automatically ---

[GitHub] flink pull request: Cleanup of low level Kafka consumer (Persisten...

Github user gaborhermann commented on the pull request: https://github.com/apache/flink/pull/474#issuecomment-81948052 Thanks for the fix. How can the above job execution failure be reproduced? I agree with adding the integration test. --- If your project is set up for

[GitHub] flink pull request: [FLINK-1695] Kick off of Flink's machine learn...

Github user hsaputra commented on a diff in the pull request: https://github.com/apache/flink/pull/479#discussion_r26526474 --- Diff: flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/common/FlinkTools.scala --- @@ -0,0 +1,259 @@ +/* + * Licensed to the Apache

[jira] [Commented] (FLINK-1695) Create machine learning library

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

[jira] [Commented] (FLINK-1558) Spurious failure in PipelinedPartitionQueueTest

[ https://issues.apache.org/jira/browse/FLINK-1558?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14362837#comment-14362837 ] Ufuk Celebi commented on FLINK-1558: This should be fixed in

[jira] [Commented] (FLINK-1615) Introduces a new InputFormat for Tweets

[ https://issues.apache.org/jira/browse/FLINK-1615?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14363685#comment-14363685 ] Henry Saputra commented on FLINK-1615: -- Why did you set the Resolution to Resolved?

[GitHub] flink pull request: Add support for building Flink with Scala 2.11

Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/477#issuecomment-81870329 I am very much in favor of adding a _2.11 suffix to the scala 2.11 artifacts. If we do not interfere with the names of the 2.10 version, there should be no problem,

[jira] [Resolved] (FLINK-1690) ProcessFailureBatchRecoveryITCase.testTaskManagerProcessFailure spuriously fails on Travis

[ https://issues.apache.org/jira/browse/FLINK-1690?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi resolved FLINK-1690. Resolution: Fixed Fixed in 81ebe980a9604173d25a194805d1d868687a1ba3.