[
https://issues.apache.org/jira/browse/FLINK-3035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15142198#comment-15142198
]
ASF GitHub Bot commented on FLINK-3035:
---
Github user sbcd90 commented on the pull re
Github user sbcd90 commented on the pull request:
https://github.com/apache/flink/pull/1617#issuecomment-182688977
@mjsax Would you open a new thread in dev-mailing-list for discussion on
redis-state-backend. I'm really interested in the topic. & would like to work
on it. I'm followin
[
https://issues.apache.org/jira/browse/FLINK-3304?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Klou reassigned FLINK-3304:
---
Assignee: Klou
> AvroOutputFormat.setSchema() doesn't work in yarn-cluster mode
> ---
[
https://issues.apache.org/jira/browse/FLINK-3371?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-3371.
---
> Move TriggerCotext and TriggerResult to their own classes
>
[
https://issues.apache.org/jira/browse/FLINK-3384?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-3384.
---
> Create atomic closable queue for communication between Kafka Threads
> -
[
https://issues.apache.org/jira/browse/FLINK-3384?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-3384.
-
Resolution: Fixed
Fixed via fd324ea72979cc3d4202ffa3ea174ec4cc9d153b
> Create atomic closable que
[
https://issues.apache.org/jira/browse/FLINK-3371?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-3371.
-
Resolution: Fixed
Fixed via 50bd65a574776817a03dd32fd438cb2327447109
> Move TriggerCotext and Tri
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/1603
---
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 enab
[
https://issues.apache.org/jira/browse/FLINK-3371?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15141729#comment-15141729
]
ASF GitHub Bot commented on FLINK-3371:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-3228?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15141688#comment-15141688
]
Nick Dimiduk commented on FLINK-3228:
-
No. In fact I'm producing to
[PhoenixOutputFor
[
https://issues.apache.org/jira/browse/FLINK-3385?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Greg Hogan reassigned FLINK-3385:
-
Assignee: Greg Hogan
> Fix outer join skipping unprobed partitions
>
[
https://issues.apache.org/jira/browse/FLINK-3385?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15141681#comment-15141681
]
Greg Hogan commented on FLINK-3385:
---
Yes, I will look into this some more.
> Fix outer
[
https://issues.apache.org/jira/browse/FLINK-2991?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15141672#comment-15141672
]
ASF GitHub Bot commented on FLINK-2991:
---
Github user aljoscha commented on the pull
Github user aljoscha commented on the pull request:
https://github.com/apache/flink/pull/1605#issuecomment-182583799
You can also do just a "fold". The window function is for when you need the
meta information about the window because the fold function does not get that.
---
If your
[
https://issues.apache.org/jira/browse/FLINK-3228?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15141650#comment-15141650
]
Stephan Ewen commented on FLINK-3228:
-
[~ndimiduk] Are you using Flink's regular {{JDB
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1605#issuecomment-182575751
Doe it always require a "WindowFunction"? Can one also use only a
FoldFunction?
---
If your project is set up for it, you can reply to this email and have your
repl
[
https://issues.apache.org/jira/browse/FLINK-2991?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15141628#comment-15141628
]
ASF GitHub Bot commented on FLINK-2991:
---
Github user StephanEwen commented on the pu
[
https://issues.apache.org/jira/browse/FLINK-2021?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15141564#comment-15141564
]
ASF GitHub Bot commented on FLINK-2021:
---
Github user fhueske commented on the pull r
Github user fhueske commented on the pull request:
https://github.com/apache/flink/pull/1581#issuecomment-182555170
Thanks a lot for updating the PR @stefanobaghino!
It's up to you if you want to squash the commits. We can also do it before
we merge the PR.
---
If your project
[
https://issues.apache.org/jira/browse/FLINK-3385?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15141551#comment-15141551
]
Fabian Hueske commented on FLINK-3385:
--
Thanks [~greghogan]! This is obviously a seri
[
https://issues.apache.org/jira/browse/FLINK-3385?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske updated FLINK-3385:
-
Priority: Blocker (was: Critical)
> Fix outer join skipping unprobed partitions
> ---
[
https://issues.apache.org/jira/browse/FLINK-3385?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15141490#comment-15141490
]
Greg Hogan commented on FLINK-3385:
---
Here is the simple function I was using to isolate
Greg Hogan created FLINK-3385:
-
Summary: Fix outer join skipping unprobed partitions
Key: FLINK-3385
URL: https://issues.apache.org/jira/browse/FLINK-3385
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-3107?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15141442#comment-15141442
]
ASF GitHub Bot commented on FLINK-3107:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-3107?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi closed FLINK-3107.
--
Resolution: Fixed
Fixed in 8df0bba
> ZooKeeperCheckpointIDCounter.start() can block JobManager actor
>
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/1610
---
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 enab
Github user uce commented on the pull request:
https://github.com/apache/flink/pull/1610#issuecomment-182528014
Thanks for the review. I'll merge it then :)
---
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-3107?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15141436#comment-15141436
]
ASF GitHub Bot commented on FLINK-3107:
---
Github user uce commented on the pull reque
Github user stefanobaghino commented on the pull request:
https://github.com/apache/flink/pull/1581#issuecomment-182520553
That's absolutely not a problem @fhueske, your remarks are reasonable and I
do appreciate the care you all take in making sure Flink turns out great. It's
my firs
[
https://issues.apache.org/jira/browse/FLINK-2021?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15141409#comment-15141409
]
ASF GitHub Bot commented on FLINK-2021:
---
Github user stefanobaghino commented on the
[
https://issues.apache.org/jira/browse/FLINK-2021?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15141319#comment-15141319
]
ASF GitHub Bot commented on FLINK-2021:
---
Github user fhueske commented on the pull r
Github user fhueske commented on the pull request:
https://github.com/apache/flink/pull/1581#issuecomment-182505103
Hi @stefanobaghino, sorry to bug you again. :-(
I understand if you don't want to refactor this PR again. Please drop a
note if you update it one last time (*promise*
[
https://issues.apache.org/jira/browse/FLINK-2021?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15141306#comment-15141306
]
ASF GitHub Bot commented on FLINK-2021:
---
Github user fhueske commented on a diff in
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/1581#discussion_r52496326
--- Diff:
flink-examples/flink-examples-batch/src/main/java/org/apache/flink/examples/java/clustering/KMeans.java
---
@@ -105,119 +110,127 @@ public static v
[
https://issues.apache.org/jira/browse/FLINK-2021?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15141305#comment-15141305
]
ASF GitHub Bot commented on FLINK-2021:
---
Github user fhueske commented on a diff in
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/1581#discussion_r52496167
--- Diff:
flink-examples/flink-examples-batch/src/main/java/org/apache/flink/examples/java/clustering/KMeans.java
---
@@ -61,42 +62,46 @@
* Cluster cen
[
https://issues.apache.org/jira/browse/FLINK-2021?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15141302#comment-15141302
]
ASF GitHub Bot commented on FLINK-2021:
---
Github user fhueske commented on a diff in
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/1581#discussion_r52495987
--- Diff:
flink-examples/flink-examples-batch/src/main/java/org/apache/flink/examples/java/clustering/KMeans.java
---
@@ -61,42 +62,46 @@
* Cluster cen
[
https://issues.apache.org/jira/browse/FLINK-2991?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15141287#comment-15141287
]
ASF GitHub Bot commented on FLINK-2991:
---
Github user StephanEwen commented on a diff
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/1605#discussion_r52494909
--- Diff:
flink-contrib/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBFoldingState.java
---
@@ -0,0 +1,175 @@
[
https://issues.apache.org/jira/browse/FLINK-3228?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15141235#comment-15141235
]
Nick Dimiduk commented on FLINK-3228:
-
Looks like this hack is not available to me as
[
https://issues.apache.org/jira/browse/FLINK-2237?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15141198#comment-15141198
]
ASF GitHub Bot commented on FLINK-2237:
---
Github user fhueske commented on a diff in
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/1517#discussion_r52489247
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/operators/hash/MemoryHashTableTest.java
---
@@ -100,340 +101,371 @@
@Test
publ
[
https://issues.apache.org/jira/browse/FLINK-2237?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15141192#comment-15141192
]
ASF GitHub Bot commented on FLINK-2237:
---
Github user fhueske commented on the pull r
Github user fhueske commented on the pull request:
https://github.com/apache/flink/pull/1517#issuecomment-182483003
The benefit of having multiple partitions is that you do not need to go
over the complete RecordArea but only over a partition. After the partition is
compacted or was e
[
https://issues.apache.org/jira/browse/FLINK-2237?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15141183#comment-15141183
]
ASF GitHub Bot commented on FLINK-2237:
---
Github user ggevay commented on a diff in t
Github user ggevay commented on a diff in the pull request:
https://github.com/apache/flink/pull/1517#discussion_r52488669
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/operators/hash/MemoryHashTableTest.java
---
@@ -100,340 +101,371 @@
@Test
publi
[
https://issues.apache.org/jira/browse/FLINK-2237?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15141174#comment-15141174
]
ASF GitHub Bot commented on FLINK-2237:
---
Github user ggevay commented on a diff in t
Github user ggevay commented on a diff in the pull request:
https://github.com/apache/flink/pull/1517#discussion_r52488021
--- Diff:
flink-tests/src/test/java/org/apache/flink/test/manual/ReducePerformance.java
---
@@ -0,0 +1,191 @@
+/*
+ * Licensed to the Apache Software
[
https://issues.apache.org/jira/browse/FLINK-3341?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-3341.
---
> Kafka connector's 'auto.offset.reset' inconsistent with Kafka
>
[
https://issues.apache.org/jira/browse/FLINK-3341?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-3341.
-
Resolution: Fixed
Fix Version/s: 1.0.0
Fixed via 9173825aa6a1525d72a78cda16cb4ae1e9b8a8e4
[
https://issues.apache.org/jira/browse/FLINK-3260?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-3260.
-
Resolution: Fixed
Fixed via 6968a57a1a31a11b33bacd2c94d6559bcabd6eb9
> ExecutionGraph gets stuck
[
https://issues.apache.org/jira/browse/FLINK-3260?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-3260.
---
> ExecutionGraph gets stuck in state FAILING
> --
>
>
[
https://issues.apache.org/jira/browse/FLINK-2237?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15141158#comment-15141158
]
ASF GitHub Bot commented on FLINK-2237:
---
Github user ggevay commented on the pull re
[
https://issues.apache.org/jira/browse/FLINK-3350?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-3350.
---
> Increase timeouts on Travis Builds
> --
>
> Key: FLINK-3
[
https://issues.apache.org/jira/browse/FLINK-3350?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-3350.
-
Resolution: Fixed
Fixed via b8f40251c6c45379118254c21b0d553c2d3b8937
> Increase timeouts on Travi
Github user ggevay commented on the pull request:
https://github.com/apache/flink/pull/1517#issuecomment-182477373
> In any case, we need to update the documentation for the added
CombineHint. I would also be good to extend ReduceITCase with a few tests that
use CombineHint.HASH.
[
https://issues.apache.org/jira/browse/FLINK-3260?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15141136#comment-15141136
]
ASF GitHub Bot commented on FLINK-3260:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-3341?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15141135#comment-15141135
]
ASF GitHub Bot commented on FLINK-3341:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/1613
---
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 enab
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/1597
---
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 enab
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/1611
---
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 enab
[
https://issues.apache.org/jira/browse/FLINK-2237?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15141015#comment-15141015
]
ASF GitHub Bot commented on FLINK-2237:
---
Github user fhueske commented on a diff in
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/1517#discussion_r52473636
--- Diff:
flink-tests/src/test/java/org/apache/flink/test/manual/ReducePerformance.java
---
@@ -0,0 +1,191 @@
+/*
+ * Licensed to the Apache Software
[
https://issues.apache.org/jira/browse/FLINK-3035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15141013#comment-15141013
]
Subhobrata Dey commented on FLINK-3035:
---
[~mjsax] [~aljoscha] I'll move this discuss
[
https://issues.apache.org/jira/browse/FLINK-3035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15140990#comment-15140990
]
ASF GitHub Bot commented on FLINK-3035:
---
Github user mjsax commented on the pull req
Github user ggevay commented on a diff in the pull request:
https://github.com/apache/flink/pull/1517#discussion_r52472588
--- Diff:
flink-tests/src/test/java/org/apache/flink/test/manual/ReducePerformance.java
---
@@ -0,0 +1,191 @@
+/*
+ * Licensed to the Apache Software
[
https://issues.apache.org/jira/browse/FLINK-2237?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15141005#comment-15141005
]
ASF GitHub Bot commented on FLINK-2237:
---
Github user ggevay commented on a diff in t
Github user mjsax commented on the pull request:
https://github.com/apache/flink/pull/1617#issuecomment-182424633
@aljoscha @rmetzger Should we move this discussion to the mailing list?
@sbcd90 are you following dev-mailing list?
---
If your project is set up for it, you can reply to
[
https://issues.apache.org/jira/browse/FLINK-2237?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15140982#comment-15140982
]
ASF GitHub Bot commented on FLINK-2237:
---
Github user fhueske commented on a diff in
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/1517#discussion_r52471392
--- Diff:
flink-tests/src/test/java/org/apache/flink/test/manual/ReducePerformance.java
---
@@ -0,0 +1,191 @@
+/*
+ * Licensed to the Apache Software
[
https://issues.apache.org/jira/browse/FLINK-2237?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15140980#comment-15140980
]
ASF GitHub Bot commented on FLINK-2237:
---
Github user ggevay commented on a diff in t
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/1517#discussion_r52471181
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/operators/hash/ReduceHashTableTest.java
---
@@ -0,0 +1,501 @@
+/*
+ * Licensed to the
Github user ggevay commented on a diff in the pull request:
https://github.com/apache/flink/pull/1517#discussion_r52471297
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/operators/hash/ReduceHashTable.java
---
@@ -0,0 +1,1014 @@
+/*
+ * Licensed to the Apac
[
https://issues.apache.org/jira/browse/FLINK-2237?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15140977#comment-15140977
]
ASF GitHub Bot commented on FLINK-2237:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-2237?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15140978#comment-15140978
]
ASF GitHub Bot commented on FLINK-2237:
---
Github user fhueske commented on a diff in
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/1517#discussion_r52471114
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/operators/hash/MemoryHashTableTest.java
---
@@ -100,340 +101,371 @@
@Test
publ
[
https://issues.apache.org/jira/browse/FLINK-2237?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15140974#comment-15140974
]
ASF GitHub Bot commented on FLINK-2237:
---
Github user fhueske commented on a diff in
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/1517#discussion_r52470915
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/operators/hash/HashTablePerformanceComparison.java
---
@@ -102,7 +102,7 @@ public void testCom
[
https://issues.apache.org/jira/browse/FLINK-3035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15140972#comment-15140972
]
ASF GitHub Bot commented on FLINK-3035:
---
Github user aljoscha commented on the pull
[
https://issues.apache.org/jira/browse/FLINK-2991?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15140970#comment-15140970
]
ASF GitHub Bot commented on FLINK-2991:
---
Github user aljoscha commented on the pull
Github user aljoscha commented on the pull request:
https://github.com/apache/flink/pull/1617#issuecomment-182421979
Yes @mjsax you have the right ideas here. :smile: Those are the things that
need to be figured out.
---
If your project is set up for it, you can reply to this email a
[
https://issues.apache.org/jira/browse/FLINK-3332?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15140971#comment-15140971
]
ASF GitHub Bot commented on FLINK-3332:
---
GitHub user zentol opened a pull request:
Github user aljoscha commented on the pull request:
https://github.com/apache/flink/pull/1605#issuecomment-182421429
I addressed the comments.
---
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
[
https://issues.apache.org/jira/browse/FLINK-2237?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15140969#comment-15140969
]
ASF GitHub Bot commented on FLINK-2237:
---
Github user fhueske commented on a diff in
GitHub user zentol opened a pull request:
https://github.com/apache/flink/pull/1620
[FLINK-3332] Cassandra connector
This PR adds an Exactly-Once Cassandra Sink.
The Exactly-once guarantee is made by saving incoming records in the
OperatorState, and only committing them int
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/1517#discussion_r52470557
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/operators/hash/ReduceHashTable.java
---
@@ -0,0 +1,1014 @@
+/*
+ * Licensed to the Apa
[
https://issues.apache.org/jira/browse/FLINK-2237?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15140958#comment-15140958
]
ASF GitHub Bot commented on FLINK-2237:
---
Github user fhueske commented on a diff in
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/1517#discussion_r52469979
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/operators/hash/ReduceHashTable.java
---
@@ -0,0 +1,1014 @@
+/*
+ * Licensed to the Apa
Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/1605#discussion_r52469417
--- Diff:
flink-contrib/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBFoldingState.java
---
@@ -0,0 +1,175 @@
[
https://issues.apache.org/jira/browse/FLINK-3035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15140949#comment-15140949
]
ASF GitHub Bot commented on FLINK-3035:
---
Github user mjsax commented on the pull req
[
https://issues.apache.org/jira/browse/FLINK-2991?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15140951#comment-15140951
]
ASF GitHub Bot commented on FLINK-2991:
---
Github user aljoscha commented on a diff in
Github user mjsax commented on the pull request:
https://github.com/apache/flink/pull/1617#issuecomment-182416665
I just put a few initial comments. Before you update this, we need to
figure out, how to deal with Redis server (ie, single server for each job,
shared server for multiple
[
https://issues.apache.org/jira/browse/FLINK-3327?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15140947#comment-15140947
]
ASF GitHub Bot commented on FLINK-3327:
---
Github user kl0u commented on the pull requ
[
https://issues.apache.org/jira/browse/FLINK-3035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15140946#comment-15140946
]
ASF GitHub Bot commented on FLINK-3035:
---
Github user aljoscha commented on a diff in
Github user kl0u commented on the pull request:
https://github.com/apache/flink/pull/1583#issuecomment-182414285
Please review the new pull request.
This pull request is the first step for the one about FLINK-2523.
Thanks a lot!
---
If your project is set up for it, you
[
https://issues.apache.org/jira/browse/FLINK-2523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15140945#comment-15140945
]
ASF GitHub Bot commented on FLINK-2523:
---
Github user kl0u commented on the pull requ
Github user kl0u commented on the pull request:
https://github.com/apache/flink/pull/1612#issuecomment-182413649
Thanks a lot for the comments @rmetzger and @tillrohrmann . I integrated
them.
Please review the new pull request.
This pull request is based upon the one about FLI
[
https://issues.apache.org/jira/browse/FLINK-3035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15140944#comment-15140944
]
ASF GitHub Bot commented on FLINK-3035:
---
Github user mjsax commented on a diff in th
Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/1617#discussion_r52468882
--- Diff:
flink-contrib/flink-statebackend-redis/src/main/java/org/apache/flink/contrib/streaming/state/AbstractRedisState.java
---
@@ -0,0 +1,374 @@
+/
1 - 100 of 266 matches
Mail list logo
