[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] [Commented] (FLINK-30221) Fix the bug of sum(try_cast(string as bigint)) return null when partial elements can't convert to bigint

2022-11-30 Thread Tony Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30221?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17641265#comment-17641265 ] Tony Zhu commented on FLINK-30221: -- [~lsy] , I agree with [~martijnvisser]  that it is as expected to

[jira] [Commented] (FLINK-30221) Fix the bug of sum(try_cast(string as bigint)) return null when partial elements can't convert to bigint

2022-11-27 Thread Tony Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30221?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17639823#comment-17639823 ] Tony Zhu commented on FLINK-30221: -- Could you assign to me and I'd like to try the fix. > Fix the bug

[jira] [Commented] (FLINK-30158) [Flink SQL][Protobuf] NullPointerException when querying Kafka topic using repeated or map attributes

2022-11-27 Thread Tony Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30158?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17639822#comment-17639822 ] Tony Zhu commented on FLINK-30158: -- [~jamesmcguirepro]  could you provide more info? I'd like to take a

[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] [Commented] (FLINK-28902) FileSystemJobResultStoreTestInternal is a unit test that's not following the unit test naming convention

2022-09-15 Thread Tony Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28902?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17605588#comment-17605588 ] Tony Zhu commented on FLINK-28902: -- Thanks for review. I created another PR 

[jira] [Comment Edited] (FLINK-28902) FileSystemJobResultStoreTestInternal is a unit test that's not following the unit test naming convents

2022-09-14 Thread Tony Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28902?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17605120#comment-17605120 ] Tony Zhu edited comment on FLINK-28902 at 9/15/22 5:39 AM: --- I created this PR

[jira] [Comment Edited] (FLINK-28902) FileSystemJobResultStoreTestInternal is a unit test that's not following the unit test naming convents

2022-09-14 Thread Tony Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28902?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17605120#comment-17605120 ] Tony Zhu edited comment on FLINK-28902 at 9/15/22 5:38 AM: --- I created this PR

[jira] [Commented] (FLINK-28902) FileSystemJobResultStoreTestInternal is a unit test that's not following the unit test naming convents

2022-09-14 Thread Tony Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28902?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17605120#comment-17605120 ] Tony Zhu commented on FLINK-28902: -- I created this PR. Could you help review please >

[jira] [Commented] (FLINK-28902) FileSystemJobResultStoreTestInternal is a unit test that's not following the unit test naming convents

2022-09-13 Thread Tony Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28902?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17603822#comment-17603822 ] Tony Zhu commented on FLINK-28902: -- Can I try this ticket? > FileSystemJobResultStoreTestInternal is a

[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

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