[jira] [Commented] (FLINK-34588) FineGrainedSlotManager checks whether resources need to reconcile but doesn't act on the result

[ https://issues.apache.org/jira/browse/FLINK-34588?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17824616#comment-17824616 ] Weihua Hu commented on FLINK-34588: --- Thanks [~mapohl]  reporting this.  At the first

[jira] [Resolved] (FLINK-34230) Update flink-docs README: add -Pskip-webui-build to the config doc generation command

[ https://issues.apache.org/jira/browse/FLINK-34230?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weihua Hu resolved FLINK-34230. --- Fix Version/s: 1.19.0 Resolution: Fixed resolved in master: ce67b7d7c380f8639ef2b13ed7b9af34b

[jira] [Assigned] (FLINK-34230) Update flink-docs README: add -Pskip-webui-build to the config doc generation command

[ https://issues.apache.org/jira/browse/FLINK-34230?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weihua Hu reassigned FLINK-34230: - Assignee: Zhanghao Chen > Update flink-docs README: add -Pskip-webui-build to the config doc ge

[jira] [Resolved] (FLINK-31449) Remove DeclarativeSlotManager related logic

[ https://issues.apache.org/jira/browse/FLINK-31449?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weihua Hu resolved FLINK-31449. --- Resolution: Fixed resolved in master: 551b776a82193eeb6bb4a9b8a6925a386ea502e4 > Remove Declarative

[jira] [Assigned] (FLINK-34103) AsyncIO example failed to run as DataGen Connector is not bundled

[ https://issues.apache.org/jira/browse/FLINK-34103?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weihua Hu reassigned FLINK-34103: - Assignee: Zhanghao Chen > AsyncIO example failed to run as DataGen Connector is not bundled > -

[jira] [Assigned] (FLINK-34052) Missing TopSpeedWindowing and SessionWindowing JARs in Flink Maven Repository

[ https://issues.apache.org/jira/browse/FLINK-34052?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weihua Hu reassigned FLINK-34052: - Assignee: Zhanghao Chen > Missing TopSpeedWindowing and SessionWindowing JARs in Flink Maven Re

[jira] [Commented] (FLINK-32880) Redundant taskManagers should always be fulfilled in FineGrainedSlotManager

[ https://issues.apache.org/jira/browse/FLINK-32880?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17800294#comment-17800294 ] Weihua Hu commented on FLINK-32880: --- [~mapohl]  Sorry for missing the merge informatio

[jira] [Resolved] (FLINK-33891) Remove the obsolete SingleJobGraphStore

[ https://issues.apache.org/jira/browse/FLINK-33891?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weihua Hu resolved FLINK-33891. --- Fix Version/s: 1.19.0 Resolution: Fixed resolved in master: c80897642152690ef23978e2090be17e6

[jira] [Assigned] (FLINK-33891) Remove the obsolete SingleJobGraphStore

[ https://issues.apache.org/jira/browse/FLINK-33891?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weihua Hu reassigned FLINK-33891: - Assignee: Zhanghao Chen > Remove the obsolete SingleJobGraphStore > ---

[jira] [Resolved] (FLINK-33702) Add IncrementalDelayRetryStrategy implementation of RetryStrategy

[ https://issues.apache.org/jira/browse/FLINK-33702?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weihua Hu resolved FLINK-33702. --- Fix Version/s: 1.19.0 Resolution: Fixed resolved in master: 0acfc1a51e8802ebd0eb1ab5c00bbfab5

[jira] [Assigned] (FLINK-33702) Add IncrementalDelayRetryStrategy implementation of RetryStrategy

[ https://issues.apache.org/jira/browse/FLINK-33702?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weihua Hu reassigned FLINK-33702: - Assignee: xiangyu feng > Add IncrementalDelayRetryStrategy implementation of RetryStrategy > --

[jira] [Resolved] (FLINK-33643) Allow StreamExecutionEnvironment's executeAsync API to use default JobName

[ https://issues.apache.org/jira/browse/FLINK-33643?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weihua Hu resolved FLINK-33643. --- Fix Version/s: 1.19.0 Resolution: Fixed resolved in master: 220287539854c8f32f9d85541026f2b01

[jira] [Assigned] (FLINK-31449) Remove DeclarativeSlotManager related logic

[ https://issues.apache.org/jira/browse/FLINK-31449?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weihua Hu reassigned FLINK-31449: - Assignee: Weihua Hu > Remove DeclarativeSlotManager related logic > ---

[jira] [Assigned] (FLINK-33643) Allow StreamExecutionEnvironment's executeAsync API to use default JobName

[ https://issues.apache.org/jira/browse/FLINK-33643?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weihua Hu reassigned FLINK-33643: - Assignee: Matt Wang (was: Weihua Hu) > Allow StreamExecutionEnvironment's executeAsync API to

[jira] [Assigned] (FLINK-33643) Allow StreamExecutionEnvironment's executeAsync API to use default JobName

[ https://issues.apache.org/jira/browse/FLINK-33643?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weihua Hu reassigned FLINK-33643: - Assignee: Weihua Hu > Allow StreamExecutionEnvironment's executeAsync API to use default JobNam

[jira] [Updated] (FLINK-31449) Remove DeclarativeSlotManager related logic

[ https://issues.apache.org/jira/browse/FLINK-31449?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weihua Hu updated FLINK-31449: -- Priority: Major (was: Blocker) > Remove DeclarativeSlotManager related logic > --

[jira] [Commented] (FLINK-31449) Remove DeclarativeSlotManager related logic

[ https://issues.apache.org/jira/browse/FLINK-31449?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17786619#comment-17786619 ] Weihua Hu commented on FLINK-31449: --- [~lincoln.86xy] Thanks for the reminding.  The r

[jira] [Resolved] (FLINK-33148) Update Web UI to adopt the new "endpoint" field in REST API

[ https://issues.apache.org/jira/browse/FLINK-33148?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weihua Hu resolved FLINK-33148. --- Resolution: Fixed resolved in master: 5f9bef4288f59f428d4b2036f6eb9b30adf08287, c4f2da4d133690c0eb9

[jira] [Closed] (FLINK-24957) show `host:port` information in `subtasks` tab

[ https://issues.apache.org/jira/browse/FLINK-24957?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weihua Hu closed FLINK-24957. - Resolution: Duplicate > show `host:port` information in `subtasks` tab > ---

[jira] [Resolved] (FLINK-33147) Introduce a new "endpoint" field in REST API to represent TaskManager endpoint (host + port) and deprecate the "host" field

[ https://issues.apache.org/jira/browse/FLINK-33147?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weihua Hu resolved FLINK-33147. --- Resolution: Fixed  resolved in master: f77dbdfd0c7d510ae32ce932c7b84ed968496130 > Introduce a new "

[jira] [Resolved] (FLINK-33160) Log the remote address when an exception occurs in the PartitionRequestQueue

[ https://issues.apache.org/jira/browse/FLINK-33160?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weihua Hu resolved FLINK-33160. --- Resolution: Fixed resolved in master: 32652e1ea10d2578f583f37aeb329e34ad0464c7 > Log the remote add

[jira] [Commented] (FLINK-33160) Log the remote address when an exception occurs in the PartitionRequestQueue

[ https://issues.apache.org/jira/browse/FLINK-33160?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17772916#comment-17772916 ] Weihua Hu commented on FLINK-33160: --- [~lsdy] makes sense to me, would you like prepare

[jira] [Assigned] (FLINK-33147) Introduce a new "endpoint" field in REST API to represent TaskManager endpoint (host + port) and deprecate the "host" field

[ https://issues.apache.org/jira/browse/FLINK-33147?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weihua Hu reassigned FLINK-33147: - Assignee: Zhanghao Chen > Introduce a new "endpoint" field in REST API to represent TaskManager

[jira] [Assigned] (FLINK-33148) Update Web UI to adopt the new "endpoint" field in REST API

[ https://issues.apache.org/jira/browse/FLINK-33148?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weihua Hu reassigned FLINK-33148: - Assignee: Zhanghao Chen > Update Web UI to adopt the new "endpoint" field in REST API > ---

[jira] [Assigned] (FLINK-33146) FLIP-363: Unify the Representation of TaskManager Location in REST API and Web UI

[ https://issues.apache.org/jira/browse/FLINK-33146?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weihua Hu reassigned FLINK-33146: - Assignee: Zhanghao Chen > FLIP-363: Unify the Representation of TaskManager Location in REST AP

[jira] [Updated] (FLINK-25371) Include data port as part of the host info for subtask detail panel on Web UI

[ https://issues.apache.org/jira/browse/FLINK-25371?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weihua Hu updated FLINK-25371: -- Parent: FLINK-33146 Issue Type: Sub-task (was: Improvement) > Include data port as part of th

[jira] [Resolved] (FLINK-32851) [JUnit5 Migration] The rest package of flink-runtime module

[ https://issues.apache.org/jira/browse/FLINK-32851?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weihua Hu resolved FLINK-32851. --- Fix Version/s: 1.19.0 Resolution: Fixed master: 4817db916889a7701481fb04333a7f8da9f5b583 > [

[jira] [Resolved] (FLINK-33126) Fix EventTimeAllWindowCheckpointingITCase jobName typo

[ https://issues.apache.org/jira/browse/FLINK-33126?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weihua Hu resolved FLINK-33126. --- Fix Version/s: 1.19.0 Resolution: Fixed master: 4f09bbb39239f5523da8ecb7c7cd5ac9fd34c0e5 > F

[jira] [Resolved] (FLINK-32846) [JUnit5 Migration] The metrics, minicluster and net packages of flink-runtime module

[ https://issues.apache.org/jira/browse/FLINK-32846?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weihua Hu resolved FLINK-32846. --- Fix Version/s: 1.19.0 Resolution: Fixed > [JUnit5 Migration] The metrics, minicluster and net

[jira] [Assigned] (FLINK-33126) Fix EventTimeAllWindowCheckpointingITCase jobName typo

[ https://issues.apache.org/jira/browse/FLINK-33126?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weihua Hu reassigned FLINK-33126: - Assignee: Yue Ma (was: Yue Ma) > Fix EventTimeAllWindowCheckpointingITCase jobName typo >

[jira] [Commented] (FLINK-32846) [JUnit5 Migration] The metrics, minicluster and net packages of flink-runtime module

[ https://issues.apache.org/jira/browse/FLINK-32846?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17767056#comment-17767056 ] Weihua Hu commented on FLINK-32846: --- Metrics merged in master: 5a8321f6385f9a108773989

[jira] [Assigned] (FLINK-33126) Fix EventTimeAllWindowCheckpointingITCase jobName typo

[ https://issues.apache.org/jira/browse/FLINK-33126?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weihua Hu reassigned FLINK-33126: - Assignee: Yue Ma > Fix EventTimeAllWindowCheckpointingITCase jobName typo > ---

[jira] [Assigned] (FLINK-32114) Make FailureEnricherContext more flexible and include task specific fields

[ https://issues.apache.org/jira/browse/FLINK-32114?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weihua Hu reassigned FLINK-32114: - Assignee: Matt Wang > Make FailureEnricherContext more flexible and include task specific field

[jira] [Commented] (FLINK-33096) Flink on k8s，if one taskmanager pod was crashed，the whole flink job will be failed

[ https://issues.apache.org/jira/browse/FLINK-33096?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17766335#comment-17766335 ] Weihua Hu commented on FLINK-33096: --- [~wawa] I think it's because the job is failed af

[jira] [Resolved] (FLINK-31895) End-to-end integration tests for failure labels

[ https://issues.apache.org/jira/browse/FLINK-31895?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weihua Hu resolved FLINK-31895. --- Fix Version/s: 1.19.0 Resolution: Fixed Resolved in master: d8630cb5db0608a630de95df0dd1d0c9f

[jira] [Resolved] (FLINK-33061) Translate failure-enricher documentation to Chinese

[ https://issues.apache.org/jira/browse/FLINK-33061?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weihua Hu resolved FLINK-33061. --- Fix Version/s: 1.19.0 Resolution: Fixed Resolved in master: c5241e502ef6228b9f4ca44372025e88a

[jira] [Updated] (FLINK-33022) Log an error when enrichers defined as part of the configuration can not be found/loaded

[ https://issues.apache.org/jira/browse/FLINK-33022?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weihua Hu updated FLINK-33022: -- Release Note: (was: Resolved in master: b51ee30c3d1a212947398d880a676f07f46f36be) > Log an error wh

[jira] [Commented] (FLINK-33022) Log an error when enrichers defined as part of the configuration can not be found/loaded

[ https://issues.apache.org/jira/browse/FLINK-33022?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17765421#comment-17765421 ] Weihua Hu commented on FLINK-33022: --- Resolved in master: b51ee30c3d1a212947398d880a676

[jira] [Resolved] (FLINK-33022) Log an error when enrichers defined as part of the configuration can not be found/loaded

[ https://issues.apache.org/jira/browse/FLINK-33022?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weihua Hu resolved FLINK-33022. --- Fix Version/s: 1.19.0 Release Note: Resolved in master: b51ee30c3d1a212947398d880a676f07f46f36be

[jira] [Assigned] (FLINK-31895) End-to-end integration tests for failure labels

[ https://issues.apache.org/jira/browse/FLINK-31895?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weihua Hu reassigned FLINK-31895: - Assignee: Matt Wang (was: Matt Wang) > End-to-end integration tests for failure labels > -

[jira] [Assigned] (FLINK-33061) Translate failure-enricher documentation to Chinese

[ https://issues.apache.org/jira/browse/FLINK-33061?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weihua Hu reassigned FLINK-33061: - Assignee: Matt Wang (was: Matt Wang) > Translate failure-enricher documentation to Chinese > -

[jira] [Assigned] (FLINK-33061) Translate failure-enricher documentation to Chinese

[ https://issues.apache.org/jira/browse/FLINK-33061?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weihua Hu reassigned FLINK-33061: - Assignee: Matt Wang > Translate failure-enricher documentation to Chinese > ---

[jira] [Assigned] (FLINK-31895) End-to-end integration tests for failure labels

[ https://issues.apache.org/jira/browse/FLINK-31895?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weihua Hu reassigned FLINK-31895: - Assignee: Matt Wang > End-to-end integration tests for failure labels > ---

[jira] [Assigned] (FLINK-33022) When FailureEnricherUtils load FailureEnricherFactory failed should throw exception or add some error logs

[ https://issues.apache.org/jira/browse/FLINK-33022?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weihua Hu reassigned FLINK-33022: - Assignee: Panagiotis Garefalakis (was: Leonardo Zanivan) > When FailureEnricherUtils load Fail

[jira] [Assigned] (FLINK-33022) When FailureEnricherUtils load FailureEnricherFactory failed should throw exception or add some error logs

[ https://issues.apache.org/jira/browse/FLINK-33022?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weihua Hu reassigned FLINK-33022: - Assignee: Leonardo Zanivan > When FailureEnricherUtils load FailureEnricherFactory failed shoul

[jira] [Commented] (FLINK-32872) Add option to control the default partitioner when the parallelism of upstream and downstream operator does not match

[ https://issues.apache.org/jira/browse/FLINK-32872?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17762051#comment-17762051 ] Weihua Hu commented on FLINK-32872: --- [~Zhanghao Chen] Thanks for bring this. We need a

[jira] [Commented] (FLINK-32803) Release Testing: Verify FLINK-32165 - Improve observability of fine-grained resource management

[ https://issues.apache.org/jira/browse/FLINK-32803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17761754#comment-17761754 ] Weihua Hu commented on FLINK-32803: --- [~chesnay], Hi, is there any other scenarios you

[jira] [Resolved] (FLINK-32821) Streaming examples failed to execute due to error in packaging

[ https://issues.apache.org/jira/browse/FLINK-32821?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weihua Hu resolved FLINK-32821. --- Fix Version/s: 1.18.0 Resolution: Fixed > Streaming examples failed to execute due to error i

[jira] [Comment Edited] (FLINK-32821) Streaming examples failed to execute due to error in packaging

[ https://issues.apache.org/jira/browse/FLINK-32821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17760207#comment-17760207 ] Weihua Hu edited comment on FLINK-32821 at 8/31/23 10:41 AM: -

[jira] [Commented] (FLINK-32803) Release Testing: Verify FLINK-32165 - Improve observability of fine-grained resource management

[ https://issues.apache.org/jira/browse/FLINK-32803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17760212#comment-17760212 ] Weihua Hu commented on FLINK-32803: --- Hi, all I have tested this feature and it looks

[jira] [Updated] (FLINK-32803) Release Testing: Verify FLINK-32165 - Improve observability of fine-grained resource management

[ https://issues.apache.org/jira/browse/FLINK-32803?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weihua Hu updated FLINK-32803: -- Attachment: image-2023-08-30-10-58-34-939.png > Release Testing: Verify FLINK-32165 - Improve observab

[jira] [Updated] (FLINK-32803) Release Testing: Verify FLINK-32165 - Improve observability of fine-grained resource management

[ https://issues.apache.org/jira/browse/FLINK-32803?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weihua Hu updated FLINK-32803: -- Attachment: image-2023-08-30-10-57-11-049.png > Release Testing: Verify FLINK-32165 - Improve observab

[jira] [Updated] (FLINK-32803) Release Testing: Verify FLINK-32165 - Improve observability of fine-grained resource management

[ https://issues.apache.org/jira/browse/FLINK-32803?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weihua Hu updated FLINK-32803: -- Attachment: image-2023-08-30-10-56-09-174.png > Release Testing: Verify FLINK-32165 - Improve observab

[jira] [Closed] (FLINK-32984) Display the host port information on the suttasks page of SubtaskExecution

[ https://issues.apache.org/jira/browse/FLINK-32984?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weihua Hu closed FLINK-32984. - Resolution: Duplicate > Display the host port information on the suttasks page of SubtaskExecution > ---

[jira] [Updated] (FLINK-32980) Support env.java.opts.all & env.java.opts.cli config for starting Session cluster CLIs

[ https://issues.apache.org/jira/browse/FLINK-32980?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weihua Hu updated FLINK-32980: -- Release Note: (was: Resolved in master: 6dbb9b8d3fcfe88a85b22e2f177e8fea7585702e) > Support env.jav

[jira] [Commented] (FLINK-32980) Support env.java.opts.all & env.java.opts.cli config for starting Session cluster CLIs

[ https://issues.apache.org/jira/browse/FLINK-32980?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17759785#comment-17759785 ] Weihua Hu commented on FLINK-32980: --- Resolved in master: 6dbb9b8d3fcfe88a85b22e2f177e8

[jira] [Resolved] (FLINK-32980) Support env.java.opts.all & env.java.opts.cli config for starting Session cluster CLIs

[ https://issues.apache.org/jira/browse/FLINK-32980?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weihua Hu resolved FLINK-32980. --- Release Note: Resolved in master: 6dbb9b8d3fcfe88a85b22e2f177e8fea7585702e Resolution: Fixed >

[jira] [Assigned] (FLINK-32980) Support env.java.opts.all & env.java.opts.cli config for starting Session cluster CLIs

[ https://issues.apache.org/jira/browse/FLINK-32980?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weihua Hu reassigned FLINK-32980: - Assignee: Zhanghao Chen > Support env.java.opts.all & env.java.opts.cli config for starting Ses

[jira] [Commented] (FLINK-32980) Support env.java.opts.all & env.java.opts.cli config for starting Session cluster CLIs

[ https://issues.apache.org/jira/browse/FLINK-32980?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17759548#comment-17759548 ] Weihua Hu commented on FLINK-32980: --- [~Zhanghao Chen] Thanks for reporting this. you a

[jira] [Commented] (FLINK-32803) Release Testing: Verify FLINK-32165 - Improve observability of fine-grained resource management

[ https://issues.apache.org/jira/browse/FLINK-32803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17757793#comment-17757793 ] Weihua Hu commented on FLINK-32803: --- I would like to take this issue. [~chesnay] [~ren

[jira] [Resolved] (FLINK-32880) Redundant taskManagers should always be fulfilled in FineGrainedSlotManager

[ https://issues.apache.org/jira/browse/FLINK-32880?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weihua Hu resolved FLINK-32880. --- Fix Version/s: 1.18.0 Release Note: Resolved in master: 7299da4cf688a2d87fd918b6327a0573bc88cbd8

[jira] [Resolved] (FLINK-32879) slotmanager.max-total-resource.cpu/memory should be ignored in standalone mode.

[ https://issues.apache.org/jira/browse/FLINK-32879?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weihua Hu resolved FLINK-32879. --- Fix Version/s: 1.18.0 (was: 1.19.0) Resolution: Fixed > slotmanager.ma

[jira] [Commented] (FLINK-32879) slotmanager.max-total-resource.cpu/memory should be ignored in standalone mode.

[ https://issues.apache.org/jira/browse/FLINK-32879?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17755787#comment-17755787 ] Weihua Hu commented on FLINK-32879: --- Resolved in master: c8cbb0e2dec6ed505ce749c453e4f

[jira] [Commented] (FLINK-32821) Streaming examples failed to execute due to error in packaging

[ https://issues.apache.org/jira/browse/FLINK-32821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17755548#comment-17755548 ] Weihua Hu commented on FLINK-32821: --- Hi, [~afedulov] Thanks for you attention.  the ch

[jira] [Resolved] (FLINK-32882) FineGrainedSlotManager cause NPE when clear pending taskmanager twice

[ https://issues.apache.org/jira/browse/FLINK-32882?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weihua Hu resolved FLINK-32882. --- Fix Version/s: 1.18.0 Resolution: Fixed master: b56ae7822f6e4ff3ad67991f1c7916a435c960e9 > F

[jira] [Created] (FLINK-32882) FineGrainedSlotManager cause NPE when clear pending taskmanager twice

Weihua Hu created FLINK-32882: - Summary: FineGrainedSlotManager cause NPE when clear pending taskmanager twice Key: FLINK-32882 URL: https://issues.apache.org/jira/browse/FLINK-32882 Project: Flink

[jira] [Commented] (FLINK-32771) Remove the invalid config option slotmanager.request-timeout

[ https://issues.apache.org/jira/browse/FLINK-32771?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17754838#comment-17754838 ] Weihua Hu commented on FLINK-32771: --- master: b3557cfdc0a2897356027c16d97161c11680c802

[jira] [Resolved] (FLINK-32771) Remove the invalid config option slotmanager.request-timeout

[ https://issues.apache.org/jira/browse/FLINK-32771?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weihua Hu resolved FLINK-32771. --- Resolution: Fixed > Remove the invalid config option slotmanager.request-timeout > -

[jira] [Assigned] (FLINK-32771) Remove the invalid config option slotmanager.request-timeout

[ https://issues.apache.org/jira/browse/FLINK-32771?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weihua Hu reassigned FLINK-32771: - Assignee: Weihua Hu (was: Weihua Hu) > Remove the invalid config option slotmanager.request-ti

[jira] [Commented] (FLINK-32821) Streaming examples failed to execute due to error in packaging

[ https://issues.apache.org/jira/browse/FLINK-32821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17753207#comment-17753207 ] Weihua Hu commented on FLINK-32821: --- Fair enough, We cannot verify these examples unle

[jira] [Closed] (FLINK-32702) streaming examples could not run

[ https://issues.apache.org/jira/browse/FLINK-32702?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weihua Hu closed FLINK-32702. - Resolution: Duplicate > streaming examples could not run > > >

[jira] [Assigned] (FLINK-32702) streaming examples could not run

[ https://issues.apache.org/jira/browse/FLINK-32702?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weihua Hu reassigned FLINK-32702: - Assignee: Weihua Hu > streaming examples could not run > > >

[jira] [Comment Edited] (FLINK-32821) Streaming examples failed to execute due to error in packaging

[ https://issues.apache.org/jira/browse/FLINK-32821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17753138#comment-17753138 ] Weihua Hu edited comment on FLINK-32821 at 8/11/23 10:18 AM: -

[jira] [Commented] (FLINK-25371) Include data port as part of the host info for subtask detail panel on Web UI

[ https://issues.apache.org/jira/browse/FLINK-25371?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17751867#comment-17751867 ] Weihua Hu commented on FLINK-25371: --- Thanks for reporting this, I think the port infor

[jira] [Updated] (FLINK-25371) Include data port as part of the host info for subtask detail panel on Web UI

[ https://issues.apache.org/jira/browse/FLINK-25371?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weihua Hu updated FLINK-25371: -- Attachment: screenshot-1.png > Include data port as part of the host info for subtask detail panel on

[jira] [Updated] (FLINK-32702) streaming examples could not run

[ https://issues.apache.org/jira/browse/FLINK-32702?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weihua Hu updated FLINK-32702: -- Description: There are some streaming examples that depend on flink-connector-datagen, but didn't pac

[jira] [Updated] (FLINK-32702) streaming examples could not run

[ https://issues.apache.org/jira/browse/FLINK-32702?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weihua Hu updated FLINK-32702: -- Description: There are some streaming examples that depend on flink-connector-datagen, but didn't pac

[jira] [Created] (FLINK-32702) streaming examples could not run

Weihua Hu created FLINK-32702: - Summary: streaming examples could not run Key: FLINK-32702 URL: https://issues.apache.org/jira/browse/FLINK-32702 Project: Flink Issue Type: Bug Componen

[jira] [Commented] (FLINK-32687) Performance regression on handleGlobalFailureAndRestartAllTasks.BATCH_EVENLY since 2023-07-23

[ https://issues.apache.org/jira/browse/FLINK-32687?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17747533#comment-17747533 ] Weihua Hu commented on FLINK-32687: --- [~martijnvisser] Thanks for reporting this. This

[jira] [Closed] (FLINK-31771) Improve select available slot from SlotPool

[ https://issues.apache.org/jira/browse/FLINK-31771?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weihua Hu closed FLINK-31771. - Fix Version/s: 1.18.0 Resolution: Fixed > Improve select available slot from SlotPool > -

[jira] [Closed] (FLINK-32045) optimize task deployment performance for large-scale jobs

[ https://issues.apache.org/jira/browse/FLINK-32045?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weihua Hu closed FLINK-32045. - Resolution: Fixed > optimize task deployment performance for large-scale jobs >

[jira] [Commented] (FLINK-32513) Job in BATCH mode with a significant number of transformations freezes on method StreamGraphGenerator.existsUnboundedSource()

[ https://issues.apache.org/jira/browse/FLINK-32513?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17740011#comment-17740011 ] Weihua Hu commented on FLINK-32513: --- Thanks [~vladislav.keda] reporting this. Could yo

[jira] [Closed] (FLINK-32205) Support Flink client to access REST API through K8s Ingress

[ https://issues.apache.org/jira/browse/FLINK-32205?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weihua Hu closed FLINK-32205. - Fix Version/s: 1.18.0 Resolution: Fixed > Support Flink client to access REST API through K8s Ing

[jira] [Created] (FLINK-32387) InputGateDeploymentDescriptor uses cache to avoid deserializing shuffle descriptors multiple times

Weihua Hu created FLINK-32387: - Summary: InputGateDeploymentDescriptor uses cache to avoid deserializing shuffle descriptors multiple times Key: FLINK-32387 URL: https://issues.apache.org/jira/browse/FLINK-32387

[jira] [Created] (FLINK-32386) Add ShuffleDescriptorsCache in TaskExecutor to cache ShuffleDescriptors

Weihua Hu created FLINK-32386: - Summary: Add ShuffleDescriptorsCache in TaskExecutor to cache ShuffleDescriptors Key: FLINK-32386 URL: https://issues.apache.org/jira/browse/FLINK-32386 Project: Flink

[jira] [Created] (FLINK-32385) Introduce a struct SerializedShuffleDescriptorAndIndices to identify a group of ShuffleDescriptorAndIndex

Weihua Hu created FLINK-32385: - Summary: Introduce a struct SerializedShuffleDescriptorAndIndices to identify a group of ShuffleDescriptorAndIndex Key: FLINK-32385 URL: https://issues.apache.org/jira/browse/FLINK-3238

[jira] [Commented] (FLINK-31234) Add an option to redirect stdout/stderr for flink on kubernetes

[ https://issues.apache.org/jira/browse/FLINK-31234?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17733482#comment-17733482 ] Weihua Hu commented on FLINK-31234: --- [~wangyang0918] [~gyfora]  I think it's worth add

[jira] [Updated] (FLINK-31234) Add an option to redirect stdout/stderr for flink on kubernetes

[ https://issues.apache.org/jira/browse/FLINK-31234?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weihua Hu updated FLINK-31234: -- Description: Flink on Kubernetes does not support redirecting stdout/stderr to files. This is to allo

[jira] [Updated] (FLINK-31234) Add an option to redirect stdout/stderr for flink on kubernetes

[ https://issues.apache.org/jira/browse/FLINK-31234?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weihua Hu updated FLINK-31234: -- Description: Flink on Kubernetes does not support redirecting stdout/stderr to files. This is to allo

[jira] [Updated] (FLINK-32205) Support Flink client to access REST API through K8s Ingress

[ https://issues.apache.org/jira/browse/FLINK-32205?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weihua Hu updated FLINK-32205: -- Description: Currently, Flink Client can only connect to the server through the address:port, which i

[jira] [Updated] (FLINK-32205) Flink Rest Client should support connecting to the server using URLs.

[ https://issues.apache.org/jira/browse/FLINK-32205?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weihua Hu updated FLINK-32205: -- Description: Currently, Flink Client can only connect to the server via the address:port, which is co

[jira] [Commented] (FLINK-31233) no error should be logged when retrieving the task manager's stdout if it does not exist

[ https://issues.apache.org/jira/browse/FLINK-31233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17730399#comment-17730399 ] Weihua Hu commented on FLINK-31233: --- After offline discussion with [~guoyangze], 1.

[jira] [Commented] (FLINK-32254) FineGrainedSlotManager may not allocate enough taskmangers if maxSlotNum is configured

[ https://issues.apache.org/jira/browse/FLINK-32254?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17729629#comment-17729629 ] Weihua Hu commented on FLINK-32254: --- Thanks for your clarification. > FineGrainedSlo

[jira] [Commented] (FLINK-32254) FineGrainedSlotManager may not allocate enough taskmangers if maxSlotNum is configured

[ https://issues.apache.org/jira/browse/FLINK-32254?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17729594#comment-17729594 ] Weihua Hu commented on FLINK-32254: --- Thanks for reporting this bug. This is definitely

[jira] [Created] (FLINK-32225) merge task deployment related fields into a new configuration

Weihua Hu created FLINK-32225: - Summary: merge task deployment related fields into a new configuration Key: FLINK-32225 URL: https://issues.apache.org/jira/browse/FLINK-32225 Project: Flink Iss

[jira] [Commented] (FLINK-32202) useless configuration

[ https://issues.apache.org/jira/browse/FLINK-32202?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17726566#comment-17726566 ] Weihua Hu commented on FLINK-32202: --- [~zhangdong7] Could you explain more about "but t

[jira] (FLINK-32202) useless configuration

[ https://issues.apache.org/jira/browse/FLINK-32202 ] Weihua Hu deleted comment on FLINK-32202: --- was (Author: huwh): [~zhangdong7] Could you explain more about "but the parameter query.server.ports:6125 will be generated when Flink starts"? I cou

[jira] [Updated] (FLINK-32205) Flink Rest Client should support connecting to the server using URLs.

[ https://issues.apache.org/jira/browse/FLINK-32205?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weihua Hu updated FLINK-32205: -- Description: Currently, Flink Client can only connect to the server via the address:port, which is co

[jira] [Created] (FLINK-32205) Flink Rest Client should support connecting to the server using URLs.

Weihua Hu created FLINK-32205: - Summary: Flink Rest Client should support connecting to the server using URLs. Key: FLINK-32205 URL: https://issues.apache.org/jira/browse/FLINK-32205 Project: Flink

[jira] [Created] (FLINK-32201) Enable the distribution of shuffle descriptors via the blob server by connection number

Weihua Hu created FLINK-32201: - Summary: Enable the distribution of shuffle descriptors via the blob server by connection number Key: FLINK-32201 URL: https://issues.apache.org/jira/browse/FLINK-32201 Pro

  1   2   3   >