Skip to content

Commit c2712c2

Browse files
author
dujie
committed
格式调整
1 parent d7f0172 commit c2712c2

File tree

1 file changed

+4
-4
lines changed

1 file changed

+4
-4
lines changed

flinkx-launcher/src/main/java/com/dtstack/flinkx/launcher/KerberosInfo.java

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -41,16 +41,16 @@ public class KerberosInfo {
4141
private static final Logger LOG = LoggerFactory.getLogger(KerberosInfo.class);
4242

4343

44-
private final String Krb5confPath;
44+
private final String krb5confPath;
4545
private final String keytab;
4646
private final String principal;
4747
private final Configuration config;
4848
private final org.apache.hadoop.conf.Configuration hadoopConfiguration;
4949

5050
public KerberosInfo(String krb5confPath, String keytab, String principal, Configuration config) {
51-
Krb5confPath = krb5confPath;
51+
this.krb5confPath = krb5confPath;
5252
this.config = config;
53-
hadoopConfiguration = HadoopUtils.getHadoopConfiguration(this.config);
53+
this.hadoopConfiguration = HadoopUtils.getHadoopConfiguration(this.config);
5454

5555
//keytab, launcherOptions.getKeytab() 比flinkConfiguration里配置的优先级高
5656
if (StringUtils.isBlank(keytab)) {
@@ -133,7 +133,7 @@ protected void check() {
133133

134134

135135
public String getKrb5confPath() {
136-
return Krb5confPath;
136+
return krb5confPath;
137137
}
138138

139139
public String getKeytab() {

0 commit comments

Comments
 (0)