[
https://issues.apache.org/jira/browse/FLINK-1731?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14606437#comment-14606437
]
ASF GitHub Bot commented on FLINK-1731:
---
Github user peedeeX21 commented on the pull
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` of
[
https://issues.apache.org/jira/browse/FLINK-2138?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14605880#comment-14605880
]
ASF GitHub Bot commented on FLINK-2138:
---
Github user gaborhermann commented on the p
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 impleme
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
d
[
https://issues.apache.org/jira/browse/FLINK-2138?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14605818#comment-14605818
]
ASF GitHub Bot commented on FLINK-2138:
---
Github user StephanEwen commented on the pu
[
https://issues.apache.org/jira/browse/FLINK-2138?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14605774#comment-14605774
]
ASF GitHub Bot commented on FLINK-2138:
---
Github user gaborhermann commented on the p
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 ho
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 Sof
[
https://issues.apache.org/jira/browse/FLINK-1731?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14605768#comment-14605768
]
ASF GitHub Bot commented on FLINK-1731:
---
Github user peedeeX21 commented on a diff i
[
https://issues.apache.org/jira/browse/FLINK-1731?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14605753#comment-14605753
]
ASF GitHub Bot commented on FLINK-1731:
---
Github user peedeeX21 commented on a diff i
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 Sof
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 Sof
[
https://issues.apache.org/jira/browse/FLINK-1731?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14605752#comment-14605752
]
ASF GitHub Bot commented on FLINK-1731:
---
Github user peedeeX21 commented on a diff i
[
https://issues.apache.org/jira/browse/FLINK-1731?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14605726#comment-14605726
]
ASF GitHub Bot commented on FLINK-1731:
---
Github user peedeeX21 commented on a diff i
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 Sof
[
https://issues.apache.org/jira/browse/FLINK-2138?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14605711#comment-14605711
]
ASF GitHub Bot commented on FLINK-2138:
---
Github user StephanEwen commented on the pu
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 partition
[
https://issues.apache.org/jira/browse/FLINK-1731?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14605680#comment-14605680
]
ASF GitHub Bot commented on FLINK-1731:
---
Github user peedeeX21 commented on a diff i
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 Sof
[
https://issues.apache.org/jira/browse/FLINK-1731?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14605665#comment-14605665
]
ASF GitHub Bot commented on FLINK-1731:
---
Github user peedeeX21 commented on a diff i
Github user peedeeX21 commented on a diff in the pull request:
https://github.com/apache/flink/pull/700#discussion_r33468244
--- Diff:
flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/clustering/KMeans.scala
---
@@ -0,0 +1,247 @@
+/*
+ * Licensed to the Apache Sof
[
https://issues.apache.org/jira/browse/FLINK-1731?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14605652#comment-14605652
]
ASF GitHub Bot commented on FLINK-1731:
---
Github user sachingoel0101 commented on the
Github user sachingoel0101 commented on the pull request:
https://github.com/apache/flink/pull/700#issuecomment-116685600
I've been following this PR since my PR on initialization schemes can't be
merged before this. I already have three initialization mechanisms [namely
Random, k-mea
Github user thvasilo commented on a diff in the pull request:
https://github.com/apache/flink/pull/700#discussion_r33466208
--- Diff:
flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/clustering/KMeans.scala
---
@@ -0,0 +1,247 @@
+/*
+ * Licensed to the Apache Soft
[
https://issues.apache.org/jira/browse/FLINK-1731?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14605638#comment-14605638
]
ASF GitHub Bot commented on FLINK-1731:
---
Github user thvasilo commented on a diff in
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 comp
[
https://issues.apache.org/jira/browse/FLINK-2138?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14605634#comment-14605634
]
ASF GitHub Bot commented on FLINK-2138:
---
Github user gaborhermann commented on the p
[
https://issues.apache.org/jira/browse/FLINK-1731?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14605632#comment-14605632
]
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-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 s
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 --
d
[
https://issues.apache.org/jira/browse/FLINK-1731?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14605627#comment-14605627
]
ASF GitHub Bot commented on FLINK-1731:
---
Github user peedeeX21 commented on a diff i
[
https://issues.apache.org/jira/browse/FLINK-1960?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Theodore Vasiloudis updated FLINK-1960:
---
Labels: documentation starter (was: documentation)
> Add comments and docs for withFo
[
https://issues.apache.org/jira/browse/FLINK-1731?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=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
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
[
https://issues.apache.org/jira/browse/FLINK-1731?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=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_r33463484
--- Diff:
flink-staging/flink-ml/src/test/scala/org/apache/flink/ml/clustering/Clustering.scala
---
@@ -0,0 +1,256 @@
+/*
--- End diff --
Re
[
https://issues.apache.org/jira/browse/FLINK-1731?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14605612#comment-14605612
]
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-tabpanel&focusedCommentId=14605607#comment-14605607
]
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_r33463192
--- Diff:
flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/clustering/KMeans.scala
---
@@ -0,0 +1,247 @@
+/*
+ * Licensed to the Apache Soft
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 Soft
[
https://issues.apache.org/jira/browse/FLINK-1731?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=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_r33462036
--- Diff:
flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/clustering/KMeans.scala
---
@@ -0,0 +1,247 @@
+/*
+ * Licensed to the Apache Soft
[
https://issues.apache.org/jira/browse/FLINK-1731?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14605595#comment-14605595
]
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_r33461173
--- Diff:
flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/clustering/KMeans.scala
---
@@ -0,0 +1,247 @@
+/*
+ * Licensed to the Apache Soft
[
https://issues.apache.org/jira/browse/FLINK-1731?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=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-tabpanel&focusedCommentId=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 Soft
[
https://issues.apache.org/jira/browse/FLINK-1731?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=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_r33460336
--- Diff:
flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/clustering/KMeans.scala
---
@@ -0,0 +1,247 @@
+/*
+ * Licensed to the Apache Soft
[
https://issues.apache.org/jira/browse/FLINK-2138?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14605570#comment-14605570
]
ASF GitHub Bot commented on FLINK-2138:
---
Github user StephanEwen commented on the pu
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 API
[
https://issues.apache.org/jira/browse/FLINK-2138?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14605565#comment-14605565
]
ASF GitHub Bot commented on FLINK-2138:
---
Github user gaborhermann commented on the p
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` in
[
https://issues.apache.org/jira/browse/FLINK-2008?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14605544#comment-14605544
]
Robert Metzger commented on FLINK-2008:
---
I'm looking into these issues now ...
> Pe
[
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 Whe
[
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 as
[
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
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-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-2289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14605534#comment-14605534
]
Till Rohrmann commented on FLINK-2289:
--
Sorry, I didn't see your issue. Will do.
> M
Aljoscha Krettek created FLINK-2290:
---
Summary: CoRecordReader Does Not Read Events From Both Inputs When
No Elements Arrive
Key: FLINK-2290
URL: https://issues.apache.org/jira/browse/FLINK-2290
Proj
[
https://issues.apache.org/jira/browse/FLINK-2200?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=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-2283?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14605416#comment-14605416
]
Stephan Ewen commented on FLINK-2283:
-
This would be a temporary solution that will mo
[
https://issues.apache.org/jira/browse/FLINK-2283?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14605357#comment-14605357
]
Gyula Fora commented on FLINK-2283:
---
I would use stateful java maps using PartitionedSta
[
https://issues.apache.org/jira/browse/FLINK-2284?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14605353#comment-14605353
]
Matthias J. Sax commented on FLINK-2284:
It is documented in {{org.apache.flink.st
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://github.com/mbalassi
[
https://issues.apache.org/jira/browse/FLINK-2285?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14605340#comment-14605340
]
ASF GitHub Bot commented on FLINK-2285:
---
GitHub user mbalassi opened a pull request:
[
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
>
[
https://issues.apache.org/jira/browse/FLINK-2282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14605335#comment-14605335
]
Gyula Fora commented on FLINK-2282:
---
Okay
> Deprecate non-grouped stream reduce/fold/ag
[
https://issues.apache.org/jira/browse/FLINK-2282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14605330#comment-14605330
]
Stephan Ewen commented on FLINK-2282:
-
Since the API is labeled "beta", it is okay to
[
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-tabpanel&focusedCommentId=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-2282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14605319#comment-14605319
]
Gyula Fora commented on FLINK-2282:
---
You are right we should have thought about this bef
[
https://issues.apache.org/jira/browse/FLINK-2284?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14605314#comment-14605314
]
Gyula Fora commented on FLINK-2284:
---
But I think it is completely okay to modify them to
[
https://issues.apache.org/jira/browse/FLINK-2284?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14605312#comment-14605312
]
Gyula Fora commented on FLINK-2284:
---
We took these names from Storm which we saw at that
[
https://issues.apache.org/jira/browse/FLINK-2289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14605308#comment-14605308
]
Ufuk Celebi commented on FLINK-2289:
Issue creation race... ;) Can you copy your text
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
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
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
[
https://issues.apache.org/jira/browse/FLINK-2283?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14605298#comment-14605298
]
Stephan Ewen commented on FLINK-2283:
-
Are these again implemented in java maps, or ar
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-2282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14605297#comment-14605297
]
Stephan Ewen edited comment on FLINK-2282 at 6/29/15 8:48 AM:
--
[
https://issues.apache.org/jira/browse/FLINK-2282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14605297#comment-14605297
]
Stephan Ewen commented on FLINK-2282:
-
Minor versions are bug-fix versions, major vers
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/872#issuecomment-116528738
I actually like this approach. We had the same discussion for the batch API
and resolved to this, because:
- You can always chain a `FlatMapFunction` with a
[
https://issues.apache.org/jira/browse/FLINK-2138?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14605296#comment-14605296
]
ASF GitHub Bot commented on FLINK-2138:
---
Github user StephanEwen commented on the pu
[
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 T
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-2230?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14605271#comment-14605271
]
ASF GitHub Bot commented on FLINK-2230:
---
Github user StephanEwen commented on the pu
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 the
[
https://issues.apache.org/jira/browse/FLINK-1735?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14605260#comment-14605260
]
ASF GitHub Bot commented on FLINK-1735:
---
Github user ChristophAl commented on the pu
[
https://issues.apache.org/jira/browse/FLINK-2281?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14605261#comment-14605261
]
Stephan Ewen commented on FLINK-2281:
-
Nice idea, but probably not very critical.
I w
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
[
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
> ---
96 matches
Mail list logo
