[
https://issues.apache.org/jira/browse/FLINK-3281?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chengxiang Li resolved FLINK-3281.
--
Resolution: Fixed
Fix Version/s: 1.0.0
> IndexOutOfBoundsException when range-partitionin
[
https://issues.apache.org/jira/browse/FLINK-2870?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15127458#comment-15127458
]
Shikhar Bhushan commented on FLINK-2870:
Thanks for the info, appreciated!
> Add
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1562#issuecomment-178195987
Rebased and extended this pull request in #1571
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If yo
GitHub user StephanEwen opened a pull request:
https://github.com/apache/flink/pull/1571
[FLINK-3312] State enhancements convenience methods for the public API
**NOTE** This pull request is based on #1570 and #1562 . It should be
addressed once these two are merged.
This pu
[
https://issues.apache.org/jira/browse/FLINK-3312?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15127048#comment-15127048
]
ASF GitHub Bot commented on FLINK-3312:
---
GitHub user StephanEwen opened a pull reque
Stephan Ewen created FLINK-3312:
---
Summary: Add convenience accessor methods for extended state
interface
Key: FLINK-3312
URL: https://issues.apache.org/jira/browse/FLINK-3312
Project: Flink
Is
Github user sbcd90 commented on the pull request:
https://github.com/apache/flink/pull/1566#issuecomment-178174969
@tillrohrmann Thanks for the review. I had a few questions based on your
comments. Kindly help me in getting the questions answered so that I can
proceed.
---
If your p
[
https://issues.apache.org/jira/browse/FLINK-2678?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15126981#comment-15126981
]
ASF GitHub Bot commented on FLINK-2678:
---
Github user sbcd90 commented on the pull re
[
https://issues.apache.org/jira/browse/FLINK-2678?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15126977#comment-15126977
]
ASF GitHub Bot commented on FLINK-2678:
---
Github user sbcd90 commented on a diff in t
Github user sbcd90 commented on a diff in the pull request:
https://github.com/apache/flink/pull/1566#discussion_r51476344
--- Diff:
flink-core/src/test/java/org/apache/flink/api/common/typeutils/base/GenericArrayComparatorTest.java
---
@@ -0,0 +1,82 @@
+/*
+ * Licensed to
[
https://issues.apache.org/jira/browse/FLINK-2678?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15126975#comment-15126975
]
ASF GitHub Bot commented on FLINK-2678:
---
Github user sbcd90 commented on a diff in t
Github user sbcd90 commented on a diff in the pull request:
https://github.com/apache/flink/pull/1566#discussion_r51476173
--- Diff:
flink-core/src/main/java/org/apache/flink/api/common/typeutils/base/GenericArrayComparator.java
---
@@ -0,0 +1,205 @@
+/*
+ * Licensed to th
Robert Metzger created FLINK-3311:
-
Summary: Add a connector for streaming data into Cassandra
Key: FLINK-3311
URL: https://issues.apache.org/jira/browse/FLINK-3311
Project: Flink
Issue Type:
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1562#issuecomment-178146614
Have rebased this onto the current master.
One thing I'd like to change is to move the HDFS copy process utils from
`flink-core` to `flink-runtime`.
Idea
Ufuk Celebi created FLINK-3310:
--
Summary: Add back pressure statistics to web frontend
Key: FLINK-3310
URL: https://issues.apache.org/jira/browse/FLINK-3310
Project: Flink
Issue Type: Improvemen
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1562#issuecomment-178130142
Okay, nice, didn't look at the code after the changes again.
+1 to merge this then
---
If your project is set up for it, you can reply to this email and hav
[
https://issues.apache.org/jira/browse/FLINK-3160?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15126783#comment-15126783
]
ASF GitHub Bot commented on FLINK-3160:
---
Github user greghogan commented on the pull
Github user greghogan commented on the pull request:
https://github.com/apache/flink/pull/1564#issuecomment-178124299
Running WordCount on a single node running two taskmanagers, the first
screenshot is the current UI (with 'Overview' renamed to 'Subtasks') and the
second screenshot i
Github user aljoscha commented on the pull request:
https://github.com/apache/flink/pull/1562#issuecomment-178111578
@StephanEwen @gyfora I have the changes reflected in this PR already.
---
If your project is set up for it, you can reply to this email and have your
reply appear on Gi
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1562#issuecomment-178099623
I think this is in quite good shape.
@gyfora's comment makes sense, +1 for such a default implementation.
The changes I am making are based on this,
[
https://issues.apache.org/jira/browse/FLINK-3276?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Maximilian Michels updated FLINK-3276:
--
Priority: Major (was: Critical)
> Move runtime parts of flink-streaming-java to flink-r
Github user tillrohrmann commented on the pull request:
https://github.com/apache/flink/pull/1566#issuecomment-178097783
Thanks for your contribution @sbcd90. I think the PR needs still a bit of
work before it can be merged. The implementation of `GenericArrayComparator`
only works fo
[
https://issues.apache.org/jira/browse/FLINK-2678?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15126664#comment-15126664
]
ASF GitHub Bot commented on FLINK-2678:
---
Github user tillrohrmann commented on the p
[
https://issues.apache.org/jira/browse/FLINK-2678?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15126663#comment-15126663
]
ASF GitHub Bot commented on FLINK-2678:
---
Github user tillrohrmann commented on a dif
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/1566#discussion_r51453894
--- Diff:
flink-java/src/test/java/org/apache/flink/api/java/operator/DataSinkTest.java
---
@@ -311,7 +311,7 @@ public void testPojoSingleOrderFull() {
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/1566#discussion_r51453735
--- Diff:
flink-core/src/main/java/org/apache/flink/api/common/typeutils/base/GenericArrayComparator.java
---
@@ -0,0 +1,205 @@
+/*
+ * Licensed
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/1566#discussion_r51453680
--- Diff:
flink-core/src/test/java/org/apache/flink/api/common/typeutils/base/GenericArrayComparatorTest.java
---
@@ -0,0 +1,82 @@
+/*
+ * Licen
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/1566#discussion_r51453634
--- Diff:
flink-core/src/main/java/org/apache/flink/api/common/typeutils/base/GenericArrayComparator.java
---
@@ -0,0 +1,205 @@
+/*
+ * Licensed
[
https://issues.apache.org/jira/browse/FLINK-3276?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Maximilian Michels updated FLINK-3276:
--
Issue Type: Improvement (was: Bug)
> Move runtime parts of flink-streaming-java to flin
[
https://issues.apache.org/jira/browse/FLINK-2678?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15126656#comment-15126656
]
ASF GitHub Bot commented on FLINK-2678:
---
Github user tillrohrmann commented on a dif
[
https://issues.apache.org/jira/browse/FLINK-2678?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15126660#comment-15126660
]
ASF GitHub Bot commented on FLINK-2678:
---
Github user tillrohrmann commented on a dif
[
https://issues.apache.org/jira/browse/FLINK-2678?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15126659#comment-15126659
]
ASF GitHub Bot commented on FLINK-2678:
---
Github user tillrohrmann commented on a dif
[
https://issues.apache.org/jira/browse/FLINK-3303?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15126651#comment-15126651
]
ASF GitHub Bot commented on FLINK-3303:
---
GitHub user StephanEwen opened a pull reque
GitHub user StephanEwen opened a pull request:
https://github.com/apache/flink/pull/1570
[FLINK-3303] Move all non-batch specific classes in "flink-java" to
"flink-core"
Currently, `flink-java` has a lot of classes that are also needed by the
streaming API. For some future changes,
[
https://issues.apache.org/jira/browse/FLINK-3276?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15126652#comment-15126652
]
Maximilian Michels commented on FLINK-3276:
---
Hi [~sbcd90]! This requires some mo
[
https://issues.apache.org/jira/browse/FLINK-2678?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15126635#comment-15126635
]
ASF GitHub Bot commented on FLINK-2678:
---
Github user tillrohrmann commented on a dif
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/1566#discussion_r51453182
--- Diff:
flink-core/src/main/java/org/apache/flink/api/common/typeutils/base/GenericArrayComparator.java
---
@@ -0,0 +1,205 @@
+/*
+ * Licensed
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/1566#discussion_r51448517
--- Diff:
flink-core/src/main/java/org/apache/flink/api/common/typeutils/base/GenericArrayComparator.java
---
@@ -0,0 +1,205 @@
+/*
+ * Licensed
[
https://issues.apache.org/jira/browse/FLINK-2678?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15126588#comment-15126588
]
ASF GitHub Bot commented on FLINK-2678:
---
Github user tillrohrmann commented on a dif
Github user sbcd90 commented on the pull request:
https://github.com/apache/flink/pull/1566#issuecomment-178034715
@StephanEwen could you also help reviewing the code?
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If yo
[
https://issues.apache.org/jira/browse/FLINK-3276?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15126524#comment-15126524
]
Subhobrata Dey commented on FLINK-3276:
---
Hello Maximilian,
If nobody else is workin
Github user fhueske commented on the pull request:
https://github.com/apache/flink/pull/1568#issuecomment-178060233
Good to merge. Thanks!
---
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
[
https://issues.apache.org/jira/browse/FLINK-3254?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15126515#comment-15126515
]
ASF GitHub Bot commented on FLINK-3254:
---
Github user fhueske commented on the pull r
[
https://issues.apache.org/jira/browse/FLINK-3271?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15126475#comment-15126475
]
ASF GitHub Bot commented on FLINK-3271:
---
Github user abhishekagarwal87 commented on
Github user abhishekagarwal87 commented on the pull request:
https://github.com/apache/flink/pull/1543#issuecomment-178049275
webhdfs api works with this commit but there could be similar classNotFound
problems in future.
---
If your project is set up for it, you can reply to this em
Github user abhishekagarwal87 commented on the pull request:
https://github.com/apache/flink/pull/1543#issuecomment-178048690
seems to be some misunderstanding. That was not the intention. I suggested
relocating hadoop classes so that any hadoop classes in the application are
loaded t
[
https://issues.apache.org/jira/browse/FLINK-3271?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15126469#comment-15126469
]
ASF GitHub Bot commented on FLINK-3271:
---
Github user abhishekagarwal87 commented on
[
https://issues.apache.org/jira/browse/FLINK-2348?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15126465#comment-15126465
]
Stephan Ewen commented on FLINK-2348:
-
Had this problem again. On Travis, the 5000 ms
Github user kl0u commented on the pull request:
https://github.com/apache/flink/pull/1568#issuecomment-178039470
Thanks a lot for the comments @fhueske . They are already integrated.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub
[
https://issues.apache.org/jira/browse/FLINK-3254?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15126435#comment-15126435
]
ASF GitHub Bot commented on FLINK-3254:
---
Github user kl0u commented on the pull requ
[
https://issues.apache.org/jira/browse/FLINK-3271?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15126452#comment-15126452
]
ASF GitHub Bot commented on FLINK-3271:
---
Github user StephanEwen commented on the pu
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1543#issuecomment-178044858
If I understood your suggestion at the beginning correctly, you wanted to
allow users to delete the "Hadoop jar" in the lib folder and replace it with
their own cust
[
https://issues.apache.org/jira/browse/FLINK-3265?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Maximilian Michels closed FLINK-3265.
-
Resolution: Fixed
The root cause of the entire issue was a test case not testing under run
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/1569
---
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-3265?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15126437#comment-15126437
]
ASF GitHub Bot commented on FLINK-3265:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-2678?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15126421#comment-15126421
]
ASF GitHub Bot commented on FLINK-2678:
---
Github user sbcd90 commented on the pull re
Github user abhishekagarwal87 commented on the pull request:
https://github.com/apache/flink/pull/1543#issuecomment-178038559
Hi @StephanEwen
how does separating out hadoop classes solve the classloader problem? Since
even if the jars are different, they will be loaded in parent c
[
https://issues.apache.org/jira/browse/FLINK-3271?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15126432#comment-15126432
]
ASF GitHub Bot commented on FLINK-3271:
---
Github user abhishekagarwal87 commented on
[
https://issues.apache.org/jira/browse/FLINK-3301?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15126410#comment-15126410
]
ASF GitHub Bot commented on FLINK-3301:
---
Github user mxm commented on the pull reque
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/1569#discussion_r51432976
--- Diff:
flink-streaming-connectors/flink-connector-rabbitmq/src/test/java/org/apache/flink/streaming/connectors/rabbitmq/RMQSourceTest.java
---
@@ -219,7 +140,
[
https://issues.apache.org/jira/browse/FLINK-3265?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15126411#comment-15126411
]
ASF GitHub Bot commented on FLINK-3265:
---
Github user mxm commented on a diff in the
Github user mxm commented on the pull request:
https://github.com/apache/flink/pull/1560#issuecomment-178029684
Thanks for the pull request. The issue has been identified in the meantime.
It is only a testing issue and not a synchronization issue in the RMQSource.
---
If your project
[
https://issues.apache.org/jira/browse/FLINK-3265?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15126403#comment-15126403
]
ASF GitHub Bot commented on FLINK-3265:
---
Github user rmetzger commented on a diff in
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/1569#discussion_r51432473
--- Diff:
flink-streaming-connectors/flink-connector-rabbitmq/src/test/java/org/apache/flink/streaming/connectors/rabbitmq/RMQSourceTest.java
---
@@ -219,7
[
https://issues.apache.org/jira/browse/FLINK-3265?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15126399#comment-15126399
]
ASF GitHub Bot commented on FLINK-3265:
---
GitHub user mxm opened a pull request:
GitHub user mxm opened a pull request:
https://github.com/apache/flink/pull/1569
[FLINK-3265][tests] adapt RabbitMQ checkpointing test to runtime behavior
This reverts the previous fix as this was merely a bug in the test. The
methods `snapshotState` and `notifyCheckpointComplete`
[
https://issues.apache.org/jira/browse/FLINK-3296?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15126388#comment-15126388
]
ASF GitHub Bot commented on FLINK-3296:
---
Github user StephanEwen commented on the pu
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1563#issuecomment-178020653
Code looks good. I would like to update the docs to include a bit more info
(like in the inline comment) and at least refer to the `addSink(...)` method,
for fault t
Github user fhueske commented on the pull request:
https://github.com/apache/flink/pull/1568#issuecomment-178011362
Thanks for the PR. I had a few minor comments. Looks good otherwise.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitH
[
https://issues.apache.org/jira/browse/FLINK-3254?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15126373#comment-15126373
]
ASF GitHub Bot commented on FLINK-3254:
---
Github user fhueske commented on the pull r
[
https://issues.apache.org/jira/browse/FLINK-3254?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15126339#comment-15126339
]
ASF GitHub Bot commented on FLINK-3254:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-3254?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15126353#comment-15126353
]
ASF GitHub Bot commented on FLINK-3254:
---
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/1568#discussion_r51428276
--- Diff:
flink-tests/src/test/java/org/apache/flink/test/javaApiOperators/ReduceWithCombinerITCase.java
---
@@ -0,0 +1,377 @@
+/*
+ * Licensed to th
[
https://issues.apache.org/jira/browse/FLINK-3296?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15126351#comment-15126351
]
ASF GitHub Bot commented on FLINK-3296:
---
Github user StephanEwen commented on a diff
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/1563#discussion_r51428065
--- Diff: docs/apis/streaming/index.md ---
@@ -1768,6 +1768,11 @@ greater than 1, the output will also be prepended
with the identifier of the tas
[
https://issues.apache.org/jira/browse/FLINK-3254?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15126347#comment-15126347
]
ASF GitHub Bot commented on FLINK-3254:
---
Github user kl0u commented on a diff in the
Github user kl0u commented on a diff in the pull request:
https://github.com/apache/flink/pull/1568#discussion_r51427689
--- Diff:
flink-java/src/main/java/org/apache/flink/api/java/operators/GroupReduceOperator.java
---
@@ -156,8 +162,8 @@ public boolean isCombinable() {
[
https://issues.apache.org/jira/browse/FLINK-3254?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15126345#comment-15126345
]
ASF GitHub Bot commented on FLINK-3254:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-3306?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-3306.
-
Resolution: Fixed
Fixed via c4bc47afa6147dd25d8b579e764b30c9c13ee8ea
> Auto type registration at
[
https://issues.apache.org/jira/browse/FLINK-3305?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-3305.
---
> Remove JavaKaffee serializer util
> -
>
> Key: FLINK-330
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/1568#discussion_r51427575
--- Diff:
flink-java/src/main/java/org/apache/flink/api/java/operators/GroupReduceOperator.java
---
@@ -193,7 +199,11 @@ public SingleInputSemanticProperties
[
https://issues.apache.org/jira/browse/FLINK-3306?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-3306.
---
> Auto type registration at Kryo is buggy
> ---
>
> Ke
[
https://issues.apache.org/jira/browse/FLINK-3305?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-3305.
-
Resolution: Fixed
Fixed via b6110dc35a17340653a39209038041a5e28054b4
> Remove JavaKaffee serializ
[
https://issues.apache.org/jira/browse/FLINK-3254?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15126329#comment-15126329
]
ASF GitHub Bot commented on FLINK-3254:
---
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/1568#discussion_r51427409
--- Diff:
flink-core/src/main/java/org/apache/flink/api/common/functions/util/CombineToGroupCombineWrapper.java
---
@@ -0,0 +1,49 @@
+/*
+ * Licensed
[
https://issues.apache.org/jira/browse/FLINK-3254?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15126338#comment-15126338
]
ASF GitHub Bot commented on FLINK-3254:
---
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/1568#discussion_r51427090
--- Diff:
flink-java/src/main/java/org/apache/flink/api/java/operators/GroupReduceOperator.java
---
@@ -156,8 +162,8 @@ public boolean isCombinable() {
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/1568#discussion_r51426746
--- Diff:
flink-java/src/main/java/org/apache/flink/api/java/operators/GroupReduceOperator.java
---
@@ -119,6 +123,8 @@ private void checkCombinability() {
Github user tedyu closed the pull request at:
https://github.com/apache/flink/pull/1560
---
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
[
https://issues.apache.org/jira/browse/FLINK-3254?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15126319#comment-15126319
]
ASF GitHub Bot commented on FLINK-3254:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-3254?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15126318#comment-15126318
]
ASF GitHub Bot commented on FLINK-3254:
---
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/1568#discussion_r51425852
--- Diff:
flink-core/src/main/java/org/apache/flink/api/common/functions/util/CombineToGroupCombineWrapper.java
---
@@ -0,0 +1,49 @@
+/*
+ * Licensed
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/1568#discussion_r51425707
--- Diff:
flink-core/src/main/java/org/apache/flink/api/common/functions/util/CombineToGroupCombineWrapper.java
---
@@ -0,0 +1,49 @@
+/*
+ * Licensed
[
https://issues.apache.org/jira/browse/FLINK-3301?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15126313#comment-15126313
]
ASF GitHub Bot commented on FLINK-3301:
---
Github user tedyu closed the pull request a
[
https://issues.apache.org/jira/browse/FLINK-3254?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15126309#comment-15126309
]
ASF GitHub Bot commented on FLINK-3254:
---
GitHub user kl0u opened a pull request:
GitHub user kl0u opened a pull request:
https://github.com/apache/flink/pull/1568
FLINK-3254: Adding functionality to support the CombineFunction contract.
Solves ISSUE-3254: now a function that implements the GroupReduceFunction
and the CombineFunction interfaces will be executed w
[
https://issues.apache.org/jira/browse/FLINK-3179?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15126305#comment-15126305
]
ASF GitHub Bot commented on FLINK-3179:
---
Github user fhueske commented on the pull r
Github user fhueske commented on the pull request:
https://github.com/apache/flink/pull/1553#issuecomment-177997324
The `GroupReduceWithCombineProperties.instanciate()` method checks the
shipping strategy of the input channel. In case of the `WordCount` example
*without* explicit hash
[
https://issues.apache.org/jira/browse/FLINK-2055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15126287#comment-15126287
]
PJ Van Aeken commented on FLINK-2055:
-
There appears to be a version mismatch which is
[
https://issues.apache.org/jira/browse/FLINK-2055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15126231#comment-15126231
]
PJ Van Aeken edited comment on FLINK-2055 at 2/1/16 2:22 PM:
-
1 - 100 of 134 matches
Mail list logo
