[jira] [Commented] (FLINK-2235) Local Flink cluster allocates too much memory

[ https://issues.apache.org/jira/browse/FLINK-2235?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14596099#comment-14596099 ] Maximilian Michels commented on FLINK-2235: --- Actually, I think the explanation

[jira] [Resolved] (FLINK-2204) Tez ConnectedComponentsStepITCase fails spuriously on Travis

[ https://issues.apache.org/jira/browse/FLINK-2204?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi resolved FLINK-2204. Resolution: Fixed Tez ConnectedComponentsStepITCase fails spuriously on Travis

[jira] [Commented] (FLINK-297) Redesign GUI client-server model

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

[GitHub] flink pull request: [streaming] Properly forward rich window funct...

Github user mbalassi commented on the pull request: https://github.com/apache/flink/pull/855#issuecomment-114179961 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: [FLINK-2111] Add terminate signal to cleanly...

Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/750#issuecomment-114188551 I disagree with the execution graph changes. I took us 6 months to get it stable, and we still discover corner cases. The new state interacts with all other states.

[jira] [Commented] (FLINK-2111) Add terminate signal to cleanly stop streaming jobs

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

[GitHub] flink pull request: [FLINK-2209] Document linking with jars not in...

Github user mbalassi commented on the pull request: https://github.com/apache/flink/pull/835#issuecomment-114149626 I do not think that we can expect that every user starts from the quickstart poms, but it is true that a reference to that would have been nicer. I have to

[jira] [Commented] (FLINK-2244) Add ability to start and stop persistent IaaS cluster

[ https://issues.apache.org/jira/browse/FLINK-2244?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14596107#comment-14596107 ] Stephan Ewen commented on FLINK-2244: - This is a very generic/broad feature. This

[jira] [Commented] (FLINK-2186) Rework CSV import to support very wide files

[ https://issues.apache.org/jira/browse/FLINK-2186?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14596116#comment-14596116 ] Stephan Ewen commented on FLINK-2186: - Not sure if we can/want to fix this on the

[jira] [Commented] (FLINK-2235) Local Flink cluster allocates too much memory

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

[jira] [Commented] (FLINK-2230) Add Support for Null-Values in TupleSerializer

[ https://issues.apache.org/jira/browse/FLINK-2230?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14596084#comment-14596084 ] Stephan Ewen commented on FLINK-2230: - There have been many discussions about whether

[jira] [Commented] (FLINK-1727) Add decision tree to machine learning library

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

[jira] [Commented] (FLINK-2245) Programs that contain collect() reported as multiple jobs in the Web frontend

[ https://issues.apache.org/jira/browse/FLINK-2245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14596187#comment-14596187 ] Stephan Ewen commented on FLINK-2245: - I would actually assume that programs with

[GitHub] flink pull request: [FLINK-2255] [streaming] Fixed a bug in TopSpe...

Github user mbalassi commented on the pull request: https://github.com/apache/flink/pull/857#issuecomment-114184152 Thanks for spotting this, Gabor. Looks good to merge. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If

[GitHub] flink pull request: [scripts] cleanup release script and make it m...

Github user mxm commented on the pull request: https://github.com/apache/flink/pull/811#issuecomment-114153093 Thanks, merging then. --- 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

[GitHub] flink pull request: New operator state interfaces

Github user hsaputra commented on a diff in the pull request: https://github.com/apache/flink/pull/747#discussion_r32949021 --- Diff: flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/state/PartitionedStreamOperatorState.java --- @@

[jira] [Commented] (FLINK-2235) Local Flink cluster allocates too much memory

[ https://issues.apache.org/jira/browse/FLINK-2235?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14596102#comment-14596102 ] Stephan Ewen commented on FLINK-2235: - Sounds like a good way to fix this... Local

[jira] [Commented] (FLINK-2231) Create a Serializer for Scala Enumerations

[ https://issues.apache.org/jira/browse/FLINK-2231?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14596071#comment-14596071 ] Stephan Ewen commented on FLINK-2231: - Exactly, the createTypeInformation macro needs

[GitHub] flink pull request: [FLINK-297] [web frontend] First part of JobMa...

Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/677#issuecomment-114176858 I think it will. I will try and add further code for the new webfrontend in the next days, and then open a new pull request that subsumes this one and #297 --- If

[GitHub] flink pull request: [FLINK-2235] fix calculation of free memory fo...

Github user uce commented on a diff in the pull request: https://github.com/apache/flink/pull/859#discussion_r32957111 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/util/EnvironmentInformation.java --- @@ -137,7 +137,13 @@ public static long

[jira] [Commented] (FLINK-2235) Local Flink cluster allocates too much memory

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

[GitHub] flink pull request: [FLINK-2143] Added ReduceFunctionWithInverse

Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/856#issuecomment-114184385 Here seems to be something with quite some broader implications. This affects the design of aggregations on windows and how they can be pre-aggregated. The

[jira] [Commented] (FLINK-2175) Allow multiple jobs in single jar file

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

[jira] [Commented] (FLINK-2245) Programs that contain collect() reported as multiple jobs in the Web frontend

[ https://issues.apache.org/jira/browse/FLINK-2245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14596188#comment-14596188 ] Stephan Ewen commented on FLINK-2245: - Ah, sorry, confusion: You were talking about

[GitHub] flink pull request: [FLINK-2119] Add ExecutionGraph support for ba...

Github user uce commented on the pull request: https://github.com/apache/flink/pull/754#issuecomment-114176855 Addressed @tillrohrmann's comments and rebased on master. @tillrohrmann, should we merge with your upcoming changes or can we merge it before? --- If your project is set up

[jira] [Commented] (FLINK-2119) Add ExecutionGraph support for leg-wise scheduling

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

[jira] [Commented] (FLINK-2209) Document how to use TableAPI, Gelly and FlinkML, StreamingConnectors on a cluster

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

[GitHub] flink pull request: [FLINK-2175] Allow multiple jobs in single jar...

Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/707#issuecomment-114165604 +1 for adding this, looks good! --- 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

[GitHub] flink pull request: [streaming] Properly forward rich window funct...

Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/855#issuecomment-114177459 Looks good, +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 well. If your project does not have

[GitHub] flink pull request: New operator state interfaces

Github user senorcarbone commented on the pull request: https://github.com/apache/flink/pull/747#issuecomment-114180337 We have added a `KeyedDataStream` type to the API as you can see in the last commit. It is basically a supertype of `GroupDataStream` and represents a `DataStream`

[GitHub] flink pull request: [scripts] cleanup release script and make it m...

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

Github user thvasilo commented on the pull request: https://github.com/apache/flink/pull/710#issuecomment-114154438 Helo @sachingoel0101, I've started reviewing this PR. It would help a lot if you check out these initial comments I made and try to fix similar issues throughout the

[jira] [Commented] (FLINK-2236) RowSerializer and CaseClassComparator are not in sync regarding Null-Values

[ https://issues.apache.org/jira/browse/FLINK-2236?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14596100#comment-14596100 ] Stephan Ewen commented on FLINK-2236: - I think this is fixed in the release, correct?

[GitHub] flink pull request: [FLINK-2235] fix calculation of free memory fo...

GitHub user mxm opened a pull request: https://github.com/apache/flink/pull/859 [FLINK-2235] fix calculation of free memory for local execution The Java runtime may return Long.MAX_VALUE for a call to the maxMemory() method of the Runtime class. In these cases, we simply use the

[GitHub] flink pull request: [Flink-1727][ml]Decision tree[WIP]

Github user sachingoel0101 commented on the pull request: https://github.com/apache/flink/pull/710#issuecomment-114173765 The fundamental idea for a scalable decision tree algorithm is to reduce the number of splits required to be checked at every node. Ideally, we'd check for every

[jira] [Commented] (FLINK-2255) In the TopSpeedWindowing examples, every window contains only 1 element, because event time is in millisec, but eviction is in sec

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

[jira] [Commented] (FLINK-2143) Add an overload to reduceWindow which takes the inverse of the reduceFunction as a second parameter

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

[GitHub] flink pull request: [Flink-1727]Decision tree

Github user thvasilo commented on a diff in the pull request: https://github.com/apache/flink/pull/710#discussion_r32941921 --- Diff: flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/classification/DecisionTree.scala --- @@ -0,0 +1,490 @@ +/* + * Licensed to the

[GitHub] flink pull request: [Flink-1727]Decision tree

Github user thvasilo commented on a diff in the pull request: https://github.com/apache/flink/pull/710#discussion_r32942116 --- Diff: flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/classification/DecisionTree.scala --- @@ -0,0 +1,490 @@ +/* + * Licensed to the

[GitHub] flink pull request: [Flink-1727]Decision tree

Github user thvasilo commented on a diff in the pull request: https://github.com/apache/flink/pull/710#discussion_r32942958 --- Diff: flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/tree/Tree.scala --- @@ -0,0 +1,327 @@ +/* + * Licensed to the Apache Software

[GitHub] flink pull request: [Flink-1727]Decision tree

Github user thvasilo commented on a diff in the pull request: https://github.com/apache/flink/pull/710#discussion_r32943140 --- Diff: flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/tree/Tree.scala --- @@ -0,0 +1,327 @@ +/* + * Licensed to the Apache Software

[GitHub] flink pull request: [Flink-1727]Decision tree

Github user thvasilo commented on a diff in the pull request: https://github.com/apache/flink/pull/710#discussion_r32944309 --- Diff: flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/classification/DecisionTree.scala --- @@ -0,0 +1,490 @@ +/* + * Licensed to the

[jira] [Commented] (FLINK-2209) Document how to use TableAPI, Gelly and FlinkML, StreamingConnectors on a cluster

[ https://issues.apache.org/jira/browse/FLINK-2209?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14596054#comment-14596054 ] Stephan Ewen commented on FLINK-2209: - Reopened this, because I think this

[GitHub] flink pull request: [FLINK-2209] Document linking with jars not in...

Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/835#issuecomment-114143834 I am a bit confused here. With the quickstart maven projects, fat jar building works without configuring, as it defines proper assembly and share configurations for

[jira] [Commented] (FLINK-2244) Add ability to start and stop persistent IaaS cluster

[ https://issues.apache.org/jira/browse/FLINK-2244?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14596378#comment-14596378 ] Theodore Vasiloudis commented on FLINK-2244: It would work differently for

[jira] [Commented] (FLINK-2236) RowSerializer and CaseClassComparator are not in sync regarding Null-Values

[ https://issues.apache.org/jira/browse/FLINK-2236?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14596436#comment-14596436 ] Aljoscha Krettek commented on FLINK-2236: - Yes, in the release the RowSerializer

[jira] [Commented] (FLINK-2194) Type extractor does not support Writable type

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

[GitHub] flink pull request: [Flink-1727]Decision tree

Github user thvasilo commented on a diff in the pull request: https://github.com/apache/flink/pull/710#discussion_r32941719 --- Diff: flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/classification/DecisionTree.scala --- @@ -0,0 +1,490 @@ +/* + * Licensed to the

[jira] [Commented] (FLINK-2209) Document how to use TableAPI, Gelly and FlinkML, StreamingConnectors on a cluster

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

[GitHub] flink pull request: [Flink-1727]Decision tree

Github user thvasilo commented on a diff in the pull request: https://github.com/apache/flink/pull/710#discussion_r32944368 --- Diff: flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/classification/DecisionTree.scala --- @@ -0,0 +1,490 @@ +/* + * Licensed to the

[GitHub] flink pull request: [Flink-1727]Decision tree

Github user thvasilo commented on a diff in the pull request: https://github.com/apache/flink/pull/710#discussion_r32944538 --- Diff: flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/classification/DecisionTree.scala --- @@ -0,0 +1,490 @@ +/* + * Licensed to the

[jira] [Reopened] (FLINK-2209) Document how to use TableAPI, Gelly and FlinkML, StreamingConnectors on a cluster

[ https://issues.apache.org/jira/browse/FLINK-2209?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen reopened FLINK-2209: - Assignee: (was: Márton Balassi) Document how to use TableAPI, Gelly and FlinkML,

[GitHub] flink pull request: [Flink-1727]Decision tree

Github user thvasilo commented on a diff in the pull request: https://github.com/apache/flink/pull/710#discussion_r32944486 --- Diff: flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/classification/DecisionTree.scala --- @@ -0,0 +1,490 @@ +/* + * Licensed to the

[jira] [Commented] (FLINK-2108) Add score function for Predictors

[ https://issues.apache.org/jira/browse/FLINK-2108?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14596056#comment-14596056 ] Theodore Vasiloudis commented on FLINK-2108: Hello Sachin, could you give us a

[jira] [Commented] (FLINK-2245) Programs that contain collect() reported as multiple jobs in the Web frontend

[ https://issues.apache.org/jira/browse/FLINK-2245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14596391#comment-14596391 ] Theodore Vasiloudis commented on FLINK-2245: Yup for me the important thing

[GitHub] flink pull request: [Flink-1727][ml]Decision tree[WIP]

Github user thvasilo commented on the pull request: https://github.com/apache/flink/pull/710#issuecomment-114211636 On that front, do you think it's possible to split the online histogram and the decision tree code into two PRs that we can review separately? If the online

[jira] [Commented] (FLINK-2180) Streaming iterate test fails spuriously

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

[jira] [Commented] (FLINK-2261) Remove reduce/aggregation from DataStream

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

[GitHub] flink pull request: [FLINK-2261] [streaming] Remove reduce/fold/ag...

GitHub user gyfora opened a pull request: https://github.com/apache/flink/pull/860 [FLINK-2261] [streaming] Remove reduce/fold/aggregations from DataStream You can merge this pull request into a Git repository by running: $ git pull https://github.com/gyfora/flink FLINK-2261

[jira] [Created] (FLINK-2262) ParameterTool API misnamed function

Greg Hogan created FLINK-2262: - Summary: ParameterTool API misnamed function Key: FLINK-2262 URL: https://issues.apache.org/jira/browse/FLINK-2262 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-2193) Partial shuffling

[ https://issues.apache.org/jira/browse/FLINK-2193?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14595725#comment-14595725 ] Stephan Ewen commented on FLINK-2193: - I think there is currently no partition

[jira] [Commented] (FLINK-2198) BlobManager tests fail on Windows

[ https://issues.apache.org/jira/browse/FLINK-2198?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14595738#comment-14595738 ] Stephan Ewen commented on FLINK-2198: - The approach to disallow folder creation is

[GitHub] flink pull request: [FLINK-2243] [storm-compat] Added finite spout...

Github user szape commented on a diff in the pull request: https://github.com/apache/flink/pull/853#discussion_r32925004 --- Diff:

[GitHub] flink pull request: Modified the equals method in all the Value ty...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/850 --- 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-2243) Add finite spout functionality to Storm compatibility layer

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

[jira] [Commented] (FLINK-2197) Scala API is not working when using batch and streaming API in the same program

[ https://issues.apache.org/jira/browse/FLINK-2197?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14595830#comment-14595830 ] Stephan Ewen commented on FLINK-2197: - How can we solve this? Can we change the

[jira] [Commented] (FLINK-2243) Add finite spout functionality to Storm compatibility layer

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

[jira] [Commented] (FLINK-2190) Enhance stream decoration/compression extensibility

[ https://issues.apache.org/jira/browse/FLINK-2190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14595818#comment-14595818 ] Stephan Ewen commented on FLINK-2190: - Sounds good! Enhance stream

[GitHub] flink pull request: [FLINK-2143] Added ReduceFunctionWithInverse

GitHub user ggevay opened a pull request: https://github.com/apache/flink/pull/856 [FLINK-2143] Added ReduceFunctionWithInverse (The first commit is the same as the second commit in PR 684) I didn't add an overload to reduce, but instead created ReduceFunctionWithInverse

[jira] [Created] (FLINK-2256) Handling Broker failures on the KafkaSink side

Márton Balassi created FLINK-2256: - Summary: Handling Broker failures on the KafkaSink side Key: FLINK-2256 URL: https://issues.apache.org/jira/browse/FLINK-2256 Project: Flink Issue Type:

[jira] [Commented] (FLINK-2243) Add finite spout functionality to Storm compatibility layer

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

[GitHub] flink pull request: [FLINK-2243] [storm-compat] Added finite spout...

Github user szape commented on a diff in the pull request: https://github.com/apache/flink/pull/853#discussion_r32913535 --- Diff:

[GitHub] flink pull request: [scripts] cleanup release script and make it m...

Github user uce commented on the pull request: https://github.com/apache/flink/pull/811#issuecomment-114039683 Is there anything blocking this? If not, feel free to go ahead and merge this. :) --- If your project is set up for it, you can reply to this email and have your reply

[GitHub] flink pull request: [FLINK-2229] add equals(...) and hashCode() to...

Github user uce commented on the pull request: https://github.com/apache/flink/pull/842#issuecomment-114039557 +1, 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: [FLINK-1818] Added api to cancel job from clie...

Github user uce commented on the pull request: https://github.com/apache/flink/pull/642#issuecomment-114040994 Another ping. @mjsax would you like to pick it up? There is a test in TaskCancelTest#cancelJob, which implements this for a test as a static method. Would be nice to

[jira] [Commented] (FLINK-1818) Provide API to cancel running job

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

[GitHub] flink pull request: [FLINK-2214] [ml] Fixes prediction join operat...

Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/844#issuecomment-114045049 The build side hinted here is also the constant (loop invariant) side, correct? --- If your project is set up for it, you can reply to this email and have your

[GitHub] flink pull request: [FLINK-2124] [streaming] Fix behavior of FromE...

Github user jreiffers commented on a diff in the pull request: https://github.com/apache/flink/pull/848#discussion_r32916185 --- Diff: flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/functions/source/FromElementsFunction.java --- @@

[jira] [Commented] (FLINK-2124) FromElementsFunction is not really Serializable

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

[GitHub] flink pull request: [FLINK-2124] [streaming] Fix behavior of FromE...

Github user jreiffers commented on a diff in the pull request: https://github.com/apache/flink/pull/848#discussion_r32916595 --- Diff: flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/functions/source/FromElementsFunction.java --- @@

[jira] [Commented] (FLINK-2124) FromElementsFunction is not really Serializable

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

[GitHub] flink pull request: [FLINK-2155] Enforce import restriction on usa...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/790 --- 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-297) Redesign GUI client-server model

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

[GitHub] flink pull request: [FLINK-2243] [storm-compat] Added finite spout...

Github user mjsax commented on a diff in the pull request: https://github.com/apache/flink/pull/853#discussion_r32919318 --- Diff:

[jira] [Commented] (FLINK-2243) Add finite spout functionality to Storm compatibility layer

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

[GitHub] flink pull request: [contrib] Storm compatibility

Github user mjsax commented on the pull request: https://github.com/apache/flink/pull/764#issuecomment-114054802 Sure. Why not. Let's discuss tomorrow at the Meetup. --- 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-1956) Runtime context not initialized in RichWindowMapFunction

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

[GitHub] flink pull request: [streaming] Properly forward rich window funct...

GitHub user mbalassi opened a pull request: https://github.com/apache/flink/pull/855 [streaming] Properly forward rich window function calls to wrapped fu… …nctions Open and close were not called, because of the wrapping in windowing. I should have realized this when

[GitHub] flink pull request: [FLINK-2243] [storm-compat] Added finite spout...

Github user mjsax commented on a diff in the pull request: https://github.com/apache/flink/pull/853#discussion_r32925744 --- Diff:

[jira] [Commented] (FLINK-2143) Add an overload to reduceWindow which takes the inverse of the reduceFunction as a second parameter

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

[GitHub] flink pull request: [FLINK-2194] [type extractor] Treats Writable ...

Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/814#issuecomment-114080543 I am unsure of where this leads us. The purpose of `Writable` is to make sure that we can use the Writable's custom serialization. If the type `Writable` itself is

[jira] [Commented] (FLINK-2194) Type extractor does not support Writable type

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

[jira] [Commented] (FLINK-2243) Add finite spout functionality to Storm compatibility layer

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

[GitHub] flink pull request: Modified the equals method in all the Value ty...

Github user uce commented on the pull request: https://github.com/apache/flink/pull/850#issuecomment-114038819 Merging. Thanks for the PR. Going for getClass. --- 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

[GitHub] flink pull request: [FLINK-1818] Added api to cancel job from clie...

Github user uce commented on the pull request: https://github.com/apache/flink/pull/642#issuecomment-114044225 Ah, didn't check the JIRA. Thanks for pointing this out. @rainiraj, can you look at the test I've mentioned and remove the code there and use your new feature? :) --- If

[GitHub] flink pull request: [FLINK-2242] deprecate RemoteCollector interfa...

Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/852#issuecomment-114043900 +1 I would go as far as to remove it, as this will work in a very limited way and requires direct client to TaskManager communication.

[jira] [Resolved] (FLINK-2155) Add an additional checkstyle validation for illegal imports

[ https://issues.apache.org/jira/browse/FLINK-2155?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi resolved FLINK-2155. Resolution: Fixed Fix Version/s: 0.10 Fixed via ab40e5d. Add an additional checkstyle

[jira] [Commented] (FLINK-2155) Add an additional checkstyle validation for illegal imports

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

[GitHub] flink pull request: [FLINK-2243] [storm-compat] Added finite spout...

Github user mjsax commented on a diff in the pull request: https://github.com/apache/flink/pull/853#discussion_r32914310 --- Diff:

[jira] [Commented] (FLINK-2243) Add finite spout functionality to Storm compatibility layer

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

  1   2   >