[jira] [Updated] (FLINK-30707) Let speculative execution take input data amount into account when detecting slow tasks

2023-01-16 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30707?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-30707: Summary: Let speculative execution take input data amount into account when detecting slow tasks (was:

[jira] [Commented] (FLINK-30707) Let speculative execution takes input data amount into account when detecting slow tasks

2023-01-16 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30707?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17677584#comment-17677584 ] Zhu Zhu commented on FLINK-30707: - Thanks for the proposal! [~xiasun] I have assigned you the ticket. >

[jira] [Assigned] (FLINK-30707) Let speculative execution takes input data amount into account when detecting slow tasks

2023-01-16 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30707?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu reassigned FLINK-30707: --- Assignee: xingbe > Let speculative execution takes input data amount into account when detecting

[jira] [Assigned] (FLINK-30683) Make adaptive batch scheduler as the default batch scheduler

2023-01-13 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30683?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu reassigned FLINK-30683: --- Assignee: Junrui Li > Make adaptive batch scheduler as the default batch scheduler >

[jira] [Assigned] (FLINK-30685) Support mark the transformations whose parallelism is infected by the input transformation

2023-01-13 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30685?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu reassigned FLINK-30685: --- Assignee: Junrui Li > Support mark the transformations whose parallelism is infected by the input

[jira] [Assigned] (FLINK-30686) Simplify the configuration of adaptive batch scheduler

2023-01-13 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30686?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu reassigned FLINK-30686: --- Assignee: Junrui Li > Simplify the configuration of adaptive batch scheduler >

[jira] [Assigned] (FLINK-30684) Use the default parallelism as a flag for vertices that can automatically derive parallelism.

2023-01-13 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30684?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu reassigned FLINK-30684: --- Assignee: Junrui Li > Use the default parallelism as a flag for vertices that can automatically >

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

2023-01-13 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30682?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu reassigned FLINK-30682: --- Assignee: Junrui Li > FLIP-283: Use adaptive batch scheduler as default scheduler for batch jobs >

[jira] [Commented] (FLINK-30108) ZooKeeperLeaderElectionConnectionHandlingTest.testLoseLeadershipOnLostConnectionIfTolerateSuspendedConnectionsIsEnabled times out

2023-01-10 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30108?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17656512#comment-17656512 ] Zhu Zhu commented on FLINK-30108: - In the test logs, I can see that {code:java} 00:59:45,201 [

[jira] [Commented] (FLINK-30108) ZooKeeperLeaderElectionConnectionHandlingTest.testLoseLeadershipOnLostConnectionIfTolerateSuspendedConnectionsIsEnabled times out

2023-01-05 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30108?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17655241#comment-17655241 ] Zhu Zhu commented on FLINK-30108: - Thanks for the input! [~mapohl] I can see tens of thousands occurring

[jira] [Commented] (FLINK-30108) flink-core module tests exited with code 143

2023-01-05 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30108?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17654892#comment-17654892 ] Zhu Zhu commented on FLINK-30108: - The case seems to be the {{grantLeadership}} did not succeed in

[jira] [Updated] (FLINK-30461) Some rocksdb sst files will remain forever

2023-01-05 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30461?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-30461: Component/s: Runtime / State Backends > Some rocksdb sst files will remain forever >

[jira] [Closed] (FLINK-30454) Inconsistent class hierarchy in TaskIOMetricGroup

2023-01-05 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30454?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu closed FLINK-30454. --- Resolution: Fixed > Inconsistent class hierarchy in TaskIOMetricGroup >

[jira] [Closed] (FLINK-30558) The metric 'numRestarts' reported in SchedulerBase will be overridden by metric 'fullRestarts'

2023-01-04 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30558?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu closed FLINK-30558. --- Resolution: Fixed master: b50f42673fcd44bdd6de73f77d646df5c2ad1eed 1.16:

[jira] [Updated] (FLINK-30558) The metric 'numRestarts' reported in SchedulerBase will be overridden by metric 'fullRestarts'

2023-01-04 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30558?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-30558: Affects Version/s: 1.16.0 > The metric 'numRestarts' reported in SchedulerBase will be overridden by >

[jira] [Updated] (FLINK-30558) The metric 'numRestarts' reported in SchedulerBase will be overridden by metric 'fullRestarts'

2023-01-04 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30558?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-30558: Fix Version/s: 1.16.1 > The metric 'numRestarts' reported in SchedulerBase will be overridden by >

[jira] [Commented] (FLINK-30558) The metric 'numRestarts' reported in SchedulerBase will be overridden by metric 'fullRestarts'

2023-01-04 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30558?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17654382#comment-17654382 ] Zhu Zhu commented on FLINK-30558: - Yes this is a problem, especially considering that {{fullRestarts}}

[jira] [Assigned] (FLINK-30558) The metric 'numRestarts' reported in SchedulerBase will be overridden by metric 'fullRestarts'

2023-01-04 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30558?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu reassigned FLINK-30558: --- Assignee: xingbe > The metric 'numRestarts' reported in SchedulerBase will be overridden by >

[jira] [Updated] (FLINK-30108) flink-core module tests exited with code 143

2022-12-29 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30108?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-30108: Component/s: Runtime / Coordination (was: API / Core) > flink-core module tests

[jira] [Commented] (FLINK-30108) flink-core module tests exited with code 143

2022-12-29 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30108?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17652779#comment-17652779 ] Zhu Zhu commented on FLINK-30108: - The stuck case is ZooKeeperLeaderElectionConnectionHandlingTest.

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

2022-12-29 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29660?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu closed FLINK-29660. --- Resolution: Won't Fix In FLINK-30358, the taskmanager IDs of failed tasks are now displayed the exception

[jira] [Updated] (FLINK-30102) Unstable test EventTimeWindowCheckpointingITCase.testPreAggregatedSlidingTimeWindow failed runs on azure

2022-12-29 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30102?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-30102: Component/s: Runtime / State Backends > Unstable test >

[jira] [Commented] (FLINK-30102) Unstable test EventTimeWindowCheckpointingITCase.testPreAggregatedSlidingTimeWindow failed runs on azure

2022-12-29 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30102?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17652770#comment-17652770 ] Zhu Zhu commented on FLINK-30102: - I can see exception below: {code:java} 2022-11-20T06:01:49.7205648Z

[jira] [Commented] (FLINK-30131) flink iterate will suspend when record is a bit large

2022-12-29 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30131?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17652765#comment-17652765 ] Zhu Zhu commented on FLINK-30131: - [~landlord] do you have any updates for this issue? > flink iterate

[jira] [Closed] (FLINK-30364) Job failed without exception stack

2022-12-29 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30364?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu closed FLINK-30364. --- Resolution: Not A Problem > Job failed without exception stack > -- > >

[jira] [Commented] (FLINK-30364) Job failed without exception stack

2022-12-29 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30364?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17652759#comment-17652759 ] Zhu Zhu commented on FLINK-30364: - Close this ticket for now because it's likely to be the case

[jira] [Closed] (FLINK-30334) SourceCoordinator error splitRequest check cause HybridSource loss of data and hang

2022-12-26 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30334?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu closed FLINK-30334. --- Resolution: Fixed master: 6e4e6c68a4a179d932dacafb2771cc84f730bbc0 1.16:

[jira] [Closed] (FLINK-30358) Show the task manager id on the exception history page

2022-12-26 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30358?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu closed FLINK-30358. --- Fix Version/s: 1.17.0 Resolution: Done master: d4f9656d56cc495e1df78eaf1f25f82c18640e02

[jira] [Commented] (FLINK-30443) Expand list of sensitive keys

2022-12-22 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30443?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17651148#comment-17651148 ] Zhu Zhu commented on FLINK-30443: - I think adding a Flink configuration, e.g. security.sensitive-keys,

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

2022-12-21 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30480?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17651066#comment-17651066 ] Zhu Zhu commented on FLINK-30480: - Thanks for volunteering. [~xiasun] I have assigned you the ticket. >

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

2022-12-21 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30480?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu reassigned FLINK-30480: --- Assignee: xingbe > Add benchmarks for adaptive batch scheduler >

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

2022-12-21 Thread Zhu Zhu (Jira)
Zhu Zhu created FLINK-30480: --- Summary: Add benchmarks for adaptive batch scheduler Key: FLINK-30480 URL: https://issues.apache.org/jira/browse/FLINK-30480 Project: Flink Issue Type: Improvement

[jira] (FLINK-15325) Input location preference which affects task distribution may make certain job performance worse

2022-12-20 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15325 ] Zhu Zhu deleted comment on FLINK-15325: - was (Author: flink-jira-bot): This issue was labeled "stale-minor" 7 days ago and has not received any updates so it is being deprioritized. If this

