[GitHub] flink pull request: [FLINK-2275] Migrate test from package 'org.ap...

GitHub user mjsax opened a pull request: https://github.com/apache/flink/pull/866 [FLINK-2275] Migrate test from package 'org.apache.flink.test.javaApiOperators' migrated test from execute() to collect() subtask of https://issues.apache.org/jira/browse/FLINK-2032 You can merge

[jira] [Commented] (FLINK-2275) Migrate test from package 'org.apache.flink.test.javaApiOperators'

[ https://issues.apache.org/jira/browse/FLINK-2275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14600477#comment-14600477 ] ASF GitHub Bot commented on FLINK-2275: --- GitHub user mjsax opened a pull request:

[jira] [Created] (FLINK-2275) Migrate test from package 'org.apache.flink.test.javaApiOperators'

Matthias J. Sax created FLINK-2275: -- Summary: Migrate test from package 'org.apache.flink.test.javaApiOperators' Key: FLINK-2275 URL: https://issues.apache.org/jira/browse/FLINK-2275 Project: Flink

[GitHub] flink pull request: [FLINK-2271] [FLINK-1522] [gelly] add missing ...

GitHub user vasia opened a pull request: https://github.com/apache/flink/pull/865 [FLINK-2271] [FLINK-1522] [gelly] add missing example tests This PR adds missing Gelly tests for PageRank and MusicProfiles examples. It also changes both vertex-centric and GSA PageRank examples to ex

[jira] [Commented] (FLINK-2271) PageRank gives wrong results with weighted graph input

[ https://issues.apache.org/jira/browse/FLINK-2271?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14600231#comment-14600231 ] ASF GitHub Bot commented on FLINK-2271: --- GitHub user vasia opened a pull request:

[GitHub] flink pull request: [FLINK-2093][gelly] Added difference Method

Github user shghatge commented on the pull request: https://github.com/apache/flink/pull/818#issuecomment-114983698 Updated PR --- 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 ena

[jira] [Commented] (FLINK-2093) Add a difference method to Gelly's Graph class

[ https://issues.apache.org/jira/browse/FLINK-2093?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14599974#comment-14599974 ] ASF GitHub Bot commented on FLINK-2093: --- Github user shghatge commented on the pull

[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-tabpanel&focusedCommentId=14599924#comment-14599924 ] ASF GitHub Bot commented on FLINK-1520: --- Github user shghatge commented on the pull

[GitHub] flink pull request: [FLINK-1520]Read edges and vertices from CSV f...

Github user shghatge commented on the pull request: https://github.com/apache/flink/pull/847#issuecomment-114975168 Updated PR --- 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 ena

[GitHub] flink pull request: [Flink-2030][ml]Online Histogram: Discrete and...

Github user thvasilo commented on the pull request: https://github.com/apache/flink/pull/861#issuecomment-114946436 Yes, we should avoid mixing java and Scala of possible. -- Sent from a mobile device. May contain autocorrect errors. On Jun 24, 2015 5:09 PM, "Sachin Go

[jira] [Commented] (FLINK-2125) String delimiter for SocketTextStream

[ https://issues.apache.org/jira/browse/FLINK-2125?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14599764#comment-14599764 ] ASF GitHub Bot commented on FLINK-2125: --- Github user hczerpak commented on the pull

[GitHub] flink pull request: FLINK-2125

Github user hczerpak commented on the pull request: https://github.com/apache/flink/pull/862#issuecomment-114945380 Yes that's true. Wasn't sure what to do with that --- 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: New operator state interfaces

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

[GitHub] flink pull request: New operator state interfaces

Github user senorcarbone commented on a diff in the pull request: https://github.com/apache/flink/pull/747#discussion_r33166608 --- Diff: flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/datastream/DataStream.java --- @@ -301,16 +301,

[jira] [Commented] (FLINK-2167) Add fromHCat() to TableEnvironment

[ https://issues.apache.org/jira/browse/FLINK-2167?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14599630#comment-14599630 ] Aljoscha Krettek commented on FLINK-2167: - Yes, this seems necessary. > Add fromH

[GitHub] flink pull request: New operator state interfaces

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

[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_r33163394 --- Diff: flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/state/PartitionedStreamOperatorState.java --- @@ -0

[jira] [Commented] (FLINK-1731) Add kMeans clustering algorithm to machine learning library

[ https://issues.apache.org/jira/browse/FLINK-1731?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14599614#comment-14599614 ] ASF GitHub Bot commented on FLINK-1731: --- Github user FGoessler commented on the pull

[GitHub] flink pull request: [FLINK-1731] [ml] Implementation of Feature K-...

Github user FGoessler commented on the pull request: https://github.com/apache/flink/pull/700#issuecomment-114921879 Just rebased and force pushed -> hoping for good Travis results :smiley: --- If your project is set up for it, you can reply to this email and have your reply appear o

[jira] [Commented] (FLINK-2152) Provide zipWithIndex utility in flink-contrib

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

[jira] [Assigned] (FLINK-2271) PageRank gives wrong results with weighted graph input

[ https://issues.apache.org/jira/browse/FLINK-2271?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vasia Kalavri reassigned FLINK-2271: Assignee: Vasia Kalavri > PageRank gives wrong results with weighted graph input >

[GitHub] flink pull request: [Flink-2030][ml]Online Histogram: Discrete and...

Github user sachingoel0101 commented on the pull request: https://github.com/apache/flink/pull/861#issuecomment-114901644 Okay. Sure. I will update the make the Discrete version online first. Should I try to explicitly use Scala library data structures instead of Java? --- I

[GitHub] flink pull request: [Flink-2030][ml]Online Histogram: Discrete and...

Github user thvasilo commented on the pull request: https://github.com/apache/flink/pull/861#issuecomment-114901089 > For the utility function, it doesn't really make a difference. We could simply have two functions which would treat the data as continuous or discrete. I would

[jira] [Commented] (FLINK-2274) Add a histogram method for DataSet[Double] in DataSetUtils

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

[GitHub] flink pull request: [Flink-2030][ml]Online Histogram: Discrete and...

Github user thvasilo commented on the pull request: https://github.com/apache/flink/pull/861#issuecomment-114900156 OK I've created an issue [here](https://issues.apache.org/jira/browse/FLINK-2274), you can link this PR to that one, and we can close both of them once this merged. --

[GitHub] flink pull request: [Flink-2030][ml]Online Histogram: Discrete and...

Github user sachingoel0101 commented on the pull request: https://github.com/apache/flink/pull/861#issuecomment-114899521 Changing the current discrete histogram implementation would not break the decision tree functionality. Although I might have to review the code for any potential

[jira] [Commented] (FLINK-2274) Add a histogram method for DataSet[Double] in DataSetUtils

[ https://issues.apache.org/jira/browse/FLINK-2274?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14599524#comment-14599524 ] Theodore Vasiloudis commented on FLINK-2274: Blocked so we get an initial vers

[jira] [Created] (FLINK-2274) Add a histogram method for DataSet[Double] in DataSetUtils

Theodore Vasiloudis created FLINK-2274: -- Summary: Add a histogram method for DataSet[Double] in DataSetUtils Key: FLINK-2274 URL: https://issues.apache.org/jira/browse/FLINK-2274 Project: Flink

[GitHub] flink pull request: [Flink-2030][ml]Online Histogram: Discrete and...

Github user thvasilo commented on the pull request: https://github.com/apache/flink/pull/861#issuecomment-114896951 > Actually, how about making the Categorical Histogram completely online too? We could just take a numClasses there too, with a semantic difference that in this case the

[GitHub] flink pull request: [Flink-2030][ml]Online Histogram: Discrete and...

Github user thvasilo commented on the pull request: https://github.com/apache/flink/pull/861#issuecomment-114896540 >The idea is to emulate a discrete probability distribution, which it does. For the continuous case, we're emulating a continuous probability distribution, which means w

[GitHub] flink pull request: [FLINK-2152] Added zipWithIndex

Github user thvasilo commented on the pull request: https://github.com/apache/flink/pull/832#issuecomment-114895752 Seems like the problem was that the wrap was returning a DataSet[(java.lang.Long, T)] If you change the map to `.map { t => (t.f0.toLong, t.f1) }` it should work

[GitHub] flink pull request: [Flink-2030][ml]Online Histogram: Discrete and...

Github user sachingoel0101 commented on the pull request: https://github.com/apache/flink/pull/861#issuecomment-114895657 Adding a Utility method does certainly make sense. User will be supposed to provide an argument depicting whether the values in DataSet[Double] are continuous or d

[GitHub] flink pull request: [Flink-2030][ml]Online Histogram: Discrete and...

Github user sachingoel0101 commented on the pull request: https://github.com/apache/flink/pull/861#issuecomment-114893705 Actually, how about making the Categorical Histogram completely online too? We could just take a numClasses there too, with a semantic difference that in this case

[jira] [Commented] (FLINK-2167) Add fromHCat() to TableEnvironment

[ https://issues.apache.org/jira/browse/FLINK-2167?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14599502#comment-14599502 ] Timo Walther commented on FLINK-2167: - Moving is also an option. I think I will implem

[jira] [Commented] (FLINK-2167) Add fromHCat() to TableEnvironment

[ https://issues.apache.org/jira/browse/FLINK-2167?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14599474#comment-14599474 ] Aljoscha Krettek commented on FLINK-2167: - Ok, maybe if we move it to another pack

[jira] [Commented] (FLINK-2152) Provide zipWithIndex utility in flink-contrib

[ https://issues.apache.org/jira/browse/FLINK-2152?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14599459#comment-14599459 ] ASF GitHub Bot commented on FLINK-2152: --- Github user andralungu commented on the pul

[jira] [Commented] (FLINK-2152) Provide zipWithIndex utility in flink-contrib

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

[jira] [Commented] (FLINK-2152) Provide zipWithIndex utility in flink-contrib

[ https://issues.apache.org/jira/browse/FLINK-2152?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14599473#comment-14599473 ] ASF GitHub Bot commented on FLINK-2152: --- Github user andralungu commented on the pul

[GitHub] flink pull request: [FLINK-2152] Added zipWithIndex

Github user andralungu commented on the pull request: https://github.com/apache/flink/pull/832#issuecomment-114883882 Uhmmm... flink.api.scala is imported. That's not the issue. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as

[GitHub] flink pull request: [Flink-2030][ml]Online Histogram: Discrete and...

Github user sachingoel0101 commented on a diff in the pull request: https://github.com/apache/flink/pull/861#discussion_r33151075 --- Diff: flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/math/ContinuousHistogram.scala --- @@ -0,0 +1,325 @@ +/* + * Licensed to th

[GitHub] flink pull request: [FLINK-2152] Added zipWithIndex

Github user andralungu commented on the pull request: https://github.com/apache/flink/pull/832#issuecomment-114878728 Actually, I get a weird compile error: it says missing Type parameter for the map in DataSet.scala... I think this is because the map is overriden... and I haven't

[GitHub] flink pull request: [Flink-2030][ml]Online Histogram: Discrete and...

Github user thvasilo commented on the pull request: https://github.com/apache/flink/pull/861#issuecomment-114881148 So in order to make this a feature that we can merge, we should add some functionality that goes beyond the decision tree use case. My thoughts were that we use

[jira] [Commented] (FLINK-1127) Utility library

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

[GitHub] flink pull request: [Flink-2030][ml]Online Histogram: Discrete and...

Github user sachingoel0101 commented on a diff in the pull request: https://github.com/apache/flink/pull/861#discussion_r33150869 --- Diff: flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/math/CategoricalHistogram.scala --- @@ -0,0 +1,167 @@ +/* + * Licensed to t

[GitHub] flink pull request: [FLINK-2152] Added zipWithIndex

Github user thvasilo commented on the pull request: https://github.com/apache/flink/pull/832#issuecomment-114880352 Is it a type inference problem? Have you tried importing org.apache.flink.api.scala._ to see if that fixes it? --- If your project is set up for it, you can reply to th

[GitHub] flink pull request: [Flink-2030][ml]Online Histogram: Discrete and...

Github user sachingoel0101 commented on the pull request: https://github.com/apache/flink/pull/861#issuecomment-114880501 Hello Theodore, the semantics for Discrete Histogram is such that you have to specify what classes or discrete values are going to arrive. Once you fix the allowed

[GitHub] flink pull request: [Flink-2030][ml]Online Histogram: Discrete and...

Github user thvasilo commented on the pull request: https://github.com/apache/flink/pull/861#issuecomment-114873908 Hello Sachin, I have some comments regarding the discrete histogram. It seems that keeping the bucket count constant is incompatible with a "true" online histogram, whic

[GitHub] flink pull request: [Flink-2030][ml]Online Histogram: Discrete and...

Github user thvasilo commented on a diff in the pull request: https://github.com/apache/flink/pull/861#discussion_r33148440 --- Diff: flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/math/CategoricalHistogram.scala --- @@ -0,0 +1,167 @@ +/* + * Licensed to the Apa

[jira] [Commented] (FLINK-2167) Add fromHCat() to TableEnvironment

[ https://issues.apache.org/jira/browse/FLINK-2167?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14599422#comment-14599422 ] Timo Walther commented on FLINK-2167: - Sure that does also work. I just thought it is

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

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

[GitHub] flink pull request: [Flink-2030][ml]Online Histogram: Discrete and...

Github user thvasilo commented on a diff in the pull request: https://github.com/apache/flink/pull/861#discussion_r33146188 --- Diff: flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/math/CategoricalHistogram.scala --- @@ -0,0 +1,167 @@ +/* + * Licensed to the Apa

[jira] [Commented] (FLINK-2152) Provide zipWithIndex utility in flink-contrib

[ https://issues.apache.org/jira/browse/FLINK-2152?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14599388#comment-14599388 ] ASF GitHub Bot commented on FLINK-2152: --- Github user tillrohrmann commented on the p

[GitHub] flink pull request: [FLINK-2152] Added zipWithIndex

Github user tillrohrmann commented on the pull request: https://github.com/apache/flink/pull/832#issuecomment-114864032 Sorry for my late reply. Has everything worked out by now? On Tue, Jun 23, 2015 at 2:43 PM, Andra Lungu wrote: > Hey @tillrohrmann

[jira] [Created] (FLINK-2273) Register special Writable Kryo serializer

Till Rohrmann created FLINK-2273: Summary: Register special Writable Kryo serializer Key: FLINK-2273 URL: https://issues.apache.org/jira/browse/FLINK-2273 Project: Flink Issue Type: Improveme

[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-tabpanel&focusedCommentId=14599370#comment-14599370 ] ASF GitHub Bot commented on FLINK-2194: --- Github user tillrohrmann commented on the p

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

Github user tillrohrmann commented on the pull request: https://github.com/apache/flink/pull/814#issuecomment-114863239 @rmetzger suggested to add a specialized Kryo serializer for the `Writable` interface. That way we could directly call the write method of `Writable` types which mig

[jira] [Commented] (FLINK-2167) Add fromHCat() to TableEnvironment

[ https://issues.apache.org/jira/browse/FLINK-2167?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14599368#comment-14599368 ] Aljoscha Krettek commented on FLINK-2167: - Does it not work we simply use the same

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

Github user tillrohrmann commented on the pull request: https://github.com/apache/flink/pull/814#issuecomment-114860764 I did not mean a special Kryo serializer but our very own `WritableSerializer`. With the current implementation `WritableTypeInformation` has precedence over `Generi

[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-tabpanel&focusedCommentId=14599357#comment-14599357 ] ASF GitHub Bot commented on FLINK-2194: --- Github user tillrohrmann commented on the p

[GitHub] flink pull request: [Flink-2030][ml]Online Histogram: Discrete and...

Github user thvasilo commented on a diff in the pull request: https://github.com/apache/flink/pull/861#discussion_r33143726 --- Diff: flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/math/ContinuousHistogram.scala --- @@ -0,0 +1,325 @@ +/* + * Licensed to the Apac

[GitHub] flink pull request: [Flink-2030][ml]Online Histogram: Discrete and...

Github user thvasilo commented on a diff in the pull request: https://github.com/apache/flink/pull/861#discussion_r33143611 --- Diff: flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/math/ContinuousHistogram.scala --- @@ -0,0 +1,325 @@ +/* + * Licensed to the Apac

[jira] [Assigned] (FLINK-2272) Move vision and roadmap for FlinkML from docs to the wiki

[ https://issues.apache.org/jira/browse/FLINK-2272?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Theodore Vasiloudis reassigned FLINK-2272: -- Assignee: Theodore Vasiloudis > Move vision and roadmap for FlinkML from docs t

[GitHub] flink pull request: [FLINK-2272] [ml] [docs] Move vision and roadm...

GitHub user thvasilo opened a pull request: https://github.com/apache/flink/pull/864 [FLINK-2272] [ml] [docs] Move vision and roadmap for FlinkML from docs to the wiki This removes the vision and roadmap from the docs, and adds a link to their new place in the wiki. You can merge

[jira] [Commented] (FLINK-2272) Move vision and roadmap for FlinkML from docs to the wiki

[ https://issues.apache.org/jira/browse/FLINK-2272?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14599304#comment-14599304 ] ASF GitHub Bot commented on FLINK-2272: --- GitHub user thvasilo opened a pull request:

[jira] [Created] (FLINK-2272) Move vision and roadmap for FlinkML from docs to the wiki

Theodore Vasiloudis created FLINK-2272: -- Summary: Move vision and roadmap for FlinkML from docs to the wiki Key: FLINK-2272 URL: https://issues.apache.org/jira/browse/FLINK-2272 Project: Flink

[jira] [Updated] (FLINK-2271) PageRank gives wrong results with weighted graph input

[ https://issues.apache.org/jira/browse/FLINK-2271?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated FLINK-2271: -- Fix Version/s: 0.10 > PageRank gives wrong results with weighted graph input > -

[jira] [Commented] (FLINK-2167) Add fromHCat() to TableEnvironment

[ https://issues.apache.org/jira/browse/FLINK-2167?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14599279#comment-14599279 ] Timo Walther commented on FLINK-2167: - Thanks Robert, I solved the issue. The hive-sit

[jira] [Updated] (FLINK-2271) PageRank gives wrong results with weighted graph input

[ https://issues.apache.org/jira/browse/FLINK-2271?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vasia Kalavri updated FLINK-2271: - Affects Version/s: (was: 0.9.1) (was: 0.10) 0

[jira] [Created] (FLINK-2271) PageRank gives wrong results with weighted graph input

Vasia Kalavri created FLINK-2271: Summary: PageRank gives wrong results with weighted graph input Key: FLINK-2271 URL: https://issues.apache.org/jira/browse/FLINK-2271 Project: Flink Issue Ty

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

Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/860#discussion_r33139196 --- Diff: flink-staging/flink-streaming/flink-streaming-core/src/test/java/org/apache/flink/streaming/api/operators/StreamFoldTest.java --- @@ -1,57 +0,0 @@

[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-tabpanel&focusedCommentId=14599277#comment-14599277 ] ASF GitHub Bot commented on FLINK-2261: --- Github user aljoscha commented on a diff in

[jira] [Created] (FLINK-2270) Error in KafkaSource Documentation

Stephan Ewen created FLINK-2270: --- Summary: Error in KafkaSource Documentation Key: FLINK-2270 URL: https://issues.apache.org/jira/browse/FLINK-2270 Project: Flink Issue Type: Bug Comp

[GitHub] flink pull request: [FLINK-2264] [gelly] changed the tests to use ...

GitHub user samk3211 opened a pull request: https://github.com/apache/flink/pull/863 [FLINK-2264] [gelly] changed the tests to use collect instead of temp… … files You can merge this pull request into a Git repository by running: $ git pull https://github.com/samk3211/flink

[jira] [Commented] (FLINK-2264) Migrate integration tests for Gelly

[ https://issues.apache.org/jira/browse/FLINK-2264?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14599232#comment-14599232 ] ASF GitHub Bot commented on FLINK-2264: --- GitHub user samk3211 opened a pull request:

[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-tabpanel&focusedCommentId=14599216#comment-14599216 ] ASF GitHub Bot commented on FLINK-2261: --- Github user gyfora commented on a diff in t

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

Github user gyfora commented on a diff in the pull request: https://github.com/apache/flink/pull/860#discussion_r33134099 --- Diff: flink-staging/flink-streaming/flink-streaming-core/src/test/java/org/apache/flink/streaming/api/operators/StreamFoldTest.java --- @@ -1,57 +0,0 @@

[jira] [Commented] (FLINK-2266) Building Flink for a specific HDP version fails

[ https://issues.apache.org/jira/browse/FLINK-2266?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14599214#comment-14599214 ] Ufuk Celebi commented on FLINK-2266: http://repo.grails.org/grails/repo/org/mortbay/je

[jira] [Commented] (FLINK-2266) Building Flink for a specific HDP version fails

[ https://issues.apache.org/jira/browse/FLINK-2266?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14599190#comment-14599190 ] Robert Metzger commented on FLINK-2266: --- It seems that {{org.mortbay.jetty:jetty-uti

[jira] [Updated] (FLINK-2266) Building Flink for a specific HDP version fails

[ https://issues.apache.org/jira/browse/FLINK-2266?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-2266: -- Description: I was talking to a user recently, who had issues using Flink's build-in HDFS clien

[jira] [Updated] (FLINK-2248) Allow disabling of sdtout logging output

[ https://issues.apache.org/jira/browse/FLINK-2248?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-2248: -- Labels: starter (was: ) > Allow disabling of sdtout logging output > --

[jira] [Created] (FLINK-2269) Add Receiver operating characteristic (ROC) curve evaluation

Theodore Vasiloudis created FLINK-2269: -- Summary: Add Receiver operating characteristic (ROC) curve evaluation Key: FLINK-2269 URL: https://issues.apache.org/jira/browse/FLINK-2269 Project: Flink

[jira] [Created] (FLINK-2268) Provide Flink binary release without Hadoop

Robert Metzger created FLINK-2268: - Summary: Provide Flink binary release without Hadoop Key: FLINK-2268 URL: https://issues.apache.org/jira/browse/FLINK-2268 Project: Flink Issue Type: Impro

[jira] [Created] (FLINK-2267) Support multi-class scoring for binary classification scores

Theodore Vasiloudis created FLINK-2267: -- Summary: Support multi-class scoring for binary classification scores Key: FLINK-2267 URL: https://issues.apache.org/jira/browse/FLINK-2267 Project: Flink

[GitHub] flink pull request: New operator state interfaces

Github user aljoscha commented on the pull request: https://github.com/apache/flink/pull/747#issuecomment-114803586 Ahh I see, my bad. :sweat_smile: --- 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 no

[GitHub] flink pull request: New operator state interfaces

Github user gyfora commented on the pull request: https://github.com/apache/flink/pull/747#issuecomment-114803149 The setConnectionType method is overwritten which will actually make this happen --- If your project is set up for it, you can reply to this email and have your reply app

[jira] [Commented] (FLINK-2125) String delimiter for SocketTextStream

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

[GitHub] flink pull request: FLINK-2125

Github user mbalassi commented on the pull request: https://github.com/apache/flink/pull/862#issuecomment-114800805 Hey, Thanks for picking up this issue. The main task here is that the `Reader#read()` method returns an int representation of a character. To use String delimit

[GitHub] flink pull request: New operator state interfaces

Github user aljoscha commented on the pull request: https://github.com/apache/flink/pull/747#issuecomment-114797858 @senorcarbone You mentioned that the KeyedDataStream disallows calls to shuffle()/repartition()/groupBy() and so on. But KeyedDataStream doesn't seem to have this functi

[GitHub] flink pull request: New operator state interfaces

Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/747#discussion_r33129995 --- Diff: flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/datastream/KeyedDataStream.java --- @@ -0,0 +1,78 @

[GitHub] flink pull request: New operator state interfaces

Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/747#discussion_r33129956 --- Diff: flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/datastream/DataStream.java --- @@ -301,16 +301,68 @

[jira] [Assigned] (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 ] Márton Balassi reassigned FLINK-2209: - Assignee: Márton Balassi > Document how to use TableAPI, Gelly and FlinkML, StreamingConn

[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-tabpanel&focusedCommentId=14599119#comment-14599119 ] ASF GitHub Bot commented on FLINK-2261: --- Github user mbalassi commented on a diff in

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

Github user mbalassi commented on a diff in the pull request: https://github.com/apache/flink/pull/860#discussion_r33128501 --- Diff: flink-staging/flink-streaming/flink-streaming-core/src/test/java/org/apache/flink/streaming/api/operators/StreamFoldTest.java --- @@ -1,57 +0,0 @@

[jira] [Created] (FLINK-2266) Building Flink for a specific HDP version fails

Robert Metzger created FLINK-2266: - Summary: Building Flink for a specific HDP version fails Key: FLINK-2266 URL: https://issues.apache.org/jira/browse/FLINK-2266 Project: Flink Issue Type: B

[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-tabpanel&focusedCommentId=14599105#comment-14599105 ] ASF GitHub Bot commented on FLINK-2209: --- Github user rmetzger commented on the pull

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

Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/835#issuecomment-114790171 Can you take care of this @mbalassi ? --- 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 do

[jira] [Closed] (FLINK-2174) Allow comments in 'slaves' file

[ https://issues.apache.org/jira/browse/FLINK-2174?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels closed FLINK-2174. - Resolution: Fixed Changed "fix version" because this was included in the 0.9.0 release. >

[jira] [Updated] (FLINK-2174) Allow comments in 'slaves' file

[ https://issues.apache.org/jira/browse/FLINK-2174?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated FLINK-2174: -- Fix Version/s: (was: 0.10) 0.9 > Allow comments in 'slaves' file

[jira] [Reopened] (FLINK-2174) Allow comments in 'slaves' file

[ https://issues.apache.org/jira/browse/FLINK-2174?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels reopened FLINK-2174: --- > Allow comments in 'slaves' file > --- > > Ke

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

[ https://issues.apache.org/jira/browse/FLINK-1962?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14599036#comment-14599036 ] Stephan Ewen commented on FLINK-1962: - Yes, all Scala projects need extra POM entries

  1   2   >