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

Weihua Hu created FLINK-32045: - Summary: optimize task deployment performance for large-scale jobs Key: FLINK-32045 URL: https://issues.apache.org/jira/browse/FLINK-32045 Project: Flink Issue Typ

[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

[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-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] [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] [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-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-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] [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] [Created] (FLINK-30517) Decrease log output interval while waiting for YARN JobManager be allocated

Weihua Hu created FLINK-30517: - Summary: Decrease log output interval while waiting for YARN JobManager be allocated Key: FLINK-30517 URL: https://issues.apache.org/jira/browse/FLINK-30517 Project: Flink

[jira] [Created] (FLINK-30525) Cannot open jobmanager configuration web page

Weihua Hu created FLINK-30525: - Summary: Cannot open jobmanager configuration web page Key: FLINK-30525 URL: https://issues.apache.org/jira/browse/FLINK-30525 Project: Flink Issue Type: Bug

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

Weihua Hu created FLINK-31233: - Summary: no error should be logged when retrieving the task manager's stdout if it does not exist Key: FLINK-31233 URL: https://issues.apache.org/jira/browse/FLINK-31233 P

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

Weihua Hu created FLINK-31234: - Summary: Add an option to redirect stdout/stderr for flink on kubernetes Key: FLINK-31234 URL: https://issues.apache.org/jira/browse/FLINK-31234 Project: Flink Is

[jira] [Created] (FLINK-31439) FLIP-298: Unifying the Implementation of SlotManager

Weihua Hu created FLINK-31439: - Summary: FLIP-298: Unifying the Implementation of SlotManager Key: FLINK-31439 URL: https://issues.apache.org/jira/browse/FLINK-31439 Project: Flink Issue Type: Im

[jira] [Created] (FLINK-31441) FineGrainedSlotManager support select slot evenly

Weihua Hu created FLINK-31441: - Summary: FineGrainedSlotManager support select slot evenly Key: FLINK-31441 URL: https://issues.apache.org/jira/browse/FLINK-31441 Project: Flink Issue Type: Sub-t

[jira] [Created] (FLINK-31443) FineGrainedSlotManager maintain some redundant task managers

Weihua Hu created FLINK-31443: - Summary: FineGrainedSlotManager maintain some redundant task managers Key: FLINK-31443 URL: https://issues.apache.org/jira/browse/FLINK-31443 Project: Flink Issue

[jira] [Created] (FLINK-31444) FineGrainedSlotManager reclaims slots when job is finished

Weihua Hu created FLINK-31444: - Summary: FineGrainedSlotManager reclaims slots when job is finished Key: FLINK-31444 URL: https://issues.apache.org/jira/browse/FLINK-31444 Project: Flink Issue Ty

[jira] [Created] (FLINK-31445) Split resource allocate/release related logic from FineGrainedSlotManager to TaskManagerTracker

Weihua Hu created FLINK-31445: - Summary: Split resource allocate/release related logic from FineGrainedSlotManager to TaskManagerTracker Key: FLINK-31445 URL: https://issues.apache.org/jira/browse/FLINK-31445

[jira] [Created] (FLINK-31448) Use FineGrainedSlotManager as the default SlotManager

Weihua Hu created FLINK-31448: - Summary: Use FineGrainedSlotManager as the default SlotManager Key: FLINK-31448 URL: https://issues.apache.org/jira/browse/FLINK-31448 Project: Flink Issue Type: S

[jira] [Created] (FLINK-31447) Aligning unit tests of FineGrainedSlotManager with DeclarativeSlotManager

Weihua Hu created FLINK-31447: - Summary: Aligning unit tests of FineGrainedSlotManager with DeclarativeSlotManager Key: FLINK-31447 URL: https://issues.apache.org/jira/browse/FLINK-31447 Project: Flink

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

Weihua Hu created FLINK-31449: - Summary: Remove DeclarativeSlotManager related logic Key: FLINK-31449 URL: https://issues.apache.org/jira/browse/FLINK-31449 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-31498) DeclartiveSlotManager always request redundant task manager when resource is not enough

Weihua Hu created FLINK-31498: - Summary: DeclartiveSlotManager always request redundant task manager when resource is not enough Key: FLINK-31498 URL: https://issues.apache.org/jira/browse/FLINK-31498 Pro

[jira] [Created] (FLINK-31529) Let yarn client exit early before JobManager running

Weihua Hu created FLINK-31529: - Summary: Let yarn client exit early before JobManager running Key: FLINK-31529 URL: https://issues.apache.org/jira/browse/FLINK-31529 Project: Flink Issue Type: Im

[jira] [Created] (FLINK-31537) Derive a new TaskManagerTrackerConfiguration from the SlotManagerConfiguration.

Weihua Hu created FLINK-31537: - Summary: Derive a new TaskManagerTrackerConfiguration from the SlotManagerConfiguration. Key: FLINK-31537 URL: https://issues.apache.org/jira/browse/FLINK-31537 Project: Fl

[jira] [Created] (FLINK-31679) [Flink][UI] Show data exchange type on web ui

Weihua Hu created FLINK-31679: - Summary: [Flink][UI] Show data exchange type on web ui Key: FLINK-31679 URL: https://issues.apache.org/jira/browse/FLINK-31679 Project: Flink Issue Type: Improveme

[jira] [Created] (FLINK-31752) SourceOperatorStreamTask increments numRecordsOut twice

Weihua Hu created FLINK-31752: - Summary: SourceOperatorStreamTask increments numRecordsOut twice Key: FLINK-31752 URL: https://issues.apache.org/jira/browse/FLINK-31752 Project: Flink Issue Type:

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

Weihua Hu created FLINK-31771: - Summary: Improve select available slot from SlotPool Key: FLINK-31771 URL: https://issues.apache.org/jira/browse/FLINK-31771 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-31808) wrong examples of how to set operator name in documents

Weihua Hu created FLINK-31808: - Summary: wrong examples of how to set operator name in documents Key: FLINK-31808 URL: https://issues.apache.org/jira/browse/FLINK-31808 Project: Flink Issue Type

[jira] [Created] (FLINK-31832) Add benchmarks for end to end  restarting tasks

Weihua Hu created FLINK-31832: - Summary: Add benchmarks for end to end  restarting tasks Key: FLINK-31832 URL: https://issues.apache.org/jira/browse/FLINK-31832 Project: Flink Issue Type: Improve

[jira] [Created] (FLINK-31842) calculate task executor's utilization only when used

Weihua Hu created FLINK-31842: - Summary: calculate task executor's utilization only when used Key: FLINK-31842 URL: https://issues.apache.org/jira/browse/FLINK-31842 Project: Flink Issue Type: Su

[jira] [Created] (FLINK-31843) Select slots from SlotPool#freeSlots in bulk

Weihua Hu created FLINK-31843: - Summary: Select slots from SlotPool#freeSlots in bulk Key: FLINK-31843 URL: https://issues.apache.org/jira/browse/FLINK-31843 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-29869) make ResourceActions declarative

Weihua Hu created FLINK-29869: - Summary: make ResourceActions declarative Key: FLINK-29869 URL: https://issues.apache.org/jira/browse/FLINK-29869 Project: Flink Issue Type: Sub-task Co

[jira] [Created] (FLINK-29870) Split ResourceActions to ResourceAllocator and ResourceAllocationNotifier

Weihua Hu created FLINK-29870: - Summary: Split ResourceActions to ResourceAllocator and ResourceAllocationNotifier Key: FLINK-29870 URL: https://issues.apache.org/jira/browse/FLINK-29870 Project: Flink

[jira] [Created] (FLINK-30084) Remove unused ResourceActions.notifyAllocationFailure

Weihua Hu created FLINK-30084: - Summary: Remove unused ResourceActions.notifyAllocationFailure Key: FLINK-30084 URL: https://issues.apache.org/jira/browse/FLINK-30084 Project: Flink Issue Type: S