[
https://issues.apache.org/jira/browse/FLINK-6341?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15980686#comment-15980686
]
ASF GitHub Bot commented on FLINK-6341:
---
Github user WangTaoTheTonic commented on th
Github user WangTaoTheTonic commented on the issue:
https://github.com/apache/flink/pull/3745
@tillrohrmann What problem it will bring if we access
`currentResourceManager` from another thread? It is a variable in JobManager
and can be shared across multi threads, right? The new added
[
https://issues.apache.org/jira/browse/FLINK-6352?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fang Yong reassigned FLINK-6352:
Assignee: Fang Yong
> FlinkKafkaConsumer should support to use timestamp to set up start offset
> -
[
https://issues.apache.org/jira/browse/FLINK-5855?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
mingleizhang reassigned FLINK-5855:
---
Assignee: mingleizhang
> Unprotected access to pendingFilesPerCheckpoint in BucketingSink
> -
[
https://issues.apache.org/jira/browse/FLINK-5855?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15980672#comment-15980672
]
ASF GitHub Bot commented on FLINK-5855:
---
GitHub user zhangminglei opened a pull requ
[
https://issues.apache.org/jira/browse/FLINK-5855?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15980673#comment-15980673
]
ASF GitHub Bot commented on FLINK-5855:
---
Github user zhangminglei commented on the i
GitHub user zhangminglei opened a pull request:
https://github.com/apache/flink/pull/3758
[FLINK-5855][Streaming Connectors] Unprotected access to pendingFilesâ¦
â¦PerCheckpoint in BucketingSink.
Thanks for contributing to Apache Flink. Before you open your pull request,
Github user zhangminglei commented on the issue:
https://github.com/apache/flink/pull/3758
cc @tillrohrmann
---
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
[
https://issues.apache.org/jira/browse/FLINK-5855?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15980671#comment-15980671
]
mingleizhang commented on FLINK-5855:
-
Okay, thanks. I will give a PR to this. I dont
[
https://issues.apache.org/jira/browse/FLINK-5855?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15980669#comment-15980669
]
Ted Yu commented on FLINK-5855:
---
lgtm
> Unprotected access to pendingFilesPerCheckpoint in
[
https://issues.apache.org/jira/browse/FLINK-5855?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15980668#comment-15980668
]
mingleizhang commented on FLINK-5855:
-
I think the code snippet would follow your sugg
[
https://issues.apache.org/jira/browse/FLINK-5855?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
mingleizhang updated FLINK-5855:
Comment: was deleted
(was: Yep. That is right. So, follow your suggestion. I would write the code
s
[
https://issues.apache.org/jira/browse/FLINK-5855?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15980664#comment-15980664
]
mingleizhang edited comment on FLINK-5855 at 4/24/17 2:57 AM:
--
[
https://issues.apache.org/jira/browse/FLINK-5855?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15980664#comment-15980664
]
mingleizhang edited comment on FLINK-5855 at 4/24/17 2:57 AM:
--
[
https://issues.apache.org/jira/browse/FLINK-5855?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15980664#comment-15980664
]
mingleizhang commented on FLINK-5855:
-
@Ted Yu, Yep. That is right. So, follow your su
[
https://issues.apache.org/jira/browse/FLINK-6295?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tao Wang updated FLINK-6295:
Summary: Update suspended ExecutionGraph to lower latency (was: use
LoadingCache instead of WeakHashMap to
[
https://issues.apache.org/jira/browse/FLINK-6295?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15980657#comment-15980657
]
ASF GitHub Bot commented on FLINK-6295:
---
Github user WangTaoTheTonic commented on th
Github user WangTaoTheTonic commented on the issue:
https://github.com/apache/flink/pull/3709
I've testet and the function is ok. Please check if it's good to go, 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
[
https://issues.apache.org/jira/browse/FLINK-5855?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15980646#comment-15980646
]
Ted Yu commented on FLINK-5855:
---
Didn't get your question: clear() is called after
handlePe
[
https://issues.apache.org/jira/browse/FLINK-6288?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15980636#comment-15980636
]
Fang Yong edited comment on FLINK-6288 at 4/24/17 2:18 AM:
---
[
https://issues.apache.org/jira/browse/FLINK-6288?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15980636#comment-15980636
]
Fang Yong commented on FLINK-6288:
--
Thanks for providing the mailing list for this issue,
[
https://issues.apache.org/jira/browse/FLINK-5855?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15980624#comment-15980624
]
mingleizhang edited comment on FLINK-5855 at 4/24/17 1:50 AM:
--
[
https://issues.apache.org/jira/browse/FLINK-5855?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15980624#comment-15980624
]
mingleizhang commented on FLINK-5855:
-
[~tedyu] Hi, Ted. I would ask if {code}pendingF
[
https://issues.apache.org/jira/browse/FLINK-6228?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15980607#comment-15980607
]
ASF GitHub Bot commented on FLINK-6228:
---
Github user sunjincheng121 commented on the
Github user sunjincheng121 commented on the issue:
https://github.com/apache/flink/pull/3743
@fhueske Thanks a lot for your comments and suggestions. And I like the
idea of move all validations into `validateInput` method. I have updated the PR
with following changes:
1.Check that
GitHub user rbonifacio opened a pull request:
https://github.com/apache/flink/pull/3757
(refactor) some opportunities to use multi-catch
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/rbonifacio/flink refactor-multi-catch
Alter
[
https://issues.apache.org/jira/browse/FLINK-6365?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Steffen Hausmann updated FLINK-6365:
Description:
As discussed in
http://apache-flink-user-mailing-list-archive.2336050.n4.nabbl
Steffen Hausmann created FLINK-6365:
---
Summary: Adapt default values of the Kinesis connector
Key: FLINK-6365
URL: https://issues.apache.org/jira/browse/FLINK-6365
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-5781?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15980505#comment-15980505
]
ASF GitHub Bot commented on FLINK-5781:
---
Github user zentol commented on the issue:
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/3495
I'm also not sure about including the short description. Looking at the
existing documentation descriptions this would result in pretty large table
entries with a lot of whitespace in the short descri
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/3495
This is working pretty nicely. Just tried out appending the generated table
to the SSL documentation, here's the result:
 Tai updated FLINK-6363:
---
Description:
Currently, there is no documentation / Javadoc mentioning the precedence
[
https://issues.apache.org/jira/browse/FLINK-6363?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai updated FLINK-6363:
---
Description:
Currently, there is no documentation / Javadoc mentioning the precedence
[
https://issues.apache.org/jira/browse/FLINK-6363?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai updated FLINK-6363:
---
Description:
Currently, there is no documentation / Javadoc mentioning the precedence
Tzu-Li (Gordon) Tai created FLINK-6363:
--
Summary: Document precedence rules of Kryo serializer registrations
Key: FLINK-6363
URL: https://issues.apache.org/jira/browse/FLINK-6363
Project: Flink
43 matches
Mail list logo
