Skip to content

Commit a12ea7e

Browse files
author
slfan1989
committed
YARN-11290. Fix CheckStyle.
1 parent 411d4d2 commit a12ea7e

File tree

3 files changed

+30
-21
lines changed

3 files changed

+30
-21
lines changed

hadoop-yarn-project/hadoop-yarn/bin/FederationStateStore/SQLServer/FederationStateStoreStoreProcs.sql

Lines changed: 25 additions & 15 deletions
Original file line numberDiff line numberDiff line change
@@ -117,21 +117,31 @@ AS BEGIN
117117
DECLARE @errorMessage nvarchar(4000)
118118

119119
BEGIN TRY
120-
SELECT
121-
[applicationId],
122-
[homeSubCluster],
123-
[createTime]
124-
FROM
125-
(SELECT
126-
[applicationId],
127-
[homeSubCluster],
128-
[createTime],
129-
row_number() over(partition by [homeSubCluster] order by [createTime] desc) AS row_num
130-
FROM [dbo].[applicationsHomeSubCluster]) AS t
131-
WHERE row_num <= @limit
132-
AND (CASE WHEN @homeSubCluster IS NULL THEN 1
133-
WHEN @homeSubCluster IS NOT NULL AND [homeSubCluster] = @homeSubCluster THEN 1
134-
ELSE 0 END) = 1
120+
IF @homeSubCluster = ''
121+
SELECT
122+
[applicationId],
123+
[homeSubCluster],
124+
[createTime]
125+
FROM(SELECT
126+
[applicationId],
127+
[homeSubCluster],
128+
[createTime],
129+
row_number() over(order by [createTime] desc) AS app_rank
130+
FROM [dbo].[applicationsHomeSubCluster]) AS t
131+
WHERE app_rank <= @limit;
132+
ELSE
133+
SELECT
134+
[applicationId],
135+
[homeSubCluster],
136+
[createTime]
137+
FROM(SELECT
138+
[applicationId],
139+
[homeSubCluster],
140+
[createTime],
141+
row_number() over(partition by [homeSubCluster] order by [createTime] desc) AS app_rank
142+
FROM [dbo].[applicationsHomeSubCluster]
143+
WHERE [homeSubCluster] = @homeSubCluster) AS t
144+
WHERE app_rank <= @limit;
135145
END TRY
136146

137147
BEGIN CATCH

hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-common/src/main/java/org/apache/hadoop/yarn/server/federation/store/records/ApplicationHomeSubCluster.java

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -55,8 +55,7 @@ public static ApplicationHomeSubCluster newInstance(ApplicationId appId,
5555
@Unstable
5656
public static ApplicationHomeSubCluster newInstance(ApplicationId appId, long createTime,
5757
SubClusterId homeSubCluster) {
58-
ApplicationHomeSubCluster appMapping =
59-
Records.newRecord(ApplicationHomeSubCluster.class);
58+
ApplicationHomeSubCluster appMapping = Records.newRecord(ApplicationHomeSubCluster.class);
6059
appMapping.setApplicationId(appId);
6160
appMapping.setHomeSubCluster(homeSubCluster);
6261
appMapping.setCreateTime(createTime);

hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-common/src/test/java/org/apache/hadoop/yarn/server/federation/store/impl/FederationStateStoreBaseTest.java

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -83,8 +83,8 @@ public abstract class FederationStateStoreBaseTest {
8383

8484
private static final MonotonicClock CLOCK = new MonotonicClock();
8585
private FederationStateStore stateStore;
86-
private static final int TEN_ROUNDS = 10;
87-
private static final int TWENTY_ROUNDS = 20;
86+
private static final int NUM_APPS_10 = 10;
87+
private static final int NUM_APPS_20 = 20;
8888

8989
protected abstract FederationStateStore createStateStore();
9090

@@ -428,7 +428,7 @@ public void testGetApplicationsHomeSubClusterFilter() throws Exception {
428428

429429
Set<ApplicationHomeSubCluster> appHomeSubClusters = new HashSet<>();
430430

431-
for (int i = 0; i < TEN_ROUNDS; i++) {
431+
for (int i = 0; i < NUM_APPS_10; i++) {
432432
ApplicationId appId = ApplicationId.newInstance(now, i);
433433
SubClusterId subClusterId = SubClusterId.newInstance("SC1");
434434
addApplicationHomeSC(appId, subClusterId);
@@ -438,7 +438,7 @@ public void testGetApplicationsHomeSubClusterFilter() throws Exception {
438438
}
439439

440440
// Add ApplicationHomeSC - SC2
441-
for (int i = TEN_ROUNDS; i < TWENTY_ROUNDS; i++) {
441+
for (int i = 10; i < NUM_APPS_20; i++) {
442442
ApplicationId appId = ApplicationId.newInstance(now, i);
443443
SubClusterId subClusterId = SubClusterId.newInstance("SC2");
444444
addApplicationHomeSC(appId, subClusterId);

0 commit comments

Comments
 (0)