[jira] (FLINK-15325) Input location preference which affects task distribution may make certain job performance worse

2022-12-20 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15325 ] Zhu Zhu deleted comment on FLINK-15325: - was (Author: flink-jira-bot): This issue was labeled "stale-major" 7 ago and has not received any updates so it is being deprioritized. If this ticket

[jira] (FLINK-15325) Input location preference which affects task distribution may make certain job performance worse

2022-12-20 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15325 ] Zhu Zhu deleted comment on FLINK-15325: - was (Author: flink-jira-bot): This major issue is unassigned and itself and all of its Sub-Tasks have not been updated for 30 days. So, it has been

[jira] (FLINK-15325) Input location preference which affects task distribution may make certain job performance worse

2022-12-20 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15325 ] Zhu Zhu deleted comment on FLINK-15325: - 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] [Comment Edited] (FLINK-30364) Job failed without exception stack

2022-12-15 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30364?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17647918#comment-17647918 ] Zhu Zhu edited comment on FLINK-30364 at 12/15/22 8:41 AM: --- [~dianfu] is there

[jira] [Commented] (FLINK-30364) Job failed without exception stack

2022-12-15 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30364?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17647918#comment-17647918 ] Zhu Zhu commented on FLINK-30364: - [~dianfu] is there a way to reproduce this issue? > Job failed

