[GitHub] flink pull request #5588: [FLINK-8750][runtime] Improve detection of no rema...

2018-02-27 Thread pnowojski
GitHub user pnowojski opened a pull request: https://github.com/apache/flink/pull/5588 [FLINK-8750][runtime] Improve detection of no remaining data after EndOfPartitionEvent Because of race condition between: 1. releasing inputChannelsWithData lock in this method and reaching

[jira] [Commented] (FLINK-8770) CompletedCheckPoints stored on ZooKeeper is not up-to-date, when JobManager is restarted it fails to recover the job due to "checkpoint FileNotFound exception"

2018-02-27 Thread Xinyang Gao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8770?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16378299#comment-16378299 ] Xinyang Gao commented on FLINK-8770: For more information, I have rerun the test and s

[jira] [Created] (FLINK-8793) Only key with password are hidden in Flink web interface

2018-02-27 Thread Etienne CARRIERE (JIRA)
Etienne CARRIERE created FLINK-8793: --- Summary: Only key with password are hidden in Flink web interface Key: FLINK-8793 URL: https://issues.apache.org/jira/browse/FLINK-8793 Project: Flink

[jira] [Updated] (FLINK-8793) Hide key containing "secret" in web interface

2018-02-27 Thread Etienne CARRIERE (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8793?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Etienne CARRIERE updated FLINK-8793: Summary: Hide key containing "secret" in web interface (was: Only key with password are hid

[jira] [Commented] (FLINK-8336) YarnFileStageTestS3ITCase.testRecursiveUploadForYarnS3 test instability

2018-02-27 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8336?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16378284#comment-16378284 ] Nico Kruber commented on FLINK-8336: Another instance: https://api.travis-ci.org/v3/jo

[jira] [Commented] (FLINK-8408) YarnFileStageTestS3ITCase.testRecursiveUploadForYarnS3n unstable on Travis

2018-02-27 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8408?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16378282#comment-16378282 ] Nico Kruber commented on FLINK-8408: Unfortunately, we cannot retrieve the full logs f

[jira] [Commented] (FLINK-8719) add README for flink-contrib to clarify its purpose

2018-02-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8719?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16378273#comment-16378273 ] ASF GitHub Bot commented on FLINK-8719: --- Github user asfgit closed the pull request

[jira] [Closed] (FLINK-8719) add README for flink-contrib to clarify its purpose

2018-02-27 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8719?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-8719. --- Resolution: Fixed master: cf7d6024248555877b8b0463bdd0fdba7ed69365 > add README for flink-con

[GitHub] flink pull request #5537: [FLINK-8719] add README for flink-contrib to clari...

2018-02-27 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5537 ---

[jira] [Commented] (FLINK-8778) Migrate queryable state ITCases to use MiniClusterResource

2018-02-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8778?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16378267#comment-16378267 ] ASF GitHub Bot commented on FLINK-8778: --- Github user aljoscha commented on the issue

[GitHub] flink issue #5579: [FLINK-8778] Migrate queryable state ITCases to use MiniC...

2018-02-27 Thread aljoscha
Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/5579 @zentol I pushed some changes, still doesn't work for FLIP-6. @GJL and/or @tillrohrmann I would appreciate if you could have a look at this. 😃 ---

[jira] [Commented] (FLINK-8778) Migrate queryable state ITCases to use MiniClusterResource

2018-02-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8778?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16378266#comment-16378266 ] ASF GitHub Bot commented on FLINK-8778: --- Github user zentol commented on a diff in t

[GitHub] flink pull request #5579: [FLINK-8778] Migrate queryable state ITCases to us...

2018-02-27 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/5579#discussion_r170854988 --- Diff: flink-queryable-state/flink-queryable-state-runtime/src/test/java/org/apache/flink/queryablestate/itcases/AbstractQueryableStateTestBase.java --- @

[jira] [Commented] (FLINK-7428) avoid one additional buffer copy when receiving messages

2018-02-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7428?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16378264#comment-16378264 ] ASF GitHub Bot commented on FLINK-7428: --- Github user NicoK commented on the issue:

[jira] [Commented] (FLINK-8778) Migrate queryable state ITCases to use MiniClusterResource

2018-02-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8778?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16378263#comment-16378263 ] ASF GitHub Bot commented on FLINK-8778: --- Github user aljoscha commented on a diff in

[GitHub] flink issue #4529: [FLINK-7428][network] avoid buffer copies when receiving ...

2018-02-27 Thread NicoK
Github user NicoK commented on the issue: https://github.com/apache/flink/pull/4529 @zhijiangW looks like we're not upgrading the netty version in Flink 1.5 at this stage due to the timing, i.e. too quite late in the development cycle. We will do the upgrade after releasing Flink 1.5

[GitHub] flink pull request #5579: [FLINK-8778] Migrate queryable state ITCases to us...

2018-02-27 Thread aljoscha
Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/5579#discussion_r170854288 --- Diff: flink-queryable-state/flink-queryable-state-runtime/src/test/java/org/apache/flink/queryablestate/itcases/AbstractQueryableStateTestBase.java ---

[jira] [Commented] (FLINK-8787) Deploying FLIP-6 YARN session with HA fails

2018-02-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8787?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16378232#comment-16378232 ] ASF GitHub Bot commented on FLINK-8787: --- Github user GJL commented on the issue:

[GitHub] flink issue #5584: [FLINK-8787][flip6] WIP Deploying FLIP-6 YARN session wit...

2018-02-27 Thread GJL
Github user GJL commented on the issue: https://github.com/apache/flink/pull/5584 @tillrohrmann Because I am creating a defensive copy of the configuration. Changing the config outside of the AbstractYarnClusterDescriptor won't have side effects. I will rewrite the test. ---

[jira] [Commented] (FLINK-8787) Deploying FLIP-6 YARN session with HA fails

2018-02-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8787?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16378224#comment-16378224 ] ASF GitHub Bot commented on FLINK-8787: --- Github user tillrohrmann commented on the i

[jira] [Commented] (FLINK-8734) SpillableSubpartition does not update byte statistics when spilled by a SpillableSubpartitionView

2018-02-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8734?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16378218#comment-16378218 ] ASF GitHub Bot commented on FLINK-8734: --- Github user asfgit closed the pull request

[jira] [Commented] (FLINK-8733) SpillableSubpartition#spillFinishedBufferConsumers() does not count spilled bytes anymore

2018-02-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8733?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16378217#comment-16378217 ] ASF GitHub Bot commented on FLINK-8733: --- Github user asfgit closed the pull request

[GitHub] flink issue #5584: [FLINK-8787][flip6] WIP Deploying FLIP-6 YARN session wit...

2018-02-27 Thread tillrohrmann
Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/5584 Why are the tests failing due to this @GJL? ---

[jira] [Commented] (FLINK-8736) Memory segment offsets for slices of slices are wrong

2018-02-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8736?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16378219#comment-16378219 ] ASF GitHub Bot commented on FLINK-8736: --- Github user asfgit closed the pull request

[jira] [Resolved] (FLINK-8736) Memory segment offsets for slices of slices are wrong

2018-02-27 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8736?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-8736. -- Resolution: Fixed Fixed via 9fb1c23aaead71bd7e81a6a73be1b4206dac405f > Memory segment offsets f

[jira] [Resolved] (FLINK-8733) SpillableSubpartition#spillFinishedBufferConsumers() does not count spilled bytes anymore

2018-02-27 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8733?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-8733. -- Resolution: Fixed Fixed via 4bf76ae69e3f22e25c2dad3e802be094554b5d43 > SpillableSubpartition#sp

[GitHub] flink pull request #5551: [FLINK-8736][network] fix memory segment offsets f...

2018-02-27 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5551 ---

[GitHub] flink pull request #5549: [FLINK-8733][network] fix SpillableSubpartition#sp...

2018-02-27 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5549 ---

[GitHub] flink pull request #5550: [FLINK-8734][network] fix partition bytes counting...

2018-02-27 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5550 ---

[jira] [Resolved] (FLINK-8734) SpillableSubpartition does not update byte statistics when spilled by a SpillableSubpartitionView

2018-02-27 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8734?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-8734. -- Resolution: Fixed Fixed via f9daf9cc4243a80b38a1f81bf2b9b37565fe2d61 > SpillableSubpartition do

[jira] [Commented] (FLINK-8543) Output Stream closed at org.apache.hadoop.fs.s3a.S3AOutputStream.checkOpen

2018-02-27 Thread chris snow (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8543?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16378211#comment-16378211 ] chris snow commented on FLINK-8543: --- Thanks for fixing this [~aljoscha]! {quote}The comm

<    1   2   3   4