Skip to content

Commit ff289be

Browse files
committed
PR comments 3
1 parent ad531a8 commit ff289be

File tree

2 files changed

+3
-5
lines changed

2 files changed

+3
-5
lines changed

tez-api/src/main/java/org/apache/tez/frameworkplugins/zookeeper/ZkStandaloneClientFrameworkService.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -23,7 +23,8 @@
2323
import org.apache.tez.frameworkplugins.ClientFrameworkService;
2424

2525
public class ZkStandaloneClientFrameworkService implements ClientFrameworkService {
26-
@Override public FrameworkClient newFrameworkClient() {
26+
@Override
27+
public FrameworkClient newFrameworkClient() {
2728
return new ZkFrameworkClient();
2829
}
2930
}

tez-dag/src/main/java/org/apache/tez/dag/app/DAGAppMaster.java

Lines changed: 1 addition & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -518,10 +518,7 @@ protected void serviceInit(final Configuration conf) throws Exception {
518518
appAttemptID, jobTokenSecretManager, amCredentials);
519519

520520
if (sessionToken == null) {
521-
sessionToken = TokenCache.getSessionToken(amCredentials);
522-
if (sessionToken == null) {
523-
throw new RuntimeException("Could not find session token in AM Credentials");
524-
}
521+
throw new RuntimeException("Could not find session token in AM Credentials");
525522
}
526523

527524
// Prepare the TaskAttemptListener server for authentication of Containers

0 commit comments

Comments
 (0)