[jira] [Comment Edited] (FLINK-30246) Registering the same metric object with different name and group will conflict in metric reporter

2022-12-14 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30246?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17647898#comment-17647898 ] Zhu Zhu edited comment on FLINK-30246 at 12/15/22 7:57 AM: --- You are right.

[jira] [Updated] (FLINK-30246) Registering the same metric object with different name and group will conflict in metric reporter

2022-12-14 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30246?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-30246: Fix Version/s: 2.0.0 > Registering the same metric object with different name and group will > conflict

[jira] [Commented] (FLINK-30246) Registering the same metric object with different name and group will conflict in metric reporter

2022-12-14 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30246?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17647898#comment-17647898 ] Zhu Zhu commented on FLINK-30246: - You are right. Unfortunately, we cannot change the protected fields

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

2022-12-13 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30198?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17646961#comment-17646961 ] Zhu Zhu commented on FLINK-30198: - In our experience, map tasks are also possible to be heavy, depending

[jira] [Commented] (FLINK-30358) Show the task manager id on the exception history page

2022-12-10 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30358?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17645714#comment-17645714 ] Zhu Zhu commented on FLINK-30358: - This sounds a good improvement. Thanks for proposing this!

[jira] [Assigned] (FLINK-30358) Show the task manager id on the exception history page

2022-12-10 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30358?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu reassigned FLINK-30358: --- Assignee: JunRui Li > Show the task manager id on the exception history page >

[jira] [Updated] (FLINK-30334) SourceCoordinator error splitRequest check cause HybridSource loss of data and hang

