[
https://issues.apache.org/jira/browse/FLINK-2200?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=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.
/div
/div
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
[
https://issues.apache.org/jira/browse/FLINK-2208?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14616397#comment-14616397
]
ASF GitHub Bot commented on FLINK-2208:
---
Github user StephanEwen commented on the
[
https://issues.apache.org/jira/browse/FLINK-1745?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14616367#comment-14616367
]
ASF GitHub Bot commented on FLINK-1745:
---
Github user chiwanpark commented on a diff
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:
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
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]
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
[
https://issues.apache.org/jira/browse/FLINK-2288?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14616639#comment-14616639
]
ASF GitHub Bot commented on FLINK-2288:
---
Github user StephanEwen commented on a diff
[
https://issues.apache.org/jira/browse/FLINK-2157?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14616580#comment-14616580
]
ASF GitHub Bot commented on FLINK-2157:
---
Github user thvasilo commented on a diff in
[
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 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 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
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-2240?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14616423#comment-14616423
]
ASF GitHub Bot commented on FLINK-2240:
---
Github user StephanEwen commented on the
[
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
[
https://issues.apache.org/jira/browse/FLINK-2321?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14616455#comment-14616455
]
ASF GitHub Bot commented on FLINK-2321:
---
Github user tillrohrmann commented on the
[
https://issues.apache.org/jira/browse/FLINK-2323?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14616453#comment-14616453
]
ASF GitHub Bot commented on FLINK-2323:
---
GitHub user gyfora opened a pull request:
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
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
[
https://issues.apache.org/jira/browse/FLINK-2157?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14616467#comment-14616467
]
ASF GitHub Bot commented on FLINK-2157:
---
Github user tillrohrmann commented on a
[
https://issues.apache.org/jira/browse/FLINK-2323?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14616503#comment-14616503
]
ASF GitHub Bot commented on FLINK-2323:
---
Github user asfgit closed the pull request
[
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 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
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
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.org/jira/browse/FLINK-2292?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14616469#comment-14616469
]
ASF GitHub Bot commented on FLINK-2292:
---
Github user mxm commented on the pull
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
[
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-2325?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14616446#comment-14616446
]
Robert Metzger commented on FLINK-2325:
---
Thank you for reporting this. I'm currently
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
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 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
[
https://issues.apache.org/jira/browse/FLINK-2288?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14616668#comment-14616668
]
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-tabpanelfocusedCommentId=14616675#comment-14616675
]
Paris Carbone commented on FLINK-2324:
--
We cannot avoid a key-value store to make
[
https://issues.apache.org/jira/browse/FLINK-2288?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14616663#comment-14616663
]
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-tabpanelfocusedCommentId=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_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-tabpanelfocusedCommentId=14616701#comment-14616701
]
ASF GitHub Bot commented on FLINK-2288:
---
Github user StephanEwen commented on the
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 {
[
https://issues.apache.org/jira/browse/FLINK-2288?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14616695#comment-14616695
]
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
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
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
[
https://issues.apache.org/jira/browse/FLINK-2288?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14616782#comment-14616782
]
ASF GitHub Bot commented on FLINK-2288:
---
Github user tillrohrmann commented on a
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
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
48 matches
Mail list logo
