[jira] [Updated] (FLINK-29339) JobMasterPartitionTrackerImpl#requestShuffleDescriptorsFromResourceManager blocks main thread
[ https://issues.apache.org/jira/browse/FLINK-29339?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-29339: --- Fix Version/s: 2.0.0 (was: 1.20.0) > JobMasterPartitionTrackerImpl#requestShuffleDescriptorsFromResourceManager > blocks main thread > - > > Key: FLINK-29339 > URL: https://issues.apache.org/jira/browse/FLINK-29339 > Project: Flink > Issue Type: Bug > Components: Runtime / Coordination >Affects Versions: 1.16.0, 1.17.0 >Reporter: Chesnay Schepler >Assignee: Xuannan Su >Priority: Critical > Labels: pull-request-available, stale-assigned > Fix For: 2.0.0 > > > {code:java} > private List requestShuffleDescriptorsFromResourceManager( > IntermediateDataSetID intermediateDataSetID) { > Preconditions.checkNotNull( > resourceManagerGateway, "JobMaster is not connected to > ResourceManager"); > try { > return this.resourceManagerGateway > .getClusterPartitionsShuffleDescriptors(intermediateDataSetID) > .get(); // <-- there's your problem > } catch (Throwable e) { > throw new RuntimeException( > String.format( > "Failed to get shuffle descriptors of intermediate > dataset %s from ResourceManager", > intermediateDataSetID), > e); > } > } > {code} -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Updated] (FLINK-29339) JobMasterPartitionTrackerImpl#requestShuffleDescriptorsFromResourceManager blocks main thread
[ https://issues.apache.org/jira/browse/FLINK-29339?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-29339: Fix Version/s: (was: 1.19.0) > JobMasterPartitionTrackerImpl#requestShuffleDescriptorsFromResourceManager > blocks main thread > - > > Key: FLINK-29339 > URL: https://issues.apache.org/jira/browse/FLINK-29339 > Project: Flink > Issue Type: Bug > Components: Runtime / Coordination >Affects Versions: 1.16.0, 1.17.0 >Reporter: Chesnay Schepler >Assignee: Xuannan Su >Priority: Critical > Labels: pull-request-available, stale-assigned > Fix For: 1.20.0 > > > {code:java} > private List requestShuffleDescriptorsFromResourceManager( > IntermediateDataSetID intermediateDataSetID) { > Preconditions.checkNotNull( > resourceManagerGateway, "JobMaster is not connected to > ResourceManager"); > try { > return this.resourceManagerGateway > .getClusterPartitionsShuffleDescriptors(intermediateDataSetID) > .get(); // <-- there's your problem > } catch (Throwable e) { > throw new RuntimeException( > String.format( > "Failed to get shuffle descriptors of intermediate > dataset %s from ResourceManager", > intermediateDataSetID), > e); > } > } > {code} -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Updated] (FLINK-29339) JobMasterPartitionTrackerImpl#requestShuffleDescriptorsFromResourceManager blocks main thread
[ https://issues.apache.org/jira/browse/FLINK-29339?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-29339: Fix Version/s: 1.20.0 > JobMasterPartitionTrackerImpl#requestShuffleDescriptorsFromResourceManager > blocks main thread > - > > Key: FLINK-29339 > URL: https://issues.apache.org/jira/browse/FLINK-29339 > Project: Flink > Issue Type: Bug > Components: Runtime / Coordination >Affects Versions: 1.16.0, 1.17.0 >Reporter: Chesnay Schepler >Assignee: Xuannan Su >Priority: Critical > Labels: pull-request-available, stale-assigned > Fix For: 1.19.0, 1.20.0 > > > {code:java} > private List requestShuffleDescriptorsFromResourceManager( > IntermediateDataSetID intermediateDataSetID) { > Preconditions.checkNotNull( > resourceManagerGateway, "JobMaster is not connected to > ResourceManager"); > try { > return this.resourceManagerGateway > .getClusterPartitionsShuffleDescriptors(intermediateDataSetID) > .get(); // <-- there's your problem > } catch (Throwable e) { > throw new RuntimeException( > String.format( > "Failed to get shuffle descriptors of intermediate > dataset %s from ResourceManager", > intermediateDataSetID), > e); > } > } > {code} -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Updated] (FLINK-29339) JobMasterPartitionTrackerImpl#requestShuffleDescriptorsFromResourceManager blocks main thread
[ https://issues.apache.org/jira/browse/FLINK-29339?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Ge updated FLINK-29339: Fix Version/s: 1.19.0 (was: 1.18.0) (was: 1.16.3) > JobMasterPartitionTrackerImpl#requestShuffleDescriptorsFromResourceManager > blocks main thread > - > > Key: FLINK-29339 > URL: https://issues.apache.org/jira/browse/FLINK-29339 > Project: Flink > Issue Type: Bug > Components: Runtime / Coordination >Affects Versions: 1.16.0, 1.17.0 >Reporter: Chesnay Schepler >Assignee: Xuannan Su >Priority: Critical > Labels: pull-request-available, stale-assigned > Fix For: 1.19.0 > > > {code:java} > private List requestShuffleDescriptorsFromResourceManager( > IntermediateDataSetID intermediateDataSetID) { > Preconditions.checkNotNull( > resourceManagerGateway, "JobMaster is not connected to > ResourceManager"); > try { > return this.resourceManagerGateway > .getClusterPartitionsShuffleDescriptors(intermediateDataSetID) > .get(); // <-- there's your problem > } catch (Throwable e) { > throw new RuntimeException( > String.format( > "Failed to get shuffle descriptors of intermediate > dataset %s from ResourceManager", > intermediateDataSetID), > e); > } > } > {code} -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Updated] (FLINK-29339) JobMasterPartitionTrackerImpl#requestShuffleDescriptorsFromResourceManager blocks main thread
[ https://issues.apache.org/jira/browse/FLINK-29339?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-29339: --- Labels: pull-request-available stale-assigned (was: pull-request-available) I am the [Flink Jira Bot|https://github.com/apache/flink-jira-bot/] and I help the community manage its development. I see this issue is assigned but has not received an update in 30 days, so it has been labeled "stale-assigned". If you are still working on the issue, please remove the label and add a comment updating the community on your progress. If this issue is waiting on feedback, please consider this a reminder to the committer/reviewer. Flink is a very active project, and so we appreciate your patience. If you are no longer working on the issue, please unassign yourself so someone else may work on it. > JobMasterPartitionTrackerImpl#requestShuffleDescriptorsFromResourceManager > blocks main thread > - > > Key: FLINK-29339 > URL: https://issues.apache.org/jira/browse/FLINK-29339 > Project: Flink > Issue Type: Bug > Components: Runtime / Coordination >Affects Versions: 1.16.0, 1.17.0 >Reporter: Chesnay Schepler >Assignee: Xuannan Su >Priority: Critical > Labels: pull-request-available, stale-assigned > Fix For: 1.18.0, 1.16.3 > > > {code:java} > private List requestShuffleDescriptorsFromResourceManager( > IntermediateDataSetID intermediateDataSetID) { > Preconditions.checkNotNull( > resourceManagerGateway, "JobMaster is not connected to > ResourceManager"); > try { > return this.resourceManagerGateway > .getClusterPartitionsShuffleDescriptors(intermediateDataSetID) > .get(); // <-- there's your problem > } catch (Throwable e) { > throw new RuntimeException( > String.format( > "Failed to get shuffle descriptors of intermediate > dataset %s from ResourceManager", > intermediateDataSetID), > e); > } > } > {code} -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Updated] (FLINK-29339) JobMasterPartitionTrackerImpl#requestShuffleDescriptorsFromResourceManager blocks main thread
[ https://issues.apache.org/jira/browse/FLINK-29339?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-29339: --- Fix Version/s: 1.16.3 (was: 1.16.2) > JobMasterPartitionTrackerImpl#requestShuffleDescriptorsFromResourceManager > blocks main thread > - > > Key: FLINK-29339 > URL: https://issues.apache.org/jira/browse/FLINK-29339 > Project: Flink > Issue Type: Bug > Components: Runtime / Coordination >Affects Versions: 1.16.0, 1.17.0 >Reporter: Chesnay Schepler >Assignee: Xuannan Su >Priority: Critical > Labels: pull-request-available > Fix For: 1.18.0, 1.16.3 > > > {code:java} > private List requestShuffleDescriptorsFromResourceManager( > IntermediateDataSetID intermediateDataSetID) { > Preconditions.checkNotNull( > resourceManagerGateway, "JobMaster is not connected to > ResourceManager"); > try { > return this.resourceManagerGateway > .getClusterPartitionsShuffleDescriptors(intermediateDataSetID) > .get(); // <-- there's your problem > } catch (Throwable e) { > throw new RuntimeException( > String.format( > "Failed to get shuffle descriptors of intermediate > dataset %s from ResourceManager", > intermediateDataSetID), > e); > } > } > {code} -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Updated] (FLINK-29339) JobMasterPartitionTrackerImpl#requestShuffleDescriptorsFromResourceManager blocks main thread
[ https://issues.apache.org/jira/browse/FLINK-29339?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-29339: - Fix Version/s: 1.18.0 (was: 1.17.0) > JobMasterPartitionTrackerImpl#requestShuffleDescriptorsFromResourceManager > blocks main thread > - > > Key: FLINK-29339 > URL: https://issues.apache.org/jira/browse/FLINK-29339 > Project: Flink > Issue Type: Bug > Components: Runtime / Coordination >Affects Versions: 1.16.0, 1.17.0 >Reporter: Chesnay Schepler >Assignee: Xuannan Su >Priority: Critical > Labels: pull-request-available > Fix For: 1.16.2, 1.18.0 > > > {code:java} > private List requestShuffleDescriptorsFromResourceManager( > IntermediateDataSetID intermediateDataSetID) { > Preconditions.checkNotNull( > resourceManagerGateway, "JobMaster is not connected to > ResourceManager"); > try { > return this.resourceManagerGateway > .getClusterPartitionsShuffleDescriptors(intermediateDataSetID) > .get(); // <-- there's your problem > } catch (Throwable e) { > throw new RuntimeException( > String.format( > "Failed to get shuffle descriptors of intermediate > dataset %s from ResourceManager", > intermediateDataSetID), > e); > } > } > {code} -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Updated] (FLINK-29339) JobMasterPartitionTrackerImpl#requestShuffleDescriptorsFromResourceManager blocks main thread
[ https://issues.apache.org/jira/browse/FLINK-29339?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-29339: --- Fix Version/s: (was: 1.16.1) > JobMasterPartitionTrackerImpl#requestShuffleDescriptorsFromResourceManager > blocks main thread > - > > Key: FLINK-29339 > URL: https://issues.apache.org/jira/browse/FLINK-29339 > Project: Flink > Issue Type: Bug > Components: Runtime / Coordination >Affects Versions: 1.16.0, 1.17.0 >Reporter: Chesnay Schepler >Assignee: Xuannan Su >Priority: Critical > Labels: pull-request-available > Fix For: 1.17.0, 1.16.2 > > > {code:java} > private List requestShuffleDescriptorsFromResourceManager( > IntermediateDataSetID intermediateDataSetID) { > Preconditions.checkNotNull( > resourceManagerGateway, "JobMaster is not connected to > ResourceManager"); > try { > return this.resourceManagerGateway > .getClusterPartitionsShuffleDescriptors(intermediateDataSetID) > .get(); // <-- there's your problem > } catch (Throwable e) { > throw new RuntimeException( > String.format( > "Failed to get shuffle descriptors of intermediate > dataset %s from ResourceManager", > intermediateDataSetID), > e); > } > } > {code} -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Updated] (FLINK-29339) JobMasterPartitionTrackerImpl#requestShuffleDescriptorsFromResourceManager blocks main thread
[ https://issues.apache.org/jira/browse/FLINK-29339?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-29339: --- Fix Version/s: 1.16.2 > JobMasterPartitionTrackerImpl#requestShuffleDescriptorsFromResourceManager > blocks main thread > - > > Key: FLINK-29339 > URL: https://issues.apache.org/jira/browse/FLINK-29339 > Project: Flink > Issue Type: Bug > Components: Runtime / Coordination >Affects Versions: 1.16.0, 1.17.0 >Reporter: Chesnay Schepler >Assignee: Xuannan Su >Priority: Critical > Labels: pull-request-available > Fix For: 1.17.0, 1.16.1, 1.16.2 > > > {code:java} > private List requestShuffleDescriptorsFromResourceManager( > IntermediateDataSetID intermediateDataSetID) { > Preconditions.checkNotNull( > resourceManagerGateway, "JobMaster is not connected to > ResourceManager"); > try { > return this.resourceManagerGateway > .getClusterPartitionsShuffleDescriptors(intermediateDataSetID) > .get(); // <-- there's your problem > } catch (Throwable e) { > throw new RuntimeException( > String.format( > "Failed to get shuffle descriptors of intermediate > dataset %s from ResourceManager", > intermediateDataSetID), > e); > } > } > {code} -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Updated] (FLINK-29339) JobMasterPartitionTrackerImpl#requestShuffleDescriptorsFromResourceManager blocks main thread
[ https://issues.apache.org/jira/browse/FLINK-29339?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-29339: Fix Version/s: 1.17.0 1.16.1 (was: 1.16.0) > JobMasterPartitionTrackerImpl#requestShuffleDescriptorsFromResourceManager > blocks main thread > - > > Key: FLINK-29339 > URL: https://issues.apache.org/jira/browse/FLINK-29339 > Project: Flink > Issue Type: Bug > Components: Runtime / Coordination >Affects Versions: 1.16.0, 1.17.0 >Reporter: Chesnay Schepler >Assignee: Xuannan Su >Priority: Critical > Labels: pull-request-available > Fix For: 1.17.0, 1.16.1 > > > {code:java} > private List requestShuffleDescriptorsFromResourceManager( > IntermediateDataSetID intermediateDataSetID) { > Preconditions.checkNotNull( > resourceManagerGateway, "JobMaster is not connected to > ResourceManager"); > try { > return this.resourceManagerGateway > .getClusterPartitionsShuffleDescriptors(intermediateDataSetID) > .get(); // <-- there's your problem > } catch (Throwable e) { > throw new RuntimeException( > String.format( > "Failed to get shuffle descriptors of intermediate > dataset %s from ResourceManager", > intermediateDataSetID), > e); > } > } > {code} -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Updated] (FLINK-29339) JobMasterPartitionTrackerImpl#requestShuffleDescriptorsFromResourceManager blocks main thread
[ https://issues.apache.org/jira/browse/FLINK-29339?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-29339: Affects Version/s: 1.17.0 > JobMasterPartitionTrackerImpl#requestShuffleDescriptorsFromResourceManager > blocks main thread > - > > Key: FLINK-29339 > URL: https://issues.apache.org/jira/browse/FLINK-29339 > Project: Flink > Issue Type: Bug > Components: Runtime / Coordination >Affects Versions: 1.16.0, 1.17.0 >Reporter: Chesnay Schepler >Assignee: Xuannan Su >Priority: Critical > Labels: pull-request-available > Fix For: 1.16.0 > > > {code:java} > private List requestShuffleDescriptorsFromResourceManager( > IntermediateDataSetID intermediateDataSetID) { > Preconditions.checkNotNull( > resourceManagerGateway, "JobMaster is not connected to > ResourceManager"); > try { > return this.resourceManagerGateway > .getClusterPartitionsShuffleDescriptors(intermediateDataSetID) > .get(); // <-- there's your problem > } catch (Throwable e) { > throw new RuntimeException( > String.format( > "Failed to get shuffle descriptors of intermediate > dataset %s from ResourceManager", > intermediateDataSetID), > e); > } > } > {code} -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Updated] (FLINK-29339) JobMasterPartitionTrackerImpl#requestShuffleDescriptorsFromResourceManager blocks main thread
[ https://issues.apache.org/jira/browse/FLINK-29339?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-29339: - Priority: Critical (was: Blocker) > JobMasterPartitionTrackerImpl#requestShuffleDescriptorsFromResourceManager > blocks main thread > - > > Key: FLINK-29339 > URL: https://issues.apache.org/jira/browse/FLINK-29339 > Project: Flink > Issue Type: Bug > Components: Runtime / Coordination >Affects Versions: 1.16.0 >Reporter: Chesnay Schepler >Assignee: Xuannan Su >Priority: Critical > Labels: pull-request-available > Fix For: 1.16.0 > > > {code:java} > private List requestShuffleDescriptorsFromResourceManager( > IntermediateDataSetID intermediateDataSetID) { > Preconditions.checkNotNull( > resourceManagerGateway, "JobMaster is not connected to > ResourceManager"); > try { > return this.resourceManagerGateway > .getClusterPartitionsShuffleDescriptors(intermediateDataSetID) > .get(); // <-- there's your problem > } catch (Throwable e) { > throw new RuntimeException( > String.format( > "Failed to get shuffle descriptors of intermediate > dataset %s from ResourceManager", > intermediateDataSetID), > e); > } > } > {code} -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Updated] (FLINK-29339) JobMasterPartitionTrackerImpl#requestShuffleDescriptorsFromResourceManager blocks main thread
[ https://issues.apache.org/jira/browse/FLINK-29339?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-29339: - Fix Version/s: 1.16.0 > JobMasterPartitionTrackerImpl#requestShuffleDescriptorsFromResourceManager > blocks main thread > - > > Key: FLINK-29339 > URL: https://issues.apache.org/jira/browse/FLINK-29339 > Project: Flink > Issue Type: Bug > Components: Runtime / Coordination >Affects Versions: 1.16.0 >Reporter: Chesnay Schepler >Assignee: Xuannan Su >Priority: Blocker > Labels: pull-request-available > Fix For: 1.16.0 > > > {code:java} > private List requestShuffleDescriptorsFromResourceManager( > IntermediateDataSetID intermediateDataSetID) { > Preconditions.checkNotNull( > resourceManagerGateway, "JobMaster is not connected to > ResourceManager"); > try { > return this.resourceManagerGateway > .getClusterPartitionsShuffleDescriptors(intermediateDataSetID) > .get(); // <-- there's your problem > } catch (Throwable e) { > throw new RuntimeException( > String.format( > "Failed to get shuffle descriptors of intermediate > dataset %s from ResourceManager", > intermediateDataSetID), > e); > } > } > {code} -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Updated] (FLINK-29339) JobMasterPartitionTrackerImpl#requestShuffleDescriptorsFromResourceManager blocks main thread
[ https://issues.apache.org/jira/browse/FLINK-29339?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-29339: - Priority: Blocker (was: Critical) > JobMasterPartitionTrackerImpl#requestShuffleDescriptorsFromResourceManager > blocks main thread > - > > Key: FLINK-29339 > URL: https://issues.apache.org/jira/browse/FLINK-29339 > Project: Flink > Issue Type: Bug > Components: Runtime / Coordination >Affects Versions: 1.16.0 >Reporter: Chesnay Schepler >Assignee: Xuannan Su >Priority: Blocker > Labels: pull-request-available > > {code:java} > private List requestShuffleDescriptorsFromResourceManager( > IntermediateDataSetID intermediateDataSetID) { > Preconditions.checkNotNull( > resourceManagerGateway, "JobMaster is not connected to > ResourceManager"); > try { > return this.resourceManagerGateway > .getClusterPartitionsShuffleDescriptors(intermediateDataSetID) > .get(); // <-- there's your problem > } catch (Throwable e) { > throw new RuntimeException( > String.format( > "Failed to get shuffle descriptors of intermediate > dataset %s from ResourceManager", > intermediateDataSetID), > e); > } > } > {code} -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Updated] (FLINK-29339) JobMasterPartitionTrackerImpl#requestShuffleDescriptorsFromResourceManager blocks main thread
[ https://issues.apache.org/jira/browse/FLINK-29339?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-29339: --- Labels: pull-request-available (was: ) > JobMasterPartitionTrackerImpl#requestShuffleDescriptorsFromResourceManager > blocks main thread > - > > Key: FLINK-29339 > URL: https://issues.apache.org/jira/browse/FLINK-29339 > Project: Flink > Issue Type: Bug > Components: Runtime / Coordination >Affects Versions: 1.16.0 >Reporter: Chesnay Schepler >Priority: Critical > Labels: pull-request-available > > {code:java} > private List requestShuffleDescriptorsFromResourceManager( > IntermediateDataSetID intermediateDataSetID) { > Preconditions.checkNotNull( > resourceManagerGateway, "JobMaster is not connected to > ResourceManager"); > try { > return this.resourceManagerGateway > .getClusterPartitionsShuffleDescriptors(intermediateDataSetID) > .get(); // <-- there's your problem > } catch (Throwable e) { > throw new RuntimeException( > String.format( > "Failed to get shuffle descriptors of intermediate > dataset %s from ResourceManager", > intermediateDataSetID), > e); > } > } > {code} -- This message was sent by Atlassian Jira (v8.20.10#820010)