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
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
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:
[
https://issues.apache.org/jira/browse/FLINK-2678?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15126975#comment-15126975
]
ASF GitHub Bot commented on FLINK-2678:
---
Github user sbcd90 commented on a diff in the pull request:
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
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`.
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
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
[
https://issues.apache.org/jira/browse/FLINK-2678?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15126977#comment-15126977
]
ASF GitHub Bot commented on FLINK-2678:
---
Github user sbcd90 commented on a diff in the pull request:
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
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
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
[
https://issues.apache.org/jira/browse/FLINK-3312?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15127048#comment-15127048
]
ASF GitHub Bot commented on FLINK-3312:
---
GitHub user StephanEwen opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-2870?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15127458#comment-15127458
]
Shikhar Bhushan commented on FLINK-2870:
Thanks for the info, appreciated!
> Add support for
[
https://issues.apache.org/jira/browse/FLINK-3033?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15125950#comment-15125950
]
Matthias J. Sax commented on FLINK-3033:
[~neo20iitkgp] please assign the JIRA to yourself and
[
https://issues.apache.org/jira/browse/FLINK-3034?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15125952#comment-15125952
]
Matthias J. Sax commented on FLINK-3034:
@ [~neo20iitkgp] please assign the JIRA to yourself and
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/1561
---
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-3300?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Maximilian Michels resolved FLINK-3300.
---
Resolution: Fixed
Fixed in 2a49eaaf3c949864457aee0ffd99343a50ac7285.
> Concurrency
[
https://issues.apache.org/jira/browse/FLINK-3300?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15125977#comment-15125977
]
ASF GitHub Bot commented on FLINK-3300:
---
Github user asfgit closed the pull request at:
Github user aljoscha commented on the pull request:
https://github.com/apache/flink/pull/1562#issuecomment-177839471
@gyfora you're right, I will add default implementations for ListState and
ReducingState and use them in the DbStateBackend. For RocksDB there are custom
Github user fhueske commented on the pull request:
https://github.com/apache/flink/pull/1559#issuecomment-177854554
@ChengXiangLi, just added you on Skype.
I'll write a mail to coordinate the time :-)
---
If your project is set up for it, you can reply to this email and
[
https://issues.apache.org/jira/browse/FLINK-3225?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15125949#comment-15125949
]
ASF GitHub Bot commented on FLINK-3225:
---
Github user fhueske commented on the pull request:
Chesnay Schepler created FLINK-3308:
---
Summary: [py] Remove debug mode
Key: FLINK-3308
URL: https://issues.apache.org/jira/browse/FLINK-3308
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-1509?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jeyhun Karimov updated FLINK-1509:
--
Assignee: (was: Jeyhun Karimov)
> Streaming Group Reduce Combiner
>
[
https://issues.apache.org/jira/browse/FLINK-2055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15126027#comment-15126027
]
PJ Van Aeken commented on FLINK-2055:
-
For Flink batch, I think HFileOutputFormat2 is a valid
[
https://issues.apache.org/jira/browse/FLINK-1509?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jeyhun Karimov updated FLINK-1509:
--
Comment: was deleted
(was: I will give a try to this problem)
> Streaming Group Reduce
[
https://issues.apache.org/jira/browse/FLINK-2870?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15125979#comment-15125979
]
Fabian Hueske commented on FLINK-2870:
--
[~shikhar], the late-arrival strategy for default time
[
https://issues.apache.org/jira/browse/FLINK-2184?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jeyhun Karimov updated FLINK-2184:
--
Assignee: (was: Jeyhun Karimov)
> Cannot get last element with maxBy/minBy
>
[
https://issues.apache.org/jira/browse/FLINK-3177?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jeyhun Karimov updated FLINK-3177:
--
Assignee: (was: Jeyhun Karimov)
> Add Stream Operator that Discards Late Elements
>
[
https://issues.apache.org/jira/browse/FLINK-2390?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jeyhun Karimov updated FLINK-2390:
--
Assignee: (was: Jeyhun Karimov)
> Replace iteration timeout with algorithm for detecting
Chesnay Schepler created FLINK-3309:
---
Summary: [py] Resolve maven warnings
Key: FLINK-3309
URL: https://issues.apache.org/jira/browse/FLINK-3309
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-3303?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15126651#comment-15126651
]
ASF GitHub Bot commented on FLINK-3303:
---
GitHub user StephanEwen opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-3276?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15126652#comment-15126652
]
Maximilian Michels commented on FLINK-3276:
---
Hi [~sbcd90]! This requires some more refactoring
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
[
https://issues.apache.org/jira/browse/FLINK-2678?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15126659#comment-15126659
]
ASF GitHub Bot commented on FLINK-2678:
---
Github user tillrohrmann commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-2678?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15126656#comment-15126656
]
ASF GitHub Bot commented on FLINK-2678:
---
Github user tillrohrmann commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-2678?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15126660#comment-15126660
]
ASF GitHub Bot commented on FLINK-2678:
---
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/1566#discussion_r51453634
--- Diff:
flink-core/src/main/java/org/apache/flink/api/common/typeutils/base/GenericArrayComparator.java
---
@@ -0,0 +1,205 @@
+/*
+ *
[
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
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 @@
+/*
+ *
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 @@
+/*
+ *
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() {
[
https://issues.apache.org/jira/browse/FLINK-2678?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15126663#comment-15126663
]
ASF GitHub Bot commented on FLINK-2678:
---
Github user tillrohrmann commented on a diff in the pull
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
[
https://issues.apache.org/jira/browse/FLINK-2678?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15126664#comment-15126664
]
ASF GitHub Bot commented on FLINK-2678:
---
Github user tillrohrmann commented on the pull request:
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 @@
+/*
+ *
[
https://issues.apache.org/jira/browse/FLINK-2678?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15126635#comment-15126635
]
ASF GitHub Bot commented on FLINK-2678:
---
Github user tillrohrmann commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-2055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15126221#comment-15126221
]
ramkrishna.s.vasudevan commented on FLINK-2055:
---
Thanks for your inputs.
For the batch case
Github user ramkrish86 commented on the pull request:
https://github.com/apache/flink/pull/1553#issuecomment-177957906
I went through the code. In both cases of WordCount program with and
without explicit partition
`[Map] --hash-partition--> [Reduce]`
`[Map] --partition-->
[
https://issues.apache.org/jira/browse/FLINK-2055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15126231#comment-15126231
]
PJ Van Aeken commented on FLINK-2055:
-
Indeed the example that you described uses the native client
[
https://issues.apache.org/jira/browse/FLINK-3265?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Maximilian Michels reassigned FLINK-3265:
-
Assignee: Maximilian Michels
> RabbitMQ Source not threadsafe:
[
https://issues.apache.org/jira/browse/FLINK-2055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15126231#comment-15126231
]
PJ Van Aeken edited comment on FLINK-2055 at 2/1/16 2:11 PM:
-
Indeed the
[
https://issues.apache.org/jira/browse/FLINK-3254?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15126515#comment-15126515
]
ASF GitHub Bot commented on FLINK-3254:
---
Github user fhueske commented on the pull request:
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
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 @@
+/*
+ *
[
https://issues.apache.org/jira/browse/FLINK-2678?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15126588#comment-15126588
]
ASF GitHub Bot commented on FLINK-2678:
---
Github user tillrohrmann commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-2348?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15126465#comment-15126465
]
Stephan Ewen commented on FLINK-2348:
-
Had this problem again. On Travis, the 5000 ms iteration
[
https://issues.apache.org/jira/browse/FLINK-3271?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15126475#comment-15126475
]
ASF GitHub Bot commented on FLINK-3271:
---
Github user abhishekagarwal87 commented on the pull
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
[
https://issues.apache.org/jira/browse/FLINK-3276?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15126524#comment-15126524
]
Subhobrata Dey commented on FLINK-3276:
---
Hello Maximilian,
If nobody else is working on this issue,
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
[
https://issues.apache.org/jira/browse/FLINK-3307?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Maximilian Michels resolved FLINK-3307.
---
Resolution: Duplicate
> RMQSourceTest failure
> -
>
>
[
https://issues.apache.org/jira/browse/FLINK-2021?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15126192#comment-15126192
]
ASF GitHub Bot commented on FLINK-2021:
---
Github user stefanobaghino closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-2021?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15126191#comment-15126191
]
ASF GitHub Bot commented on FLINK-2021:
---
Github user stefanobaghino commented on the pull request:
Github user stefanobaghino commented on the pull request:
https://github.com/apache/flink/pull/1536#issuecomment-177954808
Since it looks like I've gathered enough feedback, I'm closing the PR so
that I can keep working on it and not burden on the CI system. Sorry for the
WIP PR,
Github user stefanobaghino closed the pull request at:
https://github.com/apache/flink/pull/1536
---
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
[
https://issues.apache.org/jira/browse/FLINK-3265?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Maximilian Michels reopened FLINK-3265:
---
Assignee: (was: Robert Metzger)
Seems to be still some synchronization issue in
[
https://issues.apache.org/jira/browse/FLINK-3301?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15126148#comment-15126148
]
ASF GitHub Bot commented on FLINK-3301:
---
Github user mxm commented on a diff in the pull request:
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/1560#discussion_r51408033
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/MessageAcknowledgingSourceBase.java
---
@@ -177,21 +177,19 @@
[
https://issues.apache.org/jira/browse/FLINK-3034?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
subhankar biswas reassigned FLINK-3034:
---
Assignee: subhankar biswas
> Redis SInk Connector
>
>
>
[
https://issues.apache.org/jira/browse/FLINK-3033?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
subhankar biswas reassigned FLINK-3033:
---
Assignee: subhankar biswas
> Redis Source Connector
> --
>
>
[
https://issues.apache.org/jira/browse/FLINK-3301?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Maximilian Michels resolved FLINK-3301.
---
Resolution: Duplicate
> Ineffective synchronization in
[
https://issues.apache.org/jira/browse/FLINK-3179?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15126204#comment-15126204
]
ASF GitHub Bot commented on FLINK-3179:
---
Github user ramkrish86 commented on the pull request:
[
https://issues.apache.org/jira/browse/FLINK-3254?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15126435#comment-15126435
]
ASF GitHub Bot commented on FLINK-3254:
---
Github user kl0u commented on the pull request:
[
https://issues.apache.org/jira/browse/FLINK-3271?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15126469#comment-15126469
]
ASF GitHub Bot commented on FLINK-3271:
---
Github user abhishekagarwal87 commented on the pull
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
[
https://issues.apache.org/jira/browse/FLINK-2678?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15126981#comment-15126981
]
ASF GitHub Bot commented on FLINK-2678:
---
Github user sbcd90 commented on the pull request:
[
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
[
https://issues.apache.org/jira/browse/FLINK-3160?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15126783#comment-15126783
]
ASF GitHub Bot commented on FLINK-3160:
---
Github user greghogan commented on the pull request:
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
[
https://issues.apache.org/jira/browse/FLINK-2055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15126231#comment-15126231
]
PJ Van Aeken edited comment on FLINK-2055 at 2/1/16 2:22 PM:
-
Indeed the
[
https://issues.apache.org/jira/browse/FLINK-2055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15126287#comment-15126287
]
PJ Van Aeken commented on FLINK-2055:
-
There appears to be a version mismatch which is why we are not
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
[
https://issues.apache.org/jira/browse/FLINK-3254?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15126309#comment-15126309
]
ASF GitHub Bot commented on FLINK-3254:
---
GitHub user kl0u opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-3254?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15126338#comment-15126338
]
ASF GitHub Bot commented on FLINK-3254:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-3179?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15126305#comment-15126305
]
ASF GitHub Bot commented on FLINK-3179:
---
Github user fhueske commented on the pull request:
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
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 @@
+/*
+ *
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
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() {
[
https://issues.apache.org/jira/browse/FLINK-3301?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15126313#comment-15126313
]
ASF GitHub Bot commented on FLINK-3301:
---
Github user tedyu closed the pull request at:
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 @@
+/*
+ *
[
https://issues.apache.org/jira/browse/FLINK-3254?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15126319#comment-15126319
]
ASF GitHub Bot commented on FLINK-3254:
---
Github user fhueske commented on a diff in the pull
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 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
[
https://issues.apache.org/jira/browse/FLINK-3296?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15126388#comment-15126388
]
ASF GitHub Bot commented on FLINK-3296:
---
Github user StephanEwen commented on the 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`
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=15126399#comment-15126399
]
ASF GitHub Bot commented on FLINK-3265:
---
GitHub user mxm opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-3265?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15126403#comment-15126403
]
ASF GitHub Bot commented on FLINK-3265:
---
Github user rmetzger commented on a diff in the pull
1 - 100 of 132 matches
Mail list logo
