Skip to content

Commit 55bf95a

Browse files
committed
rename login method name
1 parent ef178da commit 55bf95a

File tree

4 files changed

+4
-4
lines changed

4 files changed

+4
-4
lines changed

core/src/main/java/com/dtstack/flink/sql/util/KrbUtils.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -43,7 +43,7 @@ public class KrbUtils {
4343
// public static final String FALSE_STR = "false";
4444
// public static final String SUBJECT_ONLY_KEY = "javax.security.auth.useSubjectCredsOnly";
4545

46-
public static UserGroupInformation getUgi(String principal, String keytabPath, String krb5confPath) throws IOException {
46+
public static UserGroupInformation loginAndReturnUgi(String principal, String keytabPath, String krb5confPath) throws IOException {
4747
LOG.info("Kerberos login with principal: {} and keytab: {}", principal, keytabPath);
4848
System.setProperty(KRB5_CONF_KEY, krb5confPath);
4949
// 不刷新会读/etc/krb5.conf

kudu/kudu-side/kudu-all-side/src/main/java/com/dtstack/flink/sql/side/kudu/KuduAllReqRow.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -249,7 +249,7 @@ private KuduClient getClient(KuduSideTableInfo tableInfo) throws IOException {
249249
}
250250

251251
if (tableInfo.isEnableKrb()) {
252-
UserGroupInformation ugi = KrbUtils.getUgi(tableInfo.getPrincipal(), tableInfo.getKeytab(), tableInfo.getKrb5conf());
252+
UserGroupInformation ugi = KrbUtils.loginAndReturnUgi(tableInfo.getPrincipal(), tableInfo.getKeytab(), tableInfo.getKrb5conf());
253253
return ugi.doAs(new PrivilegedAction<KuduClient>() {
254254
@Override
255255
public KuduClient run() {

kudu/kudu-side/kudu-async-side/src/main/java/com/dtstack/flink/sql/side/kudu/KuduAsyncReqRow.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -132,7 +132,7 @@ private AsyncKuduClient getClient() throws IOException {
132132
}
133133

134134
if (kuduSideTableInfo.isEnableKrb()) {
135-
UserGroupInformation ugi = KrbUtils.getUgi(
135+
UserGroupInformation ugi = KrbUtils.loginAndReturnUgi(
136136
kuduSideTableInfo.getPrincipal(),
137137
kuduSideTableInfo.getKeytab(),
138138
kuduSideTableInfo.getKrb5conf()

kudu/kudu-sink/src/main/java/com/dtstack/flink/sql/sink/kudu/KuduOutputFormat.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -116,7 +116,7 @@ private void establishConnection() throws IOException {
116116
}
117117

118118
if (enableKrb) {
119-
UserGroupInformation ugi = KrbUtils.getUgi(
119+
UserGroupInformation ugi = KrbUtils.loginAndReturnUgi(
120120
principal,
121121
keytab,
122122
krb5conf

0 commit comments

Comments
 (0)