GitHub user ramkrish86 opened a pull request:
https://github.com/apache/flink/pull/2495
FLINK-3322 - Make sorters to reuse the memory pages allocated for iterative
tasks
Thanks for contributing to Apache Flink. Before you open your pull request,
please take the following check list
[
https://issues.apache.org/jira/browse/FLINK-3322?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15486449#comment-15486449
]
ASF GitHub Bot commented on FLINK-3322:
---
GitHub user ramkrish86 opened a pull reques
[
https://issues.apache.org/jira/browse/FLINK-4513?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15486214#comment-15486214
]
ASF GitHub Bot commented on FLINK-4513:
---
Github user nssalian commented on the issue
Github user nssalian commented on the issue:
https://github.com/apache/flink/pull/2493
@uce, @zentol do you have some time to help review?
---
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 thi
Github user nssalian commented on the issue:
https://github.com/apache/flink/pull/2494
@uce, @zentol do you have some time to help review?
---
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 thi
[
https://issues.apache.org/jira/browse/FLINK-4614?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15486213#comment-15486213
]
ASF GitHub Bot commented on FLINK-4614:
---
Github user nssalian commented on the issue
[
https://issues.apache.org/jira/browse/FLINK-4520?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15486023#comment-15486023
]
ASF GitHub Bot commented on FLINK-4520:
---
Github user haoch commented on the issue:
Github user haoch commented on the issue:
https://github.com/apache/flink/pull/2487
@mushketyk thanks very much for reviewing, will fix as required soon.
---
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 doe
[
https://issues.apache.org/jira/browse/FLINK-2055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15485757#comment-15485757
]
ASF GitHub Bot commented on FLINK-2055:
---
Github user delding commented on a diff in
Github user delding commented on a diff in the pull request:
https://github.com/apache/flink/pull/2332#discussion_r78478766
--- Diff:
flink-streaming-connectors/flink-connector-hbase/src/main/java/org/apache/flink/streaming/connectors/hbase/HBaseMapper.java
---
@@ -0,0 +1,46 @@
[
https://issues.apache.org/jira/browse/FLINK-2055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15485747#comment-15485747
]
ASF GitHub Bot commented on FLINK-2055:
---
Github user delding commented on a diff in
Github user delding commented on a diff in the pull request:
https://github.com/apache/flink/pull/2332#discussion_r78478455
--- Diff:
flink-streaming-connectors/flink-connector-hbase/src/main/java/org/apache/flink/streaming/connectors/hbase/HBaseMapper.java
---
@@ -0,0 +1,46 @@
[
https://issues.apache.org/jira/browse/FLINK-4614?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15485552#comment-15485552
]
ASF GitHub Bot commented on FLINK-4614:
---
GitHub user nssalian opened a pull request:
GitHub user nssalian opened a pull request:
https://github.com/apache/flink/pull/2494
[FLINK-4614][Docs]: Changed the version from 1.2-SNAPSHOT to 1.2 in
docs/_config.yml
Thanks for contributing to Apache Flink. Before you open your pull request,
please take the following check lis
[
https://issues.apache.org/jira/browse/FLINK-4614?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Neelesh Srinivas Salian updated FLINK-4614:
---
Fix Version/s: (was: 1.1.3)
1.2.0
> Kafka connector doc
[
https://issues.apache.org/jira/browse/FLINK-4614?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Neelesh Srinivas Salian updated FLINK-4614:
---
Summary: Kafka connector documentation refers to Flink 1.2-SNAPSHOT (was:
CLO
[
https://issues.apache.org/jira/browse/FLINK-4614?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Neelesh Srinivas Salian updated FLINK-4614:
---
Affects Version/s: (was: 1.1.1)
1.2.0
> CLONE - Kaf
[
https://issues.apache.org/jira/browse/FLINK-2765?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-2765:
--
Description:
Currently 0.98.11 is used:
{code}
0.98.11-hadoop2
{code}
Stable release for hadoop
[
https://issues.apache.org/jira/browse/FLINK-4533?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-4533:
--
Description:
Access to meters in AbstractReporter is protected by AbstractReporter.this.
Access to meters in St
[
https://issues.apache.org/jira/browse/FLINK-4534?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-4534:
--
Description:
Iteration over state.bucketStates is protected by synchronization in other
methods, except for the
[
https://issues.apache.org/jira/browse/FLINK-3801?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-3801:
--
Description:
Currently yoda-time 2.5 is used which was very old.
We should upgrade to 2.9.3
was:
Currently
[
https://issues.apache.org/jira/browse/FLINK-3222?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-3222:
--
Description:
Here is related code:
{code}
result = 31 * result + (int) (subTaskStats.length ^ (subTaskStats.
[
https://issues.apache.org/jira/browse/FLINK-4573?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-4573:
--
Description:
{code}
try {
[
https://issues.apache.org/jira/browse/FLINK-3734?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-3734:
--
Description:
{code}
DataInputView in = inputState.getState(getUserCodeClassloader());
final long nextEv
[
https://issues.apache.org/jira/browse/FLINK-4614?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15485380#comment-15485380
]
Neelesh Srinivas Salian commented on FLINK-4614:
See this prevalent in the
Neelesh Srinivas Salian created FLINK-4614:
--
Summary: CLONE - Kafka connector documentation refers to Flink
1.2-SNAPSHOT
Key: FLINK-4614
URL: https://issues.apache.org/jira/browse/FLINK-4614
GitHub user nssalian opened a pull request:
https://github.com/apache/flink/pull/2493
[FLINK-4513] [Docs]: Kafka connector documentation refers to Flink
1.1-SNAPSHOT
Thanks for contributing to Apache Flink. Before you open your pull request,
please take the following check list int
[
https://issues.apache.org/jira/browse/FLINK-4513?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15485360#comment-15485360
]
ASF GitHub Bot commented on FLINK-4513:
---
GitHub user nssalian opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-3370?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15485274#comment-15485274
]
Adam J Heller commented on FLINK-3370:
--
Hi Stephan. Could you explain how adding an a
[
https://issues.apache.org/jira/browse/FLINK-2014?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15484612#comment-15484612
]
Victor Chen edited comment on FLINK-2014 at 9/12/16 8:55 PM:
-
[
https://issues.apache.org/jira/browse/FLINK-4520?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15485230#comment-15485230
]
ASF GitHub Bot commented on FLINK-4520:
---
Github user mushketyk commented on the issu
Github user mushketyk commented on the issue:
https://github.com/apache/flink/pull/2487
Hi @haoch,
I think it would be beneficial if you write a few words describing your
design or add more JavaDocs. This would make the review process more
straightforward.
---
If your proje
[
https://issues.apache.org/jira/browse/FLINK-4520?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15485210#comment-15485210
]
ASF GitHub Bot commented on FLINK-4520:
---
Github user mushketyk commented on a diff i
Github user mushketyk commented on a diff in the pull request:
https://github.com/apache/flink/pull/2487#discussion_r78449235
--- Diff:
flink-contrib/flink-siddhi/src/main/java/org/apache/flink/contrib/siddhi/operator/SiddhiOperatorContext.java
---
@@ -0,0 +1,162 @@
+/*
+
[
https://issues.apache.org/jira/browse/FLINK-4612?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15485185#comment-15485185
]
ASF GitHub Bot commented on FLINK-4612:
---
Github user apivovarov commented on a diff
[
https://issues.apache.org/jira/browse/FLINK-4520?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15485183#comment-15485183
]
ASF GitHub Bot commented on FLINK-4520:
---
Github user mushketyk commented on a diff i
Github user apivovarov commented on a diff in the pull request:
https://github.com/apache/flink/pull/2492#discussion_r78447379
--- Diff:
flink-core/src/test/java/org/apache/flink/testutils/TestFileUtils.java ---
@@ -55,11 +55,8 @@ public static String createTempFileInDirectory(Stri
Github user mushketyk commented on a diff in the pull request:
https://github.com/apache/flink/pull/2487#discussion_r78447224
--- Diff:
flink-contrib/flink-siddhi/src/main/java/org/apache/flink/contrib/siddhi/operator/AbstractSiddhiOperator.java
---
@@ -0,0 +1,265 @@
+/*
+
[
https://issues.apache.org/jira/browse/FLINK-4520?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15485180#comment-15485180
]
ASF GitHub Bot commented on FLINK-4520:
---
Github user mushketyk commented on a diff i
Github user mushketyk commented on a diff in the pull request:
https://github.com/apache/flink/pull/2487#discussion_r78447005
--- Diff:
flink-contrib/flink-siddhi/src/main/java/org/apache/flink/contrib/siddhi/operator/AbstractSiddhiOperator.java
---
@@ -0,0 +1,265 @@
+/*
+
[
https://issues.apache.org/jira/browse/FLINK-4520?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15485176#comment-15485176
]
ASF GitHub Bot commented on FLINK-4520:
---
Github user mushketyk commented on a diff i
Github user mushketyk commented on a diff in the pull request:
https://github.com/apache/flink/pull/2487#discussion_r78446790
--- Diff:
flink-contrib/flink-siddhi/src/main/java/org/apache/flink/contrib/siddhi/SiddhiStream.java
---
@@ -0,0 +1,224 @@
+/*
+ * Licensed to the
[
https://issues.apache.org/jira/browse/FLINK-4520?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15485174#comment-15485174
]
ASF GitHub Bot commented on FLINK-4520:
---
Github user mushketyk commented on a diff i
[
https://issues.apache.org/jira/browse/FLINK-4520?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15485172#comment-15485172
]
ASF GitHub Bot commented on FLINK-4520:
---
Github user mushketyk commented on a diff i
Github user mushketyk commented on a diff in the pull request:
https://github.com/apache/flink/pull/2487#discussion_r78446628
--- Diff:
flink-contrib/flink-siddhi/src/main/java/org/apache/flink/contrib/siddhi/SiddhiCEP.java
---
@@ -0,0 +1,116 @@
+/*
+ * Licensed to the Apa
Github user mushketyk commented on a diff in the pull request:
https://github.com/apache/flink/pull/2487#discussion_r78446460
--- Diff:
flink-contrib/flink-siddhi/src/main/java/org/apache/flink/contrib/siddhi/SiddhiCEP.java
---
@@ -0,0 +1,116 @@
+/*
+ * Licensed to the Apa
[
https://issues.apache.org/jira/browse/FLINK-4520?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15485169#comment-15485169
]
ASF GitHub Bot commented on FLINK-4520:
---
Github user mushketyk commented on a diff i
Github user mushketyk commented on a diff in the pull request:
https://github.com/apache/flink/pull/2487#discussion_r78446582
--- Diff:
flink-contrib/flink-siddhi/src/main/java/org/apache/flink/contrib/siddhi/SiddhiCEP.java
---
@@ -0,0 +1,116 @@
+/*
+ * Licensed to the Apa
[
https://issues.apache.org/jira/browse/FLINK-4520?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15485167#comment-15485167
]
ASF GitHub Bot commented on FLINK-4520:
---
Github user mushketyk commented on a diff i
Github user mushketyk commented on a diff in the pull request:
https://github.com/apache/flink/pull/2487#discussion_r78446343
--- Diff:
flink-contrib/flink-siddhi/src/main/java/org/apache/flink/contrib/siddhi/SiddhiCEP.java
---
@@ -0,0 +1,116 @@
+/*
+ * Licensed to the Apa
[
https://issues.apache.org/jira/browse/FLINK-4612?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15484935#comment-15484935
]
ASF GitHub Bot commented on FLINK-4612:
---
Github user zentol commented on a diff in t
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/2492#discussion_r78430845
--- Diff:
flink-core/src/test/java/org/apache/flink/testutils/TestFileUtils.java ---
@@ -55,11 +55,8 @@ public static String createTempFileInDirectory(String
[
https://issues.apache.org/jira/browse/FLINK-2055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15484801#comment-15484801
]
ASF GitHub Bot commented on FLINK-2055:
---
Github user ramkrish86 commented on a diff
Github user ramkrish86 commented on a diff in the pull request:
https://github.com/apache/flink/pull/2332#discussion_r78422242
--- Diff:
flink-streaming-connectors/flink-connector-hbase/src/main/java/org/apache/flink/streaming/connectors/hbase/HBaseMapper.java
---
@@ -0,0 +1,46 @@
[
https://issues.apache.org/jira/browse/FLINK-2055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15484737#comment-15484737
]
ASF GitHub Bot commented on FLINK-2055:
---
Github user delding commented on a diff in
Github user delding commented on a diff in the pull request:
https://github.com/apache/flink/pull/2332#discussion_r78418366
--- Diff:
flink-streaming-connectors/flink-connector-hbase/src/main/java/org/apache/flink/streaming/connectors/hbase/HBaseMapper.java
---
@@ -0,0 +1,46 @@
[
https://issues.apache.org/jira/browse/FLINK-2014?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15484612#comment-15484612
]
Victor Chen commented on FLINK-2014:
To do LASSO, I'm thinking of implementing Greedy
[
https://issues.apache.org/jira/browse/FLINK-3322?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15484571#comment-15484571
]
ramkrishna.s.vasudevan commented on FLINK-3322:
---
To go forward with this, I
[
https://issues.apache.org/jira/browse/FLINK-4482?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-4482:
--
Description:
In CheckpointCoordinator#stopCheckpointScheduler() :
{code}
synchronized (lock) {
...
num
[
https://issues.apache.org/jira/browse/FLINK-3322?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15484104#comment-15484104
]
ramkrishna.s.vasudevan commented on FLINK-3322:
---
I did try changing the code
[
https://issues.apache.org/jira/browse/FLINK-3929?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15483603#comment-15483603
]
ASF GitHub Bot commented on FLINK-3929:
---
Github user nielsbasjes commented on the is
Github user nielsbasjes commented on the issue:
https://github.com/apache/flink/pull/2275
Perhaps you are running into similar problems as described here:
http://stackoverflow.com/questions/2890259/running-each-junit-test-in-a-separate-jvm-in-eclipse
#JustTryingToHelp
---
If
[
https://issues.apache.org/jira/browse/FLINK-4603?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15483601#comment-15483601
]
Till Rohrmann commented on FLINK-4603:
--
That makes sense.
> KeyedStateBackend canno
Gábor Hermann created FLINK-4613:
Summary: Extend ALS to handle implicit feedback datasets
Key: FLINK-4613
URL: https://issues.apache.org/jira/browse/FLINK-4613
Project: Flink
Issue Type: New
[
https://issues.apache.org/jira/browse/FLINK-2254?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15483350#comment-15483350
]
Ivan Mushketyk commented on FLINK-2254:
---
Hi Vasia,
Thank you for reviewing the desi
65 matches
Mail list logo
