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
implementation
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 have
[
https://issues.apache.org/jira/browse/FLINK-3225?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15125949#comment-15125949
]
ASF GitHub Bot commented on FLINK-3225:
---
Github user fhueske commented on the pull r
[
https://issues.apache.org/jira/browse/FLINK-3033?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15125950#comment-15125950
]
Matthias J. Sax commented on FLINK-3033:
[~neo20iitkgp] please assign the JIRA to
[
https://issues.apache.org/jira/browse/FLINK-3034?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15125952#comment-15125952
]
Matthias J. Sax commented on FLINK-3034:
@ [~neo20iitkgp] please assign the JIRA t
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
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 enab
[
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 Bu
[
https://issues.apache.org/jira/browse/FLINK-3300?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15125977#comment-15125977
]
ASF GitHub Bot commented on FLINK-3300:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-2870?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15125979#comment-15125979
]
Fabian Hueske commented on FLINK-2870:
--
[~shikhar], the late-arrival strategy for def
[
https://issues.apache.org/jira/browse/FLINK-2055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15126027#comment-15126027
]
PJ Van Aeken commented on FLINK-2055:
-
For Flink batch, I think HFileOutputFormat2 is
[
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 Combiner
[
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-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 ter
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-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-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-3301?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Maximilian Michels resolved FLINK-3301.
---
Resolution: Duplicate
> Ineffective synchronization in MessageAcknowledgingSourceBase#
[
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&focusedCommentId=15126148#comment-15126148
]
ASF GitHub Bot commented on FLINK-3301:
---
Github user mxm commented on a diff in the
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 @@ protec
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, I'll
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 feature
[
https://issues.apache.org/jira/browse/FLINK-2021?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15126192#comment-15126192
]
ASF GitHub Bot commented on FLINK-2021:
---
Github user stefanobaghino closed the pull
[
https://issues.apache.org/jira/browse/FLINK-2021?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15126191#comment-15126191
]
ASF GitHub Bot commented on FLINK-2021:
---
Github user stefanobaghino commented on the
[
https://issues.apache.org/jira/browse/FLINK-3179?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15126204#comment-15126204
]
ASF GitHub Bot commented on FLINK-3179:
---
Github user ramkrish86 commented on the pul
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--> [Par
[
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: ConcurrentModifica
[
https://issues.apache.org/jira/browse/FLINK-2055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15126221#comment-15126221
]
ramkrishna.s.vasudevan commented on FLINK-2055:
---
Thanks for your inputs.
For
[
https://issues.apache.org/jira/browse/FLINK-2055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15126231#comment-15126231
]
PJ Van Aeken commented on FLINK-2055:
-
Indeed the example that you described uses the
[
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:11 PM:
-
[
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:
-
[
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
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-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 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-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:
[
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
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
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
[
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
[
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
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
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 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() {
[
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_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=15126329#comment-15126329
]
ASF GitHub Bot commented on FLINK-3254:
---
Github user fhueske commented on a diff in
[
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-3306?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-3306.
---
> Auto type registration at Kryo is buggy
> ---
>
> Ke
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-3305?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-3305.
---
> Remove JavaKaffee serializer util
> -
>
> Key: FLINK-330
[
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
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-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 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-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 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-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
[
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
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
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
[
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 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&focusedCommentId=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&focusedCommentId=15126403#comment-15126403
]
ASF GitHub Bot commented on FLINK-3265:
---
Github user rmetzger commented on a diff in
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=15126411#comment-15126411
]
ASF GitHub Bot commented on FLINK-3265:
---
Github user mxm commented on a diff in the
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-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 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-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
[
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
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: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 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-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 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-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
[
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
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
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
[
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
[
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
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-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 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-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 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
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
[
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
[
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
1 - 100 of 134 matches
Mail list logo
