[jira] [Updated] (FLINK-21000) set MetricGroup in SourceCoordinatorContext

2022-11-17 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21000?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-21000: Labels: (was: auto-deprioritized-major auto-deprioritized-minor stale-assigned) > set MetricGroup in

[jira] [Commented] (FLINK-29899) flink-runtime tests fail with exit code 137 returned from Docker

2022-11-17 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29899?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17635260#comment-17635260 ] Zhu Zhu commented on FLINK-29899: - The exception seems to be unrelated. I saw in the weekly updates

[jira] [Closed] (FLINK-29629) FlameGraph is empty for Legacy Source Threads

2022-11-10 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29629?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu closed FLINK-29629. --- Resolution: Not A Bug > FlameGraph is empty for Legacy Source Threads >

[jira] [Commented] (FLINK-29629) FlameGraph is empty for Legacy Source Threads

2022-11-10 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29629?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17632111#comment-17632111 ] Zhu Zhu commented on FLINK-29629: - I opened another improvement ticket FLINK-29989 to track the future

[jira] [Created] (FLINK-29989) Enable FlameGraph for arbitrary thread on TaskManager

2022-11-10 Thread Zhu Zhu (Jira)
Zhu Zhu created FLINK-29989: --- Summary: Enable FlameGraph for arbitrary thread on TaskManager Key: FLINK-29989 URL: https://issues.apache.org/jira/browse/FLINK-29989 Project: Flink Issue Type:

[jira] [Updated] (FLINK-29801) OperatorCoordinator need open the way to operate metricGroup interface

2022-11-03 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29801?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-29801: Component/s: Runtime / Metrics (was: Runtime / Coordination) > OperatorCoordinator

[jira] [Assigned] (FLINK-29801) OperatorCoordinator need open the way to operate metricGroup interface

2022-11-03 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29801?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu reassigned FLINK-29801: --- Assignee: yuemeng > OperatorCoordinator need open the way to operate metricGroup interface >

[jira] [Commented] (FLINK-29809) REST API for running a Flink job

2022-11-03 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29809?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17628150#comment-17628150 ] Zhu Zhu commented on FLINK-29809: - Flink already supports submitting a job using REST API and this is

[jira] [Commented] (FLINK-29801) OperatorCoordinator need open the way to operate metricGroup interface

2022-11-03 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29801?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17628143#comment-17628143 ] Zhu Zhu commented on FLINK-29801: - The requirement makes sense. I will take a look at the pull request.

[jira] [Commented] (FLINK-28697) MapDataSerializer doesn't declare a serialVersionUID

2022-10-31 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28697?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17626487#comment-17626487 ] Zhu Zhu commented on FLINK-28697: - My major concern is that whether the change is possible to break the

[jira] [Commented] (FLINK-28697) MapDataSerializer doesn't declare a serialVersionUID

2022-10-27 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28697?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17624970#comment-17624970 ] Zhu Zhu commented on FLINK-28697: - Thanks for reporting this problem and opening a PR to fix it.

[jira] [Closed] (FLINK-28784) ParameterTool support read and parse program arguments from yml file

2022-10-27 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28784?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu closed FLINK-28784. --- Fix Version/s: (was: 1.15.3) Resolution: Won't Do Close this ticket because it is inactive. >

[jira] [Comment Edited] (FLINK-29660) Show all attempts of subtasks in WebUI

2022-10-26 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29660?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17624818#comment-17624818 ] Zhu Zhu edited comment on FLINK-29660 at 10/27/22 2:14 AM: --- In the exception

[jira] [Commented] (FLINK-29660) Show all attempts of subtasks in WebUI

2022-10-26 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29660?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17624818#comment-17624818 ] Zhu Zhu commented on FLINK-29660: - In the exception history, it already shows all the root exceptions

[jira] [Commented] (FLINK-29629) FlameGraph is empty for Legacy Source Threads

2022-10-26 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29629?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17624812#comment-17624812 ] Zhu Zhu commented on FLINK-29629: - Unfortunately we do not have enough resources to make this

[jira] [Updated] (FLINK-29684) [UI] Upgrade runtime web Angular framework and associated deps to v14

2022-10-23 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29684?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-29684: Fix Version/s: 1.17.0 > [UI] Upgrade runtime web Angular framework and associated deps to v14 >

[jira] [Commented] (FLINK-29650) Printing the contents of error lines when parsing yaml file may leak sensitive configuration values

2022-10-20 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29650?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17620857#comment-17620857 ] Zhu Zhu commented on FLINK-29650: - [~lyssg] would you share more information about what your config is

[jira] [Commented] (FLINK-29647) report stackoverflow when using kryo

2022-10-20 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29647?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17620854#comment-17620854 ] Zhu Zhu commented on FLINK-29647: - [~jackin853] I think you are right that is is a known issue of kryo

[jira] [Commented] (FLINK-29660) Show all attempts of subtasks in WebUI

2022-10-20 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29660?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17620833#comment-17620833 ] Zhu Zhu commented on FLINK-29660: - To check the failed attempt, I think it's better to check the

[jira] [Commented] (FLINK-29629) FlameGraph is empty for Legacy Source Threads

2022-10-20 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29629?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17620781#comment-17620781 ] Zhu Zhu commented on FLINK-29629: - [~pvary] Flink is turning to [new

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

