[
https://issues.apache.org/jira/browse/FLINK-4068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15534886#comment-15534886
]
ASF GitHub Bot commented on FLINK-4068:
---
Github user wuchong commented on the issue:
Github user wuchong commented on the issue:
https://github.com/apache/flink/pull/2560
@twalthr I add some Table API tests but skip some tests doesn't supported
in Table API, such as `NULLIF`, `IN`, `EXTRACT`
---
If your project is set up for it, you can reply to this email and have
[
https://issues.apache.org/jira/browse/FLINK-4718?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15534817#comment-15534817
]
ASF GitHub Bot commented on FLINK-4718:
---
GitHub user nderraugh opened a pull request:
GitHub user nderraugh opened a pull request:
https://github.com/apache/flink/pull/2575
'Id' is the key of the stream and not the id of the event.
FLINK-4718 Confusing label in Parallel Streams Diagram
Minor text change to clarify a mildly confusing label in a diagram.
You
[
https://issues.apache.org/jira/browse/FLINK-4068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15534809#comment-15534809
]
ASF GitHub Bot commented on FLINK-4068:
---
Github user wuchong commented on a diff in the pull
Github user wuchong commented on a diff in the pull request:
https://github.com/apache/flink/pull/2560#discussion_r81270921
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/FlinkPlannerImpl.scala
---
@@ -60,6 +60,7 @@ class FlinkPlannerImpl(
[
https://issues.apache.org/jira/browse/FLINK-4715?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15534797#comment-15534797
]
Zhijiang Wang edited comment on FLINK-4715 at 9/30/16 2:31 AM:
---
Yes, we
[
https://issues.apache.org/jira/browse/FLINK-4348?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15534800#comment-15534800
]
ASF GitHub Bot commented on FLINK-4348:
---
Github user beyond1920 commented on the issue:
Neil Derraugh created FLINK-4718:
Summary: Confusing label in Parallel Streams Diagram
Key: FLINK-4718
URL: https://issues.apache.org/jira/browse/FLINK-4718
Project: Flink
Issue Type: Bug
Github user beyond1920 commented on the issue:
https://github.com/apache/flink/pull/2571
@mxm, What would happen under following cases: taskExecutor releases a
registered slot, then taskExecutor reports its latest slotReport to
ResourceManager, ResourceManager should remove the old
[
https://issues.apache.org/jira/browse/FLINK-4715?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15534797#comment-15534797
]
Zhijiang Wang commented on FLINK-4715:
--
Yes, we already experienced this problem in real production
[
https://issues.apache.org/jira/browse/FLINK-2254?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15534249#comment-15534249
]
ASF GitHub Bot commented on FLINK-2254:
---
Github user mushketyk commented on a diff in the pull
Github user mushketyk commented on a diff in the pull request:
https://github.com/apache/flink/pull/2564#discussion_r81246840
--- Diff:
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/BipartiteGraph.java
---
@@ -0,0 +1,231 @@
+/*
+ * Licensed to the
[
https://issues.apache.org/jira/browse/FLINK-2254?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15534241#comment-15534241
]
ASF GitHub Bot commented on FLINK-2254:
---
Github user mushketyk commented on a diff in the pull
Github user mushketyk commented on a diff in the pull request:
https://github.com/apache/flink/pull/2564#discussion_r81246465
--- Diff:
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/Edge.java ---
@@ -34,10 +34,10 @@
public Edge(){}
-
[
https://issues.apache.org/jira/browse/FLINK-2254?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15534239#comment-15534239
]
ASF GitHub Bot commented on FLINK-2254:
---
Github user mushketyk commented on the issue:
Github user mushketyk commented on the issue:
https://github.com/apache/flink/pull/2564
Hi @greghogan,
I like your ideas about providing different API for projections. This
should be better than my approach.
@vasia What do you think about this?
---
If your project is
[
https://issues.apache.org/jira/browse/FLINK-2254?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15534224#comment-15534224
]
ASF GitHub Bot commented on FLINK-2254:
---
Github user mushketyk commented on a diff in the pull
Github user mushketyk commented on a diff in the pull request:
https://github.com/apache/flink/pull/2564#discussion_r81245767
--- Diff:
flink-test-utils-parent/flink-test-utils/src/main/java/org/apache/flink/test/util/TestBaseUtils.java
---
@@ -480,7 +480,8 @@ protected static
[
https://issues.apache.org/jira/browse/FLINK-4329?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15534216#comment-15534216
]
ASF GitHub Bot commented on FLINK-4329:
---
Github user kl0u commented on the issue:
Github user kl0u commented on the issue:
https://github.com/apache/flink/pull/2546
Hi @StephanEwen . If I understand correctly, your suggestion is to make the
test something like the following: 1) put the split in the reader 2) read the
split 3) when the split finishes update the
[
https://issues.apache.org/jira/browse/FLINK-2254?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15534014#comment-15534014
]
ASF GitHub Bot commented on FLINK-2254:
---
Github user greghogan commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-2254?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15534015#comment-15534015
]
ASF GitHub Bot commented on FLINK-2254:
---
Github user greghogan commented on a diff in the pull
Github user greghogan commented on a diff in the pull request:
https://github.com/apache/flink/pull/2564#discussion_r81225166
--- Diff:
flink-test-utils-parent/flink-test-utils/src/main/java/org/apache/flink/test/util/TestBaseUtils.java
---
@@ -480,7 +480,8 @@ protected static
Github user greghogan commented on a diff in the pull request:
https://github.com/apache/flink/pull/2564#discussion_r81226805
--- Diff:
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/BipartiteGraph.java
---
@@ -0,0 +1,231 @@
+/*
+ * Licensed to the
Github user vasia commented on a diff in the pull request:
https://github.com/apache/flink/pull/2564#discussion_r81217922
--- Diff:
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/BipartiteGraph.java
---
@@ -0,0 +1,231 @@
+/*
+ * Licensed to the Apache
Github user vasia commented on a diff in the pull request:
https://github.com/apache/flink/pull/2564#discussion_r81218538
--- Diff:
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/Edge.java ---
@@ -34,10 +34,10 @@
public Edge(){}
- public
Github user vasia commented on a diff in the pull request:
https://github.com/apache/flink/pull/2564#discussion_r81218403
--- Diff:
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/BipartiteGraph.java
---
@@ -0,0 +1,231 @@
+/*
+ * Licensed to the Apache
Github user vasia commented on a diff in the pull request:
https://github.com/apache/flink/pull/2564#discussion_r81218056
--- Diff:
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/BipartiteGraph.java
---
@@ -0,0 +1,231 @@
+/*
+ * Licensed to the Apache
Github user vasia commented on a diff in the pull request:
https://github.com/apache/flink/pull/2564#discussion_r81218490
--- Diff:
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/BipartiteGraph.java
---
@@ -0,0 +1,231 @@
+/*
+ * Licensed to the Apache
[
https://issues.apache.org/jira/browse/FLINK-2254?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15533864#comment-15533864
]
ASF GitHub Bot commented on FLINK-2254:
---
Github user vasia commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-2254?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15533866#comment-15533866
]
ASF GitHub Bot commented on FLINK-2254:
---
Github user vasia commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-2254?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15533865#comment-15533865
]
ASF GitHub Bot commented on FLINK-2254:
---
Github user vasia commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-2254?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15533863#comment-15533863
]
ASF GitHub Bot commented on FLINK-2254:
---
Github user vasia commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-2254?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15533862#comment-15533862
]
ASF GitHub Bot commented on FLINK-2254:
---
Github user vasia commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-4329?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15533663#comment-15533663
]
ASF GitHub Bot commented on FLINK-4329:
---
Github user StephanEwen commented on a diff in the pull
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/2546#discussion_r81204726
--- Diff:
flink-fs-tests/src/test/java/org/apache/flink/hdfstests/ContinuousFileMonitoringTest.java
---
@@ -440,10 +491,50 @@ public void
[
https://issues.apache.org/jira/browse/FLINK-4329?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15533662#comment-15533662
]
ASF GitHub Bot commented on FLINK-4329:
---
Github user StephanEwen commented on a diff in the pull
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/2546#discussion_r81204990
--- Diff:
flink-fs-tests/src/test/java/org/apache/flink/hdfstests/ContinuousFileMonitoringTest.java
---
@@ -190,12 +213,30 @@ public void
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/2546#discussion_r81204828
--- Diff:
flink-fs-tests/src/test/java/org/apache/flink/hdfstests/ContinuousFileMonitoringTest.java
---
@@ -440,10 +491,50 @@ public void
[
https://issues.apache.org/jira/browse/FLINK-4636?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15533563#comment-15533563
]
ASF GitHub Bot commented on FLINK-4636:
---
Github user greghogan commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-4643?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15533562#comment-15533562
]
ASF GitHub Bot commented on FLINK-4643:
---
Github user StephanEwen commented on the issue:
Github user greghogan commented on a diff in the pull request:
https://github.com/apache/flink/pull/2568#discussion_r81200110
--- Diff:
flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/operator/AbstractCEPPatternOperator.java
---
@@ -126,11 +126,12 @@ public void
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2528
Looks good to me. Test failure is unrelated.
From my side, feel free to merge...
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub
Github user jaxbihani commented on a diff in the pull request:
https://github.com/apache/flink/pull/2568#discussion_r81199485
--- Diff:
flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/operator/AbstractCEPPatternOperator.java
---
@@ -126,11 +126,12 @@ public void
[
https://issues.apache.org/jira/browse/FLINK-4636?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15533555#comment-15533555
]
ASF GitHub Bot commented on FLINK-4636:
---
Github user jaxbihani commented on a diff in the pull
Till Rohrmann created FLINK-4717:
Summary: Naive version of atomic stop signal with savepoint
Key: FLINK-4717
URL: https://issues.apache.org/jira/browse/FLINK-4717
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-4573?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15533528#comment-15533528
]
ASF GitHub Bot commented on FLINK-4573:
---
Github user StephanEwen commented on the issue:
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2556
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 have this feature
enabled and wishes so,
[
https://issues.apache.org/jira/browse/FLINK-4650?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-4650:
-
Fix Version/s: 1.2.0
> Frequent task manager disconnects from JobManager
>
[
https://issues.apache.org/jira/browse/FLINK-4650?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-4650:
-
Affects Version/s: 1.2.0
> Frequent task manager disconnects from JobManager
>
Till Rohrmann created FLINK-4716:
Summary: Add trigger full recovery button to web UI
Key: FLINK-4716
URL: https://issues.apache.org/jira/browse/FLINK-4716
Project: Flink
Issue Type:
Till Rohrmann created FLINK-4715:
Summary: TaskManager should commit suicide after cancellation
failure
Key: FLINK-4715
URL: https://issues.apache.org/jira/browse/FLINK-4715
Project: Flink
Till Rohrmann created FLINK-4714:
Summary: Set task state to RUNNING after state has been restored
Key: FLINK-4714
URL: https://issues.apache.org/jira/browse/FLINK-4714
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-4700?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15533260#comment-15533260
]
Kostas Kloudas commented on FLINK-4700:
---
[~StephanEwen]
I am thinking that the best solution to
[
https://issues.apache.org/jira/browse/FLINK-4702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15533216#comment-15533216
]
ASF GitHub Bot commented on FLINK-4702:
---
Github user StephanEwen commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-4711?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15533215#comment-15533215
]
ASF GitHub Bot commented on FLINK-4711:
---
Github user tillrohrmann commented on the issue:
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2574
@tzulitai @rmetzger We need to make sure that the Kafka 0.10 code picks up
this change and the test case.
---
If your project is set up for it, you can reply to this email and have your
reply
Github user tillrohrmann commented on the issue:
https://github.com/apache/flink/pull/2569
Thanks for the review @uce. If Travis gives green light, I'll merge the 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
[
https://issues.apache.org/jira/browse/FLINK-4702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15533211#comment-15533211
]
ASF GitHub Bot commented on FLINK-4702:
---
Github user StephanEwen closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-4702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15533210#comment-15533210
]
ASF GitHub Bot commented on FLINK-4702:
---
Github user StephanEwen commented on the issue:
Github user StephanEwen closed the pull request at:
https://github.com/apache/flink/pull/2559
---
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
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2559
Closing this for #2574
---
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
[
https://issues.apache.org/jira/browse/FLINK-4702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15533206#comment-15533206
]
ASF GitHub Bot commented on FLINK-4702:
---
GitHub user StephanEwen opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-4348?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15533204#comment-15533204
]
ASF GitHub Bot commented on FLINK-4348:
---
Github user mxm commented on the issue:
GitHub user StephanEwen opened a pull request:
https://github.com/apache/flink/pull/2574
[FLINK-4702] [kafka connector] Commit offsets to Kafka asynchronously and
don't block on polls
This fix is quite critical!
While the KafkaConsumer is polling for new data (with a
Github user mxm commented on the issue:
https://github.com/apache/flink/pull/2571
CC @beyond1920 @KurtYoung
---
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
[
https://issues.apache.org/jira/browse/FLINK-4711?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15533193#comment-15533193
]
ASF GitHub Bot commented on FLINK-4711:
---
Github user tillrohrmann commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-4711?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15533194#comment-15533194
]
ASF GitHub Bot commented on FLINK-4711:
---
Github user tillrohrmann commented on a diff in the pull
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/2569#discussion_r81173562
--- Diff:
flink-runtime/src/main/scala/org/apache/flink/runtime/messages/TaskControlMessages.scala
---
@@ -92,16 +92,6 @@ object TaskMessages {
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/2569#discussion_r81173599
--- Diff:
flink-runtime/src/main/scala/org/apache/flink/runtime/jobmanager/JobManager.scala
---
@@ -873,8 +873,7 @@ class JobManager(
}
[
https://issues.apache.org/jira/browse/FLINK-4711?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15533192#comment-15533192
]
ASF GitHub Bot commented on FLINK-4711:
---
Github user tillrohrmann commented on a diff in the pull
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/2569#discussion_r81173481
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/taskmanager/JobManagerCommunicationFactory.java
---
@@ -27,15 +26,6 @@
public
GitHub user aljoscha opened a pull request:
https://github.com/apache/flink/pull/2573
Refactor StreamOperator Hierachy to make Keys Explicit
This is more of a preview PR, I'm not yet completely done with testing and
making sure that everything works.
R: @StephanEwen
You
[
https://issues.apache.org/jira/browse/FLINK-4552?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15533144#comment-15533144
]
ASF GitHub Bot commented on FLINK-4552:
---
GitHub user aljoscha opened a pull request:
GitHub user aljoscha opened a pull request:
https://github.com/apache/flink/pull/2572
[FLINK-4552] Refactor WindowOperator/Trigger Tests
This builds on #2570
Before, tests for WindowOperator, WindowAssigner, Trigger and WindowFunction
were all conflated in
[
https://issues.apache.org/jira/browse/FLINK-4348?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15533113#comment-15533113
]
ASF GitHub Bot commented on FLINK-4348:
---
GitHub user mxm opened a pull request:
GitHub user mxm opened a pull request:
https://github.com/apache/flink/pull/2571
[FLINK-4348] Simplify logic of SlotManager
This pull request is split up into two commits:
1. It removes some code from the `SlotManager` to make it simpler.
- It makes use of
Github user uce commented on a diff in the pull request:
https://github.com/apache/flink/pull/2569#discussion_r81164326
--- Diff:
flink-runtime/src/main/scala/org/apache/flink/runtime/messages/TaskControlMessages.scala
---
@@ -92,16 +92,6 @@ object TaskMessages {
//
[
https://issues.apache.org/jira/browse/FLINK-4711?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15533098#comment-15533098
]
ASF GitHub Bot commented on FLINK-4711:
---
Github user uce commented on a diff in the pull request:
Github user uce commented on a diff in the pull request:
https://github.com/apache/flink/pull/2569#discussion_r81162283
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/taskmanager/JobManagerCommunicationFactory.java
---
@@ -27,15 +26,6 @@
public interface
[
https://issues.apache.org/jira/browse/FLINK-4711?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15533100#comment-15533100
]
ASF GitHub Bot commented on FLINK-4711:
---
Github user uce commented on a diff in the pull request:
Github user uce commented on a diff in the pull request:
https://github.com/apache/flink/pull/2569#discussion_r81164597
--- Diff:
flink-runtime/src/main/scala/org/apache/flink/runtime/jobmanager/JobManager.scala
---
@@ -873,8 +873,7 @@ class JobManager(
}
[
https://issues.apache.org/jira/browse/FLINK-4711?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15533099#comment-15533099
]
ASF GitHub Bot commented on FLINK-4711:
---
Github user uce commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-4712?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Domokos Miklós Kelen updated FLINK-4712:
Description:
We started working on implementing ranking predictions for recommender
GitHub user aljoscha opened a pull request:
https://github.com/apache/flink/pull/2570
[FLINK-3674] Add an interface for Time aware User Functions
This moves the event-time/processing-time trigger code from
`WindowOperator` behind a well defined interface that can be used by
[
https://issues.apache.org/jira/browse/FLINK-4068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15533076#comment-15533076
]
ASF GitHub Bot commented on FLINK-4068:
---
Github user twalthr commented on a diff in the pull
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/2560#discussion_r81163353
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/FlinkPlannerImpl.scala
---
@@ -60,6 +60,7 @@ class FlinkPlannerImpl(
[
https://issues.apache.org/jira/browse/FLINK-4712?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Domokos Miklós Kelen updated FLINK-4712:
Description:
We started working on implementing ranking predictions for recommender
[
https://issues.apache.org/jira/browse/FLINK-4068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15533067#comment-15533067
]
ASF GitHub Bot commented on FLINK-4068:
---
Github user twalthr commented on the issue:
Domokos Miklós Kelen created FLINK-4713:
---
Summary: Implementing ranking evaluation scores for recommender
systems
Key: FLINK-4713
URL: https://issues.apache.org/jira/browse/FLINK-4713
Project:
Github user thvasilo commented on the issue:
https://github.com/apache/flink/pull/2542
@gaborhermann I think have a larger scale test would boost our confidence
in the implementation, and maybe point out some problems that do not manifest
with small data, which is very common.
[
https://issues.apache.org/jira/browse/FLINK-4712?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Domokos Miklós Kelen updated FLINK-4712:
Description:
We started working on implementing ranking predictions for recommender
Domokos Miklós Kelen created FLINK-4712:
---
Summary: Implementing ranking predictions for ALS
Key: FLINK-4712
URL: https://issues.apache.org/jira/browse/FLINK-4712
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-4613?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15533048#comment-15533048
]
ASF GitHub Bot commented on FLINK-4613:
---
Github user thvasilo commented on the issue:
Github user aljoscha closed the pull request at:
https://github.com/apache/flink/pull/2547
---
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
[
https://issues.apache.org/jira/browse/FLINK-4613?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15533029#comment-15533029
]
ASF GitHub Bot commented on FLINK-4613:
---
Github user thvasilo commented on a diff in the pull
Github user thvasilo commented on a diff in the pull request:
https://github.com/apache/flink/pull/2542#discussion_r81159482
--- Diff:
flink-libraries/flink-ml/src/test/scala/org/apache/flink/ml/recommendation/ImplicitALSTest.scala
---
@@ -0,0 +1,171 @@
+/*
+ * Licensed
[
https://issues.apache.org/jira/browse/FLINK-4613?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15533024#comment-15533024
]
ASF GitHub Bot commented on FLINK-4613:
---
Github user thvasilo commented on a diff in the pull
Github user thvasilo commented on a diff in the pull request:
https://github.com/apache/flink/pull/2542#discussion_r81159171
--- Diff:
flink-libraries/flink-ml/src/main/scala/org/apache/flink/ml/recommendation/ALS.scala
---
@@ -581,6 +637,16 @@ object ALS {
val
1 - 100 of 196 matches
Mail list logo
