[
https://issues.apache.org/jira/browse/FLINK-2283?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14605416#comment-14605416
]
Stephan Ewen commented on FLINK-2283:
-
This would be a temporary solution that will
Github user gaborhermann commented on the pull request:
https://github.com/apache/flink/pull/872#issuecomment-116647912
By the way, in the Scala DataSet the user should specify the Java
`Partitioner[K]` class. Wouldn't it be more convenient to wrap a function like
`(K, Int) = Int`
[
https://issues.apache.org/jira/browse/FLINK-1731?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14605571#comment-14605571
]
ASF GitHub Bot commented on FLINK-1731:
---
Github user thvasilo commented on a diff in
Github user thvasilo commented on a diff in the pull request:
https://github.com/apache/flink/pull/700#discussion_r33462036
--- Diff:
flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/clustering/KMeans.scala
---
@@ -0,0 +1,247 @@
+/*
+ * Licensed to the Apache
[
https://issues.apache.org/jira/browse/FLINK-1731?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14605612#comment-14605612
]
ASF GitHub Bot commented on FLINK-1731:
---
Github user thvasilo commented on a diff in
Github user thvasilo commented on a diff in the pull request:
https://github.com/apache/flink/pull/700#discussion_r33463484
--- Diff:
flink-staging/flink-ml/src/test/scala/org/apache/flink/ml/clustering/Clustering.scala
---
@@ -0,0 +1,256 @@
+/*
--- End diff --
[
https://issues.apache.org/jira/browse/FLINK-2138?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14605634#comment-14605634
]
ASF GitHub Bot commented on FLINK-2138:
---
Github user gaborhermann commented on the
[
https://issues.apache.org/jira/browse/FLINK-2138?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14605565#comment-14605565
]
ASF GitHub Bot commented on FLINK-2138:
---
Github user gaborhermann commented on the
[
https://issues.apache.org/jira/browse/FLINK-2138?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14605570#comment-14605570
]
ASF GitHub Bot commented on FLINK-2138:
---
Github user StephanEwen commented on the
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/872#issuecomment-116649358
In the batch API, equality of the partitioners is used to determine
compatibility of the partitioning. This may at some point become interesting
for the streaming
[
https://issues.apache.org/jira/browse/FLINK-1731?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14605613#comment-14605613
]
ASF GitHub Bot commented on FLINK-1731:
---
Github user thvasilo commented on a diff in
Github user thvasilo commented on a diff in the pull request:
https://github.com/apache/flink/pull/700#discussion_r33463634
--- Diff:
flink-staging/flink-ml/src/test/scala/org/apache/flink/ml/clustering/Clustering.scala
---
@@ -0,0 +1,256 @@
+/*
+ * Licensed to the Apache
Github user thvasilo commented on the pull request:
https://github.com/apache/flink/pull/700#issuecomment-116669400
Another note: It should not be necessary for the user to provide the
initial centroids, those should be possible to generated from the algorithm
itself, ideally with a
Github user thvasilo commented on a diff in the pull request:
https://github.com/apache/flink/pull/700#discussion_r33460336
--- Diff:
flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/clustering/KMeans.scala
---
@@ -0,0 +1,247 @@
+/*
+ * Licensed to the Apache
Github user thvasilo commented on a diff in the pull request:
https://github.com/apache/flink/pull/700#discussion_r33461173
--- Diff:
flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/clustering/KMeans.scala
---
@@ -0,0 +1,247 @@
+/*
+ * Licensed to the Apache
Github user thvasilo commented on a diff in the pull request:
https://github.com/apache/flink/pull/700#discussion_r33463192
--- Diff:
flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/clustering/KMeans.scala
---
@@ -0,0 +1,247 @@
+/*
+ * Licensed to the Apache
[
https://issues.apache.org/jira/browse/FLINK-1731?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14605607#comment-14605607
]
ASF GitHub Bot commented on FLINK-1731:
---
Github user thvasilo commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-1731?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14605627#comment-14605627
]
ASF GitHub Bot commented on FLINK-1731:
---
Github user peedeeX21 commented on a diff
Github user peedeeX21 commented on a diff in the pull request:
https://github.com/apache/flink/pull/700#discussion_r33465223
--- Diff:
flink-staging/flink-ml/src/test/scala/org/apache/flink/ml/clustering/Clustering.scala
---
@@ -0,0 +1,256 @@
+/*
--- End diff --
Github user gaborhermann commented on the pull request:
https://github.com/apache/flink/pull/872#issuecomment-116671285
I'd prefer the function implementation (like `(K, Int) = Int`), but it
should stay consistent with the batch API. I don't see why the wrapping would
effect the
[
https://issues.apache.org/jira/browse/FLINK-1731?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14605573#comment-14605573
]
ASF GitHub Bot commented on FLINK-1731:
---
Github user thvasilo commented on a diff in
Github user thvasilo commented on a diff in the pull request:
https://github.com/apache/flink/pull/700#discussion_r33460529
--- Diff:
flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/clustering/KMeans.scala
---
@@ -0,0 +1,247 @@
+/*
+ * Licensed to the Apache
[
https://issues.apache.org/jira/browse/FLINK-1731?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14605585#comment-14605585
]
ASF GitHub Bot commented on FLINK-1731:
---
Github user thvasilo commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-1731?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14605598#comment-14605598
]
ASF GitHub Bot commented on FLINK-1731:
---
Github user thvasilo commented on a diff in
Github user thvasilo commented on a diff in the pull request:
https://github.com/apache/flink/pull/700#discussion_r33462286
--- Diff:
flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/clustering/KMeans.scala
---
@@ -0,0 +1,247 @@
+/*
+ * Licensed to the Apache
[
https://issues.apache.org/jira/browse/FLINK-2008?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14605544#comment-14605544
]
Robert Metzger commented on FLINK-2008:
---
I'm looking into these issues now ...
[
https://issues.apache.org/jira/browse/FLINK-1731?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14605595#comment-14605595
]
ASF GitHub Bot commented on FLINK-1731:
---
Github user thvasilo commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-1731?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14605615#comment-14605615
]
ASF GitHub Bot commented on FLINK-1731:
---
Github user thvasilo commented on the pull
Github user thvasilo commented on the pull request:
https://github.com/apache/flink/pull/700#issuecomment-116662421
Hello I've left some initial comments. Once those have been addressed I'll
try to do some more integration testing and then pass the review over to a
commiter.
---
If
[
https://issues.apache.org/jira/browse/FLINK-1731?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14605638#comment-14605638
]
ASF GitHub Bot commented on FLINK-1731:
---
Github user thvasilo commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-2200?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14605502#comment-14605502
]
Chiwan Park commented on FLINK-2200:
Hi, I'm working on this issue. I found there is a
[
https://issues.apache.org/jira/browse/FLINK-2289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14605534#comment-14605534
]
Till Rohrmann commented on FLINK-2289:
--
Sorry, I didn't see your issue. Will do.
[
https://issues.apache.org/jira/browse/FLINK-2284?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14605353#comment-14605353
]
Matthias J. Sax commented on FLINK-2284:
It is documented in
[
https://issues.apache.org/jira/browse/FLINK-2290?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek reassigned FLINK-2290:
---
Assignee: Aljoscha Krettek
CoRecordReader Does Not Read Events From Both Inputs
Till Rohrmann created FLINK-2291:
Summary: Use ZooKeeper to elect JobManager leader and send
information to TaskManagers
Key: FLINK-2291
URL: https://issues.apache.org/jira/browse/FLINK-2291
Project:
[
https://issues.apache.org/jira/browse/FLINK-2283?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14605357#comment-14605357
]
Gyula Fora commented on FLINK-2283:
---
I would use stateful java maps using
[
https://issues.apache.org/jira/browse/FLINK-2289?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann closed FLINK-2289.
Resolution: Duplicate
See FLINK-2287
Make JobManager highly available
[
https://issues.apache.org/jira/browse/FLINK-2285?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14605340#comment-14605340
]
ASF GitHub Bot commented on FLINK-2285:
---
GitHub user mbalassi opened a pull request:
GitHub user mbalassi opened a pull request:
https://github.com/apache/flink/pull/873
[FLINK-2285] [streaming] Removed duplicate call in close from
GroupedActiveDiscretizer
You can merge this pull request into a Git repository by running:
$ git pull
[
https://issues.apache.org/jira/browse/FLINK-2291?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-2291:
-
Description:
Use ZooKeeper to determine the leader of a set of {{JobManager}} s which will
act
[
https://issues.apache.org/jira/browse/FLINK-2291?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-2291:
-
Description:
Use ZooKeeper to determine the leader of a set of {{JobManagers}} which will
act as
Github user peedeeX21 commented on a diff in the pull request:
https://github.com/apache/flink/pull/700#discussion_r33469076
--- Diff:
flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/clustering/KMeans.scala
---
@@ -0,0 +1,247 @@
+/*
+ * Licensed to the Apache
Github user peedeeX21 commented on a diff in the pull request:
https://github.com/apache/flink/pull/700#discussion_r33476507
--- Diff:
flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/clustering/KMeans.scala
---
@@ -0,0 +1,247 @@
+/*
+ * Licensed to the Apache
Github user gaborhermann commented on the pull request:
https://github.com/apache/flink/pull/872#issuecomment-116736041
Sorry for not making myself clear.
I would actually go for
4. Only the Scala function (both in the streaming and batch API)
I don't understand
[
https://issues.apache.org/jira/browse/FLINK-1731?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14605726#comment-14605726
]
ASF GitHub Bot commented on FLINK-1731:
---
Github user peedeeX21 commented on a diff
[
https://issues.apache.org/jira/browse/FLINK-1731?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14605752#comment-14605752
]
ASF GitHub Bot commented on FLINK-1731:
---
Github user peedeeX21 commented on a diff
Github user peedeeX21 commented on a diff in the pull request:
https://github.com/apache/flink/pull/700#discussion_r33475298
--- Diff:
flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/clustering/KMeans.scala
---
@@ -0,0 +1,247 @@
+/*
+ * Licensed to the Apache
[
https://issues.apache.org/jira/browse/FLINK-2138?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14605774#comment-14605774
]
ASF GitHub Bot commented on FLINK-2138:
---
Github user gaborhermann commented on the
[
https://issues.apache.org/jira/browse/FLINK-2138?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14605711#comment-14605711
]
ASF GitHub Bot commented on FLINK-2138:
---
Github user StephanEwen commented on the
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/872#issuecomment-116710090
I am confused now, what is it going to be?
1. Overloading, such that it is Scala function and Partitioner, at the
cost of redundant APIs.
2. Only
Github user peedeeX21 commented on a diff in the pull request:
https://github.com/apache/flink/pull/700#discussion_r33471983
--- Diff:
flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/clustering/KMeans.scala
---
@@ -0,0 +1,247 @@
+/*
+ * Licensed to the Apache
Github user peedeeX21 commented on a diff in the pull request:
https://github.com/apache/flink/pull/700#discussion_r33475321
--- Diff:
flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/clustering/KMeans.scala
---
@@ -0,0 +1,247 @@
+/*
+ * Licensed to the Apache
[
https://issues.apache.org/jira/browse/FLINK-1731?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14605753#comment-14605753
]
ASF GitHub Bot commented on FLINK-1731:
---
Github user peedeeX21 commented on a diff
[
https://issues.apache.org/jira/browse/FLINK-2138?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14605818#comment-14605818
]
ASF GitHub Bot commented on FLINK-2138:
---
Github user StephanEwen commented on the
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/872#issuecomment-116745707
The partitioner function in Scala was simply added as a mirror of the Java
API.
The batch API is stable, that means at most we can add a Scala function and
[
https://issues.apache.org/jira/browse/FLINK-2138?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14605880#comment-14605880
]
ASF GitHub Bot commented on FLINK-2138:
---
Github user gaborhermann commented on the
Github user gaborhermann commented on the pull request:
https://github.com/apache/flink/pull/872#issuecomment-116755999
Okay, then I will
* deprecate the partitioner implementation in the batch API
* add the function implementation to the batch API
* add the function
[
https://issues.apache.org/jira/browse/FLINK-2282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14605335#comment-14605335
]
Gyula Fora commented on FLINK-2282:
---
Okay
Deprecate non-grouped stream
[
https://issues.apache.org/jira/browse/FLINK-2282?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora closed FLINK-2282.
-
Resolution: Not A Problem
Deprecate non-grouped stream reduce/fold/aggregations for 0.9.1
Github user peedeeX21 commented on the pull request:
https://github.com/apache/flink/pull/700#issuecomment-116850459
I am having some trouble to fit our predictor into the new API.
The problem is, that with `PredictOperation` the type of the model has to
be defined. A `DataSet`
[
https://issues.apache.org/jira/browse/FLINK-2066?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-2066:
-
Assignee: Nuno Miguel Marques dos Santos
Make delay between execution retries configurable
[
https://issues.apache.org/jira/browse/FLINK-2282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14605297#comment-14605297
]
Stephan Ewen commented on FLINK-2282:
-
Minor versions are bug-fix versions, major
Till Rohrmann created FLINK-2289:
Summary: Make JobManager highly available
Key: FLINK-2289
URL: https://issues.apache.org/jira/browse/FLINK-2289
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-2283?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14605298#comment-14605298
]
Stephan Ewen commented on FLINK-2283:
-
Are these again implemented in java maps, or
[
https://issues.apache.org/jira/browse/FLINK-2282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14605330#comment-14605330
]
Stephan Ewen commented on FLINK-2282:
-
Since the API is labeled beta, it is okay to do
Stephan Ewen created FLINK-2284:
---
Summary: Confusing/inconsistent PartitioningStrategy
Key: FLINK-2284
URL: https://issues.apache.org/jira/browse/FLINK-2284
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-2282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14605297#comment-14605297
]
Stephan Ewen edited comment on FLINK-2282 at 6/29/15 8:48 AM:
--
Márton Balassi created FLINK-2286:
-
Summary: Window ParallelMerge sometimes swallows elements of the
last window
Key: FLINK-2286
URL: https://issues.apache.org/jira/browse/FLINK-2286
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-2289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14605308#comment-14605308
]
Ufuk Celebi commented on FLINK-2289:
Issue creation race... ;) Can you copy your text
[
https://issues.apache.org/jira/browse/FLINK-2285?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Márton Balassi reassigned FLINK-2285:
-
Assignee: Márton Balassi
Active policy emits elements of the last window twice
Márton Balassi created FLINK-2285:
-
Summary: Active policy emits elements of the last window twice
Key: FLINK-2285
URL: https://issues.apache.org/jira/browse/FLINK-2285
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-2284?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14605312#comment-14605312
]
Gyula Fora commented on FLINK-2284:
---
We took these names from Storm which we saw at that
Github user ChristophAl commented on the pull request:
https://github.com/apache/flink/pull/665#issuecomment-116517528
Hi,
after I rebased it on master and implemented the new pipeline interface, I
have some followup questions regarding the types we should accept for feature
Ufuk Celebi created FLINK-2287:
--
Summary: Implement JobManager high availability
Key: FLINK-2287
URL: https://issues.apache.org/jira/browse/FLINK-2287
Project: Flink
Issue Type: Improvement
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/867#issuecomment-116520207
@Shiti No need to apologize, that is all right. We are discussing a tricky
thing here...
It is true, right now, one needs to be aware of missing values in
[
https://issues.apache.org/jira/browse/FLINK-2138?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14605296#comment-14605296
]
ASF GitHub Bot commented on FLINK-2138:
---
Github user StephanEwen commented on the
[
https://issues.apache.org/jira/browse/FLINK-2281?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora closed FLINK-2281.
-
Resolution: Later
Allow chaining of operators with multiple inputs
[
https://issues.apache.org/jira/browse/FLINK-2281?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14605323#comment-14605323
]
Gyula Fora commented on FLINK-2281:
---
After a second thought, this will introduce a very
[
https://issues.apache.org/jira/browse/FLINK-2281?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14605261#comment-14605261
]
Stephan Ewen commented on FLINK-2281:
-
Nice idea, but probably not very critical.
I
[
https://issues.apache.org/jira/browse/FLINK-1735?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14605260#comment-14605260
]
ASF GitHub Bot commented on FLINK-1735:
---
Github user ChristophAl commented on the
Ufuk Celebi created FLINK-2288:
--
Summary: Setup ZooKeeper for distributed coordination
Key: FLINK-2288
URL: https://issues.apache.org/jira/browse/FLINK-2288
Project: Flink
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/FLINK-2282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14605319#comment-14605319
]
Gyula Fora commented on FLINK-2282:
---
You are right we should have thought about this
82 matches
Mail list logo
