[jira] [Closed] (FLINK-1923) Replace asynchronous logging in JobManager with regular slf4j logging

[ https://issues.apache.org/jira/browse/FLINK-1923?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-1923. --- Replace asynchronous logging in JobManager with regular slf4j logging

[jira] [Commented] (FLINK-1933) Add distance measure interface and basic implementation to machine learning library

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

[jira] [Resolved] (FLINK-1923) Replace asynchronous logging in JobManager with regular slf4j logging

[ https://issues.apache.org/jira/browse/FLINK-1923?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-1923. - Resolution: Fixed Fix Version/s: 0.9 Fixed via 5a2ca81912193552e74cd6a33637b7254e5a7174

[GitHub] flink pull request: [WIP] - [FLINK-1807/1889] - Optimization frame...

Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/613#discussion_r29323051 --- Diff: flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/optimization/GradientDescent.scala --- @@ -0,0 +1,237 @@ +/* + * Licensed to

[jira] [Closed] (FLINK-1922) Failed task deployment causes NPE on input split assignment

[ https://issues.apache.org/jira/browse/FLINK-1922?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-1922. --- Failed task deployment causes NPE on input split assignment

[jira] [Commented] (FLINK-1925) Split SubmitTask method up into two phases: Receive TDD and instantiation of TDD

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

[GitHub] flink pull request: [FLINK-1933] Add distance measure interface an...

Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/629#discussion_r29320587 --- Diff: flink-staging/flink-ml/src/test/scala/org/apache/flink/ml/math/SparseVectorSuite.scala --- @@ -87,4 +87,33 @@ class SparseVectorSuite extends

[jira] [Commented] (FLINK-1807) Stochastic gradient descent optimizer for ML library

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

[GitHub] flink pull request: [FLINK-1933] Add distance measure interface an...

Github user tillrohrmann commented on the pull request: https://github.com/apache/flink/pull/629#issuecomment-97368054 Hi @chiwanpark. Really good work :-) I had only some minor comments. One think to think about is where we place the distance measures. Currently it is in the

[GitHub] flink pull request: [FLINK-1927] [py] Operator distribution rework

Github user mxm commented on the pull request: https://github.com/apache/flink/pull/638#issuecomment-97353102 Wow! Great to see that we get rid of the only python-side dependency. It was a bit unclear under which terms we could ship the library anyways. Have you done any measurements

[GitHub] flink pull request: [FLINK-1923] Replaces asynchronous logging wit...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/628 --- 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-1933) Add distance measure interface and basic implementation to machine learning library

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

[GitHub] flink pull request: [FLINK-1927] [py] Operator distribution rework

Github user zentol commented on the pull request: https://github.com/apache/flink/pull/638#issuecomment-97389037 I didn't check performance, it shouldn't have any noticeable effect on it. --- If your project is set up for it, you can reply to this email and have your reply appear on

[jira] [Commented] (FLINK-1927) [Py] Rework operator distribution

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

[GitHub] flink pull request: [FLINK-1948] [streaming] Manual task slot shar...

Github user mbalassi commented on a diff in the pull request: https://github.com/apache/flink/pull/634#discussion_r29328859 --- Diff: flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/datastream/SingleOutputStreamOperator.java --- @@

[GitHub] flink pull request: [FLINK-1948] [streaming] Manual task slot shar...

Github user mbalassi commented on a diff in the pull request: https://github.com/apache/flink/pull/634#discussion_r29328953 --- Diff: flink-staging/flink-streaming/flink-streaming-scala/src/main/scala/org/apache/flink/streaming/api/scala/DataStream.scala --- @@ -95,9 +95,67 @@

[GitHub] flink pull request: [FLINK-1948] [streaming] Manual task slot shar...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/634 --- 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-1807) Stochastic gradient descent optimizer for ML library

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

[jira] [Commented] (FLINK-1948) Add manual task slot handling for streaming jobs

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

[jira] [Commented] (FLINK-1807) Stochastic gradient descent optimizer for ML library

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

[jira] [Commented] (FLINK-1911) DataStream and DataSet projection is out of sync

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

[jira] [Commented] (FLINK-1927) [Py] Rework operator distribution

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

[GitHub] flink pull request: [FLINK-1927] [py] Operator distribution rework

Github user zentol commented on the pull request: https://github.com/apache/flink/pull/638#issuecomment-97417603 @aljoscha that variable must be declared somewhere within the plan file. during the plan rebuild this would be executed as well, so i don't think this is a problem. in

[jira] [Commented] (FLINK-1927) [Py] Rework operator distribution

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

[jira] [Commented] (FLINK-1927) [Py] Rework operator distribution

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

[jira] [Commented] (FLINK-1948) Add manual task slot handling for streaming jobs

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

[GitHub] flink pull request: [FLINK-1843] remove SoftReferences on archived...

GitHub user mxm opened a pull request: https://github.com/apache/flink/pull/639 [FLINK-1843] remove SoftReferences on archived ExecutionGraphs The previously introduced SoftReferences to store archived execution graphs cleared old graphs in a non-transparent order. This pull

[GitHub] flink pull request: [FLINK-1911] [streaming] Streaming projection ...

Github user mbalassi commented on a diff in the pull request: https://github.com/apache/flink/pull/630#discussion_r29330901 --- Diff: flink-staging/flink-streaming/flink-streaming-core/src/test/java/org/apache/flink/streaming/api/operators/ProjectWithoutClassTest.java --- @@ -0,0

[GitHub] flink pull request: [WIP] - [FLINK-1807/1889] - Optimization frame...

Github user thvasilo commented on a diff in the pull request: https://github.com/apache/flink/pull/613#discussion_r29330897 --- Diff: flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/optimization/GradientDescent.scala --- @@ -0,0 +1,237 @@ +/* + * Licensed to the

[jira] [Commented] (FLINK-1807) Stochastic gradient descent optimizer for ML library

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

[GitHub] flink pull request: [FLINK-1927] [py] Operator distribution rework

Github user aljoscha commented on the pull request: https://github.com/apache/flink/pull/638#issuecomment-97412959 But doesn't this mean that the lambdas now must be stateless, i.e. if a user refers to some variable outside the lambda this will not be serialised with the closure

[jira] [Commented] (FLINK-1927) [Py] Rework operator distribution

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

[jira] [Commented] (FLINK-1843) Job History gets cleared too fast

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

[jira] [Commented] (FLINK-1911) DataStream and DataSet projection is out of sync

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

[GitHub] flink pull request: [FLINK-1927] [py] Operator distribution rework

Github user zentol commented on the pull request: https://github.com/apache/flink/pull/638#issuecomment-97418740 oh snap i just noticed a big flaw... well let's put this PR on hold for a bit. I'm simply re executing the plan file on each node, but forgot to deal with

[jira] [Assigned] (FLINK-1636) Improve error handling when partitions not found

[ https://issues.apache.org/jira/browse/FLINK-1636?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi reassigned FLINK-1636: -- Assignee: Ufuk Celebi Improve error handling when partitions not found

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

Github user aljoscha commented on the pull request: https://github.com/apache/flink/pull/621#issuecomment-97401561 Our travis builds are a bit unstable right now. I'm running some last tests and then I'll merge this. Thanks for staying with this and working on my requests! :smile:

[GitHub] flink pull request: [WIP] - [FLINK-1807/1889] - Optimization frame...

Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/613#discussion_r29329016 --- Diff: flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/optimization/GradientDescent.scala --- @@ -0,0 +1,237 @@ +/* + * Licensed to

[jira] [Commented] (FLINK-1948) Add manual task slot handling for streaming jobs

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

[GitHub] flink pull request: [FLINK-1948] [streaming] Manual task slot shar...

Github user mbalassi commented on a diff in the pull request: https://github.com/apache/flink/pull/634#discussion_r29328976 --- Diff: flink-staging/flink-streaming/flink-streaming-scala/src/main/scala/org/apache/flink/streaming/api/scala/StreamExecutionEnvironment.scala --- @@

[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=14519207#comment-14519207 ] ASF GitHub Bot commented on FLINK-1615: --- Github user aljoscha commented on the pull

[GitHub] flink pull request: [WIP] - [FLINK-1807/1889] - Optimization frame...

Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/613#discussion_r29329048 --- Diff: flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/optimization/GradientDescent.scala --- @@ -0,0 +1,237 @@ +/* + * Licensed to

[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=14519211#comment-14519211 ] ASF GitHub Bot commented on FLINK-1615: --- Github user Elbehery commented on the pull

[jira] [Closed] (FLINK-1948) Add manual task slot handling for streaming jobs

[ https://issues.apache.org/jira/browse/FLINK-1948?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi closed FLINK-1948. - Resolution: Implemented Fix Version/s: 0.9 Implemented via ca82b0c Add manual task slot

[jira] [Commented] (FLINK-1843) Job History gets cleared too fast

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

[jira] [Commented] (FLINK-1953) Rework Checkpoint Coordinator

[ https://issues.apache.org/jira/browse/FLINK-1953?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14519058#comment-14519058 ] Stephan Ewen commented on FLINK-1953: - First part implemented in

[jira] [Commented] (FLINK-1922) Failed task deployment causes NPE on input split assignment

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

[GitHub] flink pull request: [WIP] - [FLINK-1807/1889] - Optimization frame...

Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/613#discussion_r29322598 --- Diff: docs/libs/ml/optimization.md --- @@ -0,0 +1,218 @@ +--- +mathjax: include +title: ML - Optimization +displayTitle: a

[jira] [Commented] (FLINK-1933) Add distance measure interface and basic implementation to machine learning library

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

[jira] [Commented] (FLINK-1807) Stochastic gradient descent optimizer for ML library

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

[jira] [Commented] (FLINK-1807) Stochastic gradient descent optimizer for ML library

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

[GitHub] flink pull request: [FLINK-1925] Fixes blocking method submitTask ...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/622 --- 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: [FLINK-1933] Add distance measure interface an...

Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/629#discussion_r29319548 --- Diff: flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/math/DenseVector.scala --- @@ -80,6 +80,27 @@ case class DenseVector(val data:

[jira] [Closed] (FLINK-1925) Split SubmitTask method up into two phases: Receive TDD and instantiation of TDD

[ https://issues.apache.org/jira/browse/FLINK-1925?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-1925. --- Split SubmitTask method up into two phases: Receive TDD and instantiation of TDD

[jira] [Updated] (FLINK-1956) Runtime context not initialized in RichWindowMapFunction

[ https://issues.apache.org/jira/browse/FLINK-1956?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Bali updated FLINK-1956: --- Description: Trying to access the runtime context in a rich window map function results in an

[jira] [Created] (FLINK-1957) Improve error handling of transport failures

Ufuk Celebi created FLINK-1957: -- Summary: Improve error handling of transport failures Key: FLINK-1957 URL: https://issues.apache.org/jira/browse/FLINK-1957 Project: Flink Issue Type:

[jira] [Updated] (FLINK-1956) Runtime context not initialized in RichWindowMapFunction

[ https://issues.apache.org/jira/browse/FLINK-1956?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Bali updated FLINK-1956: --- Description: Trying to access the runtime context in a rich window map function results in an

[jira] [Updated] (FLINK-1956) Runtime context not initialized in RichWindowMapFunction

[ https://issues.apache.org/jira/browse/FLINK-1956?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Bali updated FLINK-1956: --- Description: Trying to access the runtime context in a rich window map function results in an

[jira] [Commented] (FLINK-1933) Add distance measure interface and basic implementation to machine learning library

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

[GitHub] flink pull request: [WIP] - [FLINK-1807/1889] - Optimization frame...

Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/613#discussion_r29322782 --- Diff: docs/libs/ml/optimization.md --- @@ -0,0 +1,218 @@ +--- +mathjax: include +title: ML - Optimization +displayTitle: a

[GitHub] flink pull request: [FLINK-1933] Add distance measure interface an...

Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/629#discussion_r29318498 --- Diff: flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/common/distance/MinkowskiDistanceMeasure.scala --- @@ -0,0 +1,41 @@ +/* + *

[jira] [Commented] (FLINK-1933) Add distance measure interface and basic implementation to machine learning library

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

[GitHub] flink pull request: [FLINK-1933] Add distance measure interface an...

Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/629#discussion_r29318238 --- Diff: flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/common/distance/DistanceMeasure.scala --- @@ -0,0 +1,37 @@ +/* + * Licensed

[GitHub] flink pull request: [WIP] - [FLINK-1807/1889] - Optimization frame...

Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/613#discussion_r29323162 --- Diff: flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/optimization/GradientDescent.scala --- @@ -0,0 +1,237 @@ +/* + * Licensed to

[jira] [Commented] (FLINK-1636) Misleading exception during concurrent partition release and remote request

[ https://issues.apache.org/jira/browse/FLINK-1636?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14519097#comment-14519097 ] Ufuk Celebi commented on FLINK-1636: This is an artifact of failing/cancelling sender

[jira] [Commented] (FLINK-1807) Stochastic gradient descent optimizer for ML library

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

[GitHub] flink pull request: [WIP] - [FLINK-1807/1889] - Optimization frame...

Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/613#discussion_r29323147 --- Diff: flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/optimization/GradientDescent.scala --- @@ -0,0 +1,237 @@ +/* + * Licensed to

[jira] [Commented] (FLINK-1807) Stochastic gradient descent optimizer for ML library

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

[jira] [Created] (FLINK-1956) Runtime context not initialized in RichWindowMapFunction

Daniel Bali created FLINK-1956: -- Summary: Runtime context not initialized in RichWindowMapFunction Key: FLINK-1956 URL: https://issues.apache.org/jira/browse/FLINK-1956 Project: Flink Issue

[jira] [Updated] (FLINK-1956) Runtime context not initialized in RichWindowMapFunction

[ https://issues.apache.org/jira/browse/FLINK-1956?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Bali updated FLINK-1956: --- Description: Trying to access the runtime context in a rich window map function results in an

[GitHub] flink pull request: [WIP] - [FLINK-1807/1889] - Optimization frame...

Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/613#discussion_r29348180 --- Diff: flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/optimization/LossFunction.scala --- @@ -0,0 +1,85 @@ +/* + * Licensed to the

[jira] [Commented] (FLINK-1807) Stochastic gradient descent optimizer for ML library

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

[GitHub] flink pull request: [WIP] - [FLINK-1807/1889] - Optimization frame...

Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/613#discussion_r29348536 --- Diff: flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/optimization/RegularizationType.scala --- @@ -0,0 +1,112 @@ +/* + * Licensed

[jira] [Closed] (FLINK-1961) DataSet.partitionCustom not documented

[ https://issues.apache.org/jira/browse/FLINK-1961?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger closed FLINK-1961. - Resolution: Duplicate DataSet.partitionCustom not documented

[jira] [Commented] (FLINK-1807) Stochastic gradient descent optimizer for ML library

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

[jira] [Resolved] (FLINK-1908) JobManager startup delay isn't considered when using start-cluster.sh script

[ https://issues.apache.org/jira/browse/FLINK-1908?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lukas Raska resolved FLINK-1908. Resolution: Won't Fix As TMs work differently in 0.9 and this issue doesn't occur there, it

[jira] [Closed] (FLINK-1908) JobManager startup delay isn't considered when using start-cluster.sh script

[ https://issues.apache.org/jira/browse/FLINK-1908?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lukas Raska closed FLINK-1908. -- JobManager startup delay isn't considered when using start-cluster.sh script

[GitHub] flink pull request: [FLINK-1908] JobManager startup delay isn't co...

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

[jira] [Commented] (FLINK-1908) JobManager startup delay isn't considered when using start-cluster.sh script

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

[jira] [Updated] (FLINK-1908) JobManager startup delay isn't considered when using start-cluster.sh script

[ https://issues.apache.org/jira/browse/FLINK-1908?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lukas Raska updated FLINK-1908: --- Affects Version/s: (was: 0.9) JobManager startup delay isn't considered when using

[GitHub] flink pull request: [FLINK-1911] [streaming] Streaming projection ...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/630 --- 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-1911) DataStream and DataSet projection is out of sync

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

[GitHub] flink pull request: [FLINK-1908] JobManager startup delay isn't co...

Github user uce commented on the pull request: https://github.com/apache/flink/pull/609#issuecomment-97424107 @DarkKnightCZ, only you can close the PR. Could you do so? --- 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-1908) JobManager startup delay isn't considered when using start-cluster.sh script

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

[jira] [Closed] (FLINK-1911) DataStream and DataSet projection is out of sync

[ https://issues.apache.org/jira/browse/FLINK-1911?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi closed FLINK-1911. - Resolution: Fixed Fix Version/s: 0.9 Fixed via 8c46155 and 40be172. DataStream and

[jira] [Commented] (FLINK-1960) Add comments and docs for withForwardedFields and related operators

[ https://issues.apache.org/jira/browse/FLINK-1960?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14519410#comment-14519410 ] Till Rohrmann commented on FLINK-1960: -- You can find the corresponding online

[jira] [Created] (FLINK-1961) DataSet.partitionCustom not documented

Robert Metzger created FLINK-1961: - Summary: DataSet.partitionCustom not documented Key: FLINK-1961 URL: https://issues.apache.org/jira/browse/FLINK-1961 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-1959) Accumulators BROKEN after Partitioning

[ https://issues.apache.org/jira/browse/FLINK-1959?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14519542#comment-14519542 ] Stephan Ewen commented on FLINK-1959: - Can you try if this only happens with a

[GitHub] flink pull request: [WIP] - [FLINK-1807/1889] - Optimization frame...

Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/613#discussion_r29347123 --- Diff: flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/optimization/GradientDescent.scala --- @@ -0,0 +1,237 @@ +/* + * Licensed to

[GitHub] flink pull request: [WIP] - [FLINK-1807/1889] - Optimization frame...

Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/613#discussion_r29347156 --- Diff: flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/optimization/GradientDescent.scala --- @@ -0,0 +1,237 @@ +/* + * Licensed to

[jira] [Commented] (FLINK-1807) Stochastic gradient descent optimizer for ML library

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

[jira] [Commented] (FLINK-1961) DataSet.partitionCustom not documented

[ https://issues.apache.org/jira/browse/FLINK-1961?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14519559#comment-14519559 ] Chesnay Schepler commented on FLINK-1961: - duplicate of FLINK-1260 ?

[jira] [Commented] (FLINK-1959) Accumulators BROKEN after Partitioning

[ https://issues.apache.org/jira/browse/FLINK-1959?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14519494#comment-14519494 ] mustafa elbehery commented on FLINK-1959: - BTW, the version of Flink is 0.9 but it

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

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/621 --- 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-924) Extend JarFileCreator to automatically include dependencies

[ https://issues.apache.org/jira/browse/FLINK-924?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek resolved FLINK-924. Resolution: Fixed Added in

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

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/442 --- 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-1615) Introduces a new InputFormat for Tweets

[ https://issues.apache.org/jira/browse/FLINK-1615?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14519522#comment-14519522 ] ASF GitHub Bot commented on FLINK-1615: --- Github user asfgit closed the 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=14519521#comment-14519521 ] ASF GitHub Bot commented on FLINK-1615: --- Github user asfgit closed the pull request

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

[ https://issues.apache.org/jira/browse/FLINK-1615?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek resolved FLINK-1615. - Resolution: Fixed Added in