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

2022-07-19 Thread Zhu Zhu (Jira)
[ 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

2022-07-19 Thread Zhu Zhu (Jira)
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

2022-07-18 Thread Zhu Zhu (Jira)
[ 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

2022-07-18 Thread Zhu Zhu (Jira)
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 Co

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

2022-07-18 Thread Zhu Zhu (Jira)
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

2022-07-14 Thread Zhu Zhu (Jira)
[ 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

2022-07-13 Thread Zhu Zhu (Jira)
[ 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

2022-07-13 Thread Zhu Zhu (Jira)
[ 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

2022-07-11 Thread Zhu Zhu (Jira)
[ 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 w

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

2022-07-11 Thread Zhu Zhu (Jira)
[ 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 04f2f0c2660

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

2022-07-08 Thread Zhu Zhu (Jira)
[ 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

2022-07-06 Thread Zhu Zhu (Jira)
[ 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 > RemoveCachedShuffleDescriptorTest#te

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

2022-07-06 Thread Zhu Zhu (Jira)
[ 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 > DefaultBlocklistHandlerTest.testRemo

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

2022-07-06 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28392?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17563009#comment-17563009 ] Zhu Zhu edited comment on FLINK-28392 at 7/6/22 7:25 AM: - Thanks

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

2022-07-06 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28392?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17563012#comment-17563012 ] Zhu Zhu commented on FLINK-28392: - #20178 is created to fix this problem as proposed abo

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

2022-07-06 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28392?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=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

2022-07-05 Thread Zhu Zhu (Jira)
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 I

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

2022-07-04 Thread Zhu Zhu (Jira)
[ 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

2022-07-01 Thread Zhu Zhu (Jira)
[ 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 b174deec0155

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

2022-07-01 Thread Zhu Zhu (Jira)
[ 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 speculat

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

2022-07-01 Thread Zhu Zhu (Jira)
[ 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

2022-06-30 Thread Zhu Zhu (Jira)
[ 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 eab0a1faf5e

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

2022-06-30 Thread Zhu Zhu (Jira)
[ 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 ExecutionTimeBasedSlowTaskDe

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

2022-06-30 Thread Zhu Zhu (Jira)
[ 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

2022-06-30 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28324?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17561237#comment-17561237 ] Zhu Zhu commented on FLINK-28324: - Thanks for volunteering to take it. [~Leo Zhou] I hav

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

2022-06-30 Thread Zhu Zhu (Jira)
[ 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

2022-06-30 Thread Zhu Zhu (Jira)
[ 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 m

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

2022-06-27 Thread Zhu Zhu (Jira)
Title: Message Title Zhu Zhu closed an iss

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

2022-06-27 Thread Zhu Zhu (Jira)
Title: Message Title Zhu Zhu created an is

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

2022-06-27 Thread Zhu Zhu (Jira)
Title: Message Title Zhu Zhu assigned an i

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

2022-06-27 Thread Zhu Zhu (Jira)
Title: Message Title Zhu Zhu commented on

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

2022-06-27 Thread Zhu Zhu (Jira)
Title: Message Title Zhu Zhu created an is

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

2022-06-27 Thread Zhu Zhu (Jira)
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: Fli

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

2022-06-27 Thread Zhu Zhu (Jira)
[ 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

2022-06-24 Thread Zhu Zhu (Jira)
[ 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 verte

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

2022-06-24 Thread Zhu Zhu (Jira)
[ 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 de

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

2022-06-22 Thread Zhu Zhu (Jira)
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

2022-06-22 Thread Zhu Zhu (Jira)
[ 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

2022-06-21 Thread Zhu Zhu (Jira)
[ 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

2022-06-21 Thread Zhu Zhu (Jira)
[ 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

2022-06-21 Thread Zhu Zhu (Jira)
[ 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

2022-06-21 Thread Zhu Zhu (Jira)
[ 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

2022-06-21 Thread Zhu Zhu (Jira)
[ 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

2022-06-21 Thread Zhu Zhu (Jira)
[ 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

2022-06-21 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27832?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17557207#comment-17557207 ] Zhu Zhu commented on FLINK-27832: - https://dev.azure.com/apache-flink/98463496-1af2-4620

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

2022-06-21 Thread Zhu Zhu (Jira)
[ 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

2022-06-21 Thread Zhu Zhu (Jira)
[ 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

2022-06-21 Thread Zhu Zhu (Jira)
[ 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 > -- > > Key:

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

2022-06-20 Thread Zhu Zhu (Jira)
[ 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

2022-06-20 Thread Zhu Zhu (Jira)
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

2022-06-20 Thread Zhu Zhu (Jira)
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 Co

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

2022-06-20 Thread Zhu Zhu (Jira)
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 Component

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

2022-06-20 Thread Zhu Zhu (Jira)
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

2022-06-20 Thread Zhu Zhu (Jira)
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: Z

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

2022-06-20 Thread Zhu Zhu (Jira)
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 Com

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

2022-06-20 Thread Zhu Zhu (Jira)
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: Sub-t

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

2022-06-20 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-10644?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17556334#comment-17556334 ] Zhu Zhu commented on FLINK-10644: - The [FLIP|https://cwiki.apache.org/confluence/displa

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

2022-06-20 Thread Zhu Zhu (Jira)
[ 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

2022-06-20 Thread Zhu Zhu (Jira)
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

2022-06-20 Thread Zhu Zhu (Jira)
[ 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

2022-06-17 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28105?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17555467#comment-17555467 ] Zhu Zhu commented on FLINK-28105: - Thanks for reporting this problem! [~Leo Zhou]  The

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

2022-06-17 Thread Zhu Zhu (Jira)
[ 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 > GlobFilePathFilterTest#testGlobFilterSerializ

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

2022-06-17 Thread Zhu Zhu (Jira)
[ 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 the

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

2022-06-17 Thread Zhu Zhu (Jira)
[ 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 > GlobFilePathFilterTest#testGlobFilterSerial

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

2022-06-17 Thread Zhu Zhu (Jira)
[ 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 > GlobFil

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

2022-06-14 Thread Zhu Zhu (Jira)
[ 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: 0cf8

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

2022-06-13 Thread Zhu Zhu (Jira)
[ 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 > FlinkUser

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

2022-06-13 Thread Zhu Zhu (Jira)
[ 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 un

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

2022-06-13 Thread Zhu Zhu (Jira)
[ 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

2022-06-13 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28018?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17553484#comment-17553484 ] Zhu Zhu commented on FLINK-28018: - I have assigned you the ticket. Feel free to open a f

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

2022-06-13 Thread Zhu Zhu (Jira)
[ 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) > the

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

2022-06-13 Thread Zhu Zhu (Jira)
[ 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 to

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

2022-06-13 Thread Zhu Zhu (Jira)
[ 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 BinaryInputFor

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

2022-06-13 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28018?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17553479#comment-17553479 ] Zhu Zhu commented on FLINK-28018: - Yes it is a bug. Thanks for reporting this! [~Leo Zho

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

2022-06-08 Thread Zhu Zhu (Jira)
[ 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

2022-06-08 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27710?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17551665#comment-17551665 ] Zhu Zhu commented on FLINK-27710: - Thanks for the comments. [~xtsong]  I think your con

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

2022-06-08 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27791?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17551657#comment-17551657 ] Zhu Zhu commented on FLINK-27791: - Good catch! > KerberosDelegationTokenManagerTest sta

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

2022-06-08 Thread Zhu Zhu (Jira)
[ 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{}}}  ({{{}subtaskIndex

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

2022-06-08 Thread Zhu Zhu (Jira)
[ 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{}}}  ({{{}subtaskIndex

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

2022-06-07 Thread Zhu Zhu (Jira)
[ 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 a

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

2022-06-07 Thread Zhu Zhu (Jira)
[ 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{}}}  ({{{}subtaskIndex

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

2022-06-07 Thread Zhu Zhu (Jira)
[ 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 >

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

2022-06-07 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27944?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-27944: Description: When a task has union inputs, some IO metrics(numBytesIn* and numBuffersIn*) of the differen

[jira] [Created] (FLINK-27944) IO metric collision happens when a task has union inputs

2022-06-07 Thread Zhu Zhu (Jira)
Zhu Zhu created FLINK-27944: --- Summary: IO metric collision happens when a task has union inputs Key: FLINK-27944 URL: https://issues.apache.org/jira/browse/FLINK-27944 Project: Flink Issue Type: Bu

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

2022-06-07 Thread Zhu Zhu (Jira)
[ 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{}}}  ({{{}subtaskIndex

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

2022-06-07 Thread Zhu Zhu (Jira)
[ 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{}}}  ({{{}subtaskIndex

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

2022-06-06 Thread Zhu Zhu (Jira)
[ 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{}}}  ({{{}subtaskIndex

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

2022-06-06 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27791?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17550769#comment-17550769 ] Zhu Zhu commented on FLINK-27791: - [~wangyang0918] do you have any idea of this problem?

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

2022-06-01 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27791?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17545267#comment-17545267 ] Zhu Zhu commented on FLINK-27791: - The slot allocation timeout happened because the reso

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

2022-06-01 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27791?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu closed FLINK-27791. --- Resolution: Not A Bug > SlotCountExceedingParallelismTest tests failed with > NoResourceAvailableException

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

2022-06-01 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27791?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-27791: Attachment: error.log > SlotCountExceedingParallelismTest tests failed with > NoResourceAvailableExceptio

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

2022-05-31 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27791?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17544246#comment-17544246 ] Zhu Zhu commented on FLINK-27791: - I will take a look. > SlotCountExceedingParallelismT

[jira] [Closed] (FLINK-17295) Refactor the ExecutionAttemptID to consist of ExecutionVertexID and attemptNumber

2022-05-20 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17295?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu closed FLINK-17295. --- Resolution: Done Merged into master: 061df0ba8f2cd4b4e6436ebde1bc249bc629e940 1f101edd174c5f9b743bd3128a9f

[jira] [Updated] (FLINK-17295) Refactor the ExecutionAttemptID to consist of ExecutionVertexID and attemptNumber

2022-05-20 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17295?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-17295: Fix Version/s: 1.16.0 > Refactor the ExecutionAttemptID to consist of ExecutionVertexID and > attemptNumb

[jira] [Comment Edited] (FLINK-17295) Refactor the ExecutionAttemptID to consist of ExecutionVertexID and attemptNumber

2022-05-19 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17295?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17539914#comment-17539914 ] Zhu Zhu edited comment on FLINK-17295 at 5/20/22 4:31 AM: -- I wa

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

2022-05-19 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27710?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu reassigned FLINK-27710: --- Assignee: Zhu Zhu > Improve logs to better display Execution >

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

2022-05-19 Thread Zhu Zhu (Jira)
Zhu Zhu created FLINK-27710: --- Summary: Improve logs to better display Execution Key: FLINK-27710 URL: https://issues.apache.org/jira/browse/FLINK-27710 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-17295) Refactor the ExecutionAttemptID to consist of ExecutionVertexID and attemptNumber

2022-05-19 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17295?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17539914#comment-17539914 ] Zhu Zhu commented on FLINK-17295: - I was not concerning about it because PartitionReques

[jira] [Commented] (FLINK-17295) Refactor the ExecutionAttemptID to consist of ExecutionVertexID and attemptNumber

2022-05-17 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17295?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17538581#comment-17538581 ] Zhu Zhu commented on FLINK-17295: - The benchmark value is the size of a serialized TDD.

[jira] [Closed] (FLINK-26909) Allow to set parallelism to be -1 from Cli

2022-05-16 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26909?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu closed FLINK-26909. --- Fix Version/s: 1.15.1 Resolution: Done Done via: master: 46c6d78ddd6b271cd434eff03ae65c0e74c0d53e r

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