[jira] [Updated] (FLINK-5879) ExecutionAttemptID should invoke super() in constructor

2017-02-22 Thread Biao Liu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5879?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Biao Liu updated FLINK-5879: Component/s: Core > ExecutionAttemptID should invoke super() in constructor >

[jira] [Created] (FLINK-5879) ExecutionAttemptID should invoke super() in constructor

2017-02-22 Thread Biao Liu (JIRA)
Biao Liu created FLINK-5879: --- Summary: ExecutionAttemptID should invoke super() in constructor Key: FLINK-5879 URL: https://issues.apache.org/jira/browse/FLINK-5879 Project: Flink Issue Type: Bug

[jira] [Assigned] (FLINK-5836) Race condition between slot offering and task deployment

2017-02-18 Thread Biao Liu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5836?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Biao Liu reassigned FLINK-5836: --- Assignee: Biao Liu > Race condition between slot offering and task deployment >

[jira] [Commented] (FLINK-5836) Race condition between slot offering and task deployment

2017-02-18 Thread Biao Liu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5836?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15873399#comment-15873399 ] Biao Liu commented on FLINK-5836: - +1 > Race condition between slot offering and task deployment >

[jira] [Comment Edited] (FLINK-5836) Race condition between slot offering and task deployment

2017-02-20 Thread Biao Liu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5836?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15875234#comment-15875234 ] Biao Liu edited comment on FLINK-5836 at 2/21/17 2:26 AM: -- [~wenlong.lwl] has

[jira] [Assigned] (FLINK-5836) Race condition between slot offering and task deployment

2017-02-20 Thread Biao Liu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5836?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Biao Liu reassigned FLINK-5836: --- Assignee: Wenlong Lyu (was: Biao Liu) > Race condition between slot offering and task deployment >

[jira] [Commented] (FLINK-5836) Race condition between slot offering and task deployment

2017-02-20 Thread Biao Liu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5836?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15875234#comment-15875234 ] Biao Liu commented on FLINK-5836: - [~wenlong.lwl] was already working on this, reassign to him. > Race

[jira] [Closed] (FLINK-5879) ExecutionAttemptID should invoke super() in constructor

2017-02-23 Thread Biao Liu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5879?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Biao Liu closed FLINK-5879. --- Resolution: Invalid It is no problem, that's my fault. Close it. > ExecutionAttemptID should invoke super()

[jira] [Created] (FLINK-5862) When JobManager fails, TaskManagers do not cancel tasks, but attempt to reconnect to the JobManager, and report states of tasks deployed in

2017-02-21 Thread Biao Liu (JIRA)
Biao Liu created FLINK-5862: --- Summary: When JobManager fails, TaskManagers do not cancel tasks, but attempt to reconnect to the JobManager, and report states of tasks deployed in Key: FLINK-5862 URL:

[jira] [Created] (FLINK-5861) TaskManager's components support updating JobManagerGateway

2017-02-20 Thread Biao Liu (JIRA)
Biao Liu created FLINK-5861: --- Summary: TaskManager's components support updating JobManagerGateway Key: FLINK-5861 URL: https://issues.apache.org/jira/browse/FLINK-5861 Project: Flink Issue Type:

[jira] [Updated] (FLINK-5861) TaskManager's components support updating JobManagerConnection

2017-02-20 Thread Biao Liu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5861?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Biao Liu updated FLINK-5861: Summary: TaskManager's components support updating JobManagerConnection (was: TaskManager's components

[jira] [Updated] (FLINK-5861) TaskManager's components support updating JobManagerConnection

2017-02-20 Thread Biao Liu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5861?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Biao Liu updated FLINK-5861: Description: Some components in TaskManager, such as TaskManagerActions, CheckpointResponder,

[jira] [Resolved] (FLINK-5141) Implement Flip6LocalStreamEnvironment to run new mini cluster in flip-6 branch

