Github user gaborhermann commented on the pull request:
https://github.com/apache/flink/pull/802#issuecomment-119321451
The main purpose of this is to enable a deterministic (non-time based) test
for iteration as it sometimes failed for some reason on Travis. (See [here]
(https://issu
[
https://issues.apache.org/jira/browse/FLINK-2180?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14617291#comment-14617291
]
ASF GitHub Bot commented on FLINK-2180:
---
Github user gaborhermann commented on the p
[
https://issues.apache.org/jira/browse/FLINK-2200?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14617040#comment-14617040
]
ASF GitHub Bot commented on FLINK-2200:
---
Github user chiwanpark commented on a diff
Github user chiwanpark commented on a diff in the pull request:
https://github.com/apache/flink/pull/885#discussion_r34067611
--- Diff: docs/apis/programming_guide.md ---
@@ -187,7 +187,17 @@ that creates the type information for Flink operations.
+ Scala D
[
https://issues.apache.org/jira/browse/FLINK-2180?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14616993#comment-14616993
]
ASF GitHub Bot commented on FLINK-2180:
---
Github user gyfora commented on the pull re
Github user gyfora commented on the pull request:
https://github.com/apache/flink/pull/802#issuecomment-119269914
What's the purpose of having this EndOfIteration predicate? Can you give me
a use-case where this functionality is desired?
---
If your project is set up for it, you can
Github user FelixNeutatz commented on the pull request:
https://github.com/apache/flink/pull/833#issuecomment-119234837
I have no time at the moment to think about it. But this is still an issue
...
---
If your project is set up for it, you can reply to this email and have your
reply
[
https://issues.apache.org/jira/browse/FLINK-2208?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14616839#comment-14616839
]
ASF GitHub Bot commented on FLINK-2208:
---
Github user FelixNeutatz commented on the p
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/886#discussion_r34050754
--- Diff:
flink-runtime/src/main/scala/org/apache/flink/runtime/jobmanager/JobManager.scala
---
@@ -993,9 +1000,34 @@ object JobManager {
conf
[
https://issues.apache.org/jira/browse/FLINK-2288?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14616835#comment-14616835
]
ASF GitHub Bot commented on FLINK-2288:
---
Github user tillrohrmann commented on a dif
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/782#issuecomment-119228449
I'll add a commit for closing this...
---
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
[
https://issues.apache.org/jira/browse/FLINK-2293?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14616817#comment-14616817
]
Stephan Ewen commented on FLINK-2293:
-
I have a patch coming up...
> Division by Zero
[
https://issues.apache.org/jira/browse/FLINK-2000?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14616810#comment-14616810
]
ASF GitHub Bot commented on FLINK-2000:
---
Github user StephanEwen commented on the pu
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/852#issuecomment-119228088
Looks good, merging this...
---
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 h
[
https://issues.apache.org/jira/browse/FLINK-2242?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14616809#comment-14616809
]
ASF GitHub Bot commented on FLINK-2242:
---
Github user StephanEwen commented on the pu
[
https://issues.apache.org/jira/browse/FLINK-2326?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14616804#comment-14616804
]
Robert Metzger commented on FLINK-2326:
---
Thank you for opening this issue.
You don'
[
https://issues.apache.org/jira/browse/FLINK-2288?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14616791#comment-14616791
]
ASF GitHub Bot commented on FLINK-2288:
---
Github user StephanEwen commented on a diff
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/886#discussion_r34047058
--- Diff:
flink-runtime/src/main/scala/org/apache/flink/runtime/jobmanager/JobManager.scala
---
@@ -993,9 +1000,34 @@ object JobManager {
confi
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/886#discussion_r34045870
--- Diff:
flink-runtime/src/main/scala/org/apache/flink/runtime/jobmanager/JobManager.scala
---
@@ -993,9 +1000,34 @@ object JobManager {
conf
LINTE created FLINK-2326:
Summary: Mutitenancy on Yarn
Key: FLINK-2326
URL: https://issues.apache.org/jira/browse/FLINK-2326
Project: Flink
Issue Type: Improvement
Components: YARN Client
[
https://issues.apache.org/jira/browse/FLINK-2288?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14616782#comment-14616782
]
ASF GitHub Bot commented on FLINK-2288:
---
Github user tillrohrmann commented on a dif
[
https://issues.apache.org/jira/browse/FLINK-2288?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14616701#comment-14616701
]
ASF GitHub Bot commented on FLINK-2288:
---
Github user StephanEwen commented on the pu
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/886#issuecomment-119202663
Looks like a good piece of work!
Can we actually get into ZooKeeper version conflicts here? For example, the
Kafka connector needs a certain Zookeeper version
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/886#discussion_r34038430
--- Diff:
flink-runtime/src/main/scala/org/apache/flink/runtime/taskmanager/TaskManager.scala
---
@@ -1435,6 +1435,11 @@ object TaskManager {
//
[
https://issues.apache.org/jira/browse/FLINK-2288?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14616700#comment-14616700
]
ASF GitHub Bot commented on FLINK-2288:
---
Github user StephanEwen commented on a diff
[
https://issues.apache.org/jira/browse/FLINK-2288?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14616699#comment-14616699
]
ASF GitHub Bot commented on FLINK-2288:
---
Github user StephanEwen commented on a diff
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/886#discussion_r34038403
--- Diff:
flink-runtime/src/main/scala/org/apache/flink/runtime/jobmanager/JobManager.scala
---
@@ -993,9 +1000,34 @@ object JobManager {
confi
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/886#discussion_r34038257
--- Diff:
flink-runtime/src/main/scala/org/apache/flink/runtime/jobmanager/JobManager.scala
---
@@ -993,9 +1000,34 @@ object JobManager {
confi
[
https://issues.apache.org/jira/browse/FLINK-2288?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14616695#comment-14616695
]
ASF GitHub Bot commented on FLINK-2288:
---
Github user StephanEwen commented on a diff
[
https://issues.apache.org/jira/browse/FLINK-2324?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14616675#comment-14616675
]
Paris Carbone commented on FLINK-2324:
--
We cannot avoid a key-value store to make thi
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/886#discussion_r34037018
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/zookeeper/FlinkZooKeeperQuorumPeer.java
---
@@ -0,0 +1,227 @@
+/*
+ * Licensed to t
[
https://issues.apache.org/jira/browse/FLINK-2288?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14616668#comment-14616668
]
ASF GitHub Bot commented on FLINK-2288:
---
Github user StephanEwen commented on a diff
[
https://issues.apache.org/jira/browse/FLINK-2288?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14616663#comment-14616663
]
ASF GitHub Bot commented on FLINK-2288:
---
Github user StephanEwen commented on a diff
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/886#discussion_r34036874
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/zookeeper/FlinkZooKeeperQuorumPeer.java
---
@@ -0,0 +1,227 @@
+/*
+ * Licensed to t
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/886#discussion_r34035723
--- Diff: docs/setup/jobmanager_high_availability.md ---
@@ -0,0 +1,121 @@
+---
+title: "JobManager High Availability (HA)"
+---
+
+
[
https://issues.apache.org/jira/browse/FLINK-2288?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14616639#comment-14616639
]
ASF GitHub Bot commented on FLINK-2288:
---
Github user StephanEwen commented on a diff
[
https://issues.apache.org/jira/browse/FLINK-1943?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Vasia Kalavri reassigned FLINK-1943:
Assignee: Vasia Kalavri
> Add Gelly-GSA compiler and translation tests
> --
Github user mfahimazizi commented on the pull request:
https://github.com/apache/flink/pull/765#issuecomment-119188834
Hi @vasia,
sorry for late reply.
I set indentation with tabs instead of spaces in IDE.
and push new updated files.
as I discuss in jira issue about vert
[
https://issues.apache.org/jira/browse/FLINK-2157?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14616580#comment-14616580
]
ASF GitHub Bot commented on FLINK-2157:
---
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/871#discussion_r34032155
--- Diff:
flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/evaluation/Score.scala
---
@@ -0,0 +1,137 @@
+/*
+ * Licensed to the Apache Softw
[
https://issues.apache.org/jira/browse/FLINK-2323?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora closed FLINK-2323.
-
Resolution: Fixed
> Rename OperatorState methods to .value() and .update(..)
> ---
[
https://issues.apache.org/jira/browse/FLINK-2323?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14616503#comment-14616503
]
ASF GitHub Bot commented on FLINK-2323:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/890
---
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 enabl
Github user aljoscha commented on the pull request:
https://github.com/apache/flink/pull/890#issuecomment-119164038
+2 Looks good, this is a simple rename :ski:
---
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 proj
[
https://issues.apache.org/jira/browse/FLINK-2323?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14616489#comment-14616489
]
ASF GitHub Bot commented on FLINK-2323:
---
Github user aljoscha commented on the pull
[
https://issues.apache.org/jira/browse/FLINK-1745?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14616488#comment-14616488
]
ASF GitHub Bot commented on FLINK-1745:
---
Github user chiwanpark commented on the pul
Github user chiwanpark commented on the pull request:
https://github.com/apache/flink/pull/696#issuecomment-119163944
@thvasilo Yeah exact k-NN is not scalable for gigabytes-sized,
terabytes-sized data. If I add R-Tree to this algorithm, the algorithm would be
better. But I agree that
[
https://issues.apache.org/jira/browse/FLINK-2319?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kostas updated FLINK-2319:
--
Issue Type: Bug (was: New Feature)
> Collect size limitation due to akka.
> ---
Github user kl0u commented on the pull request:
https://github.com/apache/flink/pull/887#issuecomment-119160424
Thanks a lot @mxm
---
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
[
https://issues.apache.org/jira/browse/FLINK-2292?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14616469#comment-14616469
]
ASF GitHub Bot commented on FLINK-2292:
---
Github user mxm commented on the pull reque
Github user mxm commented on the pull request:
https://github.com/apache/flink/pull/887#issuecomment-119157639
Hi @kl0u, the tickets are https://issues.apache.org/jira/browse/FLINK-2292
and https://issues.apache.org/jira/browse/FLINK-1573.
---
If your project is set up for it, you ca
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/871#discussion_r34025701
--- Diff:
flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/evaluation/Score.scala
---
@@ -0,0 +1,137 @@
+/*
+ * Licensed to the Apache S
[
https://issues.apache.org/jira/browse/FLINK-2157?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14616468#comment-14616468
]
ASF GitHub Bot commented on FLINK-2157:
---
Github user tillrohrmann commented on a dif
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/871#discussion_r34025726
--- Diff:
flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/evaluation/Score.scala
---
@@ -0,0 +1,137 @@
+/*
+ * Licensed to the Apache S
[
https://issues.apache.org/jira/browse/FLINK-2157?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14616467#comment-14616467
]
ASF GitHub Bot commented on FLINK-2157:
---
Github user tillrohrmann commented on a dif
[
https://issues.apache.org/jira/browse/FLINK-2321?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14616455#comment-14616455
]
ASF GitHub Bot commented on FLINK-2321:
---
Github user tillrohrmann commented on the p
[
https://issues.apache.org/jira/browse/FLINK-2323?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14616453#comment-14616453
]
ASF GitHub Bot commented on FLINK-2323:
---
GitHub user gyfora opened a pull request:
Github user tillrohrmann commented on the pull request:
https://github.com/apache/flink/pull/889#issuecomment-119151761
Good catch @thvasilo. LGTM. Will merge it with the next batch.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub
GitHub user gyfora opened a pull request:
https://github.com/apache/flink/pull/890
[FLINK-2323] [api-breaking] Rename OperatorState interface methods to
value() and update(..)
Refactor OperatorState interface for clearer method names
You can merge this pull request into a Git repos
[
https://issues.apache.org/jira/browse/FLINK-2325?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14616446#comment-14616446
]
Robert Metzger commented on FLINK-2325:
---
Thank you for reporting this. I'm currently
[
https://issues.apache.org/jira/browse/FLINK-2325?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger reassigned FLINK-2325:
-
Assignee: Robert Metzger
> PersistentKafkaSource throws ArrayIndexOutOfBoundsException if
Rico Bergmann created FLINK-2325:
Summary: PersistentKafkaSource throws
ArrayIndexOutOfBoundsException if reading from a topic that is created after
starting the Source
Key: FLINK-2325
URL: https://issues.apache.
Github user kl0u commented on the pull request:
https://github.com/apache/flink/pull/887#issuecomment-119140624
Ok, sounds good!
Could you give the number of the ticket of the changes @mxm is doing?
Just to have a look.
---
If your project is set up for it, you can reply to
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/887#issuecomment-119137396
I think all in all, this looks good.
We have another change by @mxm pending that changes the accumulators to do
live updates during runtime. Since @mxm's chan
[
https://issues.apache.org/jira/browse/FLINK-2240?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14616423#comment-14616423
]
ASF GitHub Bot commented on FLINK-2240:
---
Github user StephanEwen commented on the pu
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/888#issuecomment-119136367
This is a very nice idea, thank you for the contribution! The numbers look
quite encouraging.
I need to look into this carefully, as it touches a very sensiti
[
https://issues.apache.org/jira/browse/FLINK-2208?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14616397#comment-14616397
]
ASF GitHub Bot commented on FLINK-2208:
---
Github user StephanEwen commented on the pu
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/833#issuecomment-119133444
Is anything happening with this pull request?
If you do not want to update it any more, could you close it?
---
If your project is set up for it, you can re
Gyula Fora created FLINK-2324:
-
Summary: Rework partitioned state storage
Key: FLINK-2324
URL: https://issues.apache.org/jira/browse/FLINK-2324
Project: Flink
Issue Type: Improvement
Gyula Fora created FLINK-2323:
-
Summary: Rename OperatorState methods to .value() and .update(..)
Key: FLINK-2323
URL: https://issues.apache.org/jira/browse/FLINK-2323
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-1745?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14616367#comment-14616367
]
ASF GitHub Bot commented on FLINK-1745:
---
Github user chiwanpark commented on a diff
Github user chiwanpark commented on a diff in the pull request:
https://github.com/apache/flink/pull/696#discussion_r34017778
--- Diff:
flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/classification/KNN.scala
---
@@ -0,0 +1,204 @@
+/*
+ * Licensed to the Apache S
72 matches
Mail list logo
