[
https://issues.apache.org/jira/browse/FLINK-3857?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15273608#comment-15273608
]
ASF GitHub Bot commented on FLINK-3857:
---
Github user sbcd90 commented on the pull re
Github user sbcd90 commented on the pull request:
https://github.com/apache/flink/pull/1962#issuecomment-217342680
Hello @rmetzger ,
Looking at the test case `ElasticsearchSinkItCase.testTransportClient`, I
think to test the re-connect scenario the `hasFailure` may need to be
[
https://issues.apache.org/jira/browse/FLINK-3878?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15273594#comment-15273594
]
ASF GitHub Bot commented on FLINK-3878:
---
GitHub user kkrugler opened a pull request:
GitHub user kkrugler opened a pull request:
https://github.com/apache/flink/pull/1965
FLINK-3878: File cache doesn't support multiple duplicate temp directâ¦
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/kkrugler/flink FLINK-3
[
https://issues.apache.org/jira/browse/FLINK-3878?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15273572#comment-15273572
]
Ken Krugler commented on FLINK-3878:
I confirmed this fixes the issue - I was able to
[
https://issues.apache.org/jira/browse/FLINK-3878?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15273559#comment-15273559
]
Chiwan Park commented on FLINK-3878:
Hi Ken, thanks for reporting this issue and submi
[
https://issues.apache.org/jira/browse/FLINK-3878?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chiwan Park updated FLINK-3878:
---
Component/s: Local Runtime
Distributed Runtime
> File cache doesn't support multiple
[
https://issues.apache.org/jira/browse/FLINK-3878?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chiwan Park updated FLINK-3878:
---
Affects Version/s: 1.1.0
> File cache doesn't support multiple duplicate temp directories
> --
[
https://issues.apache.org/jira/browse/FLINK-3878?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ken Krugler updated FLINK-3878:
---
Attachment: FLINK-3878.patch
> File cache doesn't support multiple duplicate temp directories
> --
Ken Krugler created FLINK-3878:
--
Summary: File cache doesn't support multiple duplicate temp
directories
Key: FLINK-3878
URL: https://issues.apache.org/jira/browse/FLINK-3878
Project: Flink
Iss
Github user sbcd90 commented on the pull request:
https://github.com/apache/flink/pull/1962#issuecomment-217298024
Hello @rmetzger ,
Thanks a lot for reviewing the PR.
I have made all the changes mentioned by you as inline comments as well as
added some documentation.
[
https://issues.apache.org/jira/browse/FLINK-3857?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15273230#comment-15273230
]
ASF GitHub Bot commented on FLINK-3857:
---
Github user sbcd90 commented on the pull re
[
https://issues.apache.org/jira/browse/FLINK-3854?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15273043#comment-15273043
]
ASF GitHub Bot commented on FLINK-3854:
---
Github user IgorBerman commented on the pul
Github user IgorBerman commented on the pull request:
https://github.com/apache/flink/pull/1953#issuecomment-217273709
@aljoscha tests returned to prev state
all profiles passed except for
JDK: openjdk7
PROFILE="-Dhadoop.profile=1"
---
If your project is set up for it, yo
[
https://issues.apache.org/jira/browse/FLINK-1502?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15272825#comment-15272825
]
ASF GitHub Bot commented on FLINK-1502:
---
Github user ankitcha commented on the pull
Github user ankitcha commented on the pull request:
https://github.com/apache/flink/pull/1947#issuecomment-217240628
Guys, Thanks you for this awesome addition to Flink.
I was just wondering if there is a way to configure multiple reporters as
well?
---
If your project is s
[
https://issues.apache.org/jira/browse/FLINK-3758?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15272819#comment-15272819
]
Konstantin Knauf commented on FLINK-3758:
-
[~aljoscha] What do you think of
https
[
https://issues.apache.org/jira/browse/FLINK-1502?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15272662#comment-15272662
]
ASF GitHub Bot commented on FLINK-1502:
---
Github user rmetzger commented on the pull
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/1947#issuecomment-217214295
I'm just assuming its the missing "close()" call's I've commented already
causing this issue.
I just tried adding some custom metrics:
```java
new RichF
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/1947#issuecomment-217213101
Is it possible that submitting the same job two times doesn't work?
```
./bin/flink run ./examples/streaming/SocketWindowWordCount.jar --port 54323
[
https://issues.apache.org/jira/browse/FLINK-1502?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15272654#comment-15272654
]
ASF GitHub Bot commented on FLINK-1502:
---
Github user rmetzger commented on the pull
[
https://issues.apache.org/jira/browse/FLINK-3229?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15272584#comment-15272584
]
ASF GitHub Bot commented on FLINK-3229:
---
Github user rmetzger commented on the pull
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/1911#issuecomment-217202359
Yep, that's the right branch.
I tried working on different approaches, but its just an annoying problem
with protobuf.
I'll probably work on it tomorrow again.
Github user tzulitai commented on the pull request:
https://github.com/apache/flink/pull/1911#issuecomment-217201356
Thanks Robert. I'll keep notice of your FLINK-3229-review branch for the
changes (I'm assuming your working on FLINK-3229-review for the protobuf
problem, please tell m
[
https://issues.apache.org/jira/browse/FLINK-3229?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15272578#comment-15272578
]
ASF GitHub Bot commented on FLINK-3229:
---
Github user tzulitai commented on the pull
[
https://issues.apache.org/jira/browse/FLINK-2971?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15272553#comment-15272553
]
Dawid Wysakowicz commented on FLINK-2971:
-
Hi, I think i finished working on that
[
https://issues.apache.org/jira/browse/FLINK-3311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15272454#comment-15272454
]
ASF GitHub Bot commented on FLINK-3311:
---
Github user rmetzger commented on the pull
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/1771#issuecomment-217171304
I just tried the PR, but the recovery after a failure doesn't seem to work:
```
java.lang.RuntimeException: Error triggering a checkpoint as the result of
r
[
https://issues.apache.org/jira/browse/FLINK-3311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15272402#comment-15272402
]
ASF GitHub Bot commented on FLINK-3311:
---
Github user rmetzger commented on the pull
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/1771#issuecomment-217160848
I'll test the PR again
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have thi
Github user alkagin commented on the pull request:
https://github.com/apache/flink/pull/1771#issuecomment-217159043
Hi guys :) any update on this?
---
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 h
[
https://issues.apache.org/jira/browse/FLINK-3311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15272344#comment-15272344
]
ASF GitHub Bot commented on FLINK-3311:
---
Github user alkagin commented on the pull r
Github user greghogan commented on the pull request:
https://github.com/apache/flink/pull/1956#issuecomment-217142445
1) Yes, that sounds right. The update function can choose which of Hub or
Authority to set.
2) Does `GSAConfiguration.setDirection` work the same as in scatter
[
https://issues.apache.org/jira/browse/FLINK-2044?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15272256#comment-15272256
]
ASF GitHub Bot commented on FLINK-2044:
---
Github user greghogan commented on the pull
[
https://issues.apache.org/jira/browse/FLINK-3190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15272240#comment-15272240
]
ASF GitHub Bot commented on FLINK-3190:
---
Github user fijolekProjects commented on th
Github user fijolekProjects commented on the pull request:
https://github.com/apache/flink/pull/1954#issuecomment-217138008
That's fine @rmetzger :)
---
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
[
https://issues.apache.org/jira/browse/FLINK-3857?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15272205#comment-15272205
]
ASF GitHub Bot commented on FLINK-3857:
---
Github user rmetzger commented on the pull
[
https://issues.apache.org/jira/browse/FLINK-3190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15272206#comment-15272206
]
ASF GitHub Bot commented on FLINK-3190:
---
Github user rmetzger commented on the pull
[
https://issues.apache.org/jira/browse/FLINK-3857?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15272203#comment-15272203
]
ASF GitHub Bot commented on FLINK-3857:
---
Github user rmetzger commented on the pull
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/1962#discussion_r62174087
--- Diff:
flink-streaming-connectors/flink-connector-elasticsearch2/src/main/java/org/apache/flink/streaming/connectors/elasticsearch2/ElasticsearchSink.java
--
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/1954#issuecomment-217126222
Thanks a lot for opening a pull request!
I'm sorry that nobody from the community responded to it yet. Its just that
we are a bit overloaded currently.
---
If your
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/1962#issuecomment-217126041
The change is missing documentation updates & test cases.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well
[
https://issues.apache.org/jira/browse/FLINK-3857?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15272204#comment-15272204
]
ASF GitHub Bot commented on FLINK-3857:
---
Github user rmetzger commented on a diff in
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/1962#issuecomment-217125875
Thank you for opening the pull request.
I made some inline comments.
I don't think the proposed changes fix the issue described in the JIRA.
I would chec
[
https://issues.apache.org/jira/browse/FLINK-3857?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15272198#comment-15272198
]
ASF GitHub Bot commented on FLINK-3857:
---
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/1962#discussion_r62173382
--- Diff:
flink-streaming-connectors/flink-connector-elasticsearch2/src/main/java/org/apache/flink/streaming/connectors/elasticsearch2/ElasticsearchSink.java
--
[
https://issues.apache.org/jira/browse/FLINK-3857?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15272197#comment-15272197
]
ASF GitHub Bot commented on FLINK-3857:
---
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/1962#discussion_r62173042
--- Diff:
flink-streaming-connectors/flink-connector-elasticsearch2/src/main/java/org/apache/flink/streaming/connectors/elasticsearch2/ElasticsearchSink.java
--
[
https://issues.apache.org/jira/browse/FLINK-3857?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15272195#comment-15272195
]
ASF GitHub Bot commented on FLINK-3857:
---
Github user rmetzger commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-3857?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15272192#comment-15272192
]
ASF GitHub Bot commented on FLINK-3857:
---
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/1962#discussion_r62172954
--- Diff:
flink-streaming-connectors/flink-connector-elasticsearch2/src/main/java/org/apache/flink/streaming/connectors/elasticsearch2/ElasticsearchSink.java
--
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/1962#discussion_r62172911
--- Diff:
flink-streaming-connectors/flink-connector-elasticsearch2/src/main/java/org/apache/flink/streaming/connectors/elasticsearch2/ElasticsearchSink.java
--
[
https://issues.apache.org/jira/browse/FLINK-3857?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15272191#comment-15272191
]
ASF GitHub Bot commented on FLINK-3857:
---
Github user rmetzger commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-3857?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15272189#comment-15272189
]
ASF GitHub Bot commented on FLINK-3857:
---
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/1962#discussion_r62172611
--- Diff:
flink-streaming-connectors/flink-connector-elasticsearch2/src/main/java/org/apache/flink/streaming/connectors/elasticsearch2/ElasticsearchSink.java
--
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/1962#discussion_r62172571
--- Diff:
flink-streaming-connectors/flink-connector-elasticsearch2/src/main/java/org/apache/flink/streaming/connectors/elasticsearch2/ElasticsearchSink.java
--
[
https://issues.apache.org/jira/browse/FLINK-2926?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15272129#comment-15272129
]
Martin Liesenberg commented on FLINK-2926:
--
Is that because there is the assumpti
[
https://issues.apache.org/jira/browse/FLINK-2926?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15272119#comment-15272119
]
Martin Liesenberg commented on FLINK-2926:
--
hey [~vkalavri],
still learning about
[
https://issues.apache.org/jira/browse/FLINK-1719?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15272024#comment-15272024
]
ASF GitHub Bot commented on FLINK-1719:
---
Github user JonathanH5 commented on the pul
Github user JonathanH5 commented on the pull request:
https://github.com/apache/flink/pull/1156#issuecomment-217094415
Not since three months ago. I still wait for your review.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as we
[
https://issues.apache.org/jira/browse/FLINK-1719?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15272018#comment-15272018
]
ASF GitHub Bot commented on FLINK-1719:
---
Github user chobeat commented on the pull r
Github user chobeat commented on the pull request:
https://github.com/apache/flink/pull/1156#issuecomment-217093665
any news?
---
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
enab
62 matches
Mail list logo