2017-02-14 Thread Biao Liu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5141?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Biao Liu resolved FLINK-5141. - Resolution: Fixed > Implement Flip6LocalStreamEnvironment to run new mini cluster in flip-6 branch >

[jira] [Created] (FLINK-5784) TaskExecutor may register JobManagerLeaderListener in LeaderRetrievalService multiple times

2017-02-13 Thread Biao Liu (JIRA)
Biao Liu created FLINK-5784: --- Summary: TaskExecutor may register JobManagerLeaderListener in LeaderRetrievalService multiple times Key: FLINK-5784 URL: https://issues.apache.org/jira/browse/FLINK-5784

[jira] [Updated] (FLINK-5861) TaskManager's components support updating JobManagerConnection

2017-02-26 Thread Biao Liu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5861?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Biao Liu updated FLINK-5861: Fix Version/s: 1.3.0 > TaskManager's components support updating JobManagerConnection >

[jira] [Created] (FLINK-5140) NoResourceAvailableException is thrown while starting a new job

2016-11-22 Thread Biao Liu (JIRA)
Biao Liu created FLINK-5140: --- Summary: NoResourceAvailableException is thrown while starting a new job Key: FLINK-5140 URL: https://issues.apache.org/jira/browse/FLINK-5140 Project: Flink Issue

[jira] [Created] (FLINK-5141) Implement MiniClusterStreamEnvironment to run new mini cluster in flip-6 branch

2016-11-23 Thread Biao Liu (JIRA)
Biao Liu created FLINK-5141: --- Summary: Implement MiniClusterStreamEnvironment to run new mini cluster in flip-6 branch Key: FLINK-5141 URL: https://issues.apache.org/jira/browse/FLINK-5141 Project: Flink

[jira] [Updated] (FLINK-5141) Implement Flip6LocalStreamEnvironment to run new mini cluster in flip-6 branch

