如何避免使用 API AuthOozieClient 提示密码 - AuthType.KERBEROS

如何解决如何避免使用 API AuthOozieClient 提示密码 - AuthType.KERBEROS

我有如下代码,可以使用来自不属于集群的不同框的 OozieClient API 获取当前正在运行的协调器的作业状态。使用 AuthType 作为 KERBEROS。当我调用对象 authClient (如下)时,为了获取协调员的状态,它一次又一次地提示输入用户名和密码。 你能帮我如何避免用户名和密码提示吗。 代码

import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.security.UserGroupInformation;
import org.apache.oozie.client.AuthOozieClient;
import org.apache.oozie.client.BulkResponse;
import org.apache.oozie.client.BundleJob;
import org.apache.oozie.client.CoordinatorJob;
import org.apache.oozie.client.OozieClient;
import org.apache.oozie.client.OozieClientException;
import org.apache.oozie.client.WorkflowJob;
import org.apache.oozie.client.WorkflowJob.Status;
import java.io.IOException;
import java.net.MalformedURLException;
import java.util.ArrayList;
import java.util.HashSet;
import java.util.LinkedHashSet;
import java.util.List;
import java.util.Properties;
import java.util.Set;
import java.net.URL;
public class OozieJobClient {
    public static AuthOozieClient authClient = null;
    public static String OOZIE_SERVER_URL = "http://XAXAXA.XAXAXA.com:11000/oozie";
    public static String nameNode = "hdfs://XAXAXA.XAXAX.XAXAXA.XAXAXA.com:8020";
    public static OozieClient wc;
    public static void main(String[] args) throws IOException {
        try {           
            URL oozieUrl = new URL(OOZIE_SERVER_URL);
            //OozieJobClient client = new OozieJobClient(OOZIE_SERVER_URL);
            authClient = new AuthOozieClient(oozieUrl.toString(),AuthOozieClient.AuthType.KERBEROS.toString());            
            Properties conf = authClient.createConfiguration();
            Configuration config = new Configuration();
            config.set("fs.defaultFS",nameNode);
            config.set("fs.hdfs.impl",org.apache.hadoop.hdfs.DistributedFileSystem.class.getName());
            config.set("fs.file.impl",org.apache.hadoop.fs.LocalFileSystem.class.getName());
            config.set("hadoop.security.authentication","Kerberos");
            UserGroupInformation.setConfiguration(config);
            UserGroupInformation.loginUserFromKeytab("myusername@XAXAXA.COM","C:\\ici_fw\\Hadoop\\myusername.keytab");

            System.setProperty("java.security.krb5.realm","XAXAXA.COM");
            System.setProperty("java.security.krb5.conf","C:\\ici_fw\\krb5.ini");
            System.setProperty("java.security.krb5.kdc","axaxaxax.com");           
            System.setProperty("javax.security.auth.useSubjectCredsOnly","false");
            System.setProperty("java.security.auth.login.config","C:\\ici_fw\\jaas.conf");         
            List<BundleJob> runningBundlesList = authClient.getBundleJobsInfo("user=jobsusername",1,4000);
            System.out.println(runningBundlesList);
            for (BundleJob obj1 : runningBundlesList) {
                System.out.println(obj1.getAppName() + "," + obj1.getId() + "," + obj1.getStatus() + ","
                        + obj1.getCoordinators());

                System.out.println(authClient.getBundleJobInfo(obj1.getId()).getCoordinators());
                
            }
            System.exit(0);
        } catch (OozieClientException e) {
            e.printStackTrace();
        }   }}

输出:

