[jira] [Created] (FLINK-9120) Task Manager Fault Tolerance issue

dhiraj prajapati created FLINK-9120: --- Summary: Task Manager Fault Tolerance issue Key: FLINK-9120 URL: https://issues.apache.org/jira/browse/FLINK-9120 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-7775) Remove unreferenced method PermanentBlobCache#getNumberOfCachedJobs

[ https://issues.apache.org/jira/browse/FLINK-7775?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16421917#comment-16421917 ] ASF GitHub Bot commented on FLINK-7775: --- GitHub user yanghua opened a pull request:

[GitHub] flink pull request #5799: [FLINK-7775] Remove unreferenced method PermanentB...

GitHub user yanghua opened a pull request: https://github.com/apache/flink/pull/5799 [FLINK-7775] Remove unreferenced method PermanentBlobCache#getNumberOfCachedJobs ## What is the purpose of the change *This pull request remove unreferenced method PermanentBlobCache#getNu

[jira] [Commented] (FLINK-9056) Job submission fails with AskTimeoutException if not enough slots are available

[ https://issues.apache.org/jira/browse/FLINK-9056?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16421915#comment-16421915 ] mingleizhang commented on FLINK-9056: - Hi, [~yuqi] Could you please give the full stac

[jira] [Commented] (FLINK-9056) Job submission fails with AskTimeoutException if not enough slots are available

[ https://issues.apache.org/jira/browse/FLINK-9056?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16421887#comment-16421887 ] yuqi commented on FLINK-9056: - [~mingleizhang] You are right, Problem described by can't repro

[jira] [Assigned] (FLINK-8837) Move DataStreamUtils to package 'experimental'.

[ https://issues.apache.org/jira/browse/FLINK-8837?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li reassigned FLINK-8837: --- Assignee: Bowen Li > Move DataStreamUtils to package 'experimental'. > --

[jira] [Commented] (FLINK-9087) Return value of broadcastEvent should be closed in StreamTask#performCheckpoint

[ https://issues.apache.org/jira/browse/FLINK-9087?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16421810#comment-16421810 ] Ted Yu commented on FLINK-9087: --- When you send a pull request for this issue, some committer

[jira] [Issue Comment Deleted] (FLINK-7554) Add a testing RuntimeContext to test utilities

[ https://issues.apache.org/jira/browse/FLINK-7554?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiayi updated FLINK-7554: - Comment: was deleted (was: [~twalthr]  I think I should let you know my idea about this issue before finishing th

[jira] [Commented] (FLINK-9056) Job submission fails with AskTimeoutException if not enough slots are available

[ https://issues.apache.org/jira/browse/FLINK-9056?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16421687#comment-16421687 ] Triones Deng commented on FLINK-9056: - [~fhueske] when Job parallelism exceeds availab

[jira] [Commented] (FLINK-9056) Job submission fails with AskTimeoutException if not enough slots are available

[ https://issues.apache.org/jira/browse/FLINK-9056?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16421685#comment-16421685 ] mingleizhang commented on FLINK-9056: - Hi, [~yuqi] I think this test done with master

[jira] [Commented] (FLINK-9087) Return value of broadcastEvent should be closed in StreamTask#performCheckpoint

[ https://issues.apache.org/jira/browse/FLINK-9087?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16421679#comment-16421679 ] Triones Deng commented on FLINK-9087: - Does anyone can give me a permission to contrib

[jira] [Commented] (FLINK-9087) Return value of broadcastEvent should be closed in StreamTask#performCheckpoint

[ https://issues.apache.org/jira/browse/FLINK-9087?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16421678#comment-16421678 ] mingleizhang commented on FLINK-9087: - Hi, [~triones] I have been working on another i

[jira] [Commented] (FLINK-9087) Return value of broadcastEvent should be closed in StreamTask#performCheckpoint

[ https://issues.apache.org/jira/browse/FLINK-9087?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16421677#comment-16421677 ] Triones Deng commented on FLINK-9087: - [~mingleizhang] are you still working on this?

[jira] [Assigned] (FLINK-8914) CEP's greedy() modifier doesn't work

[ https://issues.apache.org/jira/browse/FLINK-8914?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] aitozi reassigned FLINK-8914: - Assignee: aitozi > CEP's greedy() modifier doesn't work > > >

[jira] [Comment Edited] (FLINK-7554) Add a testing RuntimeContext to test utilities

[ https://issues.apache.org/jira/browse/FLINK-7554?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16417779#comment-16417779 ] Jiayi edited comment on FLINK-7554 at 4/1/18 1:09 PM: -- [~twalthr]  I

[jira] [Commented] (FLINK-8914) CEP's greedy() modifier doesn't work

[ https://issues.apache.org/jira/browse/FLINK-8914?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16421652#comment-16421652 ] aitozi commented on FLINK-8914: --- I am woking with issue, can i take over this issue? > CEP'

[jira] [Commented] (FLINK-8993) Add a test operator with keyed state that uses Kryo serializer (registered/unregistered/custom)

[ https://issues.apache.org/jira/browse/FLINK-8993?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16421633#comment-16421633 ] mingleizhang commented on FLINK-8993: - Hi, [~srichter] I would ask, have you been plan

[jira] [Commented] (FLINK-7917) The return of taskInformationOrBlobKey should be placed inside synchronized in ExecutionJobVertex

[ https://issues.apache.org/jira/browse/FLINK-7917?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16421611#comment-16421611 ] ASF GitHub Bot commented on FLINK-7917: --- GitHub user yanghua opened a pull request:

[GitHub] flink pull request #5798: [FLINK-7917] The return of taskInformationOrBlobKe...

GitHub user yanghua opened a pull request: https://github.com/apache/flink/pull/5798 [FLINK-7917] The return of taskInformationOrBlobKey should be placed inside synchronized in ExecutionJobVertex ## What is the purpose of the change *This pull request placed the taskInform