2022-10-20 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28324?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu closed FLINK-28324. --- Resolution: Done master: 7f639a8ce4741f072621ac87976aa2589e9cfae0 > JUnit5 Migration] Module:

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

2022-10-20 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28324?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-28324: Fix Version/s: 1.17.0 > JUnit5 Migration] Module: flink-sql-client >

[jira] [Comment Edited] (FLINK-29629) FlameGraph is empty for Legacy Source Threads

2022-10-16 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29629?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17618392#comment-17618392 ] Zhu Zhu edited comment on FLINK-29629 at 10/17/22 3:13 AM: --- Thanks for

[jira] [Commented] (FLINK-29629) FlameGraph is empty for Legacy Source Threads

2022-10-16 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29629?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17618392#comment-17618392 ] Zhu Zhu commented on FLINK-29629: - Thanks for reporting this! I agree it is not ideal but I think it is

[jira] [Comment Edited] (FLINK-29629) FlameGraph is empty for Legacy Source Threads

2022-10-16 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29629?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17618392#comment-17618392 ] Zhu Zhu edited comment on FLINK-29629 at 10/17/22 3:12 AM: --- Thanks for

[jira] [Closed] (FLINK-29308) NoResourceAvailableException fails the batch job

2022-10-09 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29308?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu closed FLINK-29308. --- Resolution: Won't Fix > NoResourceAvailableException fails the batch job >

[jira] [Commented] (FLINK-29308) NoResourceAvailableException fails the batch job

2022-09-29 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29308?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17611349#comment-17611349 ] Zhu Zhu commented on FLINK-29308: - It's possible that the released resource cannot fulfill the new slot

[jira] [Comment Edited] (FLINK-29308) NoResourceAvailableException fails the batch job

2022-09-29 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29308?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17611332#comment-17611332 ] Zhu Zhu edited comment on FLINK-29308 at 9/30/22 3:34 AM: -- That may be the

[jira] [Commented] (FLINK-29308) NoResourceAvailableException fails the batch job

2022-09-29 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29308?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17611332#comment-17611332 ] Zhu Zhu commented on FLINK-29308: - That may be the cause. If using fine grained resource,

[jira] [Commented] (FLINK-29308) NoResourceAvailableException fails the batch job

2022-09-29 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29308?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17610914#comment-17610914 ] Zhu Zhu commented on FLINK-29308: - [~aitozi] would you share more details of the failed job? - Flink

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

2022-09-26 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28131?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu closed FLINK-28131. --- Release Note: Speculative execution(FLIP-168) is introduced in Flink 1.16 to mitigate batch job slowness

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

2022-09-26 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28131?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu reopened FLINK-28131: - > FLIP-168: Speculative Execution for Batch Job > - > >

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

2022-09-02 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28981?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu closed FLINK-28981. --- Resolution: Done > Release Testing: Verify FLIP-245 sources speculative execution >

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

2022-09-02 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28981?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17599499#comment-17599499 ] Zhu Zhu commented on FLINK-28981: - Thanks for helping with this release testing! [~337361...@qq.com] >

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

2022-08-31 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28980?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17598711#comment-17598711 ] Zhu Zhu commented on FLINK-28980: - Thanks for helping with the release testing! [~SleePy] > Release

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

2022-08-31 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28980?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu closed FLINK-28980. --- Resolution: Done > Release Testing: Verify FLIP-168 speculative execution >

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

2022-08-31 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28907?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-28907: Fix Version/s: (was: 1.16.0) > Flink docs do not compile locally > -

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

2022-08-31 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28907?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu closed FLINK-28907. --- Resolution: Won't Fix > Flink docs do not compile locally > - > >

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

2022-08-31 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28907?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17598246#comment-17598246 ] Zhu Zhu commented on FLINK-28907: - Got it! Thanks for the explanation. > Flink docs do not compile

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

2022-08-30 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28907?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17598146#comment-17598146 ] Zhu Zhu commented on FLINK-28907: - Thanks for looking into this! [~martijnvisser] Do you mean the

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

2022-08-29 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28940?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu closed FLINK-28940. --- Resolution: Done > Release Testing: Verify FLIP-248 Dynamic Partition Prunning >

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

2022-08-16 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28980?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu reassigned FLINK-28980: --- Assignee: Biao Liu > Release Testing: Verify FLIP-168 speculative execution >

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

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

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

2022-08-16 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28980?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-28980: Labels: release-testing (was: test-stability) > Release Testing: Verify FLIP-168 speculative execution >

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

2022-08-10 Thread Zhu Zhu (Jira)
Zhu Zhu created FLINK-28907: --- Summary: Flink docs does not compile Key: FLINK-28907 URL: https://issues.apache.org/jira/browse/FLINK-28907 Project: Flink Issue Type: Bug Components:

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

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

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

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

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

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

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

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

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

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

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

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

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

2022-08-04 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: Fix Version/s: (was: 1.16.0) > Improve logs to better display Execution >

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

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

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

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

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

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

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

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

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

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

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

2022-08-01 Thread Zhu Zhu (Jira)
Zhu Zhu created FLINK-28771: --- Summary: Assign speculative execution attempt with correct CREATED timestamp Key: FLINK-28771 URL: https://issues.apache.org/jira/browse/FLINK-28771 Project: Flink

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

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

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

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

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

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

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

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

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