log4j:WARN No appenders could be found for logger (org.apache.hadoop.metrics2.lib.MutableMetricsFactory).
log4j:WARN Please initialize the log4j system properly.
log4j:WARN See http://logging.apache.org/log4j/1.2/faq.html#noconfig for more info.
SLF4J: Class path contains multiple SLF4J bindings.
SLF4J: Found binding in [jar:file:/C:/Users/myusername/.m2/repository/org/slf4j/slf4j-simple/1.6.6/slf4j-simple-1.6.6.jar!/org/slf4j/impl/StaticLoggerBinder.class]
SLF4J: Found binding in [jar:file:/C:/Users/myusername/.m2/repository/org/slf4j/slf4j-log4j12/1.7.5/slf4j-log4j12-1.7.5.jar!/org/slf4j/impl/StaticLoggerBinder.class]
SLF4J: Found binding in [jar:file:/C:/Users/myusername/.m2/repository/org/apache/logging/log4j/log4j-slf4j-impl/2.4.1/log4j-slf4j-impl-2.4.1.jar!/org/slf4j/impl/StaticLoggerBinder.class]
SLF4J: See http://www.slf4j.org/codes.html#multiple_bindings for an explanation.
SLF4J: Actual binding is of type [org.slf4j.impl.SimpleLoggerFactory]
null
Kerberos username [MYUSERNAME]: myusername [PROMPT1]
Kerberos password for myusername: mypassword [PROMPT1]
Kerberos username [MYUSERNAME]: myusername [PROMPT2]
Kerberos password for myusername: mypassword [PROMPT2]
[Bundle id[0031119-201108094620631-oozie-oozi-B] status[<STATUS>],Bundle id[0013446-201108094923150-oozie-oozi-B] status[<STATUS>],Bundle id[0013436-201108094923150-oozie-oozi-B] status[<STATUS>],Bundle id[0029646-201108094620631-oozie-oozi-B] status[<STATUS>],Bundle id[0022880-201108094742175-oozie-oozi-B] status[<STATUS>],Bundle id[0022131-201108094620631-oozie-oozi-B] status[<STATUS>],Bundle id[0010296-201108094851999-oozie-oozi-B] status[<STATUS>],Bundle id[0004481-201108094923150-oozie-oozi-B] status[<STATUS>],Bundle id[0003595-201108094923150-oozie-oozi-B] status[<STATUS>],Bundle id[0033268-201011102512157-oozie-oozi-B] status[<STATUS>],Bundle id[0030233-201011102515944-oozie-oozi-B] status[<STATUS>],Bundle id[0025747-201011102515944-oozie-oozi-B] status[<STATUS>],Bundle id[0017968-201011102515944-oozie-oozi-B] status[<STATUS>],Bundle id[0019437-201011102512157-oozie-oozi-B] status[<STATUS>],Bundle id[0069111-200913110022211-oozie-oozi-B] status[<STATUS>],Bundle id[0057009-200913110022211-oozie-oozi-B] status[<STATUS>],Bundle id[0022712-200913110100677-oozie-oozi-B] status[<STATUS>],Bundle id[0010082-200913110022211-oozie-oozi-B] status[<STATUS>],Bundle id[0013891-200831170601093-oozie-oozi-B] status[<STATUS>],Bundle id[0013117-200831170600297-oozie-oozi-B] status[<STATUS>],Bundle id[0013110-200831170600297-oozie-oozi-B] status[<STATUS>],Bundle id[0007502-200831170606985-oozie-oozi-B] status[<STATUS>],Bundle id[0007034-200831170606985-oozie-oozi-B] status[<STATUS>],]
ICXXX_XXXXXXXX_CCLOAD,0043335-210117205952974-oozie-oozi-B,<STATUS>,[]
Kerberos username [myusername]: XXXXXXXXXXXXX.......so on 

版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。

相关推荐


