[jira] [Closed] (FLINK-32306) Multiple batch scheduler performance regressions

[ https://issues.apache.org/jira/browse/FLINK-32306?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu closed FLINK-32306. --- Fix Version/s: (was: 1.18.0) Resolution: Duplicate > Multiple batch scheduler performance

[jira] [Commented] (FLINK-32306) Multiple batch scheduler performance regressions

[ https://issues.apache.org/jira/browse/FLINK-32306?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17731485#comment-17731485 ] Zhu Zhu commented on FLINK-32306: - Given that the only problem is the schedulingDownstreamTasks.BATCH, I

[jira] [Closed] (FLINK-30480) Add benchmarks for adaptive batch scheduler

[ https://issues.apache.org/jira/browse/FLINK-30480?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu closed FLINK-30480. --- Resolution: Done > Add benchmarks for adaptive batch scheduler >

[jira] [Comment Edited] (FLINK-30480) Add benchmarks for adaptive batch scheduler

[ https://issues.apache.org/jira/browse/FLINK-30480?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17730866#comment-17730866 ] Zhu Zhu edited comment on FLINK-30480 at 6/12/23 7:57 AM: -- flink master:

[jira] [Comment Edited] (FLINK-32306) Multiple batch scheduler performance regressions

[ https://issues.apache.org/jira/browse/FLINK-32306?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17731351#comment-17731351 ] Zhu Zhu edited comment on FLINK-32306 at 6/12/23 2:46 AM: -- Thanks for reporting

[jira] [Comment Edited] (FLINK-32306) Multiple batch scheduler performance regressions

[ https://issues.apache.org/jira/browse/FLINK-32306?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17731351#comment-17731351 ] Zhu Zhu edited comment on FLINK-32306 at 6/11/23 2:03 PM: -- Thanks for reporting

[jira] [Comment Edited] (FLINK-32306) Multiple batch scheduler performance regressions

[ https://issues.apache.org/jira/browse/FLINK-32306?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17731351#comment-17731351 ] Zhu Zhu edited comment on FLINK-32306 at 6/11/23 2:01 PM: -- Thanks for reporting

[jira] [Commented] (FLINK-32306) Multiple batch scheduler performance regressions

[ https://issues.apache.org/jira/browse/FLINK-32306?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17731351#comment-17731351 ] Zhu Zhu commented on FLINK-32306: - Thanks for reporting this! [~martijnvisser] This happens because we

[jira] [Comment Edited] (FLINK-30480) Add benchmarks for adaptive batch scheduler

[ https://issues.apache.org/jira/browse/FLINK-30480?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17730866#comment-17730866 ] Zhu Zhu edited comment on FLINK-30480 at 6/9/23 8:31 AM: - flink repo side

[jira] [Closed] (FLINK-30480) Add benchmarks for adaptive batch scheduler

[ https://issues.apache.org/jira/browse/FLINK-30480?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu closed FLINK-30480. --- Resolution: Done Done via 27285d671276f70c197c3ef79adcb518a37ec560 > Add benchmarks for adaptive batch

[jira] [Reopened] (FLINK-30480) Add benchmarks for adaptive batch scheduler

[ https://issues.apache.org/jira/browse/FLINK-30480?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu reopened FLINK-30480: - > Add benchmarks for adaptive batch scheduler > --- > >

[jira] [Commented] (FLINK-32288) Improve the scheduling performance of AdaptiveBatchScheduler

[ https://issues.apache.org/jira/browse/FLINK-32288?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17730470#comment-17730470 ] Zhu Zhu commented on FLINK-32288: - Thanks for reporting this! [~xiasun] The root cause is that the

[jira] [Assigned] (FLINK-32288) Improve the scheduling performance of AdaptiveBatchScheduler

[ https://issues.apache.org/jira/browse/FLINK-32288?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu reassigned FLINK-32288: --- Assignee: xingbe > Improve the scheduling performance of AdaptiveBatchScheduler >

[jira] [Updated] (FLINK-30480) Add benchmarks for adaptive batch scheduler

[ https://issues.apache.org/jira/browse/FLINK-30480?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-30480: Fix Version/s: 1.18.0 > Add benchmarks for adaptive batch scheduler >

[jira] [Updated] (FLINK-32199) MetricStore does not remove metrics of nonexistent parallelism in TaskMetricStore when scale down job parallelism

[ https://issues.apache.org/jira/browse/FLINK-32199?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-32199: Component/s: Runtime / REST > MetricStore does not remove metrics of nonexistent parallelism in >

[jira] [Updated] (FLINK-32217) Retain metric store can cause NPE

[ https://issues.apache.org/jira/browse/FLINK-32217?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-32217: Component/s: Runtime / REST > Retain metric store can cause NPE > -- > >

[jira] [Closed] (FLINK-31868) Fix DefaultInputSplitAssigner javadoc for class

[ https://issues.apache.org/jira/browse/FLINK-31868?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu closed FLINK-31868. --- Fix Version/s: 1.18.0 Resolution: Fixed Fixed via f240a5110a0d28473b534cf377d287d5d072a93e > Fix

[jira] [Updated] (FLINK-31868) Fix DefaultInputSplitAssigner javadoc for class

[ https://issues.apache.org/jira/browse/FLINK-31868?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-31868: Affects Version/s: 1.18.0 > Fix DefaultInputSplitAssigner javadoc for class >

[jira] [Updated] (FLINK-31868) Fix DefaultInputSplitAssigner javadoc for class

[ https://issues.apache.org/jira/browse/FLINK-31868?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-31868: Issue Type: Bug (was: Improvement) > Fix DefaultInputSplitAssigner javadoc for class >

[jira] [Updated] (FLINK-31868) Fix DefaultInputSplitAssigner javadoc for class

[ https://issues.apache.org/jira/browse/FLINK-31868?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-31868: Priority: Minor (was: Major) > Fix DefaultInputSplitAssigner javadoc for class >

[jira] [Assigned] (FLINK-31868) Fix DefaultInputSplitAssigner javadoc for class

[ https://issues.apache.org/jira/browse/FLINK-31868?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu reassigned FLINK-31868: --- Assignee: Peter Vary > Fix DefaultInputSplitAssigner javadoc for class >

[jira] [Closed] (FLINK-31853) Remove use of ExecutionAttemptMappingProvider

[ https://issues.apache.org/jira/browse/FLINK-31853?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu closed FLINK-31853. --- Resolution: Done > Remove use of ExecutionAttemptMappingProvider >

[jira] [Commented] (FLINK-31853) Remove use of ExecutionAttemptMappingProvider

[ https://issues.apache.org/jira/browse/FLINK-31853?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17714400#comment-17714400 ] Zhu Zhu commented on FLINK-31853: - Thanks for reporting this issue and fixing it! [~JunRuiLi] Done via

[jira] [Updated] (FLINK-31853) Remove use of ExecutionAttemptMappingProvider

[ https://issues.apache.org/jira/browse/FLINK-31853?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-31853: Issue Type: Technical Debt (was: Improvement) > Remove use of ExecutionAttemptMappingProvider >

[jira] [Assigned] (FLINK-31853) Remove use of ExecutionAttemptMappingProvider

[ https://issues.apache.org/jira/browse/FLINK-31853?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu reassigned FLINK-31853: --- Assignee: Junrui Li > Remove use of ExecutionAttemptMappingProvider >

[jira] [Updated] (FLINK-27299) flink parsing parameter bug

[ https://issues.apache.org/jira/browse/FLINK-27299?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-27299: Fix Version/s: 2.0.0 (was: 1.18.0) > flink parsing parameter bug >

[jira] (FLINK-26692) migrate TpcdsTestProgram.java to new source

[ https://issues.apache.org/jira/browse/FLINK-26692 ] Zhu Zhu deleted comment on FLINK-26692: - 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] (FLINK-26692) migrate TpcdsTestProgram.java to new source

[ https://issues.apache.org/jira/browse/FLINK-26692 ] Zhu Zhu deleted comment on FLINK-26692: - 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] [Closed] (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 closed FLINK-27710. --- Resolution: Won't Do Won't do at the moment until we get more inputs from users. > Improve logs to better

[jira] [Closed] (FLINK-31115) Support a task to specify multiple slots

[ https://issues.apache.org/jira/browse/FLINK-31115?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu closed FLINK-31115. --- Fix Version/s: (was: 1.18.0) Resolution: Duplicate > Support a task to specify multiple slots >

[jira] [Updated] (FLINK-31437) Wrong key 'lookup.cache.caching-missing-key' in connector documentation

[ https://issues.apache.org/jira/browse/FLINK-31437?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-31437: Component/s: Documentation > Wrong key 'lookup.cache.caching-missing-key' in connector documentation >

[jira] [Updated] (FLINK-31437) Wrong key 'lookup.cache.caching-missing-key' in connector documentation

[ https://issues.apache.org/jira/browse/FLINK-31437?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-31437: Summary: Wrong key 'lookup.cache.caching-missing-key' in connector documentation (was:

[jira] [Updated] (FLINK-31437) Wrong key 'lookup.cache.caching-missing-key' in connector documentation

[ https://issues.apache.org/jira/browse/FLINK-31437?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-31437: Component/s: Connectors / HBase > Wrong key 'lookup.cache.caching-missing-key' in connector documentation

[jira] [Updated] (FLINK-31437) 'lookup.cache.caching-missing-key' change should be configured as 'lookup.partial-cache.cache-missing-key'

[ https://issues.apache.org/jira/browse/FLINK-31437?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-31437: Component/s: Connectors / JDBC > 'lookup.cache.caching-missing-key' change should be configured as >

[jira] [Updated] (FLINK-31437) 'lookup.cache.caching-missing-key' change should be configured as 'lookup.partial-cache.cache-missing-key'

[ https://issues.apache.org/jira/browse/FLINK-31437?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-31437: Summary: 'lookup.cache.caching-missing-key' change should be configured as

[jira] [Assigned] (FLINK-31437) 'lookup.cache.caching-missing-key' change should be configured as 'lookup.partial-cache.caching-missing-key'

[ https://issues.apache.org/jira/browse/FLINK-31437?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu reassigned FLINK-31437: --- Assignee: Junrui Li > 'lookup.cache.caching-missing-key' change should be configured as >

[jira] [Comment Edited] (FLINK-31144) Slow scheduling on large-scale batch jobs

[ https://issues.apache.org/jira/browse/FLINK-31144?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17699955#comment-17699955 ] Zhu Zhu edited comment on FLINK-31144 at 3/14/23 5:41 AM: -- IIRC, the

[jira] [Commented] (FLINK-31144) Slow scheduling on large-scale batch jobs

[ https://issues.apache.org/jira/browse/FLINK-31144?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17699955#comment-17699955 ] Zhu Zhu commented on FLINK-31144: - IIRC, the parallelism of that benchmark job is 4000, which is

[jira] [Updated] (FLINK-31144) Slow scheduling on large-scale batch jobs

[ https://issues.apache.org/jira/browse/FLINK-31144?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-31144: Affects Version/s: 1.16.1 1.15.3 1.17.0 > Slow scheduling

[jira] [Closed] (FLINK-31144) Slow scheduling on large-scale batch jobs

[ https://issues.apache.org/jira/browse/FLINK-31144?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu closed FLINK-31144. --- Fix Version/s: 1.17.0 Resolution: Fixed master: 6d79f6fc52bcd338d0528d19cd1f7289d8e339da

[jira] [Assigned] (FLINK-31144) Slow scheduling on large-scale batch jobs

[ https://issues.apache.org/jira/browse/FLINK-31144?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu reassigned FLINK-31144: --- Assignee: Junrui Li > Slow scheduling on large-scale batch jobs >

[jira] [Commented] (FLINK-31144) Slow scheduling on large-scale batch jobs

[ https://issues.apache.org/jira/browse/FLINK-31144?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17696033#comment-17696033 ] Zhu Zhu commented on FLINK-31144: - Thanks for volunteering! [~JunRuiLi] I have assigned you the ticket.

[jira] [Closed] (FLINK-29859) TPC-DS end-to-end test with adaptive batch scheduler failed due to oo non-empty .out files.

[ https://issues.apache.org/jira/browse/FLINK-29859?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu closed FLINK-29859. --- Resolution: Fixed master: 28e75620db7b0794ff1c19f8928ce7d33516ba64 release-1.17:

[jira] [Commented] (FLINK-31144) Slow scheduling on large-scale batch jobs

[ https://issues.apache.org/jira/browse/FLINK-31144?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17693882#comment-17693882 ] Zhu Zhu commented on FLINK-31144: - Sorry I made a mistake! [~jto] What I meant is to change the check to

[jira] [Assigned] (FLINK-29859) TPC-DS end-to-end test with adaptive batch scheduler failed due to oo non-empty .out files.

[ https://issues.apache.org/jira/browse/FLINK-29859?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu reassigned FLINK-29859: --- Assignee: Junrui Li (was: Lijie Wang) > TPC-DS end-to-end test with adaptive batch scheduler

[jira] [Closed] (FLINK-31077) Trigger checkpoint failed but it were shown as COMPLETED by rest API

[ https://issues.apache.org/jira/browse/FLINK-31077?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu closed FLINK-31077. --- Resolution: Fixed master: eb17ec3f05d4bd512bc70ee79296d0b884894eaf release-1.17:

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

[ https://issues.apache.org/jira/browse/FLINK-31123?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu closed FLINK-31123. --- Fix Version/s: 1.17.0 Resolution: Done master: f244945aa7cf9d3fb5d2fd2fe49446dd759f9aef

[jira] [Closed] (FLINK-28294) Some metric reporters don't allow register same metric with different names

[ https://issues.apache.org/jira/browse/FLINK-28294?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu closed FLINK-28294. --- Resolution: Duplicate It is a duplicate issue of FLINK-30246. The specific problem of

[jira] [Commented] (FLINK-31144) Slow scheduling on large-scale batch jobs

[ https://issues.apache.org/jira/browse/FLINK-31144?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17692527#comment-17692527 ] Zhu Zhu commented on FLINK-31144: - I suspect the slowness is caused by the N^2 complexity to compute the

[jira] [Comment Edited] (FLINK-31144) Slow scheduling on large-scale batch jobs

[ https://issues.apache.org/jira/browse/FLINK-31144?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17692527#comment-17692527 ] Zhu Zhu edited comment on FLINK-31144 at 2/23/23 7:06 AM: -- I suspect the

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

[ https://issues.apache.org/jira/browse/FLINK-31124?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu closed FLINK-31124. --- Fix Version/s: 1.17.0 Resolution: Done master: db6e01e028ec69d7702d3371d6b3db253aafbbf8

[jira] [Commented] (FLINK-31144) Slow scheduling on large-scale batch jobs

[ https://issues.apache.org/jira/browse/FLINK-31144?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17691916#comment-17691916 ] Zhu Zhu commented on FLINK-31144: - Thanks for reporting this issue! [~jto] What's the the parallelism of

[jira] [Closed] (FLINK-31052) Release Testing: Verify FLINK-30707 Improve slow task detection

[ https://issues.apache.org/jira/browse/FLINK-31052?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu closed FLINK-31052. --- Resolution: Done Thanks for helping with the testing! [~JunRuiLi] > Release Testing: Verify FLINK-30707

[jira] [Closed] (FLINK-31005) Release Testing: Verify FLIP-281 Supports speculative execution of sinks

[ https://issues.apache.org/jira/browse/FLINK-31005?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu closed FLINK-31005. --- Resolution: Done Thanks for helping with the testing! [~wanglijie] > Release Testing: Verify FLIP-281

[jira] [Updated] (FLINK-31077) Trigger checkpoint failed but it were shown as COMPLETED by rest API

[ https://issues.apache.org/jira/browse/FLINK-31077?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-31077: Fix Version/s: (was: 1.15.4) > Trigger checkpoint failed but it were shown as COMPLETED by rest API >

[jira] [Updated] (FLINK-31077) Trigger checkpoint failed but it were shown as COMPLETED by rest API

[ https://issues.apache.org/jira/browse/FLINK-31077?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-31077: Priority: Major (was: Critical) > Trigger checkpoint failed but it were shown as COMPLETED by rest API >

[jira] [Comment Edited] (FLINK-31077) Trigger checkpoint failed but it were shown as COMPLETED by rest API

[ https://issues.apache.org/jira/browse/FLINK-31077?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17688858#comment-17688858 ] Zhu Zhu edited comment on FLINK-31077 at 2/20/23 9:53 AM: -- Thanks for reporting

[jira] [Comment Edited] (FLINK-31077) Trigger checkpoint failed but it were shown as COMPLETED by rest API

[ https://issues.apache.org/jira/browse/FLINK-31077?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17688858#comment-17688858 ] Zhu Zhu edited comment on FLINK-31077 at 2/20/23 9:52 AM: -- Thanks for reporting

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

[ https://issues.apache.org/jira/browse/FLINK-31124?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-31124: Component/s: Tests > Add it case for HiveTableSink speculative execution >

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

[ https://issues.apache.org/jira/browse/FLINK-31123?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-31123: Component/s: Tests > Add it case for FileSink speculative execution >

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

[ https://issues.apache.org/jira/browse/FLINK-31123?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17690774#comment-17690774 ] Zhu Zhu commented on FLINK-31123: - Thanks for volunteering to take this task. [~freeke] I have assigned

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

[ https://issues.apache.org/jira/browse/FLINK-31123?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-31123: Priority: Major (was: Minor) > Add it case for FileSink speculative execution >

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

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

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

[ https://issues.apache.org/jira/browse/FLINK-31124?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17690773#comment-17690773 ] Zhu Zhu commented on FLINK-31124: - Thanks for creating the PR! I will take a look. The ticket is now

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

[ https://issues.apache.org/jira/browse/FLINK-31124?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu reassigned FLINK-31124: --- Assignee: Shuiqiang Chen (was: chenshuiqiang) > Add it case for HiveTableSink speculative

[jira] [Commented] (FLINK-31041) Race condition in DefaultScheduler results in memory leak and busy loop

[ https://issues.apache.org/jira/browse/FLINK-31041?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17690678#comment-17690678 ] Zhu Zhu commented on FLINK-31041: - I have assigned you the ticket. [~huwh] Feel free to open a pr for

[jira] [Assigned] (FLINK-31041) Race condition in DefaultScheduler results in memory leak and busy loop

[ https://issues.apache.org/jira/browse/FLINK-31041?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu reassigned FLINK-31041: --- Assignee: Weihua Hu (was: Danny Cranmer) > Race condition in DefaultScheduler results in memory

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

[ https://issues.apache.org/jira/browse/FLINK-31124?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17690677#comment-17690677 ] Zhu Zhu commented on FLINK-31124: - [~csq] Thanks for volunteering! I have assigned you the ticket. >

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

[ https://issues.apache.org/jira/browse/FLINK-31124?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-31124: Priority: Major (was: Minor) > Add it case for HiveTableSink speculative execution >

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

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

[jira] [Comment Edited] (FLINK-31041) Race condition in DefaultScheduler results in memory leak and busy loop

[ https://issues.apache.org/jira/browse/FLINK-31041?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17689653#comment-17689653 ] Zhu Zhu edited comment on FLINK-31041 at 2/17/23 9:48 AM: -- Thanks for the

[jira] [Commented] (FLINK-31041) Race condition in DefaultScheduler results in memory leak and busy loop

[ https://issues.apache.org/jira/browse/FLINK-31041?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17690131#comment-17690131 ] Zhu Zhu commented on FLINK-31041: - I think yes, or even a wider scope in

[jira] [Commented] (FLINK-31041) Race condition in DefaultScheduler results in memory leak and busy loop

[ https://issues.apache.org/jira/browse/FLINK-31041?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17689677#comment-17689677 ] Zhu Zhu commented on FLINK-31041: - [~huwh] I just see you comments. I think it's mostly answered in my

[jira] [Comment Edited] (FLINK-31041) Race condition in DefaultScheduler results in memory leak and busy loop

[ https://issues.apache.org/jira/browse/FLINK-31041?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17689653#comment-17689653 ] Zhu Zhu edited comment on FLINK-31041 at 2/16/23 9:51 AM: -- Thanks for the

[jira] [Comment Edited] (FLINK-31041) Race condition in DefaultScheduler results in memory leak and busy loop

[ https://issues.apache.org/jira/browse/FLINK-31041?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17689653#comment-17689653 ] Zhu Zhu edited comment on FLINK-31041 at 2/16/23 9:50 AM: -- Thanks for the

[jira] [Commented] (FLINK-31041) Race condition in DefaultScheduler results in memory leak and busy loop

[ https://issues.apache.org/jira/browse/FLINK-31041?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17689653#comment-17689653 ] Zhu Zhu commented on FLINK-31041: - Thanks for the inputs! I took another look through the failure

[jira] [Updated] (FLINK-31041) Race condition in DefaultScheduler results in memory leak and busy loop

[ https://issues.apache.org/jira/browse/FLINK-31041?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-31041: Attachment: failovers.log > Race condition in DefaultScheduler results in memory leak and busy loop >

[jira] [Updated] (FLINK-31041) Race condition in DefaultScheduler results in memory leak and busy loop

[ https://issues.apache.org/jira/browse/FLINK-31041?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-31041: Attachment: test-restart-strategy.log > Race condition in DefaultScheduler results in memory leak and

[jira] [Commented] (FLINK-31041) Race condition in DefaultScheduler results in memory leak and busy loop

[ https://issues.apache.org/jira/browse/FLINK-31041?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17689015#comment-17689015 ] Zhu Zhu commented on FLINK-31041: - Thanks for reporting this issue! [~dannycranmer] I have tried to

[jira] [Updated] (FLINK-31077) Trigger checkpoint failed but it were shown as COMPLETED by rest API

[ https://issues.apache.org/jira/browse/FLINK-31077?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-31077: Priority: Critical (was: Major) > Trigger checkpoint failed but it were shown as COMPLETED by rest API >

[jira] [Assigned] (FLINK-31077) Trigger checkpoint failed but it were shown as COMPLETED by rest API

[ https://issues.apache.org/jira/browse/FLINK-31077?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu reassigned FLINK-31077: --- Assignee: Junrui Li > Trigger checkpoint failed but it were shown as COMPLETED by rest API >

[jira] [Commented] (FLINK-31077) Trigger checkpoint failed but it were shown as COMPLETED by rest API

[ https://issues.apache.org/jira/browse/FLINK-31077?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17688858#comment-17688858 ] Zhu Zhu commented on FLINK-31077: - Thanks for reporting this issue! [~JunRuiLi] I think it is indeed a

[jira] [Updated] (FLINK-31052) Release Testing: Verify FLINK-30707 Improve slow task detection

[ https://issues.apache.org/jira/browse/FLINK-31052?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-31052: Description: This task aims to verify [FLINK-30707|https://issues.apache.org/jira/browse/FLINK-30707]

[jira] [Updated] (FLINK-31052) Release Testing: Verify FLINK-30707 Improve slow task detection

[ https://issues.apache.org/jira/browse/FLINK-31052?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-31052: Priority: Blocker (was: Major) > Release Testing: Verify FLINK-30707 Improve slow task detection >

[jira] [Created] (FLINK-31052) Release Testing: Verify FLINK-30707 Improve slow task detection

Zhu Zhu created FLINK-31052: --- Summary: Release Testing: Verify FLINK-30707 Improve slow task detection Key: FLINK-31052 URL: https://issues.apache.org/jira/browse/FLINK-31052 Project: Flink Issue

[jira] [Closed] (FLINK-30904) Update the documentation and configuration description of slow task detector

[ https://issues.apache.org/jira/browse/FLINK-30904?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu closed FLINK-30904. --- Resolution: Done master: ffecb68b11e2cd914f92699112b5adb62a48724e release-1.17:

[jira] [Updated] (FLINK-31005) Release Testing: Verify FLIP-281 Supports speculative execution of sinks

[ https://issues.apache.org/jira/browse/FLINK-31005?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-31005: Description: This task aims to verify [FLIP-281 Supports speculative execution of

[jira] [Created] (FLINK-31005) Release Testing: Verify FLIP-281 Supports speculative execution of sinks

Zhu Zhu created FLINK-31005: --- Summary: Release Testing: Verify FLIP-281 Supports speculative execution of sinks Key: FLINK-31005 URL: https://issues.apache.org/jira/browse/FLINK-31005 Project: Flink

[jira] [Updated] (FLINK-30990) Performance of deployDownstreamTasks.BATCH has worsened

[ https://issues.apache.org/jira/browse/FLINK-30990?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-30990: Labels: (was: pull-request-available) > Performance of deployDownstreamTasks.BATCH has worsened >

[jira] [Commented] (FLINK-30942) Fix the bug that the decided parallelism by adaptive batch scheduler may be larger than the max parallelism

[ https://issues.apache.org/jira/browse/FLINK-30942?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17686492#comment-17686492 ] Zhu Zhu commented on FLINK-30942: - master: 5a4e0ea31aef51dfc50b9c401c91c7b869a154c4 release-1.17:

[jira] [Comment Edited] (FLINK-30990) Performance of deployDownstreamTasks.BATCH has worsened

[ https://issues.apache.org/jira/browse/FLINK-30990?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17686485#comment-17686485 ] Zhu Zhu edited comment on FLINK-30990 at 2/9/23 1:21 PM: - Thanks for reporting!

[jira] [Commented] (FLINK-30990) Performance of deployDownstreamTasks.BATCH has worsened

[ https://issues.apache.org/jira/browse/FLINK-30990?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17686485#comment-17686485 ] Zhu Zhu commented on FLINK-30990: - This regression should have been caused by some recent improvements

[jira] [Commented] (FLINK-30198) Support AdaptiveBatchScheduler to set per-task size for reducer task

[ https://issues.apache.org/jira/browse/FLINK-30198?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17686326#comment-17686326 ] Zhu Zhu commented on FLINK-30198: - Flink scheduler currently is not aware of operators at the moment,

[jira] [Comment Edited] (FLINK-30198) Support AdaptiveBatchScheduler to set per-task size for reducer task

[ https://issues.apache.org/jira/browse/FLINK-30198?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17646961#comment-17646961 ] Zhu Zhu edited comment on FLINK-30198 at 2/9/23 9:41 AM: - In our experience, map

[jira] [Comment Edited] (FLINK-30838) Update documentation about the AdaptiveBatchScheduler

[ https://issues.apache.org/jira/browse/FLINK-30838?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17686158#comment-17686158 ] Zhu Zhu edited comment on FLINK-30838 at 2/9/23 6:49 AM: - master:

[jira] [Closed] (FLINK-30682) FLIP-283: Use adaptive batch scheduler as default scheduler for batch jobs

[ https://issues.apache.org/jira/browse/FLINK-30682?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu closed FLINK-30682. --- Release Note: Adaptive batch scheduler are now used for batch jobs by default. It will automatically decide

[jira] [Updated] (FLINK-30972) E2e tests always fail in phase "Prepare E2E run"

[ https://issues.apache.org/jira/browse/FLINK-30972?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-30972: Priority: Blocker (was: Critical) > E2e tests always fail in phase "Prepare E2E run" >

[jira] [Updated] (FLINK-30972) E2e tests always fail in phase "Prepare E2E run"

[ https://issues.apache.org/jira/browse/FLINK-30972?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-30972: Affects Version/s: 1.17.0 > E2e tests always fail in phase "Prepare E2E run" >

[jira] [Updated] (FLINK-30917) The user configured max parallelism does not take effect when using adaptive batch scheduler

[ https://issues.apache.org/jira/browse/FLINK-30917?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-30917: Affects Version/s: 1.16.1 1.17.0 > The user configured max parallelism does not

[jira] [Updated] (FLINK-30942) Fix the bug that the decided parallelism by adaptive batch scheduler may be larger than the max parallelism

[ https://issues.apache.org/jira/browse/FLINK-30942?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-30942: Affects Version/s: 1.16.1 1.17.0 > Fix the bug that the decided parallelism by

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