[jira] [Commented] (FLINK-28940) Release Testing: Verify FLIP-248 Dynamic Partition Prunning

[ https://issues.apache.org/jira/browse/FLINK-28940?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17597069#comment-17597069 ] Zhu Zhu commented on FLINK-28940: - I have tested it and it looks good to me. I used sql client to do the

[jira] [Updated] (FLINK-28981) Release Testing: Verify FLIP-245 sources speculative execution

[ https://issues.apache.org/jira/browse/FLINK-28981?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-28981: Description: Speculative execution is introduced in Flink 1.16 to deal with temporary slow tasks caused

[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 ] Zhu Zhu updated FLINK-28980: Description: Speculative execution is introduced in Flink 1.16 to deal with temporary slow tasks caused

[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 ] Zhu Zhu updated FLINK-28980: Description: Speculative execution is introduced in Flink 1.16 to deal with temporary slow tasks caused

[jira] [Updated] (FLINK-28981) Release Testing: Verify FLIP-245 sources speculative execution

[ https://issues.apache.org/jira/browse/FLINK-28981?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-28981: Description: Speculative execution is introduced in Flink 1.16 to deal with temporary slow tasks caused

[jira] [Updated] (FLINK-28981) Release Testing: Verify FLIP-245 sources speculative execution

[ https://issues.apache.org/jira/browse/FLINK-28981?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-28981: Description: Speculative execution is introduced in Flink 1.16 to deal with temporary slow tasks caused

[jira] [Commented] (FLINK-28940) Release Testing: Verify FLIP-248 Dynamic Partition Prunning

[ https://issues.apache.org/jira/browse/FLINK-28940?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17584162#comment-17584162 ] Zhu Zhu commented on FLINK-28940: - I'm working on it and it may need a bit more time. > Release

[jira] [Closed] (FLINK-28139) Add documentation for speculative execution

[ https://issues.apache.org/jira/browse/FLINK-28139?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu closed FLINK-28139. --- Resolution: Done Done via 70d9f6c31b289b6ea284a02fdb1d8cfc1a1a5414 > Add documentation for speculative

[jira] [Commented] (FLINK-28213) StreamExecutionEnvironment configure method support override pipeline.jars option

[ https://issues.apache.org/jira/browse/FLINK-28213?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17580685#comment-17580685 ] Zhu Zhu commented on FLINK-28213: - I agree that we should not change the semantics of the

[jira] [Assigned] (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 ] Zhu Zhu reassigned FLINK-28980: --- Assignee: Biao Liu > Release Testing: Verify FLIP-168 speculative execution >

[jira] [Updated] (FLINK-28981) Release Testing: Verify FLIP-245 sources speculative execution

[ https://issues.apache.org/jira/browse/FLINK-28981?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-28981: Description: Speculative execution is introduced in Flink 1.16 to deal with temporary slow tasks caused

[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 ] Zhu Zhu updated FLINK-28980: Labels: release-testing (was: test-stability) > Release Testing: Verify FLIP-168 speculative execution >

[jira] [Updated] (FLINK-28981) Release Testing: Verify FLIP-245 sources speculative execution

[ https://issues.apache.org/jira/browse/FLINK-28981?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-28981: Description: Speculative execution is introduced in Flink 1.16 to deal with temporary slow tasks caused

[jira] [Updated] (FLINK-28981) Release Testing: Verify FLIP-245 sources speculative execution

[ https://issues.apache.org/jira/browse/FLINK-28981?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-28981: Labels: release-testing (was: test-stability) > Release Testing: Verify FLIP-245 sources speculative

[jira] [Closed] (FLINK-28130) FLIP-224: Blocklist Mechanism

[ https://issues.apache.org/jira/browse/FLINK-28130?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu closed FLINK-28130. --- Resolution: Done > FLIP-224: Blocklist Mechanism > - > > Key:

[jira] [Closed] (FLINK-28587) FLIP-249: Flink Web UI Enhancement for Speculative Execution

[ https://issues.apache.org/jira/browse/FLINK-28587?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu closed FLINK-28587. --- Fix Version/s: 1.16.0 Resolution: Done > FLIP-249: Flink Web UI Enhancement for Speculative

[jira] [Closed] (FLINK-28397) [FLIP-245] Source Supports Speculative Execution For Batch Job

[ https://issues.apache.org/jira/browse/FLINK-28397?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu closed FLINK-28397. --- Resolution: Done > [FLIP-245] Source Supports Speculative Execution For Batch Job >

[jira] [Created] (FLINK-28981) Release Testing: Verify FLIP-245 sources speculative execution

Zhu Zhu created FLINK-28981: --- Summary: Release Testing: Verify FLIP-245 sources speculative execution Key: FLINK-28981 URL: https://issues.apache.org/jira/browse/FLINK-28981 Project: Flink Issue

[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 ] Zhu Zhu updated FLINK-28980: Description: Speculative execution is introduced in Flink 1.16 to deal with temporary slow tasks caused

[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 ] Zhu Zhu updated FLINK-28980: Description: Speculative execution is introduced in Flink 1.16 to deal with temporary slow tasks caused

[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 ] Zhu Zhu updated FLINK-28980: Description: Speculative execution is introduced in Flink 1.16 to deal with temporary slow tasks caused

[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 ] Zhu Zhu updated FLINK-28980: Description: Speculative execution is introduced in Flink 1.16 to deal with temporary slow tasks caused

[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 ] Zhu Zhu updated FLINK-28980: Description: Speculative execution is introduced in Flink 1.16 to deal with temporary slow tasks caused

[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 ] Zhu Zhu updated FLINK-28980: Description: Speculative execution is introduced in Flink 1.16 to deal with temporary slow tasks caused

[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 ] Zhu Zhu updated FLINK-28980: Description: Speculative execution is introduced in Flink 1.16 to deal with temporary slow tasks caused

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

Zhu Zhu created FLINK-28980: --- Summary: Release Testing: Verify FLIP-168 speculative execution Key: FLINK-28980 URL: https://issues.apache.org/jira/browse/FLINK-28980 Project: Flink Issue Type:

[jira] [Comment Edited] (FLINK-28878) PipelinedRegionSchedulingITCase.testRecoverFromPartitionException failed with AssertionError

[ https://issues.apache.org/jira/browse/FLINK-28878?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17579512#comment-17579512 ] Zhu Zhu edited comment on FLINK-28878 at 8/15/22 3:44 AM: -- Fixed via master:

[jira] [Updated] (FLINK-28878) PipelinedRegionSchedulingITCase.testRecoverFromPartitionException failed with AssertionError

[ https://issues.apache.org/jira/browse/FLINK-28878?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-28878: Fix Version/s: 1.15.2 > PipelinedRegionSchedulingITCase.testRecoverFromPartitionException failed with >

[jira] [Closed] (FLINK-28878) PipelinedRegionSchedulingITCase.testRecoverFromPartitionException failed with AssertionError

[ https://issues.apache.org/jira/browse/FLINK-28878?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu closed FLINK-28878. --- Resolution: Fixed Fixed via 5f8f387cba774a2c3900ea38e8a3dad017cf1790 >

[jira] [Updated] (FLINK-28878) PipelinedRegionSchedulingITCase.testRecoverFromPartitionException failed with AssertionError

[ https://issues.apache.org/jira/browse/FLINK-28878?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-28878: Component/s: Tests (was: Runtime / Coordination) >

[jira] [Updated] (FLINK-28878) PipelinedRegionSchedulingITCase.testRecoverFromPartitionException failed with AssertionError

[ https://issues.apache.org/jira/browse/FLINK-28878?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-28878: Affects Version/s: 1.14.5 > PipelinedRegionSchedulingITCase.testRecoverFromPartitionException failed with

[jira] [Updated] (FLINK-28878) PipelinedRegionSchedulingITCase.testRecoverFromPartitionException failed with AssertionError

[ https://issues.apache.org/jira/browse/FLINK-28878?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-28878: Affects Version/s: 1.15.1 > PipelinedRegionSchedulingITCase.testRecoverFromPartitionException failed with

[jira] [Commented] (FLINK-28766) UnalignedCheckpointStressITCase.runStressTest failed with NoSuchFileException

[ https://issues.apache.org/jira/browse/FLINK-28766?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17578887#comment-17578887 ] Zhu Zhu commented on FLINK-28766: -

[jira] [Assigned] (FLINK-28878) PipelinedRegionSchedulingITCase.testRecoverFromPartitionException failed with AssertionError

[ https://issues.apache.org/jira/browse/FLINK-28878?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu reassigned FLINK-28878: --- Assignee: Zhu Zhu > PipelinedRegionSchedulingITCase.testRecoverFromPartitionException failed with

[jira] [Updated] (FLINK-28878) PipelinedRegionSchedulingITCase.testRecoverFromPartitionException failed with AssertionError

[ https://issues.apache.org/jira/browse/FLINK-28878?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-28878: Fix Version/s: 1.16.0 > PipelinedRegionSchedulingITCase.testRecoverFromPartitionException failed with >

[jira] [Commented] (FLINK-28878) PipelinedRegionSchedulingITCase.testRecoverFromPartitionException failed with AssertionError

[ https://issues.apache.org/jira/browse/FLINK-28878?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17578780#comment-17578780 ] Zhu Zhu commented on FLINK-28878: - Thanks for reporting it! [~hxbks2ks] The test fails due to an

[jira] [Updated] (FLINK-28907) Flink docs do not compile locally

[ https://issues.apache.org/jira/browse/FLINK-28907?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-28907: Description: Flink docs fail to compile locally. The error is as below: go:

[jira] [Commented] (FLINK-28907) Flink docs do not compile locally

[ https://issues.apache.org/jira/browse/FLINK-28907?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17577905#comment-17577905 ] Zhu Zhu commented on FLINK-28907: - Tried building docs of latest Flink master on other dev machines,

[jira] [Updated] (FLINK-28907) Flink docs do not compile locally

[ https://issues.apache.org/jira/browse/FLINK-28907?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-28907: Summary: Flink docs do not compile locally (was: Flink docs do not compile) > Flink docs do not compile

[jira] [Updated] (FLINK-28907) Flink docs do not compile

[ https://issues.apache.org/jira/browse/FLINK-28907?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-28907: Priority: Major (was: Blocker) > Flink docs do not compile > - > >

[jira] [Updated] (FLINK-28907) Flink docs do not compile

[ https://issues.apache.org/jira/browse/FLINK-28907?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-28907: Summary: Flink docs do not compile (was: Flink docs does not compile) > Flink docs do not compile >

[jira] [Created] (FLINK-28907) Flink docs does not compile

Zhu Zhu created FLINK-28907: --- Summary: Flink docs does not compile Key: FLINK-28907 URL: https://issues.apache.org/jira/browse/FLINK-28907 Project: Flink Issue Type: Bug Components:

[jira] [Closed] (FLINK-28873) Make "jobmanager.scheduler" visible in documentation

[ https://issues.apache.org/jira/browse/FLINK-28873?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu closed FLINK-28873. --- Resolution: Fixed Fixed via 15f87d4a470e9bf29fd18874c26c4506ea57c09f > Make "jobmanager.scheduler" visible

[jira] [Assigned] (FLINK-28873) Make "jobmanager.scheduler" visible in documentation

[ https://issues.apache.org/jira/browse/FLINK-28873?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu reassigned FLINK-28873: --- Assignee: Lijie Wang > Make "jobmanager.scheduler" visible in documentation >

[jira] [Updated] (FLINK-28324) JUnit5 Migration] Module: flink-sql-client

[ https://issues.apache.org/jira/browse/FLINK-28324?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-28324: Priority: Major (was: Minor) > JUnit5 Migration] Module: flink-sql-client >

[jira] (FLINK-28324) JUnit5 Migration] Module: flink-sql-client

[ https://issues.apache.org/jira/browse/FLINK-28324 ] Zhu Zhu deleted comment on FLINK-28324: - was (Author: flink-jira-bot): I am the [Flink Jira Bot|https://github.com/apache/flink-jira-bot/] and I help the community manage its development. I see

[jira] [Updated] (FLINK-28324) JUnit5 Migration] Module: flink-sql-client

[ https://issues.apache.org/jira/browse/FLINK-28324?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-28324: Labels: pull-request-available (was: pull-request-available stale-assigned) > JUnit5 Migration] Module:

[jira] [Assigned] (FLINK-28139) Add documentation for speculative execution

[ https://issues.apache.org/jira/browse/FLINK-28139?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu reassigned FLINK-28139: --- Assignee: Zhu Zhu > Add documentation for speculative execution >

[jira] [Updated] (FLINK-27710) Improve logs to better display Execution

[ https://issues.apache.org/jira/browse/FLINK-27710?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-27710: Fix Version/s: (was: 1.16.0) > Improve logs to better display Execution >

[jira] [Commented] (FLINK-28769) Flink History Server show wrong name of batch jobs

[ https://issues.apache.org/jira/browse/FLINK-28769?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17575001#comment-17575001 ] Zhu Zhu commented on FLINK-28769: - Loos to me the the specified name does work after checking the code

[jira] [Closed] (FLINK-23174) Log improvement in Task throws Error

[ https://issues.apache.org/jira/browse/FLINK-23174?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu closed FLINK-23174. --- Resolution: Won't Fix Close due to inactive and no response. > Log improvement in Task throws Error >

[jira] [Closed] (FLINK-28771) Assign speculative execution attempt with correct CREATED timestamp

[ https://issues.apache.org/jira/browse/FLINK-28771?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu closed FLINK-28771. --- Resolution: Fixed Fixed via e1a74df4427e99f4b0f3aaa4e8f4f5ff7cbd044e > Assign speculative execution

[jira] [Closed] (FLINK-28759) Enable speculative execution for in AdaptiveBatchScheduler TPC-DS e2e tests

[ https://issues.apache.org/jira/browse/FLINK-28759?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu closed FLINK-28759. --- Resolution: Done Done via 16b0cc1117d4bda11b89440e962646024b2ff6c5 > Enable speculative execution for in

[jira] [Closed] (FLINK-28589) Enhance Web UI for Speculative Execution

[ https://issues.apache.org/jira/browse/FLINK-28589?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu closed FLINK-28589. --- Fix Version/s: 1.16.0 Resolution: Done Done via 4af75011fe32506a70076a2fe9e847cef39587bb

[jira] [Created] (FLINK-28771) Assign speculative execution attempt with correct CREATED timestamp

Zhu Zhu created FLINK-28771: --- Summary: Assign speculative execution attempt with correct CREATED timestamp Key: FLINK-28771 URL: https://issues.apache.org/jira/browse/FLINK-28771 Project: Flink

[jira] [Commented] (FLINK-28759) Enable speculative execution for in AdaptiveBatchScheduler TPC-DS e2e tests

[ https://issues.apache.org/jira/browse/FLINK-28759?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17573568#comment-17573568 ] Zhu Zhu commented on FLINK-28759: - [~JunRuiLi] I have assign you the ticket. Go a head to open a PR for

[jira] [Assigned] (FLINK-28759) Enable speculative execution for in AdaptiveBatchScheduler TPC-DS e2e tests

[ https://issues.apache.org/jira/browse/FLINK-28759?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu reassigned FLINK-28759: --- Assignee: JUNRUILi > Enable speculative execution for in AdaptiveBatchScheduler TPC-DS e2e tests >

[jira] [Created] (FLINK-28759) Enable speculative execution for in AdaptiveBatchScheduler TPC-DS e2e tests

Zhu Zhu created FLINK-28759: --- Summary: Enable speculative execution for in AdaptiveBatchScheduler TPC-DS e2e tests Key: FLINK-28759 URL: https://issues.apache.org/jira/browse/FLINK-28759 Project: Flink

[jira] [Closed] (FLINK-28696) Notify all newlyAdded/Merged blocked nodes to BlocklistListener

[ https://issues.apache.org/jira/browse/FLINK-28696?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu closed FLINK-28696. --- Resolution: Fixed Fixed via bbaeb628f48a4bc4c324bfc4afd06ddf34f546f0 > Notify all newlyAdded/Merged

[jira] [Assigned] (FLINK-28696) Notify all newlyAdded/Merged blocked nodes to BlocklistListener

[ https://issues.apache.org/jira/browse/FLINK-28696?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu reassigned FLINK-28696: --- Assignee: Lijie Wang > Notify all newlyAdded/Merged blocked nodes to BlocklistListener >

[jira] [Closed] (FLINK-28610) Enable speculative execution of sources

[ https://issues.apache.org/jira/browse/FLINK-28610?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu closed FLINK-28610. --- Resolution: Done Done via 9192446847b6fb29beb8d36d49d6900de1e61685 > Enable speculative execution of

[jira] [Closed] (FLINK-28660) Simplify logs of blocklist

[ https://issues.apache.org/jira/browse/FLINK-28660?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu closed FLINK-28660. --- Resolution: Fixed Fixed via 64ad6709f412e80c5e48d24127e7a558bed99e8a > Simplify logs of blocklist >

[jira] [Closed] (FLINK-28585) Speculative execution for InputFormat sources

[ https://issues.apache.org/jira/browse/FLINK-28585?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu closed FLINK-28585. --- Resolution: Done Done via 7611928d0f1a7bb20ec5b0538e0fbe9102a07023 > Speculative execution for InputFormat

[jira] [Assigned] (FLINK-28660) Simplify logs of blocklist

[ https://issues.apache.org/jira/browse/FLINK-28660?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu reassigned FLINK-28660: --- Assignee: Lijie Wang > Simplify logs of blocklist > -- > >

[jira] [Closed] (FLINK-28640) Let BlocklistDeclarativeSlotPool accept duplicate slot offers

[ https://issues.apache.org/jira/browse/FLINK-28640?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu closed FLINK-28640. --- Resolution: Done Done via f6a22eaf99d4ba2ef03445bae54a0da7c39c4d1a > Let BlocklistDeclarativeSlotPool

[jira] [Assigned] (FLINK-28610) Enable speculative execution of sources

[ https://issues.apache.org/jira/browse/FLINK-28610?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu reassigned FLINK-28610: --- Assignee: Zhu Zhu > Enable speculative execution of sources >

[jira] [Closed] (FLINK-28146) Sync blocklist information between JobMaster & ResourceManager

[ https://issues.apache.org/jira/browse/FLINK-28146?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu closed FLINK-28146. --- Fix Version/s: 1.16.0 Resolution: Done Done via 7b05a1b4c9a4ae664fb6b7c4bb85fb3ea6281505 > Sync

[jira] [Assigned] (FLINK-28640) Let BlocklistDeclarativeSlotPool accept duplicate slot offers

[ https://issues.apache.org/jira/browse/FLINK-28640?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu reassigned FLINK-28640: --- Assignee: Lijie Wang > Let BlocklistDeclarativeSlotPool accept duplicate slot offers >

[jira] [Closed] (FLINK-28586) Speculative execution for new sources

[ https://issues.apache.org/jira/browse/FLINK-28586?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu closed FLINK-28586. --- Resolution: Done Done via 79d93f2512f6826baefb14c8dc9b59d419d7df0a 9af271f3108ce8af6b6972fabf5420b99e55fc71

[jira] [Closed] (FLINK-28138) Add metrics for speculative execution

[ https://issues.apache.org/jira/browse/FLINK-28138?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu closed FLINK-28138. --- Resolution: Done Done via 2173b45b570de8ff1507b8e29a884e2449ffea62 19b0a95c30afd9ed65252c49fb00cef882412553

[jira] [Closed] (FLINK-28145) Let ResourceManager support blocklist mechanism

[ https://issues.apache.org/jira/browse/FLINK-28145?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu closed FLINK-28145. --- Fix Version/s: 1.16.0 Resolution: Done Done via 6f7455b078ba89302b8c05e9d39d3a1ca114700c

[jira] [Assigned] (FLINK-28585) Speculative execution for InputFormat sources

[ https://issues.apache.org/jira/browse/FLINK-28585?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu reassigned FLINK-28585: --- Assignee: Zhu Zhu > Speculative execution for InputFormat sources >

[jira] [Assigned] (FLINK-28588) Enhance REST API for Speculative Execution

[ https://issues.apache.org/jira/browse/FLINK-28588?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu reassigned FLINK-28588: --- Assignee: Gen Luo > Enhance REST API for Speculative Execution >

[jira] [Updated] (FLINK-28547) Add IT cases for SpeculativeScheduler

[ https://issues.apache.org/jira/browse/FLINK-28547?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-28547: Component/s: Tests > Add IT cases for SpeculativeScheduler > - > >

[jira] [Closed] (FLINK-28547) Add IT cases for SpeculativeScheduler

[ https://issues.apache.org/jira/browse/FLINK-28547?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu closed FLINK-28547. --- Resolution: Done Done via fd763672b858e74b24760e5c98ff9af22caa8a14 > Add IT cases for SpeculativeScheduler

[jira] [Closed] (FLINK-28612) Cancel pending slot allocation after canceling executions

[ https://issues.apache.org/jira/browse/FLINK-28612?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu closed FLINK-28612. --- Resolution: Fixed Fixed via 3278995372d1ea27b6fd86806e9a860a644694c7 > Cancel pending slot allocation

[jira] [Created] (FLINK-28612) Cancel pending slot allocation after canceling executions

Zhu Zhu created FLINK-28612: --- Summary: Cancel pending slot allocation after canceling executions Key: FLINK-28612 URL: https://issues.apache.org/jira/browse/FLINK-28612 Project: Flink Issue Type:

[jira] [Assigned] (FLINK-28612) Cancel pending slot allocation after canceling executions

[ https://issues.apache.org/jira/browse/FLINK-28612?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu reassigned FLINK-28612: --- Assignee: Zhu Zhu > Cancel pending slot allocation after canceling executions >

[jira] [Created] (FLINK-28610) Enable speculative execution of sources

Zhu Zhu created FLINK-28610: --- Summary: Enable speculative execution of sources Key: FLINK-28610 URL: https://issues.apache.org/jira/browse/FLINK-28610 Project: Flink Issue Type: Sub-task

[jira] [Assigned] (FLINK-28586) Speculative execution for new sources

[ https://issues.apache.org/jira/browse/FLINK-28586?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu reassigned FLINK-28586: --- Assignee: Zhu Zhu > Speculative execution for new sources > -

[jira] [Created] (FLINK-28586) Speculative execution for new sources

Zhu Zhu created FLINK-28586: --- Summary: Speculative execution for new sources Key: FLINK-28586 URL: https://issues.apache.org/jira/browse/FLINK-28586 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-28585) Speculative execution for InputFormat sources

Zhu Zhu created FLINK-28585: --- Summary: Speculative execution for InputFormat sources Key: FLINK-28585 URL: https://issues.apache.org/jira/browse/FLINK-28585 Project: Flink Issue Type: Sub-task

[jira] [Assigned] (FLINK-28547) Add IT cases for SpeculativeScheduler

[ https://issues.apache.org/jira/browse/FLINK-28547?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu reassigned FLINK-28547: --- Assignee: Lijie Wang > Add IT cases for SpeculativeScheduler >

[jira] [Closed] (FLINK-28137) Introduce SpeculativeScheduler

[ https://issues.apache.org/jira/browse/FLINK-28137?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu closed FLINK-28137. --- Resolution: Done Done via 81c739ae462412e531216bb46bc567fce2355dd8 265612c2cf93a589d87d7fc8ca168bc19d838885

[jira] [Assigned] (FLINK-28138) Add metrics for speculative execution

[ https://issues.apache.org/jira/browse/FLINK-28138?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu reassigned FLINK-28138: --- Assignee: Zhu Zhu > Add metrics for speculative execution > -

[jira] [Closed] (FLINK-28402) Create FailureHandlingResultSnapshot with the truly failed execution

[ https://issues.apache.org/jira/browse/FLINK-28402?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu closed FLINK-28402. --- Resolution: Done Done via edd10a1d8fd09f8a5e296ecdf0201945d77d5ff2 > Create FailureHandlingResultSnapshot

[jira] [Closed] (FLINK-28144) Let JobMaster support blocklist mechanism

[ https://issues.apache.org/jira/browse/FLINK-28144?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu closed FLINK-28144. --- Fix Version/s: 1.16.0 Resolution: Done Done via: f2f83e1956eccecaa2371b21bddaf7778bb4f819

[jira] [Assigned] (FLINK-28402) Create FailureHandlingResultSnapshot with the truly failed execution

[ https://issues.apache.org/jira/browse/FLINK-28402?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu reassigned FLINK-28402: --- Assignee: Zhu Zhu > Create FailureHandlingResultSnapshot with the truly failed execution >

[jira] [Closed] (FLINK-28392) RemoveCachedShuffleDescriptorTest#testRemoveOffloadedCacheForPointwiseEdgeAfterFailover causes fatal error on CI

[ https://issues.apache.org/jira/browse/FLINK-28392?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu closed FLINK-28392. --- Resolution: Fixed Fixed via e5c4e3f519f364b5951e7cac331eb8af48f0ed84 >

[jira] [Closed] (FLINK-28391) DefaultBlocklistHandlerTest.testRemoveTimeoutNodes fails

[ https://issues.apache.org/jira/browse/FLINK-28391?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu closed FLINK-28391. --- Resolution: Fixed Fixed via 2bd8c209df72679684aeb493c6df03a167fbd2f6 >

[jira] [Comment Edited] (FLINK-28392) RemoveCachedShuffleDescriptorTest#testRemoveOffloadedCacheForPointwiseEdgeAfterFailover causes fatal error on CI

[ https://issues.apache.org/jira/browse/FLINK-28392?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17563009#comment-17563009 ] Zhu Zhu edited comment on FLINK-28392 at 7/6/22 7:25 AM: - Thanks for reporting

[jira] [Commented] (FLINK-28392) RemoveCachedShuffleDescriptorTest#testRemoveOffloadedCacheForPointwiseEdgeAfterFailover causes fatal error on CI

[ https://issues.apache.org/jira/browse/FLINK-28392?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17563012#comment-17563012 ] Zhu Zhu commented on FLINK-28392: - #20178 is created to fix this problem as proposed above. >

[jira] [Commented] (FLINK-28392) RemoveCachedShuffleDescriptorTest#testRemoveOffloadedCacheForPointwiseEdgeAfterFailover causes fatal error on CI

[ https://issues.apache.org/jira/browse/FLINK-28392?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17563009#comment-17563009 ] Zhu Zhu commented on FLINK-28392: - Thanks for reporting this issue and investigating it.

[jira] [Created] (FLINK-28402) Create FailureHandlingResultSnapshot with the truly failed execution

Zhu Zhu created FLINK-28402: --- Summary: Create FailureHandlingResultSnapshot with the truly failed execution Key: FLINK-28402 URL: https://issues.apache.org/jira/browse/FLINK-28402 Project: Flink

[jira] [Assigned] (FLINK-28137) Introduce SpeculativeScheduler

[ https://issues.apache.org/jira/browse/FLINK-28137?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu reassigned FLINK-28137: --- Assignee: Zhu Zhu > Introduce SpeculativeScheduler > -- > >

[jira] [Closed] (FLINK-28143) Introduce BlocklistHandler

[ https://issues.apache.org/jira/browse/FLINK-28143?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu closed FLINK-28143. --- Fix Version/s: 1.16.0 Resolution: Done Done via 57f1b6e508159cb40b60ef34d58f29044c88286c

[jira] [Closed] (FLINK-28271) Add configuration options for speculative scheduler

[ https://issues.apache.org/jira/browse/FLINK-28271?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu closed FLINK-28271. --- Resolution: Done Done via 2aae49748350806a8523b3b0d95b6f795a9327f0 > Add configuration options for

[jira] [Closed] (FLINK-28134) Introduce SpeculativeExecutionVertex

[ https://issues.apache.org/jira/browse/FLINK-28134?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu closed FLINK-28134. --- Resolution: Done Done via b96d476d4cd05de1e6c0b001f2477aaed98bd473 e73225e4071fb7ffe7c4d5cbfd89983129fe3312

[jira] [Closed] (FLINK-28142) Enrich TaskManagerLocation with node information

[ https://issues.apache.org/jira/browse/FLINK-28142?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu closed FLINK-28142. --- Fix Version/s: 1.16.0 Resolution: Done Done via: 51c139b601806cc4f4272fb678f4d1bed4cf06ab

[jira] [Closed] (FLINK-28136) Implement ExecutionTimeBasedSlowTaskDetector

[ https://issues.apache.org/jira/browse/FLINK-28136?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu closed FLINK-28136. --- Resolution: Done Done via ef07590403ad7448a523ef5da78da0306cccdae7 > Implement

<    1   2   3   4   5   6   7   8   9   10   >