2022-12-09 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30334?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-30334: Fix Version/s: 1.16.1 > SourceCoordinator error splitRequest check cause HybridSource loss of data > and

[jira] [Updated] (FLINK-30334) SourceCoordinator error splitRequest check cause HybridSource loss of data and hang

2022-12-09 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30334?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-30334: Fix Version/s: 1.17.0 > SourceCoordinator error splitRequest check cause HybridSource loss of data > and

[jira] [Commented] (FLINK-30334) SourceCoordinator error splitRequest check cause HybridSource loss of data and hang

2022-12-09 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30334?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17645220#comment-17645220 ] Zhu Zhu commented on FLINK-30334: - Thanks for volunteering to fix it. [~lemonjing] I have assigned you

[jira] [Assigned] (FLINK-30334) SourceCoordinator error splitRequest check cause HybridSource loss of data and hang

2022-12-09 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30334?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu reassigned FLINK-30334: --- Assignee: Ran Tao > SourceCoordinator error splitRequest check cause HybridSource loss of data >

[jira] [Commented] (FLINK-30334) SourceCoordinator error splitRequest check cause HybridSource loss of data and hang

2022-12-08 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30334?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17645062#comment-17645062 ] Zhu Zhu commented on FLINK-30334: - Thanks for reporting this issue! [~lemonjing] It is unexpected that

[jira] [Closed] (FLINK-28982) Start TaskInterrupter when task switch from DEPLOYING to CANCELING

2022-12-08 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28982?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu closed FLINK-28982. --- Resolution: Not A Bug > Start TaskInterrupter when task switch from DEPLOYING to CANCELING >

[jira] [Commented] (FLINK-28982) Start TaskInterrupter when task switch from DEPLOYING to CANCELING

2022-12-08 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28982?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17644693#comment-17644693 ] Zhu Zhu commented on FLINK-28982: - The related remote shuffle service problem is already fixed:

[jira] [Commented] (FLINK-28982) Start TaskInterrupter when task switch from DEPLOYING to CANCELING

2022-12-08 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28982?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17644688#comment-17644688 ] Zhu Zhu commented on FLINK-28982: - This is an intentional behavior because Flink does not want to

[jira] [Assigned] (FLINK-30246) Registering the same metric object with different name and group will conflict in metric reporter

2022-12-07 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30246?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu reassigned FLINK-30246: --- Assignee: xingbe > Registering the same metric object with different name and group will >

[jira] [Commented] (FLINK-30246) Registering the same metric object with different name and group will conflict in metric reporter

2022-12-07 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30246?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17644595#comment-17644595 ] Zhu Zhu commented on FLINK-30246: - Thanks for volunteering to take this ticket! I have assigned you the

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

2022-12-01 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29809?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu closed FLINK-29809. --- Resolution: Invalid > REST API for running a Flink job > > >

[jira] [Commented] (FLINK-29167) Time out-of-order optimization for merging multiple data streams into one data stream

2022-12-01 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29167?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17641771#comment-17641771 ] Zhu Zhu commented on FLINK-29167: - The record orders are retained if they are from the same source and

[jira] [Closed] (FLINK-29167) Time out-of-order optimization for merging multiple data streams into one data stream

2022-12-01 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29167?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu closed FLINK-29167. --- Resolution: Not A Problem Closing the ticket because it does not seem to be a problem and is not active

[jira] [Updated] (FLINK-29167) Time out-of-order optimization for merging multiple data streams into one data stream

2022-12-01 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29167?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-29167: Fix Version/s: (was: 1.14.2) > Time out-of-order optimization for merging multiple data streams into

[jira] [Updated] (FLINK-30072) Cannot assign instance of SerializedLambda to field KeyGroupStreamPartitioner.keySelector

2022-12-01 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30072?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-30072: Component/s: Runtime / Task (was: Runtime / Coordination) > Cannot assign instance

[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 >

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