2016-11-27 Thread Biao Liu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5141?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Biao Liu updated FLINK-5141: Summary: Implement Flip6LocalStreamEnvironment to run new mini cluster in flip-6 branch (was: Implement

[jira] [Created] (FLINK-5076) Shutting down TM when shutting down new mini cluster

2016-11-15 Thread Biao Liu (JIRA)
Biao Liu created FLINK-5076: --- Summary: Shutting down TM when shutting down new mini cluster Key: FLINK-5076 URL: https://issues.apache.org/jira/browse/FLINK-5076 Project: Flink Issue Type:

[jira] [Assigned] (FLINK-5076) Shutting down TM when shutting down new mini cluster

2016-11-18 Thread Biao Liu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5076?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Biao Liu reassigned FLINK-5076: --- Assignee: Biao Liu > Shutting down TM when shutting down new mini cluster >

[jira] [Updated] (FLINK-5093) java.util.ConcurrentModificationException is thrown when stopping TimerService

2016-11-18 Thread Biao Liu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5093?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Biao Liu updated FLINK-5093: Description: In stop method of TimerService, removing Timeout instance while iterating the map will cause

[jira] [Created] (FLINK-5093) java.util.ConcurrentModificationException is thrown when stopping TimerService

2016-11-18 Thread Biao Liu (JIRA)
Biao Liu created FLINK-5093: --- Summary: java.util.ConcurrentModificationException is thrown when stopping TimerService Key: FLINK-5093 URL: https://issues.apache.org/jira/browse/FLINK-5093 Project: Flink

[jira] [Updated] (FLINK-5076) Shutting down TM when shutting down new mini cluster

2016-11-18 Thread Biao Liu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5076?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Biao Liu updated FLINK-5076: Issue Type: Bug (was: Improvement) > Shutting down TM when shutting down new mini cluster >

[jira] [Updated] (FLINK-5093) java.util.ConcurrentModificationException is thrown when stopping TimerService

2016-11-18 Thread Biao Liu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5093?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Biao Liu updated FLINK-5093: Description: In stop method of TimerService, removing Timeout instance while iterating the map will cause

[jira] [Resolved] (FLINK-5980) Expose max-parallelism value in RuntimeContext

2017-03-10 Thread Biao Liu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5980?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Biao Liu resolved FLINK-5980. - Resolution: Fixed > Expose max-parallelism value in RuntimeContext >

[jira] [Created] (FLINK-5980) Expose max-parallelism value in RuntimeContext

2017-03-07 Thread Biao Liu (JIRA)
Biao Liu created FLINK-5980: --- Summary: Expose max-parallelism value in RuntimeContext Key: FLINK-5980 URL: https://issues.apache.org/jira/browse/FLINK-5980 Project: Flink Issue Type: Improvement

[jira] [Assigned] (FLINK-6397) MultipleProgramsTestBase does not reset ContextEnvironment

2017-04-27 Thread Biao Liu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6397?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Biao Liu reassigned FLINK-6397: --- Assignee: Biao Liu > MultipleProgramsTestBase does not reset ContextEnvironment >

[jira] [Commented] (FLINK-6397) MultipleProgramsTestBase does not reset ContextEnvironment

2017-04-27 Thread Biao Liu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6397?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15988079#comment-15988079 ] Biao Liu commented on FLINK-6397: - I would like to fix this problem. But I didn't find the

[jira] [Assigned] (FLINK-7871) SlotPool should release its unused slot to RM

2017-11-16 Thread Biao Liu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7871?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Biao Liu reassigned FLINK-7871: --- Assignee: Biao Liu (was: shuai.xu) > SlotPool should release its unused slot to RM >

[jira] [Updated] (FLINK-9315) TaskManagerRunner.shutDown() would stuck in waiting rpc service terminated

2018-05-07 Thread Biao Liu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Biao Liu updated FLINK-9315: Description: Currently shutdown TaskManagerRunner would stuck > TaskManagerRunner.shutDown() would stuck in

[jira] [Updated] (FLINK-9315) TaskManagerRunner.shutDown() may be stuck in waiting rpc service terminated

2018-05-07 Thread Biao Liu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Biao Liu updated FLINK-9315: Summary: TaskManagerRunner.shutDown() may be stuck in waiting rpc service terminated (was:

[jira] [Updated] (FLINK-9315) TaskManagerRunner.shutDown() would be stuck in waiting rpc service terminated

2018-05-07 Thread Biao Liu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Biao Liu updated FLINK-9315: Summary: TaskManagerRunner.shutDown() would be stuck in waiting rpc service terminated (was:

[jira] [Updated] (FLINK-9315) TaskManagerRunner.shutDown() would be stuck in waiting rpc service terminated

2018-05-07 Thread Biao Liu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Biao Liu updated FLINK-9315: Description: Currently shutdown TaskManagerRunner may be stuck. Because  (was: Currently shutdown

[jira] [Created] (FLINK-9315) TaskManagerRunner.shutDown() would stuck in waiting rpc service terminated

2018-05-07 Thread Biao Liu (JIRA)
Biao Liu created FLINK-9315: --- Summary: TaskManagerRunner.shutDown() would stuck in waiting rpc service terminated Key: FLINK-9315 URL: https://issues.apache.org/jira/browse/FLINK-9315 Project: Flink

[jira] [Updated] (FLINK-9315) TaskManagerRunner.shutDown() may be stuck in waiting rpc service terminated

2018-05-07 Thread Biao Liu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Biao Liu updated FLINK-9315: Description: Currently the TaskManagerRunner would be waiting for rpc service terminated synchronously. If

[jira] [Assigned] (FLINK-8368) Port SubtaskExecutionAttemptDetailsHandler to new REST endpoint

2018-01-07 Thread Biao Liu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8368?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Biao Liu reassigned FLINK-8368: --- Assignee: Biao Liu > Port SubtaskExecutionAttemptDetailsHandler to new REST endpoint >

[jira] [Assigned] (FLINK-8367) Port SubtaskCurrentAttemptDetailsHandler to new REST endpoint

2018-01-07 Thread Biao Liu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8367?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Biao Liu reassigned FLINK-8367: --- Assignee: Biao Liu > Port SubtaskCurrentAttemptDetailsHandler to new REST endpoint >

[jira] [Created] (FLINK-8368) Port SubtaskExecutionAttemptDetailsHandler to new REST endpoint

2018-01-05 Thread Biao Liu (JIRA)
Biao Liu created FLINK-8368: --- Summary: Port SubtaskExecutionAttemptDetailsHandler to new REST endpoint Key: FLINK-8368 URL: https://issues.apache.org/jira/browse/FLINK-8368 Project: Flink Issue

[jira] [Created] (FLINK-8369) Port SubtaskExecutionAttemptAccumulatorsHandler to new REST endpoint

2018-01-05 Thread Biao Liu (JIRA)
Biao Liu created FLINK-8369: --- Summary: Port SubtaskExecutionAttemptAccumulatorsHandler to new REST endpoint Key: FLINK-8369 URL: https://issues.apache.org/jira/browse/FLINK-8369 Project: Flink

[jira] [Created] (FLINK-8367) Port SubtaskCurrentAttemptDetailsHandler to new REST endpoint

2018-01-05 Thread Biao Liu (JIRA)
Biao Liu created FLINK-8367: --- Summary: Port SubtaskCurrentAttemptDetailsHandler to new REST endpoint Key: FLINK-8367 URL: https://issues.apache.org/jira/browse/FLINK-8367 Project: Flink Issue

[jira] [Assigned] (FLINK-8369) Port SubtaskExecutionAttemptAccumulatorsHandler to new REST endpoint

2018-01-08 Thread Biao Liu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8369?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Biao Liu reassigned FLINK-8369: --- Assignee: Biao Liu > Port SubtaskExecutionAttemptAccumulatorsHandler to new REST endpoint >

[jira] [Closed] (FLINK-9315) TaskManagerRunner.shutDown() may be stuck in waiting rpc service terminated

2018-09-10 Thread Biao Liu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Biao Liu closed FLINK-9315. --- Resolution: Fixed This issue has already been fixed in a hotfix patch by Till Will close it. >

[jira] [Closed] (FLINK-5862) When JobManager fails, TaskManagers do not cancel tasks, but attempt to reconnect to the JobManager, and report states of tasks deployed in

2018-09-10 Thread Biao Liu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5862?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Biao Liu closed FLINK-5862. --- Resolution: Won't Fix This is an out of date issue, close it. > When JobManager fails, TaskManagers do not

[jira] [Closed] (FLINK-5861) TaskManager's components support updating JobManagerConnection

2018-09-10 Thread Biao Liu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5861?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Biao Liu closed FLINK-5861. --- Resolution: Won't Fix This proposal is not a good way to solve the probleom, close it. > TaskManager's

[jira] [Closed] (FLINK-5784) TaskExecutor may register JobManagerLeaderListener in LeaderRetrievalService multiple times

2018-09-11 Thread Biao Liu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5784?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Biao Liu closed FLINK-5784. --- Resolution: Won't Fix This bug is already fixed by Till in a different way, abandon this > TaskExecutor may

[jira] [Commented] (FLINK-10621) BootstrapToolsTest.testConcurrentActorSystemCreation hangs forever when running locally

2018-10-24 Thread Biao Liu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10621?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16663146#comment-16663146 ] Biao Liu commented on FLINK-10621: -- Thank you for reporting. [~alexeyt820] It's an unstable case. Would

[jira] [Assigned] (FLINK-10621) BootstrapToolsTest.testConcurrentActorSystemCreation hangs forever when running locally

2018-10-24 Thread Biao Liu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10621?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Biao Liu reassigned FLINK-10621: Assignee: Biao Liu > BootstrapToolsTest.testConcurrentActorSystemCreation hangs forever when >

[jira] [Commented] (FLINK-10361) Elasticsearch (v6.3.1) sink end-to-end test instable

2018-11-08 Thread Biao Liu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10361?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16679175#comment-16679175 ] Biao Liu commented on FLINK-10361: -- Hi [~twalthr] Could you offer more details? The stdout/stderr of

[jira] [Commented] (FLINK-10634) End-to-end test: Metrics accessible via REST API

2018-11-07 Thread Biao Liu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16678125#comment-16678125 ] Biao Liu commented on FLINK-10634: -- [~Zentol]  Not yet. Please feel free to take it.  > End-to-end

[jira] [Assigned] (FLINK-10634) End-to-end test: Metrics accessible via REST API

2018-11-05 Thread Biao Liu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10634?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Biao Liu reassigned FLINK-10634: Assignee: Biao Liu > End-to-end test: Metrics accessible via REST API >

[jira] [Commented] (FLINK-9845) Make InternalTimerService's timer processing interruptible/abortable

2018-10-10 Thread Biao Liu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9845?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16644530#comment-16644530 ] Biao Liu commented on FLINK-9845: - [~till.rohrmann] This proposal sounds great. We have encountered the

[jira] [Assigned] (FLINK-9845) Make InternalTimerService's timer processing interruptible/abortable

2018-10-10 Thread Biao Liu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9845?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Biao Liu reassigned FLINK-9845: --- Assignee: Biao Liu > Make InternalTimerService's timer processing interruptible/abortable >

[jira] [Assigned] (FLINK-10361) Elasticsearch (v6.3.1) sink end-to-end test instable

2018-10-09 Thread Biao Liu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10361?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Biao Liu reassigned FLINK-10361: Assignee: Biao Liu > Elasticsearch (v6.3.1) sink end-to-end test instable >

[jira] [Commented] (FLINK-9788) ExecutionGraph Inconsistency prevents Job from recovering

2018-10-08 Thread Biao Liu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9788?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16642744#comment-16642744 ] Biao Liu commented on FLINK-9788: - After checking the log file, I believe this is a critical bug. If the

[jira] [Commented] (FLINK-10361) Elasticsearch (v6.3.1) sink end-to-end test instable

2018-10-09 Thread Biao Liu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10361?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16642969#comment-16642969 ] Biao Liu commented on FLINK-10361: -- Hi [~till.rohrmann] I have tested this end-to-end test case in my

[jira] [Commented] (FLINK-10361) Elasticsearch (v6.3.1) sink end-to-end test instable

2018-10-09 Thread Biao Liu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10361?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16643005#comment-16643005 ] Biao Liu commented on FLINK-10361: -- [~till.rohrmann] Of course, I'm working on this, will make a pull

[jira] [Commented] (FLINK-9788) ExecutionGraph Inconsistency prevents Job from recovering

2018-10-09 Thread Biao Liu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9788?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16642989#comment-16642989 ] Biao Liu commented on FLINK-9788: - +1 I think 'allowing the state transition RESTARTING --> FAILING'

[jira] [Commented] (FLINK-9845) Make InternalTimerService's timer processing interruptible/abortable

2018-10-11 Thread Biao Liu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9845?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16646336#comment-16646336 ] Biao Liu commented on FLINK-9845: - Hi [~till.rohrmann] After looking at the code related, I think there

[jira] [Updated] (FLINK-10344) Rethink SubmittedJobGraphListener

2018-09-21 Thread Biao Liu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10344?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Biao Liu updated FLINK-10344: - Attachment: (was: Tornado.pdf) > Rethink SubmittedJobGraphListener >

[jira] [Commented] (FLINK-10344) Rethink SubmittedJobGraphListener

2018-09-21 Thread Biao Liu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10344?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16623273#comment-16623273 ] Biao Liu commented on FLINK-10344: -- [~dangdangdang] Oh that's my fault. I was reading a paper. Dragged

[jira] [Updated] (FLINK-10344) Rethink SubmittedJobGraphListener

2018-09-21 Thread Biao Liu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10344?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Biao Liu updated FLINK-10344: - Attachment: (was: Tornado.pdf) > Rethink SubmittedJobGraphListener >

[jira] [Created] (FLINK-11137) Unexpected RegistrationTimeoutException of TaskExecutor

2018-12-11 Thread Biao Liu (JIRA)
Biao Liu created FLINK-11137: Summary: Unexpected RegistrationTimeoutException of TaskExecutor Key: FLINK-11137 URL: https://issues.apache.org/jira/browse/FLINK-11137 Project: Flink Issue Type:

[jira] [Commented] (FLINK-9920) BucketingSinkFaultToleranceITCase fails on travis

2018-12-17 Thread Biao Liu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9920?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16722935#comment-16722935 ] Biao Liu commented on FLINK-9920: - Another instance: [https://api.travis-ci.org/v3/job/466986082/log.txt]

[jira] [Created] (FLINK-11185) StreamSourceOperatorWatermarksTest failed with InterruptedException

2018-12-17 Thread Biao Liu (JIRA)
Biao Liu created FLINK-11185: Summary: StreamSourceOperatorWatermarksTest failed with InterruptedException Key: FLINK-11185 URL: https://issues.apache.org/jira/browse/FLINK-11185 Project: Flink

[jira] [Commented] (FLINK-11215) TaskExecutor RegistrationTimeoutException within the specified maximum registration duration 300000ms

2018-12-24 Thread Biao Liu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11215?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16728605#comment-16728605 ] Biao Liu commented on FLINK-11215: -- Hi Liu, it looks like another issue I opened a few days ago. See 

[jira] [Commented] (FLINK-10928) Job unable to stabilise after restart

2018-11-19 Thread Biao Liu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10928?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16692618#comment-16692618 ] Biao Liu commented on FLINK-10928: -- Hi [~djharper] 1. "Why does YARN kill the containers with out of

[jira] [Comment Edited] (FLINK-10928) Job unable to stabilise after restart

2018-11-19 Thread Biao Liu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10928?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16692618#comment-16692618 ] Biao Liu edited comment on FLINK-10928 at 11/20/18 4:08 AM: Hi [~djharper]

[jira] [Created] (FLINK-11312) The link to Zookeeper is broken in "jobmanager_high_availability" document

2019-01-13 Thread Biao Liu (JIRA)
Biao Liu created FLINK-11312: Summary: The link to Zookeeper is broken in "jobmanager_high_availability" document Key: FLINK-11312 URL: https://issues.apache.org/jira/browse/FLINK-11312 Project: Flink

[jira] [Updated] (FLINK-10312) Wrong / missing exception when submitting job

2018-09-18 Thread Biao Liu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10312?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Biao Liu updated FLINK-10312: - Attachment: lmerge-TR.pdf > Wrong / missing exception when submitting job >

[jira] [Updated] (FLINK-10344) Rethink SubmittedJobGraphListener

2018-09-18 Thread Biao Liu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10344?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Biao Liu updated FLINK-10344: - Attachment: Tornado.pdf > Rethink SubmittedJobGraphListener > - > >

[jira] [Updated] (FLINK-10344) Rethink SubmittedJobGraphListener

2018-09-18 Thread Biao Liu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10344?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Biao Liu updated FLINK-10344: - Attachment: Tornado.pdf > Rethink SubmittedJobGraphListener > - > >

[jira] [Commented] (FLINK-12095) Canceling vs cancelling

2019-04-03 Thread Biao Liu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12095?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16808473#comment-16808473 ] Biao Liu commented on FLINK-12095: -- Wow! impressive report (y) > Canceling vs cancelling >

[jira] [Commented] (FLINK-12172) Flink fails to close pending BucketingSink

2019-04-15 Thread Biao Liu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12172?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16818588#comment-16818588 ] Biao Liu commented on FLINK-12172: -- Hi Mario, Could you share more detail information about this? Like

[jira] [Commented] (FLINK-12172) Flink fails to close pending BucketingSink

2019-04-16 Thread Biao Liu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12172?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16819041#comment-16819041 ] Biao Liu commented on FLINK-12172: -- Hi Mario, Here is a simple transition illustration of different

[jira] [Commented] (FLINK-12172) Flink fails to close pending BucketingSink

2019-04-16 Thread Biao Liu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12172?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16819016#comment-16819016 ] Biao Liu commented on FLINK-12172: -- Aha, I know what you meant now. However you don't need to worry

[jira] [Updated] (FLINK-11915) DataInputViewStream skip returns wrong value

2019-04-16 Thread Biao Liu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11915?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Biao Liu updated FLINK-11915: - Affects Version/s: 1.6.3 1.6.4 1.7.2

[jira] [Assigned] (FLINK-11915) DataInputViewStream skip returns wrong value

2019-04-16 Thread Biao Liu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11915?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Biao Liu reassigned FLINK-11915: Assignee: Biao Liu > DataInputViewStream skip returns wrong value >

[jira] [Commented] (FLINK-11915) DataInputViewStream skip returns wrong value

2019-04-16 Thread Biao Liu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11915?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16819704#comment-16819704 ] Biao Liu commented on FLINK-11915: -- Hi Andrew, Thank you for reporting and analyzing. It's indeed a

[jira] [Commented] (FLINK-12686) Disentangle StreamGraph/StreamNode and StreamGraphGenerator from StreamExecutionEnvironment

2019-06-03 Thread Biao Liu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12686?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16854476#comment-16854476 ] Biao Liu commented on FLINK-12686: -- Hi [~aljoscha], it's a good point. How about the proposal that

[jira] [Updated] (FLINK-12686) StreamGraph Supports Blink Batch Mode

2019-05-30 Thread Biao Liu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12686?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Biao Liu updated FLINK-12686: - Description: This is a part of merging Blink batch runner. I would like to improvement the StreamGraph

[jira] [Created] (FLINK-12686) StreamGraph Supports Blink Batch Mode

2019-05-30 Thread Biao Liu (JIRA)
Biao Liu created FLINK-12686: Summary: StreamGraph Supports Blink Batch Mode Key: FLINK-12686 URL: https://issues.apache.org/jira/browse/FLINK-12686 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-12681) Provide an implementation of a thread-safe counter

2019-05-31 Thread Biao Liu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12681?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16852791#comment-16852791 ] Biao Liu commented on FLINK-12681: -- After taking a glance at the relevant codes, there is no need for

[jira] [Assigned] (FLINK-12681) Provide an implementation of a thread-safe counter

2019-05-31 Thread Biao Liu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12681?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Biao Liu reassigned FLINK-12681: Assignee: Biao Liu > Provide an implementation of a thread-safe counter >

[jira] [Commented] (FLINK-12681) Make SimpleCounter thread-safe.

2019-05-30 Thread Biao Liu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12681?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16851560#comment-16851560 ] Biao Liu commented on FLINK-12681: -- The {{SimpleCounter}} is widely used. Especially in per-record

[jira] [Assigned] (FLINK-12686) Disentangle StreamGraph/StreamNode and StreamGraphGenerator from StreamExecutionEnvironment

2019-06-03 Thread Biao Liu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12686?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Biao Liu reassigned FLINK-12686: Assignee: Biao Liu > Disentangle StreamGraph/StreamNode and StreamGraphGenerator from >

[jira] [Commented] (FLINK-12686) Disentangle StreamGraph/StreamNode and StreamGraphGenerator from StreamExecutionEnvironment

2019-06-03 Thread Biao Liu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12686?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16855282#comment-16855282 ] Biao Liu commented on FLINK-12686: -- Hi [~aljoscha], yes, there is no setting for slot sharing

[jira] [Commented] (FLINK-12823) PartitionTransformation supports DataExchangeMode property

2019-06-13 Thread Biao Liu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12823?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16862792#comment-16862792 ] Biao Liu commented on FLINK-12823: -- Hi [~lzljs3620320], [~aljoscha], yes, you are right. I should use

[jira] [Updated] (FLINK-12823) PartitionTransformation supports DataExchangeMode property

2019-06-13 Thread Biao Liu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12823?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Biao Liu updated FLINK-12823: - Description: Currently {{ResultPartitionType}} of {{StreamTransformation}} job is hard-coded with 

[jira] [Created] (FLINK-12866) Connectors module failed on Travis checking

2019-06-16 Thread Biao Liu (JIRA)
Biao Liu created FLINK-12866: Summary: Connectors module failed on Travis checking Key: FLINK-12866 URL: https://issues.apache.org/jira/browse/FLINK-12866 Project: Flink Issue Type: Test

[jira] [Updated] (FLINK-12866) Travis building failed due to cache dir missing

2019-06-17 Thread Biao Liu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12866?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Biao Liu updated FLINK-12866: - Priority: Blocker (was: Minor) > Travis building failed due to cache dir missing >

[jira] [Updated] (FLINK-12866) Travis building failed due to cache dir missing

2019-06-17 Thread Biao Liu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12866?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Biao Liu updated FLINK-12866: - Description: Here is the failure information. Cached flink dir /home/travis/flink_cache/37821/flink

[jira] [Updated] (FLINK-12866) Travis building failed due to cache dir missing

2019-06-17 Thread Biao Liu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12866?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Biao Liu updated FLINK-12866: - Summary: Travis building failed due to cache dir missing (was: Connectors module failed on Travis

[jira] [Updated] (FLINK-12866) Travis building failed due to cache dir missing

2019-06-17 Thread Biao Liu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12866?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Biao Liu updated FLINK-12866: - Description: Here is the failure information. Cached flink dir /home/travis/flink_cache/37821/flink

[jira] [Created] (FLINK-12974) Bump checkstyle version to 8.14

2019-06-25 Thread Biao Liu (JIRA)
Biao Liu created FLINK-12974: Summary: Bump checkstyle version to 8.14 Key: FLINK-12974 URL: https://issues.apache.org/jira/browse/FLINK-12974 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-12961) StreamExecutionEnvironment supports executing job with StreamGraph

2019-06-24 Thread Biao Liu (JIRA)
Biao Liu created FLINK-12961: Summary: StreamExecutionEnvironment supports executing job with StreamGraph Key: FLINK-12961 URL: https://issues.apache.org/jira/browse/FLINK-12961 Project: Flink

[jira] [Created] (FLINK-12823) PartitionTransformation supports DataExchangeMode property

2019-06-12 Thread Biao Liu (JIRA)
Biao Liu created FLINK-12823: Summary: PartitionTransformation supports DataExchangeMode property Key: FLINK-12823 URL: https://issues.apache.org/jira/browse/FLINK-12823 Project: Flink Issue

[jira] [Assigned] (FLINK-12591) StatsDReporterTest is unstable

2019-05-23 Thread Biao Liu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12591?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Biao Liu reassigned FLINK-12591: Assignee: Biao Liu > StatsDReporterTest is unstable > -- > >

[jira] [Commented] (FLINK-12574) using sink StreamingFileSink files are overwritten when resuming application causing data loss

2019-05-24 Thread Biao Liu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12574?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16847298#comment-16847298 ] Biao Liu commented on FLINK-12574: -- Hi [~yitz589], In my opinion this is more like a customized issue.

[jira] [Reopened] (FLINK-12961) StreamExecutionEnvironment supports executing job with StreamGraph

2019-07-05 Thread Biao Liu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12961?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Biao Liu reopened FLINK-12961: -- We need to re-think about the proposal... > StreamExecutionEnvironment supports executing job with

[jira] [Created] (FLINK-13101) Introduce "blocking after chaining off" property of StreamGraph

2019-07-04 Thread Biao Liu (JIRA)
Biao Liu created FLINK-13101: Summary: Introduce "blocking after chaining off" property of StreamGraph Key: FLINK-13101 URL: https://issues.apache.org/jira/browse/FLINK-13101 Project: Flink

  1   2   3   >