使用本地python环境可以成功执行 import pandas as pd import matplotlib.pyplot as plt # 设置字体 plt.rcParams[&#39;font.sans-serif&#39;] = [&#39;SimHei&#39;] # 能正确显示负号 p
错误1:Request method ‘DELETE‘ not supported 错误还原:controller层有一个接口,访问该接口时报错:Request method ‘DELETE‘ not supported 错误原因:没有接收到前端传入的参数,修改为如下 参考 错误2:cannot r
错误1:启动docker镜像时报错:Error response from daemon: driver failed programming external connectivity on endpoint quirky_allen 解决方法:重启docker -&gt; systemctl r
错误1:private field ‘xxx‘ is never assigned 按Altʾnter快捷键,选择第2项 参考:https://blog.csdn.net/shi_hong_fei_hei/article/details/88814070 错误2:启动时报错,不能找到主启动类 #
报错如下,通过源不能下载,最后警告pip需升级版本 Requirement already satisfied: pip in c:\users\ychen\appdata\local\programs\python\python310\lib\site-packages (22.0.4) Coll
错误1:maven打包报错 错误还原:使用maven打包项目时报错如下 [ERROR] Failed to execute goal org.apache.maven.plugins:maven-resources-plugin:3.2.0:resources (default-resources)
错误1:服务调用时报错 服务消费者模块assess通过openFeign调用服务提供者模块hires 如下为服务提供者模块hires的控制层接口 @RestController @RequestMapping(&quot;/hires&quot;) public class FeignControl
错误1:运行项目后报如下错误 解决方案 报错2:Failed to execute goal org.apache.maven.plugins:maven-compiler-plugin:3.8.1:compile (default-compile) on project sb 解决方案:在pom.
参考 错误原因 过滤器或拦截器在生效时,redisTemplate还没有注入 解决方案:在注入容器时就生效 @Component //项目运行时就注入Spring容器 public class RedisBean { @Resource private RedisTemplate&lt;String
使用vite构建项目报错 C:\Users\ychen\work&gt;npm init @vitejs/app @vitejs/create-app is deprecated, use npm init vite instead C:\Users\ychen\AppData\Local\npm-
参考1 参考2 解决方案 # 点击安装源 协议选择 http:// 路径填写 mirrors.aliyun.com/centos/8.3.2011/BaseOS/x86_64/os URL类型 软件库URL 其他路径 # 版本 7 mirrors.aliyun.com/centos/7/os/x86
报错1 [root@slave1 data_mocker]# kafka-console-consumer.sh --bootstrap-server slave1:9092 --topic topic_db [2023-12-19 18:31:12,770] WARN [Consumer clie
错误1 # 重写数据 hive (edu)&gt; insert overwrite table dwd_trade_cart_add_inc &gt; select data.id, &gt; data.user_id, &gt; data.course_id, &gt; date_format(
错误1 hive (edu)&gt; insert into huanhuan values(1,&#39;haoge&#39;); Query ID = root_20240110071417_fe1517ad-3607-41f4-bdcf-d00b98ac443e Total jobs = 1
报错1:执行到如下就不执行了,没有显示Successfully registered new MBean. [root@slave1 bin]# /usr/local/software/flume-1.9.0/bin/flume-ng agent -n a1 -c /usr/local/softwa
虚拟及没有启动任何服务器查看jps会显示jps,如果没有显示任何东西 [root@slave2 ~]# jps 9647 Jps 解决方案 # 进入/tmp查看 [root@slave1 dfs]# cd /tmp [root@slave1 tmp]# ll 总用量 48 drwxr-xr-x. 2
报错1 hive&gt; show databases; OK Failed with exception java.io.IOException:java.lang.RuntimeException: Error in configuring object Time taken: 0.474 se
报错1 [root@localhost ~]# vim -bash: vim: 未找到命令 安装vim yum -y install vim* # 查看是否安装成功 [root@hadoop01 hadoop]# rpm -qa |grep vim vim-X11-7.4.629-8.el7_9.x
修改hadoop配置 vi /usr/local/software/hadoop-2.9.2/etc/hadoop/yarn-site.xml # 添加如下 &lt;configuration&gt; &lt;property&gt; &lt;name&gt;yarn.nodemanager.res