[jira] [Commented] (FLINK-31167) Verify that no exclusions were erroneously added to the japicmp plugin

[ https://issues.apache.org/jira/browse/FLINK-31167?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17696081#comment-17696081 ] Biao Liu commented on FLINK-31167: -- Hi [~mapohl] , sorry for the late response. {quote}

[jira] [Commented] (FLINK-31167) Verify that no exclusions were erroneously added to the japicmp plugin

[ https://issues.apache.org/jira/browse/FLINK-31167?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17691970#comment-17691970 ] Biao Liu commented on FLINK-31167: -- Hi [~mapohl] , As you mentioned, the new method wi

[jira] [Created] (FLINK-31124) Add it case for HiveTableSink speculative execution

Biao Liu created FLINK-31124: Summary: Add it case for HiveTableSink speculative execution Key: FLINK-31124 URL: https://issues.apache.org/jira/browse/FLINK-31124 Project: Flink Issue Type: Impro

[jira] [Created] (FLINK-31123) Add it case for FileSink speculative execution

Biao Liu created FLINK-31123: Summary: Add it case for FileSink speculative execution Key: FLINK-31123 URL: https://issues.apache.org/jira/browse/FLINK-31123 Project: Flink Issue Type: Improvemen

[jira] [Updated] (FLINK-30823) Enable speculative execution for some of the typical built-in sinks

[ https://issues.apache.org/jira/browse/FLINK-30823?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Biao Liu updated FLINK-30823: - Description: After the Sink supports speculative execution, here we enable speculative execution for so

[jira] [Updated] (FLINK-30823) Enable speculative execution for some of the typical built-in sinks

[ https://issues.apache.org/jira/browse/FLINK-30823?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Biao Liu updated FLINK-30823: - Description: After the Sink supports speculative execution, here we enable speculative execution for so

[jira] [Created] (FLINK-30842) Add document for sink supports speculative execution

Biao Liu created FLINK-30842: Summary: Add document for sink supports speculative execution Key: FLINK-30842 URL: https://issues.apache.org/jira/browse/FLINK-30842 Project: Flink Issue Type: Sub-

[jira] [Created] (FLINK-30823) Enable speculative execution for some of the typical built-in sinks

Biao Liu created FLINK-30823: Summary: Enable speculative execution for some of the typical built-in sinks Key: FLINK-30823 URL: https://issues.apache.org/jira/browse/FLINK-30823 Project: Flink

[jira] [Commented] (FLINK-30727) JoinReorderITCase.testBushyTreeJoinReorder failed due to IOException

[ https://issues.apache.org/jira/browse/FLINK-30727?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17681722#comment-17681722 ] Biao Liu commented on FLINK-30727: -- Another instance: https://dev.azure.com/apache-fli

[jira] [Created] (FLINK-30799) Make SinkFunction support speculative execution for batch jobs

Biao Liu created FLINK-30799: Summary: Make SinkFunction support speculative execution for batch jobs Key: FLINK-30799 URL: https://issues.apache.org/jira/browse/FLINK-30799 Project: Flink Issue

[jira] [Created] (FLINK-30798) Make OutputFormat support speculative execution for batch jobs

Biao Liu created FLINK-30798: Summary: Make OutputFormat support speculative execution for batch jobs Key: FLINK-30798 URL: https://issues.apache.org/jira/browse/FLINK-30798 Project: Flink Issue

[jira] [Created] (FLINK-30755) Make SinkV2 support speculative execution for batch jobs

Biao Liu created FLINK-30755: Summary: Make SinkV2 support speculative execution for batch jobs Key: FLINK-30755 URL: https://issues.apache.org/jira/browse/FLINK-30755 Project: Flink Issue Type:

[jira] [Created] (FLINK-30725) FLIP-281: Sink Supports Speculative Execution For Batch Job

Biao Liu created FLINK-30725: Summary: FLIP-281: Sink Supports Speculative Execution For Batch Job Key: FLINK-30725 URL: https://issues.apache.org/jira/browse/FLINK-30725 Project: Flink Issue Ty

[jira] [Updated] (FLINK-28980) Release Testing: Verify FLIP-168 speculative execution

[ https://issues.apache.org/jira/browse/FLINK-28980?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Biao Liu updated FLINK-28980: - Attachment: stdout > Release Testing: Verify FLIP-168 speculative execution > --

[jira] [Updated] (FLINK-28980) Release Testing: Verify FLIP-168 speculative execution

[ https://issues.apache.org/jira/browse/FLINK-28980?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Biao Liu updated FLINK-28980: - Attachment: flink-root-taskexecutor-0-VM_199_24_centos.log > Release Testing: Verify FLIP-168 speculativ

[jira] [Updated] (FLINK-28980) Release Testing: Verify FLIP-168 speculative execution

[ https://issues.apache.org/jira/browse/FLINK-28980?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Biao Liu updated FLINK-28980: - Attachment: screenshot1 > Release Testing: Verify FLIP-168 speculative execution > -

[jira] [Updated] (FLINK-28980) Release Testing: Verify FLIP-168 speculative execution

[ https://issues.apache.org/jira/browse/FLINK-28980?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Biao Liu updated FLINK-28980: - Attachment: screenshot2 > Release Testing: Verify FLIP-168 speculative execution > -

[jira] [Updated] (FLINK-28980) Release Testing: Verify FLIP-168 speculative execution

[ https://issues.apache.org/jira/browse/FLINK-28980?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Biao Liu updated FLINK-28980: - Attachment: flink-root-taskexecutor-0-VM_38_195_centos.log > Release Testing: Verify FLIP-168 speculativ

[jira] [Updated] (FLINK-28980) Release Testing: Verify FLIP-168 speculative execution

[ https://issues.apache.org/jira/browse/FLINK-28980?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Biao Liu updated FLINK-28980: - Attachment: flink-root-standalonesession-0-VM_38_195_centos.log > Release Testing: Verify FLIP-168 specu

[jira] [Commented] (FLINK-28980) Release Testing: Verify FLIP-168 speculative execution

[ https://issues.apache.org/jira/browse/FLINK-28980?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17598422#comment-17598422 ] Biao Liu commented on FLINK-28980: -- I've tested the scenario, and it looks good to me.

[jira] [Commented] (FLINK-28980) Release Testing: Verify FLIP-168 speculative execution

[ https://issues.apache.org/jira/browse/FLINK-28980?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17597890#comment-17597890 ] Biao Liu commented on FLINK-28980: -- [~godfreyhe] Sorry for late response, I missed the

[jira] [Commented] (FLINK-17073) Slow checkpoint cleanup causing OOMs

[ https://issues.apache.org/jira/browse/FLINK-17073?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17170015#comment-17170015 ] Biao Liu commented on FLINK-17073: -- [~echauchot], sorry for the late reply. Thanks for

[jira] [Commented] (FLINK-16945) Execute CheckpointFailureManager.FailJobCallback directly in main thread executor

[ https://issues.apache.org/jira/browse/FLINK-16945?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17168439#comment-17168439 ] Biao Liu commented on FLINK-16945: -- [~dian.fu], yes, I'm working on this. It depends on

[jira] [Commented] (FLINK-17073) Slow checkpoint cleanup causing OOMs

[ https://issues.apache.org/jira/browse/FLINK-17073?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17166244#comment-17166244 ] Biao Liu commented on FLINK-17073: -- BTW [~echauchot], before writing any codes, it woul

[jira] [Commented] (FLINK-18641) "Failure to finalize checkpoint" error in MasterTriggerRestoreHook

[ https://issues.apache.org/jira/browse/FLINK-18641?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17166057#comment-17166057 ] Biao Liu commented on FLINK-18641: -- [~becket_qin], [~pnowojski], the ticket has not bee

[jira] [Commented] (FLINK-17073) Slow checkpoint cleanup causing OOMs

[ https://issues.apache.org/jira/browse/FLINK-17073?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17165518#comment-17165518 ] Biao Liu commented on FLINK-17073: -- To [~roman_khachatryan], thanks for nice suggestion

[jira] [Commented] (FLINK-18641) "Failure to finalize checkpoint" error in MasterTriggerRestoreHook

[ https://issues.apache.org/jira/browse/FLINK-18641?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17163341#comment-17163341 ] Biao Liu commented on FLINK-18641: -- Ah, sorry [~pnowojski], I forgot this change is not

[jira] [Commented] (FLINK-18641) "Failure to finalize checkpoint" error in MasterTriggerRestoreHook

[ https://issues.apache.org/jira/browse/FLINK-18641?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17162553#comment-17162553 ] Biao Liu commented on FLINK-18641: -- Thanks [~becket_qin] for analyzing this issue. The

[jira] [Commented] (FLINK-17073) Slow checkpoint cleanup causing OOMs

[ https://issues.apache.org/jira/browse/FLINK-17073?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17161657#comment-17161657 ] Biao Liu commented on FLINK-17073: -- [~echauchot], sorry I don't have the authorization

[jira] [Commented] (FLINK-17073) Slow checkpoint cleanup causing OOMs

[ https://issues.apache.org/jira/browse/FLINK-17073?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17151618#comment-17151618 ] Biao Liu commented on FLINK-17073: -- Hi [~echauchot], thanks for doing so much. I left a

[jira] [Commented] (FLINK-18137) JobMasterTriggerSavepointITCase.testStopJobAfterSavepoint fails with AskTimeoutException

[ https://issues.apache.org/jira/browse/FLINK-18137?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=1717#comment-1717 ] Biao Liu commented on FLINK-18137: -- I just saw this issue. I think [~trohrmann] is righ

[jira] [Commented] (FLINK-14971) Make all the non-IO operations in CheckpointCoordinator single-threaded

[ https://issues.apache.org/jira/browse/FLINK-14971?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17129274#comment-17129274 ] Biao Liu commented on FLINK-14971: -- I spent a bit time to recall the summary of Stephan

[jira] [Commented] (FLINK-9900) Fix unstable test ZooKeeperHighAvailabilityITCase#testRestoreBehaviourWithFaultyStateHandles

[ https://issues.apache.org/jira/browse/FLINK-9900?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17101335#comment-17101335 ] Biao Liu commented on FLINK-9900: - Thanks [~rmetzger] for reporting. This time, the case

[jira] [Updated] (FLINK-9900) Fix unstable test ZooKeeperHighAvailabilityITCase#testRestoreBehaviourWithFaultyStateHandles

[ https://issues.apache.org/jira/browse/FLINK-9900?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Biao Liu updated FLINK-9900: Attachment: mvn-2.log > Fix unstable test > ZooKeeperHighAvailabilityITCase#testRestoreBehaviourWithFaulty

[jira] [Comment Edited] (FLINK-16770) Resuming Externalized Checkpoint (rocks, incremental, scale up) end-to-end test fails with no such file

[ https://issues.apache.org/jira/browse/FLINK-16770?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17092098#comment-17092098 ] Biao Liu edited comment on FLINK-16770 at 4/25/20, 7:12 AM:

[jira] [Commented] (FLINK-16770) Resuming Externalized Checkpoint (rocks, incremental, scale up) end-to-end test fails with no such file

[ https://issues.apache.org/jira/browse/FLINK-16770?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17092098#comment-17092098 ] Biao Liu commented on FLINK-16770: -- Technically speaking, the scenario we discussed her

[jira] [Commented] (FLINK-16931) Large _metadata file lead to JobManager not responding when restart

[ https://issues.apache.org/jira/browse/FLINK-16931?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17085579#comment-17085579 ] Biao Liu commented on FLINK-16931: -- Hi [~qqibrow], thanks for opening the PR. I'll try

[jira] [Commented] (FLINK-16770) Resuming Externalized Checkpoint (rocks, incremental, scale up) end-to-end test fails with no such file

[ https://issues.apache.org/jira/browse/FLINK-16770?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17083325#comment-17083325 ] Biao Liu commented on FLINK-16770: -- Thanks [~rmetzger] for reminding. [~yunta] good job

[jira] [Comment Edited] (FLINK-16770) Resuming Externalized Checkpoint (rocks, incremental, scale up) end-to-end test fails with no such file

[ https://issues.apache.org/jira/browse/FLINK-16770?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17083018#comment-17083018 ] Biao Liu edited comment on FLINK-16770 at 4/14/20, 9:13 AM:

[jira] [Commented] (FLINK-16770) Resuming Externalized Checkpoint (rocks, incremental, scale up) end-to-end test fails with no such file

[ https://issues.apache.org/jira/browse/FLINK-16770?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17083018#comment-17083018 ] Biao Liu commented on FLINK-16770: -- [~aljoscha], the uploading to transfer.sh failed, I

[jira] [Commented] (FLINK-16770) Resuming Externalized Checkpoint (rocks, incremental, scale up) end-to-end test fails with no such file

[ https://issues.apache.org/jira/browse/FLINK-16770?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17078067#comment-17078067 ] Biao Liu commented on FLINK-16770: -- To [~rmetzger], I think FLINK-16423 and this ticket

[jira] [Comment Edited] (FLINK-16423) test_ha_per_job_cluster_datastream.sh gets stuck

[ https://issues.apache.org/jira/browse/FLINK-16423?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17078057#comment-17078057 ] Biao Liu edited comment on FLINK-16423 at 4/8/20, 10:56 AM:

[jira] [Commented] (FLINK-16423) test_ha_per_job_cluster_datastream.sh gets stuck

[ https://issues.apache.org/jira/browse/FLINK-16423?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17078057#comment-17078057 ] Biao Liu commented on FLINK-16423: -- Thanks [~rmetzger] for analyzing so deeply. I check

[jira] [Commented] (FLINK-16770) Resuming Externalized Checkpoint (rocks, incremental, scale up) end-to-end test fails with no such file

[ https://issues.apache.org/jira/browse/FLINK-16770?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17076161#comment-17076161 ] Biao Liu commented on FLINK-16770: -- Thanks [~rmetzger] for manually verifying and mergi

[jira] [Commented] (FLINK-16770) Resuming Externalized Checkpoint (rocks, incremental, scale up) end-to-end test fails with no such file

[ https://issues.apache.org/jira/browse/FLINK-16770?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17074438#comment-17074438 ] Biao Liu commented on FLINK-16770: -- After a short discussion with [~yunta] offline, we

[jira] [Comment Edited] (FLINK-16931) Large _metadata file lead to JobManager not responding when restart

[ https://issues.apache.org/jira/browse/FLINK-16931?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17073927#comment-17073927 ] Biao Liu edited comment on FLINK-16931 at 4/2/20, 5:31 PM: --- [~

[jira] [Comment Edited] (FLINK-16931) Large _metadata file lead to JobManager not responding when restart

[ https://issues.apache.org/jira/browse/FLINK-16931?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17073927#comment-17073927 ] Biao Liu edited comment on FLINK-16931 at 4/2/20, 5:31 PM: --- [~

[jira] [Commented] (FLINK-16931) Large _metadata file lead to JobManager not responding when restart

[ https://issues.apache.org/jira/browse/FLINK-16931?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17073927#comment-17073927 ] Biao Liu commented on FLINK-16931: -- [~trohrmann], my pleasure :) I could share some co

[jira] [Created] (FLINK-16945) Execute CheckpointFailureManager.FailJobCallback directly in main thread executor

Biao Liu created FLINK-16945: Summary: Execute CheckpointFailureManager.FailJobCallback directly in main thread executor Key: FLINK-16945 URL: https://issues.apache.org/jira/browse/FLINK-16945 Project: Fl

[jira] [Commented] (FLINK-16561) Resuming Externalized Checkpoint (rocks, incremental, no parallelism change) end-to-end test fails on Azure

[ https://issues.apache.org/jira/browse/FLINK-16561?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17073441#comment-17073441 ] Biao Liu commented on FLINK-16561: -- [~rmetzger], I have closed this ticket, let's discu

[jira] [Closed] (FLINK-16561) Resuming Externalized Checkpoint (rocks, incremental, no parallelism change) end-to-end test fails on Azure

[ https://issues.apache.org/jira/browse/FLINK-16561?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Biao Liu closed FLINK-16561. Resolution: Duplicate > Resuming Externalized Checkpoint (rocks, incremental, no parallelism change) > en

[jira] [Comment Edited] (FLINK-16770) Resuming Externalized Checkpoint (rocks, incremental, scale up) end-to-end test fails with no such file

[ https://issues.apache.org/jira/browse/FLINK-16770?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17073388#comment-17073388 ] Biao Liu edited comment on FLINK-16770 at 4/2/20, 5:52 AM: --- Hi

[jira] [Commented] (FLINK-16770) Resuming Externalized Checkpoint (rocks, incremental, scale up) end-to-end test fails with no such file

[ https://issues.apache.org/jira/browse/FLINK-16770?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17073388#comment-17073388 ] Biao Liu commented on FLINK-16770: -- Hi [~yunta], thanks for the response. If I understa

[jira] [Commented] (FLINK-16770) Resuming Externalized Checkpoint (rocks, incremental, scale up) end-to-end test fails with no such file

[ https://issues.apache.org/jira/browse/FLINK-16770?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17072553#comment-17072553 ] Biao Liu commented on FLINK-16770: -- Hi [~yunta], thanks for the analysis. I have a ques

[jira] [Commented] (FLINK-9741) Register JVM metrics for each JM separately

[ https://issues.apache.org/jira/browse/FLINK-9741?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17070980#comment-17070980 ] Biao Liu commented on FLINK-9741: - Oops, sorry, I forgot this issue. I gave it a lower pr

[jira] [Commented] (FLINK-13848) Support “scheduleAtFixedRate/scheduleAtFixedDelay” in RpcEndpoint#MainThreadExecutor

[ https://issues.apache.org/jira/browse/FLINK-13848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17064761#comment-17064761 ] Biao Liu commented on FLINK-13848: -- Just an update, we have a work-around solution inst

[jira] [Updated] (FLINK-13848) Support “scheduleAtFixedRate/scheduleAtFixedDelay” in RpcEndpoint#MainThreadExecutor

[ https://issues.apache.org/jira/browse/FLINK-13848?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Biao Liu updated FLINK-13848: - Fix Version/s: (was: 1.11.0) > Support “scheduleAtFixedRate/scheduleAtFixedDelay” in > RpcEndpoint#

[jira] [Updated] (FLINK-13848) Support “scheduleAtFixedRate/scheduleAtFixedDelay” in RpcEndpoint#MainThreadExecutor

[ https://issues.apache.org/jira/browse/FLINK-13848?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Biao Liu updated FLINK-13848: - Parent: (was: FLINK-13698) Issue Type: Improvement (was: Sub-task) > Support “scheduleAtFix

[jira] [Commented] (FLINK-16720) Maven gets stuck downloading artifacts on Azure

[ https://issues.apache.org/jira/browse/FLINK-16720?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17064715#comment-17064715 ] Biao Liu commented on FLINK-16720: -- Another instance, https://dev.azure.com/rmetzger/F

[jira] [Created] (FLINK-16561) Resuming Externalized Checkpoint (rocks, incremental, no parallelism change) end-to-end test fails on Azure

Biao Liu created FLINK-16561: Summary: Resuming Externalized Checkpoint (rocks, incremental, no parallelism change) end-to-end test fails on Azure Key: FLINK-16561 URL: https://issues.apache.org/jira/browse/FLINK-1656

[jira] [Updated] (FLINK-14971) Make all the non-IO operations in CheckpointCoordinator single-threaded

[ https://issues.apache.org/jira/browse/FLINK-14971?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Biao Liu updated FLINK-14971: - Description: Currently the ACK and declined message handling are executed in IO thread. This is the onl

[jira] [Updated] (FLINK-14971) Make all the non-IO operations in CheckpointCoordinator single-threaded

[ https://issues.apache.org/jira/browse/FLINK-14971?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Biao Liu updated FLINK-14971: - Description: Currently the ACK and declined message handling are executed in IO thread. This is the onl

[jira] [Updated] (FLINK-14971) Make all the non-IO operations in CheckpointCoordinator single-threaded

[ https://issues.apache.org/jira/browse/FLINK-14971?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Biao Liu updated FLINK-14971: - Summary: Make all the non-IO operations in CheckpointCoordinator single-threaded (was: Move ACK and dec

[jira] [Commented] (FLINK-15611) KafkaITCase.testOneToOneSources fails on Travis

[ https://issues.apache.org/jira/browse/FLINK-15611?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17017789#comment-17017789 ] Biao Liu commented on FLINK-15611: -- [~jqin], could you take a look at this case? > Kaf

[jira] [Commented] (FLINK-14742) Unstable tests TaskExecutorTest#testSubmitTaskBeforeAcceptSlot

[ https://issues.apache.org/jira/browse/FLINK-14742?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17017779#comment-17017779 ] Biao Liu commented on FLINK-14742: -- Such a subtle case if it couldn't be reproduced :)

[jira] [Commented] (FLINK-15611) KafkaITCase.testOneToOneSources fails on Travis

[ https://issues.apache.org/jira/browse/FLINK-15611?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17017767#comment-17017767 ] Biao Liu commented on FLINK-15611: -- {quote} ... Caused by: java.lang.Exception: Receive

[jira] [Commented] (FLINK-15541) FlinkKinesisConsumerTest.testSourceSynchronization is unstable on travis.

[ https://issues.apache.org/jira/browse/FLINK-15541?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17014083#comment-17014083 ] Biao Liu commented on FLINK-15541: -- This is an obvious bug of unstable test case. Pleas

[jira] [Commented] (FLINK-15503) FileUploadHandlerTest.testMixedMultipart and FileUploadHandlerTest. testUploadCleanupOnUnknownAttribute failed on Azure

[ https://issues.apache.org/jira/browse/FLINK-15503?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17010674#comment-17010674 ] Biao Liu commented on FLINK-15503: -- This case costed over 100 seconds. It's incredibly

[jira] [Updated] (FLINK-13905) Separate checkpoint triggering into stages

[ https://issues.apache.org/jira/browse/FLINK-13905?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Biao Liu updated FLINK-13905: - Priority: Major (was: Blocker) > Separate checkpoint triggering into stages > -

[jira] [Commented] (FLINK-13848) Support “scheduleAtFixedRate/scheduleAtFixedDelay” in RpcEndpoint#MainThreadExecutor

[ https://issues.apache.org/jira/browse/FLINK-13848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16992662#comment-16992662 ] Biao Liu commented on FLINK-13848: -- [~trohrmann], this is an alternative implementation

[jira] [Commented] (FLINK-15032) Remove the eager serialization from `RemoteRpcInvocation`

[ https://issues.apache.org/jira/browse/FLINK-15032?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16991225#comment-16991225 ] Biao Liu commented on FLINK-15032: -- [~trohrmann], thanks for explanation! I think you h

[jira] [Commented] (FLINK-15043) Possible thread leak in task manager

[ https://issues.apache.org/jira/browse/FLINK-15043?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16988367#comment-16988367 ] Biao Liu commented on FLINK-15043: -- [~Jordan.Hatcher], that's OK. Glad to hear it has b

[jira] [Commented] (FLINK-15043) Possible thread leak in task manager

[ https://issues.apache.org/jira/browse/FLINK-15043?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16987497#comment-16987497 ] Biao Liu commented on FLINK-15043: -- Hi [~Jordan.Hatcher], could you explain the reason

[jira] [Comment Edited] (FLINK-15032) Remove the eagerly serialization from `RemoteRpcInvocation`

[ https://issues.apache.org/jira/browse/FLINK-15032?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16986721#comment-16986721 ] Biao Liu edited comment on FLINK-15032 at 12/3/19 8:52 AM: --- Hi

[jira] [Commented] (FLINK-15032) Remove the eagerly serialization from `RemoteRpcInvocation`

[ https://issues.apache.org/jira/browse/FLINK-15032?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16986721#comment-16986721 ] Biao Liu commented on FLINK-15032: -- Hi [~maguowei], thanks for the impressive proposal.

[jira] [Commented] (FLINK-14950) Support getKey in WindowOperator.Context

[ https://issues.apache.org/jira/browse/FLINK-14950?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16984922#comment-16984922 ] Biao Liu commented on FLINK-14950: -- [~wind_ljy], {quote}By the way, Since the key acce

[jira] [Commented] (FLINK-14950) Support getKey in WindowOperator.Context

[ https://issues.apache.org/jira/browse/FLINK-14950?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16984853#comment-16984853 ] Biao Liu commented on FLINK-14950: -- Hi [~wind_ljy], thanks for explanation. I'm not su

[jira] [Created] (FLINK-14971) Move ACK and declined message handling in the same thread with triggering

Biao Liu created FLINK-14971: Summary: Move ACK and declined message handling in the same thread with triggering Key: FLINK-14971 URL: https://issues.apache.org/jira/browse/FLINK-14971 Project: Flink

[jira] [Commented] (FLINK-14950) Support getKey in WindowOperator.Context

[ https://issues.apache.org/jira/browse/FLINK-14950?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16983131#comment-16983131 ] Biao Liu commented on FLINK-14950: -- Hi Jiayi, It's an interesting ticket. Could you pr

[jira] [Commented] (FLINK-14344) A preparation for snapshotting master hook state asynchronously

[ https://issues.apache.org/jira/browse/FLINK-14344?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16973128#comment-16973128 ] Biao Liu commented on FLINK-14344: -- [~pnowojski], makes sense. I have updated the title

[jira] [Updated] (FLINK-14344) A preparation for snapshotting master hook state asynchronously

[ https://issues.apache.org/jira/browse/FLINK-14344?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Biao Liu updated FLINK-14344: - Summary: A preparation for snapshotting master hook state asynchronously (was: Snapshot master hook sta

[jira] [Updated] (FLINK-14344) Snapshot master hook state asynchronously

[ https://issues.apache.org/jira/browse/FLINK-14344?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Biao Liu updated FLINK-14344: - Release Note: Makes the semantic of MasterTriggerRestoreHook#triggerCheckpoint more clearer. It should b

[jira] [Updated] (FLINK-14344) Snapshot master hook state asynchronously

[ https://issues.apache.org/jira/browse/FLINK-14344?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Biao Liu updated FLINK-14344: - Release Note: Makes the semantic of {{MasterTriggerRestoreHook#triggerCheckpoint}} more clearer. It shou

[jira] [Commented] (FLINK-14344) Snapshot master hook state asynchronously

[ https://issues.apache.org/jira/browse/FLINK-14344?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16966566#comment-16966566 ] Biao Liu commented on FLINK-14344: -- [~pnowojski], Yes, BTW, I just resolved a tiny con

[jira] [Commented] (FLINK-14344) Snapshot master hook state asynchronously

[ https://issues.apache.org/jira/browse/FLINK-14344?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16966521#comment-16966521 ] Biao Liu commented on FLINK-14344: -- [~pnowojski], {quote}That you would prefer to keep

[jira] [Commented] (FLINK-14598) The use of FlinkUserCodeClassLoaders is unreasonable.

[ https://issues.apache.org/jira/browse/FLINK-14598?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16966485#comment-16966485 ] Biao Liu commented on FLINK-14598: -- There is already a similar ticket (FLINK-13749) ope

[jira] [Commented] (FLINK-13905) Separate checkpoint triggering into stages

[ https://issues.apache.org/jira/browse/FLINK-13905?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16964944#comment-16964944 ] Biao Liu commented on FLINK-13905: -- [~pnowojski], {quote}If all things equal, I would

[jira] [Commented] (FLINK-14344) Snapshot master hook state asynchronously

[ https://issues.apache.org/jira/browse/FLINK-14344?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16964939#comment-16964939 ] Biao Liu commented on FLINK-14344: -- Hi [~pnowojski], {quote}this is `PublicEvolving` cl

[jira] [Commented] (FLINK-13905) Separate checkpoint triggering into stages

[ https://issues.apache.org/jira/browse/FLINK-13905?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16964855#comment-16964855 ] Biao Liu commented on FLINK-13905: -- Hi [~pnowojski], {quote}So the periodic trigger wou

[jira] [Commented] (FLINK-13861) No new checkpoint will be trigged when canceling an expired checkpoint failed

[ https://issues.apache.org/jira/browse/FLINK-13861?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16962091#comment-16962091 ] Biao Liu commented on FLINK-13861: -- Thanks for reporting [~klion26]! It's definitely a

[jira] [Commented] (FLINK-13848) Support “scheduleAtFixedRate/scheduleAtFixedDelay” in RpcEndpoint#MainThreadExecutor

[ https://issues.apache.org/jira/browse/FLINK-13848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16961732#comment-16961732 ] Biao Liu commented on FLINK-13848: -- {quote}> Anyway it's no harm to enrich the MainThre

[jira] [Commented] (FLINK-14344) Snapshot master hook state asynchronously

[ https://issues.apache.org/jira/browse/FLINK-14344?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16961729#comment-16961729 ] Biao Liu commented on FLINK-14344: -- [~pnowojski], thanks a lot for feedback. {quote}Af

[jira] [Commented] (FLINK-13848) Support “scheduleAtFixedRate/scheduleAtFixedDelay” in RpcEndpoint#MainThreadExecutor

[ https://issues.apache.org/jira/browse/FLINK-13848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16961152#comment-16961152 ] Biao Liu commented on FLINK-13848: -- [~pnowojski], {quote}Do I understand it correctly,

[jira] [Commented] (FLINK-14308) Kafka09ProducerITCase>KafkaProducerTestBase.testOneToOneAtLeastOnceCustomOperator fails on Travis

[ https://issues.apache.org/jira/browse/FLINK-14308?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16956600#comment-16956600 ] Biao Liu commented on FLINK-14308: -- Another instance, https://travis-ci.com/flink-ci/fl

[jira] [Commented] (FLINK-13848) Support “scheduleAtFixedRate/scheduleAtFixedDelay” in RpcEndpoint#MainThreadExecutor

[ https://issues.apache.org/jira/browse/FLINK-13848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16956009#comment-16956009 ] Biao Liu commented on FLINK-13848: -- I would like to activate this ticket. There is a d

[jira] [Commented] (FLINK-14344) Snapshot master hook state asynchronously

[ https://issues.apache.org/jira/browse/FLINK-14344?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16950976#comment-16950976 ] Biao Liu commented on FLINK-14344: -- Hi [~pnowojski], {quote}I think ideally I would pre

[jira] [Commented] (FLINK-14344) Snapshot master hook state asynchronously

[ https://issues.apache.org/jira/browse/FLINK-14344?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16949578#comment-16949578 ] Biao Liu commented on FLINK-14344: -- Hi [~pnowojski], thanks for feedback. Regarding to

[jira] [Updated] (FLINK-14344) Snapshot master hook state asynchronously

[ https://issues.apache.org/jira/browse/FLINK-14344?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Biao Liu updated FLINK-14344: - Description: Currently we snapshot the master hook state synchronously. As a part of reworking threadin

[jira] [Commented] (FLINK-14344) Snapshot master hook state asynchronously

[ https://issues.apache.org/jira/browse/FLINK-14344?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16947662#comment-16947662 ] Biao Liu commented on FLINK-14344: -- When I start implementing this part, I just realize

[jira] [Updated] (FLINK-14344) Snapshot master hook state asynchronously

[ https://issues.apache.org/jira/browse/FLINK-14344?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Biao Liu updated FLINK-14344: - Description: Currently we snapshot the master hook state synchronously. As a part of reworking threadin

  1   2   3   >