[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

[jira] [Closed] (FLINK-28135) Introduce SlowTaskDetector

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

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

[ https://issues.apache.org/jira/browse/FLINK-28324?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17561237#comment-17561237 ] Zhu Zhu commented on FLINK-28324: - Thanks for volunteering to take it. [~Leo Zhou] I have assigned you

[jira] [Assigned] (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 reassigned FLINK-28324: --- Assignee: zl > JUnit5 Migration] Module: flink-sql-client >

[jira] [Closed] (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:all-tabpanel ] Zhu Zhu closed FLINK-28213. --- Resolution: Done Done via 065018dde64a10e8a4cf0ba296e2851a6867871c > StreamExecutionEnvironment configure

[jira] [Closed] (FLINK-28258) Introduce ExecutionHistory to host historical executions for each execution vertex

Title: Message Title Zhu Zhu closed an

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

Title: Message Title Zhu Zhu created an

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

Title: Message Title Zhu Zhu assigned an

[jira] [Commented] (FLINK-28267) KafkaSourceLegacyITCase.testBrokerFailure hang on azure

Title: Message Title Zhu Zhu commented on

[jira] [Created] (FLINK-28267) KafkaSourceLegacyITCase.testBrokerFailure hang on azure

Title: Message Title Zhu Zhu created an

[jira] [Created] (FLINK-28258) Introduce ExecutionHistory to host historical executions for each execution vertex

Zhu Zhu created FLINK-28258: --- Summary: Introduce ExecutionHistory to host historical executions for each execution vertex Key: FLINK-28258 URL: https://issues.apache.org/jira/browse/FLINK-28258 Project:

[jira] [Assigned] (FLINK-28258) Introduce ExecutionHistory to host historical executions for each execution vertex

[ https://issues.apache.org/jira/browse/FLINK-28258?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu reassigned FLINK-28258: --- Assignee: Zhu Zhu > Introduce ExecutionHistory to host historical executions for each execution >

[jira] [Closed] (FLINK-28193) Enable to identify whether a job vertex contains source/sink operators

[ https://issues.apache.org/jira/browse/FLINK-28193?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu closed FLINK-28193. --- Resolution: Done Done via cef491eab34f904cf67f8a0392d48c03def249ff > Enable to identify whether a job

[jira] [Closed] (FLINK-28133) Rework DefaultScheduler to directly deploy executions

[ https://issues.apache.org/jira/browse/FLINK-28133?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu closed FLINK-28133. --- Resolution: Done Done via c66101d518615ec2d6a36c829568583a6a5d93f9 > Rework DefaultScheduler to directly

[jira] [Created] (FLINK-28193) Enable to identify whether a job vertex contains source/sink operators

Zhu Zhu created FLINK-28193: --- Summary: Enable to identify whether a job vertex contains source/sink operators Key: FLINK-28193 URL: https://issues.apache.org/jira/browse/FLINK-28193 Project: Flink

[jira] [Assigned] (FLINK-28193) Enable to identify whether a job vertex contains source/sink operators

[ https://issues.apache.org/jira/browse/FLINK-28193?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu reassigned FLINK-28193: --- Assignee: Zhu Zhu > Enable to identify whether a job vertex contains source/sink operators >

[jira] [Assigned] (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 reassigned FLINK-28146: --- Assignee: Lijie Wang > Sync blocklist information between JobMaster & ResourceManager >

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

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

[jira] [Assigned] (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 reassigned FLINK-28145: --- Assignee: Lijie Wang > Let ResourceManager support blocklist mechanism >

[jira] [Assigned] (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 reassigned FLINK-28144: --- Assignee: Lijie Wang > Let JobMaster support blocklist mechanism >

[jira] [Assigned] (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 reassigned FLINK-28142: --- Assignee: Lijie Wang > Enrich TaskManagerLocation with node information >

[jira] [Assigned] (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 reassigned FLINK-28130: --- Assignee: Lijie Wang > FLIP-224: Blocklist Mechanism > - > >

[jira] [Commented] (FLINK-27832) SplitAggregateITCase tests failed with Could not acquire the minimum required resources

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

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

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

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

[ https://issues.apache.org/jira/browse/FLINK-28136?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu reassigned FLINK-28136: --- Assignee: wangwj > Implement ExecutionTimeBasedSlowTaskDetector >

[jira] [Assigned] (FLINK-28135) Introduce SlowTaskDetector

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

[jira] [Assigned] (FLINK-28133) Rework DefaultScheduler to directly deploy executions

[ https://issues.apache.org/jira/browse/FLINK-28133?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu reassigned FLINK-28133: --- Assignee: Zhu Zhu > Rework DefaultScheduler to directly deploy executions >

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

Zhu Zhu created FLINK-28139: --- Summary: Add documentation for speculative execution Key: FLINK-28139 URL: https://issues.apache.org/jira/browse/FLINK-28139 Project: Flink Issue Type: Sub-task

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

Zhu Zhu created FLINK-28138: --- Summary: Add metrics for speculative execution Key: FLINK-28138 URL: https://issues.apache.org/jira/browse/FLINK-28138 Project: Flink Issue Type: Sub-task

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

Zhu Zhu created FLINK-28137: --- Summary: Introduce SpeculativeScheduler Key: FLINK-28137 URL: https://issues.apache.org/jira/browse/FLINK-28137 Project: Flink Issue Type: Sub-task

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

Zhu Zhu created FLINK-28136: --- Summary: Implement ExecutionTimeBasedSlowTaskDetector Key: FLINK-28136 URL: https://issues.apache.org/jira/browse/FLINK-28136 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-28135) Introduce SlowTaskDetector

Zhu Zhu created FLINK-28135: --- Summary: Introduce SlowTaskDetector Key: FLINK-28135 URL: https://issues.apache.org/jira/browse/FLINK-28135 Project: Flink Issue Type: Sub-task Reporter:

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

Zhu Zhu created FLINK-28134: --- Summary: Introduce SpeculativeExecutionVertex Key: FLINK-28134 URL: https://issues.apache.org/jira/browse/FLINK-28134 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-28133) Rework DefaultScheduler to directly deploy executions

Zhu Zhu created FLINK-28133: --- Summary: Rework DefaultScheduler to directly deploy executions Key: FLINK-28133 URL: https://issues.apache.org/jira/browse/FLINK-28133 Project: Flink Issue Type:

[jira] [Commented] (FLINK-10644) Batch Job: Speculative execution

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

[jira] [Assigned] (FLINK-28131) FLIP-168: Speculative Execution for Batch Job

[ https://issues.apache.org/jira/browse/FLINK-28131?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu reassigned FLINK-28131: --- Assignee: Zhu Zhu > FLIP-168: Speculative Execution for Batch Job >

[jira] [Created] (FLINK-28131) FLIP-168: Speculative Execution for Batch Job

Zhu Zhu created FLINK-28131: --- Summary: FLIP-168: Speculative Execution for Batch Job Key: FLINK-28131 URL: https://issues.apache.org/jira/browse/FLINK-28131 Project: Flink Issue Type: New Feature

[jira] [Closed] (FLINK-28105) We should test the copied object in GlobFilePathFilterTest#testGlobFilterSerializable

[ https://issues.apache.org/jira/browse/FLINK-28105?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu closed FLINK-28105. --- Resolution: Fixed Fixed via 44b941557e131ea03486ba5324232fe7b421a6c4 > We should test the copied object in

[jira] [Commented] (FLINK-28105) We should test the copied object in GlobFilePathFilterTest#testGlobFilterSerializable

[ https://issues.apache.org/jira/browse/FLINK-28105?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17555467#comment-17555467 ] Zhu Zhu commented on FLINK-28105: - Thanks for reporting this problem! [~Leo Zhou]  The ticket is

[jira] [Assigned] (FLINK-28105) We should test the copied object in GlobFilePathFilterTest#testGlobFilterSerializable

[ https://issues.apache.org/jira/browse/FLINK-28105?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu reassigned FLINK-28105: --- Assignee: zl > We should test the copied object in >

[jira] [Updated] (FLINK-28105) We should test the copied object in GlobFilePathFilterTest#testGlobFilterSerializable

[ https://issues.apache.org/jira/browse/FLINK-28105?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-28105: Affects Version/s: 1.14.4 1.15.0 1.16.0 > We should test

[jira] [Updated] (FLINK-28105) We should test the copied object in GlobFilePathFilterTest#testGlobFilterSerializable

[ https://issues.apache.org/jira/browse/FLINK-28105?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-28105: Fix Version/s: 1.16.0 > We should test the copied object in >

[jira] [Updated] (FLINK-28105) We should test the copied object in GlobFilePathFilterTest#testGlobFilterSerializable

[ https://issues.apache.org/jira/browse/FLINK-28105?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-28105: Component/s: Tests (was: API / Core) > We should test the copied object in >

[jira] [Closed] (FLINK-28018) the start index to create empty splits in BinaryInputFormat#createInputSplits is inappropriate

[ https://issues.apache.org/jira/browse/FLINK-28018?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu closed FLINK-28018. --- Fix Version/s: 1.15.1 (was: 1.15.2) Resolution: Fixed Fixed via: master:

[jira] [Closed] (FLINK-27658) FlinkUserCodeClassLoader expose addURL method to allow to register jar dynamically

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

[jira] [Updated] (FLINK-27944) IO metrics collision happens if a task has union inputs

[ https://issues.apache.org/jira/browse/FLINK-27944?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-27944: Fix Version/s: 1.15.2 (was: 1.15.1) > IO metrics collision happens if a task has

[jira] [Assigned] (FLINK-28018) the start index to create empty splits in BinaryInputFormat#createInputSplits is inappropriate

[ https://issues.apache.org/jira/browse/FLINK-28018?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu reassigned FLINK-28018: --- Assignee: zl > the start index to create empty splits in BinaryInputFormat#createInputSplits > is

[jira] [Commented] (FLINK-28018) the start index to create empty splits in BinaryInputFormat#createInputSplits is inappropriate

[ https://issues.apache.org/jira/browse/FLINK-28018?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17553484#comment-17553484 ] Zhu Zhu commented on FLINK-28018: - I have assigned you the ticket. Feel free to open a fix for it. >

[jira] [Updated] (FLINK-28018) the start index to create empty splits in BinaryInputFormat#createInputSplits is inappropriate

[ https://issues.apache.org/jira/browse/FLINK-28018?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-28018: Component/s: Formats (JSON, Avro, Parquet, ORC, SequenceFile) (was: API / Core) >

[jira] [Updated] (FLINK-28018) the start index to create empty splits in BinaryInputFormat#createInputSplits is inappropriate

[ https://issues.apache.org/jira/browse/FLINK-28018?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-28018: Affects Version/s: 1.14.4 1.15.0 1.16.0 > the start index

[jira] [Updated] (FLINK-28018) the start index to create empty splits in BinaryInputFormat#createInputSplits is inappropriate

[ https://issues.apache.org/jira/browse/FLINK-28018?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-28018: Fix Version/s: 1.16.0 1.15.2 > the start index to create empty splits in

[jira] [Commented] (FLINK-28018) the start index to create empty splits in BinaryInputFormat#createInputSplits is inappropriate

[ https://issues.apache.org/jira/browse/FLINK-28018?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17553479#comment-17553479 ] Zhu Zhu commented on FLINK-28018: - Yes it is a bug. Thanks for reporting this! [~Leo Zhou]  Do you want

[jira] [Updated] (FLINK-27944) IO metrics collision happens if a task has union inputs

[ https://issues.apache.org/jira/browse/FLINK-27944?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-27944: Fix Version/s: 1.15.1 > IO metrics collision happens if a task has union inputs >

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

[ https://issues.apache.org/jira/browse/FLINK-27710?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17551665#comment-17551665 ] Zhu Zhu commented on FLINK-27710: - Thanks for the comments. [~xtsong]  I think your concern is valid.

[jira] [Commented] (FLINK-27791) KerberosDelegationTokenManagerTest static UGI mock leaks into other tests

[ https://issues.apache.org/jira/browse/FLINK-27791?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17551657#comment-17551657 ] Zhu Zhu commented on FLINK-27791: - Good catch! > KerberosDelegationTokenManagerTest static UGI mock

[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: Description: Currently, an execution is usually represented as "{{{}job vertex name{}}} 

[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: Description: Currently, an execution is usually represented as "{{{}job vertex name{}}} 

[jira] [Updated] (FLINK-27944) IO metrics collision happens if a task has union inputs

[ https://issues.apache.org/jira/browse/FLINK-27944?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-27944: Summary: IO metrics collision happens if a task has union inputs (was: IO metric collision happens when

[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: Description: Currently, an execution is usually represented as "{{{}job vertex name{}}} 

[jira] [Reopened] (FLINK-27791) SlotCountExceedingParallelismTest tests failed with NoResourceAvailableException

[ https://issues.apache.org/jira/browse/FLINK-27791?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu reopened FLINK-27791: - > SlotCountExceedingParallelismTest tests failed with > NoResourceAvailableException >

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