public class org.apache.hive.service.server.HiveServer extends org.apache.hive.service.CompositeService
{
private static final org.slf4j.Logger LOG;
public static final java.lang.String INSTANCE_URI_CONFIG;
private static final int SHUTDOWN_TIME;
private static java.util.concurrent.CountDownLatch zkDeleteSignal;
private static volatile org.apache.zookeeper.KeeperException$Code zkDeleteResultCode;
private org.apache.hive.service.cli.CLIService cliService;
private org.apache.hive.service.cli.thrift.ThriftCLIService thriftCLIService;
private org.apache.curator.framework.CuratorFramework zKClientForPrivSync;
private org.apache.hive.http.HttpServer webServer;
private org.apache.hadoop.hive.ql.exec.tez.TezSessionPoolManager tezSessionPoolManager;
private org.apache.hadoop.hive.ql.exec.tez.WorkloadManager wm;
private org.apache.hive.http.security.PamAuthenticator pamAuthenticator;
private java.util.Map confsToPublish;
private java.lang.String serviceUri;
private boolean serviceDiscovery;
private boolean activePassiveHA;
private org.apache.curator.framework.recipes.leader.LeaderLatchListener leaderLatchListener;
private java.util.concurrent.ExecutorService leaderActionsExecutorService;
private org.apache.hive.service.server.HS2ActivePassiveHARegistry hs2HARegistry;
private org.apache.hadoop.hive.ql.metadata.Hive sessionHive;
private java.lang.String wmQueue;
private java.util.concurrent.atomic.AtomicBoolean isLeader;
private com.google.common.util.concurrent.SettableFuture isLeaderTestFuture;
private com.google.common.util.concurrent.SettableFuture notLeaderTestFuture;
private org.apache.hadoop.hive.common.ZooKeeperHiveHelper zooKeeperHelper;
private org.apache.hadoop.hive.ql.scheduled.ScheduledQueryExecutionService scheduledQueryService;
private org.apache.curator.framework.api.ACLProvider zooKeeperAclProvider;
public void <init>()
{
java.util.concurrent.atomic.AtomicBoolean v;
org.apache.hive.service.server.HiveServer v;
java.lang.Class v;
java.util.HashMap v;
java.lang.String v;
com.google.common.util.concurrent.SettableFuture v, v;
v := @this: org.apache.hive.service.server.HiveServer;
v = class "Lorg/apache/hive/service/server/HiveServer;";
v = virtualinvoke v.<java.lang.Class: java.lang.String getSimpleName()>();
specialinvoke v.<org.apache.hive.service.CompositeService: void <init>(java.lang.String)>(v);
v.<org.apache.hive.service.server.HiveServer2: org.apache.curator.framework.CuratorFramework zKClientForPrivSync> = null;
v = new java.util.HashMap;
specialinvoke v.<java.util.HashMap: void <init>()>();
v.<org.apache.hive.service.server.HiveServer2: java.util.Map confsToPublish> = v;
v = new java.util.concurrent.atomic.AtomicBoolean;
specialinvoke v.<java.util.concurrent.atomic.AtomicBoolean: void <init>(boolean)>(0);
v.<org.apache.hive.service.server.HiveServer2: java.util.concurrent.atomic.AtomicBoolean isLeader> = v;
v = staticinvoke <com.google.common.util.concurrent.SettableFuture: com.google.common.util.concurrent.SettableFuture create()>();
v.<org.apache.hive.service.server.HiveServer2: com.google.common.util.concurrent.SettableFuture isLeaderTestFuture> = v;
v = staticinvoke <com.google.common.util.concurrent.SettableFuture: com.google.common.util.concurrent.SettableFuture create()>();
v.<org.apache.hive.service.server.HiveServer2: com.google.common.util.concurrent.SettableFuture notLeaderTestFuture> = v;
v.<org.apache.hive.service.server.HiveServer2: org.apache.hadoop.hive.common.ZooKeeperHiveHelper zooKeeperHelper> = null;
staticinvoke <org.apache.hadoop.hive.conf.HiveConf: void setLoadHiveServer2Config(boolean)>(1);
return;
}
public void <init>(org.apache.hive.http.security.PamAuthenticator)
{
java.util.concurrent.atomic.AtomicBoolean v;
java.util.HashMap v;
com.google.common.util.concurrent.SettableFuture v, v;
org.apache.hive.http.security.PamAuthenticator v;
org.apache.hive.service.server.HiveServer v;
java.lang.Class v;
java.lang.String v;
v := @this: org.apache.hive.service.server.HiveServer;
v := @parameter: org.apache.hive.http.security.PamAuthenticator;
v = class "Lorg/apache/hive/service/server/HiveServer;";
v = virtualinvoke v.<java.lang.Class: java.lang.String getSimpleName()>();
specialinvoke v.<org.apache.hive.service.CompositeService: void <init>(java.lang.String)>(v);
v.<org.apache.hive.service.server.HiveServer2: org.apache.curator.framework.CuratorFramework zKClientForPrivSync> = null;
v = new java.util.HashMap;
specialinvoke v.<java.util.HashMap: void <init>()>();
v.<org.apache.hive.service.server.HiveServer2: java.util.Map confsToPublish> = v;
v = new java.util.concurrent.atomic.AtomicBoolean;
specialinvoke v.<java.util.concurrent.atomic.AtomicBoolean: void <init>(boolean)>(0);
v.<org.apache.hive.service.server.HiveServer2: java.util.concurrent.atomic.AtomicBoolean isLeader> = v;
v = staticinvoke <com.google.common.util.concurrent.SettableFuture: com.google.common.util.concurrent.SettableFuture create()>();
v.<org.apache.hive.service.server.HiveServer2: com.google.common.util.concurrent.SettableFuture isLeaderTestFuture> = v;
v = staticinvoke <com.google.common.util.concurrent.SettableFuture: com.google.common.util.concurrent.SettableFuture create()>();
v.<org.apache.hive.service.server.HiveServer2: com.google.common.util.concurrent.SettableFuture notLeaderTestFuture> = v;
v.<org.apache.hive.service.server.HiveServer2: org.apache.hadoop.hive.common.ZooKeeperHiveHelper zooKeeperHelper> = null;
staticinvoke <org.apache.hadoop.hive.conf.HiveConf: void setLoadHiveServer2Config(boolean)>(1);
v.<org.apache.hive.service.server.HiveServer2: org.apache.hive.http.security.PamAuthenticator pamAuthenticator> = v;
return;
}
public org.apache.hive.service.cli.CLIService getCliService()
{
org.apache.hive.service.server.HiveServer v;
org.apache.hive.service.cli.CLIService v;
v := @this: org.apache.hive.service.server.HiveServer;
v = v.<org.apache.hive.service.server.HiveServer2: org.apache.hive.service.cli.CLIService cliService>;
return v;
}
public void setPamAuthenticator(org.apache.hive.http.security.PamAuthenticator)
{
org.apache.hive.service.server.HiveServer v;
org.apache.hive.http.security.PamAuthenticator v;
v := @this: org.apache.hive.service.server.HiveServer;
v := @parameter: org.apache.hive.http.security.PamAuthenticator;
v.<org.apache.hive.service.server.HiveServer2: org.apache.hive.http.security.PamAuthenticator pamAuthenticator> = v;
return;
}
public com.google.common.util.concurrent.SettableFuture getIsLeaderTestFuture()
{
org.apache.hive.service.server.HiveServer v;
com.google.common.util.concurrent.SettableFuture v;
v := @this: org.apache.hive.service.server.HiveServer;
v = v.<org.apache.hive.service.server.HiveServer2: com.google.common.util.concurrent.SettableFuture isLeaderTestFuture>;
return v;
}
public com.google.common.util.concurrent.SettableFuture getNotLeaderTestFuture()
{
org.apache.hive.service.server.HiveServer v;
com.google.common.util.concurrent.SettableFuture v;
v := @this: org.apache.hive.service.server.HiveServer;
v = v.<org.apache.hive.service.server.HiveServer2: com.google.common.util.concurrent.SettableFuture notLeaderTestFuture>;
return v;
}
private void resetIsLeaderTestFuture()
{
org.apache.hive.service.server.HiveServer v;
com.google.common.util.concurrent.SettableFuture v;
v := @this: org.apache.hive.service.server.HiveServer;
v = staticinvoke <com.google.common.util.concurrent.SettableFuture: com.google.common.util.concurrent.SettableFuture create()>();
v.<org.apache.hive.service.server.HiveServer2: com.google.common.util.concurrent.SettableFuture isLeaderTestFuture> = v;
return;
}
private void resetNotLeaderTestFuture()
{
org.apache.hive.service.server.HiveServer v;
com.google.common.util.concurrent.SettableFuture v;
v := @this: org.apache.hive.service.server.HiveServer;
v = staticinvoke <com.google.common.util.concurrent.SettableFuture: com.google.common.util.concurrent.SettableFuture create()>();
v.<org.apache.hive.service.server.HiveServer2: com.google.common.util.concurrent.SettableFuture notLeaderTestFuture> = v;
return;
}
public synchronized void init(org.apache.hadoop.hive.conf.HiveConf)
{
java.lang.Integer v;
org.apache.hive.http.security.PamAuthenticator v, v, v, v, v, v;
byte v;
java.util.Map v;
org.apache.hive.http.HttpServer v, v, v;
org.apache.hive.service.cli.session.SessionManager v;
org.apache.hadoop.hive.shims.HadoopShims v;
org.apache.hive.service.server.HS2ActivePassiveHARegistry v, v;
java.lang.Object[] v;
long v, v, v;
java.io.IOException v, v;
java.lang.Runnable v;
java.util.concurrent.ThreadFactory v;
org.apache.hadoop.hive.ql.session.SessionState v;
java.util.concurrent.atomic.AtomicBoolean v;
int v, v, v;
org.apache.hive.service.cli.thrift.ThriftBinaryCLIService v;
java.util.concurrent.ExecutorService v;
org.apache.hive.service.server.HiveServer2$FailoverHandlerCallback v;
org.slf4j.Logger v, v, v, v, v;
org.apache.hive.service.cli.CLIService v, v, v, v, v;
org.apache.hadoop.hive.conf.HiveConf v, v;
org.apache.hive.service.ServiceException v, v;
org.apache.hive.http.HttpServer$Builder v, v, v;
java.lang.Exception v, v, v, v;
java.lang.Throwable v, v, v;
java.lang.Error v;
java.lang.String v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
java.lang.RuntimeException v, v, v, v, v;
org.apache.hive.service.server.HiveServer v;
org.apache.hadoop.hive.ql.metadata.HiveMaterializedViewsRegistry v;
boolean v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
javax.servlet.jsp.JspFactory v;
org.apache.jasper.runtime.JspFactoryImpl v;
com.google.common.util.concurrent.ThreadFactoryBuilder v, v, v;
org.apache.curator.framework.api.ACLProvider v;
org.apache.hive.service.server.HiveServer2$HS2LeaderLatchListener v;
org.apache.hadoop.hive.conf.HiveConf$ConfVars v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
org.apache.hive.service.cli.thrift.ThriftHttpCLIService v;
org.apache.hadoop.hive.ql.metadata.Hive v;
org.apache.hive.service.cli.thrift.ThriftCLIService v, v;
org.apache.hadoop.hive.ql.scheduled.ScheduledQueryExecutionService v;
java.lang.IllegalArgumentException v, v, v, v, v;
java.util.concurrent.TimeUnit v;
v := @this: org.apache.hive.service.server.HiveServer;
v := @parameter: org.apache.hadoop.hive.conf.HiveConf;
label:
v = <org.apache.hadoop.hive.conf.HiveConf$ConfVars: org.apache.hadoop.hive.conf.HiveConf$ConfVars HIVE_SERVER2_METRICS_ENABLED>;
v = virtualinvoke v.<org.apache.hadoop.hive.conf.HiveConf: boolean getBoolVar(org.apache.hadoop.hive.conf.HiveConf$ConfVars)>(v);
if v == 0 goto label;
staticinvoke <org.apache.hadoop.hive.common.metrics.common.MetricsFactory: void init(org.apache.hadoop.conf.Configuration)>(v);
label:
goto label;
label:
v := @caughtexception;
v = <org.apache.hive.service.server.HiveServer2: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void warn(java.lang.String,java.lang.Throwable)>("Could not initiate the HiveServer Metrics system.  Metrics may not be reported.", v);
label:
v = new org.apache.hive.service.cli.CLIService;
specialinvoke v.<org.apache.hive.service.cli.CLIService: void <init>(org.apache.hive.service.server.HiveServer,boolean)>(v, 0);
v.<org.apache.hive.service.server.HiveServer2: org.apache.hive.service.cli.CLIService cliService> = v;
v = v.<org.apache.hive.service.server.HiveServer2: org.apache.hive.service.cli.CLIService cliService>;
virtualinvoke v.<org.apache.hive.service.server.HiveServer2: void addService(org.apache.hive.service.Service)>(v);
v = staticinvoke <org.apache.hive.service.server.HiveServer2: boolean isHttpTransportMode(org.apache.hadoop.hive.conf.HiveConf)>(v);
v = staticinvoke <org.apache.hive.service.server.HiveServer2: boolean isAllTransportMode(org.apache.hadoop.hive.conf.HiveConf)>(v);
if v != 0 goto label;
if v == 0 goto label;
label:
v = new org.apache.hive.service.cli.thrift.ThriftHttpCLIService;
v = v.<org.apache.hive.service.server.HiveServer2: org.apache.hive.service.cli.CLIService cliService>;
specialinvoke v.<org.apache.hive.service.cli.thrift.ThriftHttpCLIService: void <init>(org.apache.hive.service.cli.CLIService)>(v);
v.<org.apache.hive.service.server.HiveServer2: org.apache.hive.service.cli.thrift.ThriftCLIService thriftCLIService> = v;
v = v.<org.apache.hive.service.server.HiveServer2: org.apache.hive.service.cli.thrift.ThriftCLIService thriftCLIService>;
virtualinvoke v.<org.apache.hive.service.server.HiveServer2: void addService(org.apache.hive.service.Service)>(v);
label:
if v == 0 goto label;
if v == 0 goto label;
label:
v = new org.apache.hive.service.cli.thrift.ThriftBinaryCLIService;
v = v.<org.apache.hive.service.server.HiveServer2: org.apache.hive.service.cli.CLIService cliService>;
specialinvoke v.<org.apache.hive.service.cli.thrift.ThriftBinaryCLIService: void <init>(org.apache.hive.service.cli.CLIService)>(v);
v.<org.apache.hive.service.server.HiveServer2: org.apache.hive.service.cli.thrift.ThriftCLIService thriftCLIService> = v;
v = v.<org.apache.hive.service.server.HiveServer2: org.apache.hive.service.cli.thrift.ThriftCLIService thriftCLIService>;
virtualinvoke v.<org.apache.hive.service.server.HiveServer2: void addService(org.apache.hive.service.Service)>(v);
label:
specialinvoke v.<org.apache.hive.service.CompositeService: void init(org.apache.hadoop.hive.conf.HiveConf)>(v);
label:
v = <org.apache.hadoop.hive.conf.HiveConf$ConfVars: org.apache.hadoop.hive.conf.HiveConf$ConfVars HIVE_SERVER2_THRIFT_BIND_HOST>;
v = v.<org.apache.hadoop.hive.conf.HiveConf$ConfVars: java.lang.String varname>;
v = virtualinvoke v.<org.apache.hive.service.server.HiveServer2: java.lang.String getServerHost()>();
virtualinvoke v.<org.apache.hadoop.hive.conf.HiveConf: void set(java.lang.String,java.lang.String)>(v, v);
label:
goto label;
label:
v := @caughtexception;
v = new java.lang.Error;
specialinvoke v.<java.lang.Error: void <init>(java.lang.String,java.lang.Throwable)>("Unable to initialize HiveServer2", v);
throw v;
label:
v = <org.apache.hadoop.hive.conf.HiveConf$ConfVars: org.apache.hadoop.hive.conf.HiveConf$ConfVars LLAP_HS2_ENABLE_COORDINATOR>;
v = staticinvoke <org.apache.hadoop.hive.conf.HiveConf: boolean getBoolVar(org.apache.hadoop.conf.Configuration,org.apache.hadoop.hive.conf.HiveConf$ConfVars)>(v, v);
if v == 0 goto label;
label:
staticinvoke <org.apache.hadoop.hive.llap.coordinator.LlapCoordinator: void initializeInstance(org.apache.hadoop.hive.conf.HiveConf)>(v);
label:
goto label;
label:
v := @caughtexception;
v = new java.lang.RuntimeException;
specialinvoke v.<java.lang.RuntimeException: void <init>(java.lang.Throwable)>(v);
throw v;
label:
v = <org.apache.hadoop.hive.conf.HiveConf$ConfVars: org.apache.hadoop.hive.conf.HiveConf$ConfVars LLAP_DAEMON_SERVICE_HOSTS>;
v = staticinvoke <org.apache.hadoop.hive.conf.HiveConf: java.lang.String getVar(org.apache.hadoop.conf.Configuration,org.apache.hadoop.hive.conf.HiveConf$ConfVars)>(v, v);
if v == null goto label;
v = virtualinvoke v.<java.lang.String: boolean isEmpty()>();
if v != 0 goto label;
staticinvoke <org.apache.hadoop.hive.llap.registry.impl.LlapRegistryService: org.apache.hadoop.hive.llap.registry.impl.LlapRegistryService getClient(org.apache.hadoop.conf.Configuration)>(v);
label:
staticinvoke <org.apache.hadoop.hive.ql.parse.CalcitePlanner: void warmup()>();
label:
v = staticinvoke <org.apache.hadoop.hive.ql.metadata.Hive: org.apache.hadoop.hive.ql.metadata.Hive get(org.apache.hadoop.hive.conf.HiveConf)>(v);
v.<org.apache.hive.service.server.HiveServer2: org.apache.hadoop.hive.ql.metadata.Hive sessionHive> = v;
label:
goto label;
label:
v := @caughtexception;
v = new java.lang.RuntimeException;
specialinvoke v.<java.lang.RuntimeException: void <init>(java.lang.String,java.lang.Throwable)>("Failed to get metastore connection", v);
throw v;
label:
v = staticinvoke <org.apache.hadoop.hive.ql.metadata.HiveMaterializedViewsRegistry: org.apache.hadoop.hive.ql.metadata.HiveMaterializedViewsRegistry get()>();
virtualinvoke v.<org.apache.hadoop.hive.ql.metadata.HiveMaterializedViewsRegistry: void init()>();
staticinvoke <org.apache.hadoop.hive.ql.plan.mapper.StatsSources: void initialize(org.apache.hadoop.hive.conf.HiveConf)>(v);
v = <org.apache.hadoop.hive.conf.HiveConf$ConfVars: org.apache.hadoop.hive.conf.HiveConf$ConfVars HIVE_SCHEDULED_QUERIES_EXECUTOR_ENABLED>;
v = virtualinvoke v.<org.apache.hadoop.hive.conf.HiveConf: boolean getBoolVar(org.apache.hadoop.hive.conf.HiveConf$ConfVars)>(v);
if v == 0 goto label;
v = staticinvoke <org.apache.hadoop.hive.ql.scheduled.ScheduledQueryExecutionService: org.apache.hadoop.hive.ql.scheduled.ScheduledQueryExecutionService startScheduledQueryExecutorService(org.apache.hadoop.hive.conf.HiveConf)>(v);
v.<org.apache.hive.service.server.HiveServer2: org.apache.hadoop.hive.ql.scheduled.ScheduledQueryExecutionService scheduledQueryService> = v;
label:
v = <org.apache.hadoop.hive.conf.HiveConf$ConfVars: org.apache.hadoop.hive.conf.HiveConf$ConfVars HIVE_QUERY_RESULTS_CACHE_ENABLED>;
v = virtualinvoke v.<org.apache.hadoop.hive.conf.HiveConf: boolean getBoolVar(org.apache.hadoop.hive.conf.HiveConf$ConfVars)>(v);
if v == 0 goto label;
label:
staticinvoke <org.apache.hadoop.hive.ql.cache.results.QueryResultsCache: void initialize(org.apache.hadoop.hive.conf.HiveConf)>(v);
label:
goto label;
label:
v := @caughtexception;
v = new java.lang.RuntimeException;
specialinvoke v.<java.lang.RuntimeException: void <init>(java.lang.String,java.lang.Throwable)>("Error initializing the query results cache", v);
throw v;
label:
v = <org.apache.hadoop.hive.conf.HiveConf$ConfVars: org.apache.hadoop.hive.conf.HiveConf$ConfVars MSC_CACHE_ENABLED>;
v = virtualinvoke v.<org.apache.hadoop.hive.conf.HiveConf: boolean getBoolVar(org.apache.hadoop.hive.conf.HiveConf$ConfVars)>(v);
if v == 0 goto label;
staticinvoke <org.apache.hadoop.hive.ql.metadata.HiveMetaStoreClientWithLocalCache: void init(org.apache.hadoop.conf.Configuration)>(v);
label:
staticinvoke <org.apache.hadoop.hive.ql.metadata.events.NotificationEventPoll: void initialize(org.apache.hadoop.conf.Configuration)>(v);
label:
goto label;
label:
v := @caughtexception;
v = new java.lang.RuntimeException;
specialinvoke v.<java.lang.RuntimeException: void <init>(java.lang.String,java.lang.Throwable)>("Error initializing notification event poll", v);
throw v;
label:
v = <org.apache.hadoop.hive.conf.HiveConf$ConfVars: org.apache.hadoop.hive.conf.HiveConf$ConfVars HIVE_SERVER2_TEZ_INTERACTIVE_QUEUE>;
v = v.<org.apache.hadoop.hive.conf.HiveConf$ConfVars: java.lang.String varname>;
v = virtualinvoke v.<org.apache.hadoop.hive.conf.HiveConf: java.lang.String get(java.lang.String,java.lang.String)>(v, "");
v = virtualinvoke v.<java.lang.String: java.lang.String trim()>();
v.<org.apache.hive.service.server.HiveServer2: java.lang.String wmQueue> = v;
v = specialinvoke v.<org.apache.hive.service.server.HiveServer2: org.apache.curator.framework.api.ACLProvider getACLProvider(org.apache.hadoop.hive.conf.HiveConf)>(v);
v.<org.apache.hive.service.server.HiveServer2: org.apache.curator.framework.api.ACLProvider zooKeeperAclProvider> = v;
v = <org.apache.hadoop.hive.conf.HiveConf$ConfVars: org.apache.hadoop.hive.conf.HiveConf$ConfVars HIVE_SERVER2_SUPPORT_DYNAMIC_SERVICE_DISCOVERY>;
v = virtualinvoke v.<org.apache.hadoop.hive.conf.HiveConf: boolean getBoolVar(org.apache.hadoop.hive.conf.HiveConf$ConfVars)>(v);
v.<org.apache.hive.service.server.HiveServer2: boolean serviceDiscovery> = v;
v = <org.apache.hadoop.hive.conf.HiveConf$ConfVars: org.apache.hadoop.hive.conf.HiveConf$ConfVars HIVE_SERVER2_ACTIVE_PASSIVE_HA_ENABLE>;
v = virtualinvoke v.<org.apache.hadoop.hive.conf.HiveConf: boolean getBoolVar(org.apache.hadoop.hive.conf.HiveConf$ConfVars)>(v);
v.<org.apache.hive.service.server.HiveServer2: boolean activePassiveHA> = v;
label:
v = v.<org.apache.hive.service.server.HiveServer2: boolean serviceDiscovery>;
if v == 0 goto label;
v = virtualinvoke v.<org.apache.hive.service.server.HiveServer2: java.lang.String getServerInstanceURI()>();
v.<org.apache.hive.service.server.HiveServer2: java.lang.String serviceUri> = v;
v = v.<org.apache.hive.service.server.HiveServer2: java.util.Map confsToPublish>;
v = v.<org.apache.hive.service.server.HiveServer2: java.lang.String serviceUri>;
specialinvoke v.<org.apache.hive.service.server.HiveServer2: void addConfsToPublish(org.apache.hadoop.hive.conf.HiveConf,java.util.Map,java.lang.String)>(v, v, v);
v = v.<org.apache.hive.service.server.HiveServer2: boolean activePassiveHA>;
if v == 0 goto label;
v = v.<org.apache.hive.service.server.HiveServer2: java.lang.String serviceUri>;
virtualinvoke v.<org.apache.hadoop.hive.conf.HiveConf: void set(java.lang.String,java.lang.String)>("hive.server.instance.uri", v);
v = new org.apache.hive.service.server.HiveServer2$HS2LeaderLatchListener;
v = staticinvoke <org.apache.hadoop.hive.ql.session.SessionState: org.apache.hadoop.hive.ql.session.SessionState get()>();
specialinvoke v.<org.apache.hive.service.server.HiveServer2$HS2LeaderLatchListener: void <init>(org.apache.hive.service.server.HiveServer,org.apache.hadoop.hive.ql.session.SessionState)>(v, v);
v.<org.apache.hive.service.server.HiveServer2: org.apache.curator.framework.recipes.leader.LeaderLatchListener leaderLatchListener> = v;
v = new com.google.common.util.concurrent.ThreadFactoryBuilder;
specialinvoke v.<com.google.common.util.concurrent.ThreadFactoryBuilder: void <init>()>();
v = virtualinvoke v.<com.google.common.util.concurrent.ThreadFactoryBuilder: com.google.common.util.concurrent.ThreadFactoryBuilder setDaemon(boolean)>(1);
v = virtualinvoke v.<com.google.common.util.concurrent.ThreadFactoryBuilder: com.google.common.util.concurrent.ThreadFactoryBuilder setNameFormat(java.lang.String)>("Leader Actions Handler Thread");
v = virtualinvoke v.<com.google.common.util.concurrent.ThreadFactoryBuilder: java.util.concurrent.ThreadFactory build()>();
v = staticinvoke <java.util.concurrent.Executors: java.util.concurrent.ExecutorService newSingleThreadExecutor(java.util.concurrent.ThreadFactory)>(v);
v.<org.apache.hive.service.server.HiveServer2: java.util.concurrent.ExecutorService leaderActionsExecutorService> = v;
v = staticinvoke <org.apache.hive.service.server.HS2ActivePassiveHARegistry: org.apache.hive.service.server.HS2ActivePassiveHARegistry create(org.apache.hadoop.conf.Configuration,boolean)>(v, 0);
v.<org.apache.hive.service.server.HiveServer2: org.apache.hive.service.server.HS2ActivePassiveHARegistry hs2HARegistry> = v;
label:
goto label;
label:
v := @caughtexception;
v = new org.apache.hive.service.ServiceException;
specialinvoke v.<org.apache.hive.service.ServiceException: void <init>(java.lang.Throwable)>(v);
throw v;
label:
specialinvoke v.<org.apache.hive.service.server.HiveServer2: void logCompactionParameters(org.apache.hadoop.hive.conf.HiveConf)>(v);
specialinvoke v.<org.apache.hive.service.server.HiveServer2: void maybeStartCompactorThreads(org.apache.hadoop.hive.conf.HiveConf)>(v);
label:
goto label;
label:
v := @caughtexception;
v = new java.lang.RuntimeException;
specialinvoke v.<java.lang.RuntimeException: void <init>(java.lang.Throwable)>(v);
throw v;
label:
v = <org.apache.hadoop.hive.conf.HiveConf$ConfVars: org.apache.hadoop.hive.conf.HiveConf$ConfVars HIVE_SERVER2_WEBUI_PORT>;
v = virtualinvoke v.<org.apache.hadoop.hive.conf.HiveConf: int getIntVar(org.apache.hadoop.hive.conf.HiveConf$ConfVars)>(v);
v = <org.apache.hadoop.hive.conf.HiveConf$ConfVars: org.apache.hadoop.hive.conf.HiveConf$ConfVars HIVE_SERVER2_WEBUI_BIND_HOST>;
v = virtualinvoke v.<org.apache.hadoop.hive.conf.HiveConf: java.lang.String getVar(org.apache.hadoop.hive.conf.HiveConf$ConfVars)>(v);
v = <org.apache.hadoop.hive.conf.HiveConf$ConfVars: org.apache.hadoop.hive.conf.HiveConf$ConfVars HIVE_IN_TEST>;
v = virtualinvoke v.<org.apache.hadoop.hive.conf.HiveConf: boolean getBoolVar(org.apache.hadoop.hive.conf.HiveConf$ConfVars)>(v);
if v == 0 goto label;
v = <org.apache.hadoop.hive.conf.HiveConf$ConfVars: org.apache.hadoop.hive.conf.HiveConf$ConfVars HIVE_SERVER2_WEBUI_PORT>;
v = virtualinvoke v.<org.apache.hadoop.hive.conf.HiveConf$ConfVars: java.lang.String getDefaultValue()>();
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(java.lang.String)>(v);
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
if v != v goto label;
v = 1;
goto label;
label:
v = 0;
label:
if v == 0 goto label;
v = <org.apache.hive.service.server.HiveServer2: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String)>("Web UI is disabled in test mode since webui port was not specified");
goto label;
label:
if v > 0 goto label;
v = <org.apache.hive.service.server.HiveServer2: org.slf4j.Logger LOG>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (int)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("Web UI is disabled since port is set to \u0001");
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String)>(v);
goto label;
label:
v = <org.apache.hive.service.server.HiveServer2: org.slf4j.Logger LOG>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (int)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("Starting Web UI on port \u0001");
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String)>(v);
v = staticinvoke <javax.servlet.jsp.JspFactory: javax.servlet.jsp.JspFactory getDefaultFactory()>();
if v != null goto label;
v = new org.apache.jasper.runtime.JspFactoryImpl;
specialinvoke v.<org.apache.jasper.runtime.JspFactoryImpl: void <init>()>();
staticinvoke <javax.servlet.jsp.JspFactory: void setDefaultFactory(javax.servlet.jsp.JspFactory)>(v);
label:
v = new org.apache.hive.http.HttpServer$Builder;
specialinvoke v.<org.apache.hive.http.HttpServer$Builder: void <init>(java.lang.String)>("hiveserver2");
v = virtualinvoke v.<org.apache.hive.http.HttpServer$Builder: org.apache.hive.http.HttpServer$Builder setPort(int)>(v);
virtualinvoke v.<org.apache.hive.http.HttpServer$Builder: org.apache.hive.http.HttpServer$Builder setConf(org.apache.hadoop.hive.conf.HiveConf)>(v);
virtualinvoke v.<org.apache.hive.http.HttpServer$Builder: org.apache.hive.http.HttpServer$Builder setHost(java.lang.String)>(v);
v = <org.apache.hadoop.hive.conf.HiveConf$ConfVars: org.apache.hadoop.hive.conf.HiveConf$ConfVars HIVE_SERVER2_WEBUI_MAX_THREADS>;
v = virtualinvoke v.<org.apache.hadoop.hive.conf.HiveConf: int getIntVar(org.apache.hadoop.hive.conf.HiveConf$ConfVars)>(v);
virtualinvoke v.<org.apache.hive.http.HttpServer$Builder: org.apache.hive.http.HttpServer$Builder setMaxThreads(int)>(v);
v = <org.apache.hadoop.hive.conf.HiveConf$ConfVars: org.apache.hadoop.hive.conf.HiveConf$ConfVars USERS_IN_ADMIN_ROLE>;
v = virtualinvoke v.<org.apache.hadoop.hive.conf.HiveConf: java.lang.String getVar(org.apache.hadoop.hive.conf.HiveConf$ConfVars)>(v);
virtualinvoke v.<org.apache.hive.http.HttpServer$Builder: org.apache.hive.http.HttpServer$Builder setAdmins(java.lang.String)>(v);
v = v.<org.apache.hive.service.server.HiveServer2: org.apache.hive.service.cli.CLIService cliService>;
v = virtualinvoke v.<org.apache.hive.service.cli.CLIService: org.apache.hive.service.cli.session.SessionManager getSessionManager()>();
virtualinvoke v.<org.apache.hive.http.HttpServer$Builder: org.apache.hive.http.HttpServer$Builder setContextAttribute(java.lang.String,java.lang.Object)>("hive.sm", v);
v = staticinvoke <java.lang.System: long currentTimeMillis()>();
v = staticinvoke <java.lang.String: java.lang.String valueOf(long)>(v);
virtualinvoke v.<org.apache.hadoop.hive.conf.HiveConf: void set(java.lang.String,java.lang.String)>("startcode", v);
v = <org.apache.hadoop.hive.conf.HiveConf$ConfVars: org.apache.hadoop.hive.conf.HiveConf$ConfVars HIVE_SERVER2_WEBUI_USE_SSL>;
v = virtualinvoke v.<org.apache.hadoop.hive.conf.HiveConf: boolean getBoolVar(org.apache.hadoop.hive.conf.HiveConf$ConfVars)>(v);
if v == 0 goto label;
v = <org.apache.hadoop.hive.conf.HiveConf$ConfVars: org.apache.hadoop.hive.conf.HiveConf$ConfVars HIVE_SERVER2_WEBUI_SSL_KEYSTORE_PATH>;
v = virtualinvoke v.<org.apache.hadoop.hive.conf.HiveConf: java.lang.String getVar(org.apache.hadoop.hive.conf.HiveConf$ConfVars)>(v);
v = staticinvoke <org.apache.commons.lang.StringUtils: boolean isBlank(java.lang.CharSequence)>(v);
if v == 0 goto label;
v = new java.lang.IllegalArgumentException;
v = <org.apache.hadoop.hive.conf.HiveConf$ConfVars: org.apache.hadoop.hive.conf.HiveConf$ConfVars HIVE_SERVER2_WEBUI_SSL_KEYSTORE_PATH>;
v = v.<org.apache.hadoop.hive.conf.HiveConf$ConfVars: java.lang.String varname>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("\u Not configured for SSL connection");
specialinvoke v.<java.lang.IllegalArgumentException: void <init>(java.lang.String)>(v);
throw v;
label:
v = staticinvoke <org.apache.hadoop.hive.shims.ShimLoader: org.apache.hadoop.hive.shims.HadoopShims getHadoopShims()>();
v = <org.apache.hadoop.hive.conf.HiveConf$ConfVars: org.apache.hadoop.hive.conf.HiveConf$ConfVars HIVE_SERVER2_WEBUI_SSL_KEYSTORE_PASSWORD>;
v = v.<org.apache.hadoop.hive.conf.HiveConf$ConfVars: java.lang.String varname>;
v = interfaceinvoke v.<org.apache.hadoop.hive.shims.HadoopShims: java.lang.String getPassword(org.apache.hadoop.conf.Configuration,java.lang.String)>(v, v);
virtualinvoke v.<org.apache.hive.http.HttpServer$Builder: org.apache.hive.http.HttpServer$Builder setKeyStorePassword(java.lang.String)>(v);
virtualinvoke v.<org.apache.hive.http.HttpServer$Builder: org.apache.hive.http.HttpServer$Builder setKeyStorePath(java.lang.String)>(v);
v = <org.apache.hadoop.hive.conf.HiveConf$ConfVars: org.apache.hadoop.hive.conf.HiveConf$ConfVars HIVE_SERVER2_WEBUI_SSL_KEYSTORE_TYPE>;
v = virtualinvoke v.<org.apache.hadoop.hive.conf.HiveConf: java.lang.String getVar(org.apache.hadoop.hive.conf.HiveConf$ConfVars)>(v);
virtualinvoke v.<org.apache.hive.http.HttpServer$Builder: org.apache.hive.http.HttpServer$Builder setKeyStoreType(java.lang.String)>(v);
v = <org.apache.hadoop.hive.conf.HiveConf$ConfVars: org.apache.hadoop.hive.conf.HiveConf$ConfVars HIVE_SERVER2_WEBUI_SSL_KEYMANAGERFACTORY_ALGORITHM>;
v = virtualinvoke v.<org.apache.hadoop.hive.conf.HiveConf: java.lang.String getVar(org.apache.hadoop.hive.conf.HiveConf$ConfVars)>(v);
virtualinvoke v.<org.apache.hive.http.HttpServer$Builder: org.apache.hive.http.HttpServer$Builder setKeyManagerFactoryAlgorithm(java.lang.String)>(v);
v = <org.apache.hadoop.hive.conf.HiveConf$ConfVars: org.apache.hadoop.hive.conf.HiveConf$ConfVars HIVE_SERVER2_WEBUI_SSL_EXCLUDE_CIPHERSUITES>;
v = virtualinvoke v.<org.apache.hadoop.hive.conf.HiveConf: java.lang.String getVar(org.apache.hadoop.hive.conf.HiveConf$ConfVars)>(v);
virtualinvoke v.<org.apache.hive.http.HttpServer$Builder: org.apache.hive.http.HttpServer$Builder setExcludeCiphersuites(java.lang.String)>(v);
virtualinvoke v.<org.apache.hive.http.HttpServer$Builder: org.apache.hive.http.HttpServer$Builder setUseSSL(boolean)>(1);
label:
v = <org.apache.hadoop.hive.conf.HiveConf$ConfVars: org.apache.hadoop.hive.conf.HiveConf$ConfVars HIVE_SERVER2_WEBUI_USE_SPNEGO>;
v = virtualinvoke v.<org.apache.hadoop.hive.conf.HiveConf: boolean getBoolVar(org.apache.hadoop.hive.conf.HiveConf$ConfVars)>(v);
if v == 0 goto label;
v = <org.apache.hadoop.hive.conf.HiveConf$ConfVars: org.apache.hadoop.hive.conf.HiveConf$ConfVars HIVE_SERVER2_WEBUI_SPNEGO_PRINCIPAL>;
v = virtualinvoke v.<org.apache.hadoop.hive.conf.HiveConf: java.lang.String getVar(org.apache.hadoop.hive.conf.HiveConf$ConfVars)>(v);
v = <org.apache.hadoop.hive.conf.HiveConf$ConfVars: org.apache.hadoop.hive.conf.HiveConf$ConfVars HIVE_SERVER2_WEBUI_SPNEGO_KEYTAB>;
v = virtualinvoke v.<org.apache.hadoop.hive.conf.HiveConf: java.lang.String getVar(org.apache.hadoop.hive.conf.HiveConf$ConfVars)>(v);
v = staticinvoke <org.apache.commons.lang.StringUtils: boolean isBlank(java.lang.CharSequence)>(v);
if v != 0 goto label;
v = staticinvoke <org.apache.commons.lang.StringUtils: boolean isBlank(java.lang.CharSequence)>(v);
if v == 0 goto label;
label:
v = new java.lang.IllegalArgumentException;
v = <org.apache.hadoop.hive.conf.HiveConf$ConfVars: org.apache.hadoop.hive.conf.HiveConf$ConfVars HIVE_SERVER2_WEBUI_SPNEGO_PRINCIPAL>;
v = v.<org.apache.hadoop.hive.conf.HiveConf$ConfVars: java.lang.String varname>;
v = <org.apache.hadoop.hive.conf.HiveConf$ConfVars: org.apache.hadoop.hive.conf.HiveConf$ConfVars HIVE_SERVER2_WEBUI_SPNEGO_KEYTAB>;
v = v.<org.apache.hadoop.hive.conf.HiveConf$ConfVars: java.lang.String varname>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,java.lang.String)>(v, v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("\u0001/\u Not configured for SPNEGO authentication");
specialinvoke v.<java.lang.IllegalArgumentException: void <init>(java.lang.String)>(v);
throw v;
label:
virtualinvoke v.<org.apache.hive.http.HttpServer$Builder: org.apache.hive.http.HttpServer$Builder setSPNEGOPrincipal(java.lang.String)>(v);
virtualinvoke v.<org.apache.hive.http.HttpServer$Builder: org.apache.hive.http.HttpServer$Builder setSPNEGOKeytab(java.lang.String)>(v);
virtualinvoke v.<org.apache.hive.http.HttpServer$Builder: org.apache.hive.http.HttpServer$Builder setUseSPNEGO(boolean)>(1);
label:
v = <org.apache.hadoop.hive.conf.HiveConf$ConfVars: org.apache.hadoop.hive.conf.HiveConf$ConfVars HIVE_SERVER2_WEBUI_ENABLE_CORS>;
v = virtualinvoke v.<org.apache.hadoop.hive.conf.HiveConf: boolean getBoolVar(org.apache.hadoop.hive.conf.HiveConf$ConfVars)>(v);
if v == 0 goto label;
virtualinvoke v.<org.apache.hive.http.HttpServer$Builder: org.apache.hive.http.HttpServer$Builder setEnableCORS(boolean)>(1);
v = <org.apache.hadoop.hive.conf.HiveConf$ConfVars: org.apache.hadoop.hive.conf.HiveConf$ConfVars HIVE_SERVER2_WEBUI_CORS_ALLOWED_ORIGINS>;
v = virtualinvoke v.<org.apache.hadoop.hive.conf.HiveConf: java.lang.String getVar(org.apache.hadoop.hive.conf.HiveConf$ConfVars)>(v);
v = <org.apache.hadoop.hive.conf.HiveConf$ConfVars: org.apache.hadoop.hive.conf.HiveConf$ConfVars HIVE_SERVER2_WEBUI_CORS_ALLOWED_METHODS>;
v = virtualinvoke v.<org.apache.hadoop.hive.conf.HiveConf: java.lang.String getVar(org.apache.hadoop.hive.conf.HiveConf$ConfVars)>(v);
v = <org.apache.hadoop.hive.conf.HiveConf$ConfVars: org.apache.hadoop.hive.conf.HiveConf$ConfVars HIVE_SERVER2_WEBUI_CORS_ALLOWED_HEADERS>;
v = virtualinvoke v.<org.apache.hadoop.hive.conf.HiveConf: java.lang.String getVar(org.apache.hadoop.hive.conf.HiveConf$ConfVars)>(v);
v = staticinvoke <org.apache.commons.lang.StringUtils: boolean isBlank(java.lang.CharSequence)>(v);
if v != 0 goto label;
v = staticinvoke <org.apache.commons.lang.StringUtils: boolean isBlank(java.lang.CharSequence)>(v);
if v != 0 goto label;
v = staticinvoke <org.apache.commons.lang.StringUtils: boolean isBlank(java.lang.CharSequence)>(v);
if v == 0 goto label;
label:
v = new java.lang.IllegalArgumentException;
v = <org.apache.hadoop.hive.conf.HiveConf$ConfVars: org.apache.hadoop.hive.conf.HiveConf$ConfVars HIVE_SERVER2_WEBUI_CORS_ALLOWED_ORIGINS>;
v = v.<org.apache.hadoop.hive.conf.HiveConf$ConfVars: java.lang.String varname>;
v = <org.apache.hadoop.hive.conf.HiveConf$ConfVars: org.apache.hadoop.hive.conf.HiveConf$ConfVars HIVE_SERVER2_WEBUI_CORS_ALLOWED_METHODS>;
v = v.<org.apache.hadoop.hive.conf.HiveConf$ConfVars: java.lang.String varname>;
v = <org.apache.hadoop.hive.conf.HiveConf$ConfVars: org.apache.hadoop.hive.conf.HiveConf$ConfVars HIVE_SERVER2_WEBUI_CORS_ALLOWED_HEADERS>;
v = v.<org.apache.hadoop.hive.conf.HiveConf$ConfVars: java.lang.String varname>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,java.lang.String,java.lang.String)>(v, v, v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("CORS enabled. But \u0001/\u0001/\u0001/ is not configured");
specialinvoke v.<java.lang.IllegalArgumentException: void <init>(java.lang.String)>(v);
throw v;
label:
virtualinvoke v.<org.apache.hive.http.HttpServer$Builder: org.apache.hive.http.HttpServer$Builder setAllowedOrigins(java.lang.String)>(v);
virtualinvoke v.<org.apache.hive.http.HttpServer$Builder: org.apache.hive.http.HttpServer$Builder setAllowedMethods(java.lang.String)>(v);
virtualinvoke v.<org.apache.hive.http.HttpServer$Builder: org.apache.hive.http.HttpServer$Builder setAllowedHeaders(java.lang.String)>(v);
v = <org.apache.hive.service.server.HiveServer2: org.slf4j.Logger LOG>;
v = newarray (java.lang.Object)[3];
v[0] = v;
v[1] = v;
v[2] = v;
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String,java.lang.Object[])>("CORS enabled - allowed-origins: {} allowed-methods: {} allowed-headers: {}", v);
label:
v = <org.apache.hadoop.hive.conf.HiveConf$ConfVars: org.apache.hadoop.hive.conf.HiveConf$ConfVars HIVE_SERVER2_WEBUI_XFRAME_ENABLED>;
v = virtualinvoke v.<org.apache.hadoop.hive.conf.HiveConf: boolean getBoolVar(org.apache.hadoop.hive.conf.HiveConf$ConfVars)>(v);
if v == 0 goto label;
v = virtualinvoke v.<org.apache.hive.http.HttpServer$Builder: org.apache.hive.http.HttpServer$Builder configureXFrame(boolean)>(1);
v = <org.apache.hadoop.hive.conf.HiveConf$ConfVars: org.apache.hadoop.hive.conf.HiveConf$ConfVars HIVE_SERVER2_WEBUI_XFRAME_VALUE>;
v = virtualinvoke v.<org.apache.hadoop.hive.conf.HiveConf: java.lang.String getVar(org.apache.hadoop.hive.conf.HiveConf$ConfVars)>(v);
virtualinvoke v.<org.apache.hive.http.HttpServer$Builder: org.apache.hive.http.HttpServer$Builder setXFrameOption(java.lang.String)>(v);
label:
v = <org.apache.hadoop.hive.conf.HiveConf$ConfVars: org.apache.hadoop.hive.conf.HiveConf$ConfVars HIVE_SERVER2_WEBUI_USE_PAM>;
v = virtualinvoke v.<org.apache.hadoop.hive.conf.HiveConf: boolean getBoolVar(org.apache.hadoop.hive.conf.HiveConf$ConfVars)>(v);
if v == 0 goto label;
v = <org.apache.hadoop.hive.conf.HiveConf$ConfVars: org.apache.hadoop.hive.conf.HiveConf$ConfVars HIVE_SERVER2_WEBUI_USE_SSL>;
v = virtualinvoke v.<org.apache.hadoop.hive.conf.HiveConf: boolean getBoolVar(org.apache.hadoop.hive.conf.HiveConf$ConfVars)>(v);
if v == 0 goto label;
v = <org.apache.hadoop.hive.conf.HiveConf$ConfVars: org.apache.hadoop.hive.conf.HiveConf$ConfVars HIVE_SERVER2_PAM_SERVICES>;
v = virtualinvoke v.<org.apache.hadoop.hive.conf.HiveConf: java.lang.String getVar(org.apache.hadoop.hive.conf.HiveConf$ConfVars)>(v);
if v == null goto label;
v = virtualinvoke v.<java.lang.String: boolean isEmpty()>();
if v == 0 goto label;
label:
v = new java.lang.IllegalArgumentException;
v = <org.apache.hadoop.hive.conf.HiveConf$ConfVars: org.apache.hadoop.hive.conf.HiveConf$ConfVars HIVE_SERVER2_PAM_SERVICES>;
v = v.<org.apache.hadoop.hive.conf.HiveConf$ConfVars: java.lang.String varname>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("\u are not configured.");
specialinvoke v.<java.lang.IllegalArgumentException: void <init>(java.lang.String)>(v);
throw v;
label:
v = v.<org.apache.hive.service.server.HiveServer2: org.apache.hive.http.security.PamAuthenticator pamAuthenticator>;
if v != null goto label;
v = new org.apache.hive.http.security.PamAuthenticator;
v = v;
specialinvoke v.<org.apache.hive.http.security.PamAuthenticator: void <init>(org.apache.hadoop.hive.conf.HiveConf)>(v);
goto label;
label:
v = v.<org.apache.hive.service.server.HiveServer2: org.apache.hive.http.security.PamAuthenticator pamAuthenticator>;
label:
virtualinvoke v.<org.apache.hive.http.HttpServer$Builder: org.apache.hive.http.HttpServer$Builder setPAMAuthenticator(org.apache.hive.http.security.PamAuthenticator)>(v);
virtualinvoke v.<org.apache.hive.http.HttpServer$Builder: org.apache.hive.http.HttpServer$Builder setUsePAM(boolean)>(1);
goto label;
label:
v = <org.apache.hadoop.hive.conf.HiveConf$ConfVars: org.apache.hadoop.hive.conf.HiveConf$ConfVars HIVE_IN_TEST>;
v = virtualinvoke v.<org.apache.hadoop.hive.conf.HiveConf: boolean getBoolVar(org.apache.hadoop.hive.conf.HiveConf$ConfVars)>(v);
if v == 0 goto label;
v = v.<org.apache.hive.service.server.HiveServer2: org.apache.hive.http.security.PamAuthenticator pamAuthenticator>;
if v != null goto label;
v = new org.apache.hive.http.security.PamAuthenticator;
v = v;
specialinvoke v.<org.apache.hive.http.security.PamAuthenticator: void <init>(org.apache.hadoop.hive.conf.HiveConf)>(v);
goto label;
label:
v = v.<org.apache.hive.service.server.HiveServer2: org.apache.hive.http.security.PamAuthenticator pamAuthenticator>;
label:
virtualinvoke v.<org.apache.hive.http.HttpServer$Builder: org.apache.hive.http.HttpServer$Builder setPAMAuthenticator(org.apache.hive.http.security.PamAuthenticator)>(v);
virtualinvoke v.<org.apache.hive.http.HttpServer$Builder: org.apache.hive.http.HttpServer$Builder setUsePAM(boolean)>(1);
goto label;
label:
v = new java.lang.IllegalArgumentException;
v = <org.apache.hadoop.hive.conf.HiveConf$ConfVars: org.apache.hadoop.hive.conf.HiveConf$ConfVars HIVE_SERVER2_WEBUI_USE_SSL>;
v = v.<org.apache.hadoop.hive.conf.HiveConf$ConfVars: java.lang.String varname>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("\u has false value. It is recommended to set to true when PAM is used.");
specialinvoke v.<java.lang.IllegalArgumentException: void <init>(java.lang.String)>(v);
throw v;
label:
v = v.<org.apache.hive.service.server.HiveServer2: boolean serviceDiscovery>;
if v == 0 goto label;
v = v.<org.apache.hive.service.server.HiveServer2: boolean activePassiveHA>;
if v == 0 goto label;
v = v.<org.apache.hive.service.server.HiveServer2: java.util.concurrent.atomic.AtomicBoolean isLeader>;
virtualinvoke v.<org.apache.hive.http.HttpServer$Builder: org.apache.hive.http.HttpServer$Builder setContextAttribute(java.lang.String,java.lang.Object)>("hs.isLeader", v);
v = new org.apache.hive.service.server.HiveServer2$FailoverHandlerCallback;
v = v.<org.apache.hive.service.server.HiveServer2: org.apache.hive.service.server.HS2ActivePassiveHARegistry hs2HARegistry>;
specialinvoke v.<org.apache.hive.service.server.HiveServer2$FailoverHandlerCallback: void <init>(org.apache.hive.service.server.HS2ActivePassiveHARegistry)>(v);
virtualinvoke v.<org.apache.hive.http.HttpServer$Builder: org.apache.hive.http.HttpServer$Builder setContextAttribute(java.lang.String,java.lang.Object)>("hs.failover.callback", v);
virtualinvoke v.<org.apache.hive.http.HttpServer$Builder: org.apache.hive.http.HttpServer$Builder setContextAttribute(java.lang.String,java.lang.Object)>("hiveconf", v);
virtualinvoke v.<org.apache.hive.http.HttpServer$Builder: org.apache.hive.http.HttpServer$Builder addServlet(java.lang.String,java.lang.Class)>("leader", class "Lorg/apache/hive/service/servlet/HS2LeadershipStatus;");
virtualinvoke v.<org.apache.hive.http.HttpServer$Builder: org.apache.hive.http.HttpServer$Builder addServlet(java.lang.String,java.lang.Class)>("peers", class "Lorg/apache/hive/service/servlet/HS2Peers;");
label:
virtualinvoke v.<org.apache.hive.http.HttpServer$Builder: org.apache.hive.http.HttpServer$Builder addServlet(java.lang.String,java.lang.Class)>("llap", class "Lorg/apache/hive/http/LlapServlet;");
virtualinvoke v.<org.apache.hive.http.HttpServer$Builder: org.apache.hive.http.HttpServer$Builder addServlet(java.lang.String,java.lang.Class)>("jdbcjar", class "Lorg/apache/hive/http/JdbcJarDownloadServlet;");
virtualinvoke v.<org.apache.hive.http.HttpServer$Builder: org.apache.hive.http.HttpServer$Builder setContextRootRewriteTarget(java.lang.String)>("/hiveserver.jsp");
v = virtualinvoke v.<org.apache.hive.http.HttpServer$Builder: org.apache.hive.http.HttpServer build()>();
v.<org.apache.hive.service.server.HiveServer2: org.apache.hive.http.HttpServer webServer> = v;
v = v.<org.apache.hive.service.server.HiveServer2: org.apache.hive.http.HttpServer webServer>;
virtualinvoke v.<org.apache.hive.http.HttpServer: void addServlet(java.lang.String,java.lang.String,java.lang.Class)>("query_page", "/query_page.html", class "Lorg/apache/hive/service/servlet/QueryProfileServlet;");
v = v.<org.apache.hive.service.server.HiveServer2: org.apache.hive.http.HttpServer webServer>;
virtualinvoke v.<org.apache.hive.http.HttpServer: void addServlet(java.lang.String,java.lang.String,java.lang.Class)>("api", "/api/*", class "Lorg/apache/hive/service/servlet/QueriesRESTfulAPIServlet;");
label:
goto label;
label:
v := @caughtexception;
v = new org.apache.hive.service.ServiceException;
specialinvoke v.<org.apache.hive.service.ServiceException: void <init>(java.lang.Throwable)>(v);
throw v;
label:
v = virtualinvoke v.<org.apache.hive.service.server.HiveServer2: org.apache.hadoop.hive.conf.HiveConf getHiveConf()>();
v = <org.apache.hadoop.hive.conf.HiveConf$ConfVars: org.apache.hadoop.hive.conf.HiveConf$ConfVars HIVE_SERVER2_GRACEFUL_STOP_TIMEOUT>;
v = <java.util.concurrent.TimeUnit: java.util.concurrent.TimeUnit SECONDS>;
v = staticinvoke <org.apache.hadoop.hive.conf.HiveConf: long getTimeVar(org.apache.hadoop.conf.Configuration,org.apache.hadoop.hive.conf.HiveConf$ConfVars,java.util.concurrent.TimeUnit)>(v, v, v);
v = staticinvoke <org.apache.hive.service.server.HiveServer2$lambda_init_0__30: java.lang.Runnable bootstrap$(org.apache.hive.service.server.HiveServer)>(v);
v = v cmp 0L;
if v != 0 goto label;
v = 30L;
goto label;
label:
v = v;
label:
staticinvoke <org.apache.hive.common.util.ShutdownHookManager: void addGracefulShutDownHook(java.lang.Runnable,long)>(v, v);
return;
catch java.lang.Throwable from label to label with label;
catch java.lang.Throwable from label to label with label;
catch java.io.IOException from label to label with label;
catch org.apache.hadoop.hive.ql.metadata.HiveException from label to label with label;
catch java.lang.Exception from label to label with label;
catch java.lang.Exception from label to label with label;
catch java.lang.Exception from label to label with label;
catch java.lang.Exception from label to label with label;
catch java.io.IOException from label to label with label;
}
private void logCompactionParameters(org.apache.hadoop.hive.conf.HiveConf)
{
org.slf4j.Logger v, v, v, v;
org.apache.hadoop.hive.conf.HiveConf v;
java.lang.Integer v, v;
int v;
org.apache.hadoop.hive.metastore.conf.MetastoreConf$ConfVars v, v;
org.apache.hive.service.server.HiveServer v;
java.lang.String v, v;
boolean v;
v := @this: org.apache.hive.service.server.HiveServer;
v := @parameter: org.apache.hadoop.hive.conf.HiveConf;
v = <org.apache.hive.service.server.HiveServer2: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String)>("Compaction HS2 parameters:");
v = <org.apache.hadoop.hive.metastore.conf.MetastoreConf$ConfVars: org.apache.hadoop.hive.metastore.conf.MetastoreConf$ConfVars HIVE_METASTORE_RUNWORKER_IN>;
v = staticinvoke <org.apache.hadoop.hive.metastore.conf.MetastoreConf: java.lang.String getVar(org.apache.hadoop.conf.Configuration,org.apache.hadoop.hive.metastore.conf.MetastoreConf$ConfVars)>(v, v);
v = <org.apache.hive.service.server.HiveServer2: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String,java.lang.Object)>("hive.metastore.runworker.in = {}", v);
v = <org.apache.hadoop.hive.metastore.conf.MetastoreConf$ConfVars: org.apache.hadoop.hive.metastore.conf.MetastoreConf$ConfVars COMPACTOR_WORKER_THREADS>;
v = staticinvoke <org.apache.hadoop.hive.metastore.conf.MetastoreConf: int getIntVar(org.apache.hadoop.conf.Configuration,org.apache.hadoop.hive.metastore.conf.MetastoreConf$ConfVars)>(v, v);
v = <org.apache.hive.service.server.HiveServer2: org.slf4j.Logger LOG>;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String,java.lang.Object)>("metastore.compactor.worker.threads = {}", v);
v = "hs2";
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>(v);
if v == 0 goto label;
if v >= 1 goto label;
v = <org.apache.hive.service.server.HiveServer2: org.slf4j.Logger LOG>;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
interfaceinvoke v.<org.slf4j.Logger: void warn(java.lang.String,java.lang.Object)>("Invalid number of Compactor Worker threads({}) on HS2", v);
label:
return;
}
private org.apache.hadoop.hive.metastore.api.WMFullResourcePlan createTestResourcePlan()
{
org.apache.hadoop.hive.metastore.api.WMPool[] v;
org.apache.hadoop.hive.metastore.api.WMPool v;
org.apache.hadoop.hive.metastore.api.WMFullResourcePlan v;
org.apache.hadoop.hive.metastore.api.WMResourcePlan v, v;
org.apache.hive.service.server.HiveServer v;
java.util.ArrayList v;
v := @this: org.apache.hive.service.server.HiveServer;
v = new org.apache.hadoop.hive.metastore.api.WMPool;
specialinvoke v.<org.apache.hadoop.hive.metastore.api.WMPool: void <init>(java.lang.String,java.lang.String)>("testDefault", "llap");
virtualinvoke v.<org.apache.hadoop.hive.metastore.api.WMPool: void setAllocFraction(double)>(1.0);
virtualinvoke v.<org.apache.hadoop.hive.metastore.api.WMPool: void setQueryParallelism(int)>(1);
v = new org.apache.hadoop.hive.metastore.api.WMFullResourcePlan;
v = new org.apache.hadoop.hive.metastore.api.WMResourcePlan;
specialinvoke v.<org.apache.hadoop.hive.metastore.api.WMResourcePlan: void <init>(java.lang.String)>("testDefault");
v = newarray (org.apache.hadoop.hive.metastore.api.WMPool)[1];
v[0] = v;
v = staticinvoke <com.google.common.collect.Lists: java.util.ArrayList newArrayList(java.lang.Object[])>(v);
specialinvoke v.<org.apache.hadoop.hive.metastore.api.WMFullResourcePlan: void <init>(org.apache.hadoop.hive.metastore.api.WMResourcePlan,java.util.List)>(v, v);
v = virtualinvoke v.<org.apache.hadoop.hive.metastore.api.WMFullResourcePlan: org.apache.hadoop.hive.metastore.api.WMResourcePlan getPlan()>();
virtualinvoke v.<org.apache.hadoop.hive.metastore.api.WMResourcePlan: void setDefaultPoolPath(java.lang.String)>("testDefault");
return v;
}
public static boolean isHttpTransportMode(org.apache.hadoop.hive.conf.HiveConf)
{
org.apache.hadoop.hive.conf.HiveConf$ConfVars v;
org.apache.hadoop.hive.conf.HiveConf v;
java.lang.String v, v;
org.apache.hadoop.hive.conf.HiveServer2TransportMode v;
boolean v;
v := @parameter: org.apache.hadoop.hive.conf.HiveConf;
v = staticinvoke <java.lang.System: java.lang.String getenv(java.lang.String)>("HIVE_SERVER2_TRANSPORT_MODE");
if v != null goto label;
v = <org.apache.hadoop.hive.conf.HiveConf$ConfVars: org.apache.hadoop.hive.conf.HiveConf$ConfVars HIVE_SERVER2_TRANSPORT_MODE>;
v = virtualinvoke v.<org.apache.hadoop.hive.conf.HiveConf: java.lang.String getVar(org.apache.hadoop.hive.conf.HiveConf$ConfVars)>(v);
label:
if v == null goto label;
v = <org.apache.hadoop.hive.conf.HiveServer2TransportMode: org.apache.hadoop.hive.conf.HiveServer2TransportMode http>;
v = virtualinvoke v.<org.apache.hadoop.hive.conf.HiveServer2TransportMode: java.lang.String toString()>();
v = virtualinvoke v.<java.lang.String: boolean equalsIgnoreCase(java.lang.String)>(v);
if v == 0 goto label;
return 1;
label:
return 0;
}
public static boolean isAllTransportMode(org.apache.hadoop.hive.conf.HiveConf)
{
org.apache.hadoop.hive.conf.HiveConf$ConfVars v;
org.apache.hadoop.hive.conf.HiveConf v;
java.lang.String v, v;
org.apache.hadoop.hive.conf.HiveServer2TransportMode v;
boolean v;
v := @parameter: org.apache.hadoop.hive.conf.HiveConf;
v = staticinvoke <java.lang.System: java.lang.String getenv(java.lang.String)>("HIVE_SERVER2_TRANSPORT_MODE");
if v != null goto label;
v = <org.apache.hadoop.hive.conf.HiveConf$ConfVars: org.apache.hadoop.hive.conf.HiveConf$ConfVars HIVE_SERVER2_TRANSPORT_MODE>;
v = virtualinvoke v.<org.apache.hadoop.hive.conf.HiveConf: java.lang.String getVar(org.apache.hadoop.hive.conf.HiveConf$ConfVars)>(v);
label:
if v == null goto label;
v = <org.apache.hadoop.hive.conf.HiveServer2TransportMode: org.apache.hadoop.hive.conf.HiveServer2TransportMode all>;
v = virtualinvoke v.<org.apache.hadoop.hive.conf.HiveServer2TransportMode: java.lang.String toString()>();
v = virtualinvoke v.<java.lang.String: boolean equalsIgnoreCase(java.lang.String)>(v);
if v == 0 goto label;
return 1;
label:
return 0;
}
private org.apache.curator.framework.api.ACLProvider getACLProvider(org.apache.hadoop.hive.conf.HiveConf)
{
org.apache.hadoop.hive.conf.HiveConf v;
org.apache.hive.service.server.HiveServer2$1 v;
org.apache.hive.service.server.HiveServer v;
boolean v;
v := @this: org.apache.hive.service.server.HiveServer;
v := @parameter: org.apache.hadoop.hive.conf.HiveConf;
v = staticinvoke <org.apache.hadoop.hive.registry.impl.ZookeeperUtils: boolean isKerberosEnabled(org.apache.hadoop.conf.Configuration)>(v);
v = new org.apache.hive.service.server.HiveServer2$1;
specialinvoke v.<org.apache.hive.service.server.HiveServer2$1: void <init>(org.apache.hive.service.server.HiveServer,boolean)>(v, v);
return v;
}
private void addConfsToPublish(org.apache.hadoop.hive.conf.HiveConf, java.util.Map, java.lang.String)
{
java.util.Map v;
boolean v, v, v, v;
org.apache.hadoop.hive.conf.HiveConf$ConfVars v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
int v, v;
java.lang.String v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
org.apache.hadoop.hive.conf.HiveConf v;
org.apache.hive.service.server.HiveServer v;
v := @this: org.apache.hive.service.server.HiveServer;
v := @parameter: org.apache.hadoop.hive.conf.HiveConf;
v := @parameter: java.util.Map;
v := @parameter: java.lang.String;
v = <org.apache.hadoop.hive.conf.HiveConf$ConfVars: org.apache.hadoop.hive.conf.HiveConf$ConfVars HIVE_SERVER2_THRIFT_BIND_HOST>;
v = v.<org.apache.hadoop.hive.conf.HiveConf$ConfVars: java.lang.String varname>;
v = <org.apache.hadoop.hive.conf.HiveConf$ConfVars: org.apache.hadoop.hive.conf.HiveConf$ConfVars HIVE_SERVER2_THRIFT_BIND_HOST>;
v = virtualinvoke v.<org.apache.hadoop.hive.conf.HiveConf: java.lang.String getVar(org.apache.hadoop.hive.conf.HiveConf$ConfVars)>(v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("hive.server.instance.uri", v);
v = <org.apache.hadoop.hive.conf.HiveConf$ConfVars: org.apache.hadoop.hive.conf.HiveConf$ConfVars HIVE_SERVER2_TRANSPORT_MODE>;
v = v.<org.apache.hadoop.hive.conf.HiveConf$ConfVars: java.lang.String varname>;
v = <org.apache.hadoop.hive.conf.HiveConf$ConfVars: org.apache.hadoop.hive.conf.HiveConf$ConfVars HIVE_SERVER2_TRANSPORT_MODE>;
v = virtualinvoke v.<org.apache.hadoop.hive.conf.HiveConf: java.lang.String getVar(org.apache.hadoop.hive.conf.HiveConf$ConfVars)>(v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
v = staticinvoke <org.apache.hive.service.server.HiveServer2: boolean isHttpTransportMode(org.apache.hadoop.hive.conf.HiveConf)>(v);
v = staticinvoke <org.apache.hive.service.server.HiveServer2: boolean isAllTransportMode(org.apache.hadoop.hive.conf.HiveConf)>(v);
if v != 0 goto label;
if v == 0 goto label;
label:
v = <org.apache.hadoop.hive.conf.HiveConf$ConfVars: org.apache.hadoop.hive.conf.HiveConf$ConfVars HIVE_SERVER2_THRIFT_HTTP_PORT>;
v = v.<org.apache.hadoop.hive.conf.HiveConf$ConfVars: java.lang.String varname>;
v = <org.apache.hadoop.hive.conf.HiveConf$ConfVars: org.apache.hadoop.hive.conf.HiveConf$ConfVars HIVE_SERVER2_THRIFT_HTTP_PORT>;
v = virtualinvoke v.<org.apache.hadoop.hive.conf.HiveConf: int getIntVar(org.apache.hadoop.hive.conf.HiveConf$ConfVars)>(v);
v = staticinvoke <java.lang.Integer: java.lang.String toString(int)>(v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
v = <org.apache.hadoop.hive.conf.HiveConf$ConfVars: org.apache.hadoop.hive.conf.HiveConf$ConfVars HIVE_SERVER2_THRIFT_HTTP_PATH>;
v = v.<org.apache.hadoop.hive.conf.HiveConf$ConfVars: java.lang.String varname>;
v = <org.apache.hadoop.hive.conf.HiveConf$ConfVars: org.apache.hadoop.hive.conf.HiveConf$ConfVars HIVE_SERVER2_THRIFT_HTTP_PATH>;
v = virtualinvoke v.<org.apache.hadoop.hive.conf.HiveConf: java.lang.String getVar(org.apache.hadoop.hive.conf.HiveConf$ConfVars)>(v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
label:
if v == 0 goto label;
if v == 0 goto label;
label:
v = <org.apache.hadoop.hive.conf.HiveConf$ConfVars: org.apache.hadoop.hive.conf.HiveConf$ConfVars HIVE_SERVER2_THRIFT_PORT>;
v = v.<org.apache.hadoop.hive.conf.HiveConf$ConfVars: java.lang.String varname>;
v = <org.apache.hadoop.hive.conf.HiveConf$ConfVars: org.apache.hadoop.hive.conf.HiveConf$ConfVars HIVE_SERVER2_THRIFT_PORT>;
v = virtualinvoke v.<org.apache.hadoop.hive.conf.HiveConf: int getIntVar(org.apache.hadoop.hive.conf.HiveConf$ConfVars)>(v);
v = staticinvoke <java.lang.Integer: java.lang.String toString(int)>(v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
v = <org.apache.hadoop.hive.conf.HiveConf$ConfVars: org.apache.hadoop.hive.conf.HiveConf$ConfVars HIVE_SERVER2_THRIFT_SASL_QOP>;
v = v.<org.apache.hadoop.hive.conf.HiveConf$ConfVars: java.lang.String varname>;
v = <org.apache.hadoop.hive.conf.HiveConf$ConfVars: org.apache.hadoop.hive.conf.HiveConf$ConfVars HIVE_SERVER2_THRIFT_SASL_QOP>;
v = virtualinvoke v.<org.apache.hadoop.hive.conf.HiveConf: java.lang.String getVar(org.apache.hadoop.hive.conf.HiveConf$ConfVars)>(v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
label:
v = <org.apache.hadoop.hive.conf.HiveConf$ConfVars: org.apache.hadoop.hive.conf.HiveConf$ConfVars HIVE_SERVER2_AUTHENTICATION>;
v = v.<org.apache.hadoop.hive.conf.HiveConf$ConfVars: java.lang.String varname>;
v = <org.apache.hadoop.hive.conf.HiveConf$ConfVars: org.apache.hadoop.hive.conf.HiveConf$ConfVars HIVE_SERVER2_AUTHENTICATION>;
v = virtualinvoke v.<org.apache.hadoop.hive.conf.HiveConf: java.lang.String getVar(org.apache.hadoop.hive.conf.HiveConf$ConfVars)>(v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
v = staticinvoke <org.apache.hive.service.auth.AuthType: boolean isKerberosAuthMode(org.apache.hadoop.conf.Configuration)>(v);
if v == 0 goto label;
v = <org.apache.hadoop.hive.conf.HiveConf$ConfVars: org.apache.hadoop.hive.conf.HiveConf$ConfVars HIVE_SERVER2_KERBEROS_PRINCIPAL>;
v = v.<org.apache.hadoop.hive.conf.HiveConf$ConfVars: java.lang.String varname>;
v = <org.apache.hadoop.hive.conf.HiveConf$ConfVars: org.apache.hadoop.hive.conf.HiveConf$ConfVars HIVE_SERVER2_KERBEROS_PRINCIPAL>;
v = virtualinvoke v.<org.apache.hadoop.hive.conf.HiveConf: java.lang.String getVar(org.apache.hadoop.hive.conf.HiveConf$ConfVars)>(v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
label:
v = <org.apache.hadoop.hive.conf.HiveConf$ConfVars: org.apache.hadoop.hive.conf.HiveConf$ConfVars HIVE_SERVER2_USE_SSL>;
v = v.<org.apache.hadoop.hive.conf.HiveConf$ConfVars: java.lang.String varname>;
v = <org.apache.hadoop.hive.conf.HiveConf$ConfVars: org.apache.hadoop.hive.conf.HiveConf$ConfVars HIVE_SERVER2_USE_SSL>;
v = virtualinvoke v.<org.apache.hadoop.hive.conf.HiveConf: boolean getBoolVar(org.apache.hadoop.hive.conf.HiveConf$ConfVars)>(v);
v = staticinvoke <java.lang.Boolean: java.lang.String toString(boolean)>(v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
return;
}
private static void setUpZooKeeperAuth(org.apache.hadoop.hive.conf.HiveConf) throws java.lang.Exception
{
org.apache.hadoop.hive.conf.HiveConf v;
java.io.IOException v, v;
org.apache.hadoop.hive.conf.HiveConf$ConfVars v, v;
java.lang.String v, v;
boolean v, v, v;
v := @parameter: org.apache.hadoop.hive.conf.HiveConf;
v = staticinvoke <org.apache.hadoop.hive.registry.impl.ZookeeperUtils: boolean isKerberosEnabled(org.apache.hadoop.conf.Configuration)>(v);
if v == 0 goto label;
v = <org.apache.hadoop.hive.conf.HiveConf$ConfVars: org.apache.hadoop.hive.conf.HiveConf$ConfVars HIVE_SERVER2_KERBEROS_PRINCIPAL>;
v = virtualinvoke v.<org.apache.hadoop.hive.conf.HiveConf: java.lang.String getVar(org.apache.hadoop.hive.conf.HiveConf$ConfVars)>(v);
v = virtualinvoke v.<java.lang.String: boolean isEmpty()>();
if v == 0 goto label;
v = new java.io.IOException;
specialinvoke v.<java.io.IOException: void <init>(java.lang.String)>("HiveServer Kerberos principal is empty");
throw v;
label:
v = <org.apache.hadoop.hive.conf.HiveConf$ConfVars: org.apache.hadoop.hive.conf.HiveConf$ConfVars HIVE_SERVER2_KERBEROS_KEYTAB>;
v = virtualinvoke v.<org.apache.hadoop.hive.conf.HiveConf: java.lang.String getVar(org.apache.hadoop.hive.conf.HiveConf$ConfVars)>(v);
v = virtualinvoke v.<java.lang.String: boolean isEmpty()>();
if v == 0 goto label;
v = new java.io.IOException;
specialinvoke v.<java.io.IOException: void <init>(java.lang.String)>("HiveServer Kerberos keytab is empty");
throw v;
label:
staticinvoke <org.apache.hadoop.hive.shims.Utils: void setZookeeperClientKerberosJaasConfig(java.lang.String,java.lang.String)>(v, v);
label:
return;
}
public boolean isLeader()
{
java.util.concurrent.atomic.AtomicBoolean v;
org.apache.hive.service.server.HiveServer v;
boolean v;
v := @this: org.apache.hive.service.server.HiveServer;
v = v.<org.apache.hive.service.server.HiveServer2: java.util.concurrent.atomic.AtomicBoolean isLeader>;
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicBoolean: boolean get()>();
return v;
}
public int getOpenSessionsCount()
{
org.apache.hive.service.cli.session.SessionManager v;
org.apache.hive.service.cli.CLIService v, v;
int v;
org.apache.hive.service.server.HiveServer v;
v := @this: org.apache.hive.service.server.HiveServer;
v = v.<org.apache.hive.service.server.HiveServer2: org.apache.hive.service.cli.CLIService cliService>;
if v == null goto label;
v = v.<org.apache.hive.service.server.HiveServer2: org.apache.hive.service.cli.CLIService cliService>;
v = virtualinvoke v.<org.apache.hive.service.cli.CLIService: org.apache.hive.service.cli.session.SessionManager getSessionManager()>();
v = virtualinvoke v.<org.apache.hive.service.cli.session.SessionManager: int getOpenSessionCount()>();
goto label;
label:
v = 0;
label:
return v;
}
public boolean isDeregisteredWithZooKeeper()
{
org.apache.hadoop.hive.common.ZooKeeperHiveHelper v, v;
org.apache.hive.service.server.HiveServer v;
boolean v, v, v;
v := @this: org.apache.hive.service.server.HiveServer;
v = v.<org.apache.hive.service.server.HiveServer2: boolean serviceDiscovery>;
if v == 0 goto label;
v = v.<org.apache.hive.service.server.HiveServer2: boolean activePassiveHA>;
if v != 0 goto label;
v = v.<org.apache.hive.service.server.HiveServer2: org.apache.hadoop.hive.common.ZooKeeperHiveHelper zooKeeperHelper>;
if v == null goto label;
v = v.<org.apache.hive.service.server.HiveServer2: org.apache.hadoop.hive.common.ZooKeeperHiveHelper zooKeeperHelper>;
v = virtualinvoke v.<org.apache.hadoop.hive.common.ZooKeeperHiveHelper: boolean isDeregisteredWithZooKeeper()>();
return v;
label:
return 0;
}
public java.lang.String getServerInstanceURI() throws java.lang.Exception
{
org.apache.hive.service.cli.thrift.ThriftCLIService v, v, v, v;
java.lang.Exception v;
java.net.InetAddress v, v;
int v;
org.apache.hive.service.server.HiveServer v;
java.lang.String v, v;
v := @this: org.apache.hive.service.server.HiveServer;
v = v.<org.apache.hive.service.server.HiveServer2: org.apache.hive.service.cli.thrift.ThriftCLIService thriftCLIService>;
if v == null goto label;
v = v.<org.apache.hive.service.server.HiveServer2: org.apache.hive.service.cli.thrift.ThriftCLIService thriftCLIService>;
v = virtualinvoke v.<org.apache.hive.service.cli.thrift.ThriftCLIService: java.net.InetAddress getServerIPAddress()>();
if v != null goto label;
label:
v = new java.lang.Exception;
specialinvoke v.<java.lang.Exception: void <init>(java.lang.String)>("Unable to get the server address; it hasn\'t been initialized yet.");
throw v;
label:
v = v.<org.apache.hive.service.server.HiveServer2: org.apache.hive.service.cli.thrift.ThriftCLIService thriftCLIService>;
v = virtualinvoke v.<org.apache.hive.service.cli.thrift.ThriftCLIService: java.net.InetAddress getServerIPAddress()>();
v = virtualinvoke v.<java.net.InetAddress: java.lang.String getCanonicalHostName()>();
v = v.<org.apache.hive.service.server.HiveServer2: org.apache.hive.service.cli.thrift.ThriftCLIService thriftCLIService>;
v = virtualinvoke v.<org.apache.hive.service.cli.thrift.ThriftCLIService: int getPortNumber()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,int)>(v, v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("\u0001:\u0001");
return v;
}
public java.lang.String getServerHost() throws java.lang.Exception
{
org.apache.hive.service.cli.thrift.ThriftCLIService v, v, v;
java.lang.Exception v;
java.net.InetAddress v, v;
org.apache.hive.service.server.HiveServer v;
java.lang.String v;
v := @this: org.apache.hive.service.server.HiveServer;
v = v.<org.apache.hive.service.server.HiveServer2: org.apache.hive.service.cli.thrift.ThriftCLIService thriftCLIService>;
if v == null goto label;
v = v.<org.apache.hive.service.server.HiveServer2: org.apache.hive.service.cli.thrift.ThriftCLIService thriftCLIService>;
v = virtualinvoke v.<org.apache.hive.service.cli.thrift.ThriftCLIService: java.net.InetAddress getServerIPAddress()>();
if v != null goto label;
label:
v = new java.lang.Exception;
specialinvoke v.<java.lang.Exception: void <init>(java.lang.String)>("Unable to get the server address; it hasn\'t been initialized yet.");
throw v;
label:
v = v.<org.apache.hive.service.server.HiveServer2: org.apache.hive.service.cli.thrift.ThriftCLIService thriftCLIService>;
v = virtualinvoke v.<org.apache.hive.service.cli.thrift.ThriftCLIService: java.net.InetAddress getServerIPAddress()>();
v = virtualinvoke v.<java.net.InetAddress: java.lang.String getCanonicalHostName()>();
return v;
}
public synchronized void start()
{
org.apache.hive.service.ServiceException v, v, v, v;
org.apache.hadoop.hive.common.ZooKeeperHiveHelper v, v, v;
java.util.Map v, v;
org.apache.hive.http.HttpServer v, v, v;
boolean v, v, v, v, v, v, v;
org.apache.hive.service.server.HiveServer2$DeRegisterWatcher v;
java.lang.Exception v, v, v, v;
org.apache.hive.service.server.HS2ActivePassiveHARegistry v, v;
org.apache.curator.framework.recipes.leader.LeaderLatchListener v;
com.google.common.base.Joiner v;
org.apache.curator.framework.api.ACLProvider v;
org.apache.hadoop.hive.conf.HiveConf$ConfVars v, v;
int v;
java.lang.String v, v, v, v, v, v, v;
java.util.concurrent.ExecutorService v;
org.slf4j.Logger v, v, v, v, v, v, v, v;
org.apache.hadoop.hive.conf.HiveConf v;
com.google.common.base.Joiner$MapJoiner v;
org.apache.hive.service.server.HiveServer v;
v := @this: org.apache.hive.service.server.HiveServer;
specialinvoke v.<org.apache.hive.service.CompositeService: void start()>();
v = virtualinvoke v.<org.apache.hive.service.server.HiveServer2: org.apache.hadoop.hive.conf.HiveConf getHiveConf()>();
v = v.<org.apache.hive.service.server.HiveServer2: boolean serviceDiscovery>;
if v == 0 goto label;
v = v.<org.apache.hive.service.server.HiveServer2: boolean activePassiveHA>;
if v != 0 goto label;
label:
specialinvoke v.<org.apache.hive.service.server.HiveServer2: void allowClientSessions()>();
label:
v = v.<org.apache.hive.service.server.HiveServer2: boolean serviceDiscovery>;
if v == 0 goto label;
label:
v = v.<org.apache.hive.service.server.HiveServer2: boolean activePassiveHA>;
if v == 0 goto label;
v = v.<org.apache.hive.service.server.HiveServer2: org.apache.hive.service.server.HS2ActivePassiveHARegistry hs2HARegistry>;
v = v.<org.apache.hive.service.server.HiveServer2: org.apache.curator.framework.recipes.leader.LeaderLatchListener leaderLatchListener>;
v = v.<org.apache.hive.service.server.HiveServer2: java.util.concurrent.ExecutorService leaderActionsExecutorService>;
virtualinvoke v.<org.apache.hive.service.server.HS2ActivePassiveHARegistry: void registerLeaderLatchListener(org.apache.curator.framework.recipes.leader.LeaderLatchListener,java.util.concurrent.ExecutorService)>(v, v);
v = v.<org.apache.hive.service.server.HiveServer2: org.apache.hive.service.server.HS2ActivePassiveHARegistry hs2HARegistry>;
virtualinvoke v.<org.apache.hive.service.server.HS2ActivePassiveHARegistry: void start()>();
v = <org.apache.hive.service.server.HiveServer2: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String)>("HS2 HA registry started");
goto label;
label:
v = <org.apache.hadoop.hive.conf.HiveConf$ConfVars: org.apache.hadoop.hive.conf.HiveConf$ConfVars HIVE_SERVER2_ZOOKEEPER_PUBLISH_CONFIGS>;
v = virtualinvoke v.<org.apache.hadoop.hive.conf.HiveConf: boolean getBoolVar(org.apache.hadoop.hive.conf.HiveConf$ConfVars)>(v);
v = virtualinvoke v.<org.apache.hive.service.server.HiveServer2: java.lang.String getServerInstanceURI()>();
if v == 0 goto label;
v = v.<org.apache.hive.service.server.HiveServer2: java.util.Map confsToPublish>;
v = virtualinvoke v.<org.apache.hive.service.server.HiveServer2: java.lang.String getServerInstanceURI()>();
specialinvoke v.<org.apache.hive.service.server.HiveServer2: void addConfsToPublish(org.apache.hadoop.hive.conf.HiveConf,java.util.Map,java.lang.String)>(v, v, v);
v = staticinvoke <com.google.common.base.Joiner: com.google.common.base.Joiner on(char)>(59);
v = virtualinvoke v.<com.google.common.base.Joiner: com.google.common.base.Joiner$MapJoiner withKeyValueSeparator(java.lang.String)>("=");
v = v.<org.apache.hive.service.server.HiveServer2: java.util.Map confsToPublish>;
v = virtualinvoke v.<com.google.common.base.Joiner$MapJoiner: java.lang.String join(java.util.Map)>(v);
goto label;
label:
v = v;
label:
v = virtualinvoke v.<org.apache.hadoop.hive.conf.HiveConf: org.apache.hadoop.hive.common.ZooKeeperHiveHelper getZKConfig()>();
v.<org.apache.hive.service.server.HiveServer2: org.apache.hadoop.hive.common.ZooKeeperHiveHelper zooKeeperHelper> = v;
v = staticinvoke <org.apache.hive.common.util.HiveVersionInfo: java.lang.String getVersion()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,java.lang.String)>(v, v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("serverUri=\u;version=\u;sequence=");
v = v.<org.apache.hive.service.server.HiveServer2: org.apache.hadoop.hive.common.ZooKeeperHiveHelper zooKeeperHelper>;
v = v.<org.apache.hive.service.server.HiveServer2: org.apache.curator.framework.api.ACLProvider zooKeeperAclProvider>;
v = new org.apache.hive.service.server.HiveServer2$DeRegisterWatcher;
v = v.<org.apache.hive.service.server.HiveServer2: org.apache.hadoop.hive.common.ZooKeeperHiveHelper zooKeeperHelper>;
specialinvoke v.<org.apache.hive.service.server.HiveServer2$DeRegisterWatcher: void <init>(org.apache.hive.service.server.HiveServer,org.apache.hadoop.hive.common.ZooKeeperHiveHelper)>(v, v);
virtualinvoke v.<org.apache.hadoop.hive.common.ZooKeeperHiveHelper: void addServerInstanceToZooKeeper(java.lang.String,java.lang.String,org.apache.curator.framework.api.ACLProvider,org.apache.hadoop.hive.common.ZKDeRegisterWatcher)>(v, v, v, v);
label:
goto label;
label:
v := @caughtexception;
v = <org.apache.hive.service.server.HiveServer2: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void error(java.lang.String,java.lang.Throwable)>("Error adding this HiveServer instance to ZooKeeper: ", v);
v = new org.apache.hive.service.ServiceException;
specialinvoke v.<org.apache.hive.service.ServiceException: void <init>(java.lang.Throwable)>(v);
throw v;
label:
virtualinvoke v.<org.apache.hive.service.server.HiveServer2: void startPrivilegeSynchronizer(org.apache.hadoop.hive.conf.HiveConf)>(v);
label:
goto label;
label:
v := @caughtexception;
v = <org.apache.hive.service.server.HiveServer2: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void error(java.lang.String,java.lang.Throwable)>("Error starting priviledge synchronizer: ", v);
v = new org.apache.hive.service.ServiceException;
specialinvoke v.<org.apache.hive.service.ServiceException: void <init>(java.lang.Throwable)>(v);
throw v;
label:
v = v.<org.apache.hive.service.server.HiveServer2: org.apache.hive.http.HttpServer webServer>;
if v == null goto label;
label:
v = v.<org.apache.hive.service.server.HiveServer2: org.apache.hive.http.HttpServer webServer>;
virtualinvoke v.<org.apache.hive.http.HttpServer: void start()>();
v = <org.apache.hive.service.server.HiveServer2: org.slf4j.Logger LOG>;
v = v.<org.apache.hive.service.server.HiveServer2: org.apache.hive.http.HttpServer webServer>;
v = virtualinvoke v.<org.apache.hive.http.HttpServer: int getPort()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (int)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("Web UI has started on port \u0001");
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String)>(v);
label:
goto label;
label:
v := @caughtexception;
v = <org.apache.hive.service.server.HiveServer2: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void error(java.lang.String,java.lang.Throwable)>("Error starting Web UI: ", v);
v = new org.apache.hive.service.ServiceException;
specialinvoke v.<org.apache.hive.service.ServiceException: void <init>(java.lang.Throwable)>(v);
throw v;
label:
v = <org.apache.hadoop.hive.conf.HiveConf$ConfVars: org.apache.hadoop.hive.conf.HiveConf$ConfVars HIVE_EXECUTION_ENGINE>;
v = virtualinvoke v.<org.apache.hadoop.hive.conf.HiveConf: java.lang.String getVar(org.apache.hadoop.hive.conf.HiveConf$ConfVars)>(v);
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>("tez");
if v == 0 goto label;
v = v.<org.apache.hive.service.server.HiveServer2: boolean activePassiveHA>;
if v != 0 goto label;
v = <org.apache.hive.service.server.HiveServer2: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String)>("HS2 interactive HA not enabled. Starting tez sessions..");
label:
specialinvoke v.<org.apache.hive.service.server.HiveServer2: void startOrReconnectTezSessions()>();
label:
goto label;
label:
v := @caughtexception;
v = <org.apache.hive.service.server.HiveServer2: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void error(java.lang.String,java.lang.Throwable)>("Error starting  Tez sessions: ", v);
v = new org.apache.hive.service.ServiceException;
specialinvoke v.<org.apache.hive.service.ServiceException: void <init>(java.lang.Throwable)>(v);
throw v;
label:
v = <org.apache.hive.service.server.HiveServer2: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String)>("HS2 interactive HA enabled. Tez sessions will be started/reconnected by the leader.");
label:
return;
catch java.lang.Exception from label to label with label;
catch java.lang.Exception from label to label with label;
catch java.lang.Exception from label to label with label;
catch java.lang.Exception from label to label with label;
}
private void startOrReconnectTezSessions()
{
java.lang.Throwable v;
org.apache.hadoop.hive.ql.metadata.Hive v;
org.slf4j.Logger v, v;
org.apache.hadoop.hive.conf.HiveConf v, v;
org.apache.hadoop.hive.metastore.api.WMFullResourcePlan v;
java.lang.RuntimeException v;
org.apache.hadoop.hive.conf.HiveConf$ConfVars v, v;
org.apache.hive.service.server.HiveServer v;
boolean v, v;
v := @this: org.apache.hive.service.server.HiveServer;
v = <org.apache.hive.service.server.HiveServer2: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String)>("Starting/Reconnecting tez sessions..");
label:
v = v.<org.apache.hive.service.server.HiveServer2: org.apache.hadoop.hive.ql.metadata.Hive sessionHive>;
v = virtualinvoke v.<org.apache.hadoop.hive.ql.metadata.Hive: org.apache.hadoop.hive.metastore.api.WMFullResourcePlan getActiveResourcePlan()>();
label:
goto label;
label:
v := @caughtexception;
v = virtualinvoke v.<org.apache.hive.service.server.HiveServer2: org.apache.hadoop.hive.conf.HiveConf getHiveConf()>();
v = <org.apache.hadoop.hive.conf.HiveConf$ConfVars: org.apache.hadoop.hive.conf.HiveConf$ConfVars HIVE_IN_TEST_SSL>;
v = staticinvoke <org.apache.hadoop.hive.conf.HiveConf: boolean getBoolVar(org.apache.hadoop.conf.Configuration,org.apache.hadoop.hive.conf.HiveConf$ConfVars)>(v, v);
if v != 0 goto label;
v = new java.lang.RuntimeException;
specialinvoke v.<java.lang.RuntimeException: void <init>(java.lang.Throwable)>(v);
throw v;
label:
v = null;
label:
if v != null goto label;
v = virtualinvoke v.<org.apache.hive.service.server.HiveServer2: org.apache.hadoop.hive.conf.HiveConf getHiveConf()>();
v = <org.apache.hadoop.hive.conf.HiveConf$ConfVars: org.apache.hadoop.hive.conf.HiveConf$ConfVars HIVE_IN_TEST>;
v = staticinvoke <org.apache.hadoop.hive.conf.HiveConf: boolean getBoolVar(org.apache.hadoop.conf.Configuration,org.apache.hadoop.hive.conf.HiveConf$ConfVars)>(v, v);
if v == 0 goto label;
v = <org.apache.hive.service.server.HiveServer2: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String)>("Creating a default resource plan for test");
v = specialinvoke v.<org.apache.hive.service.server.HiveServer2: org.apache.hadoop.hive.metastore.api.WMFullResourcePlan createTestResourcePlan()>();
label:
specialinvoke v.<org.apache.hive.service.server.HiveServer2: void initAndStartTezSessionPoolManager(org.apache.hadoop.hive.metastore.api.WMFullResourcePlan)>(v);
specialinvoke v.<org.apache.hive.service.server.HiveServer2: void initAndStartWorkloadManager(org.apache.hadoop.hive.metastore.api.WMFullResourcePlan)>(v);
return;
catch org.apache.hadoop.hive.ql.metadata.HiveException from label to label with label;
}
private void allowClientSessions()
{
org.apache.hive.service.cli.session.SessionManager v;
org.apache.hive.service.server.HiveServer v;
org.apache.hive.service.cli.CLIService v;
v := @this: org.apache.hive.service.server.HiveServer;
v = v.<org.apache.hive.service.server.HiveServer2: org.apache.hive.service.cli.CLIService cliService>;
v = virtualinvoke v.<org.apache.hive.service.cli.CLIService: org.apache.hive.service.cli.session.SessionManager getSessionManager()>();
virtualinvoke v.<org.apache.hive.service.cli.session.SessionManager: void allowSessions(boolean)>(1);
return;
}
private void initAndStartTezSessionPoolManager(org.apache.hadoop.hive.metastore.api.WMFullResourcePlan)
{
org.apache.hive.service.ServiceException v;
org.apache.hadoop.hive.metastore.api.WMFullResourcePlan v;
org.apache.hadoop.hive.metastore.api.WMResourcePlan v, v;
org.apache.hadoop.hive.conf.HiveConf$ConfVars v;
java.lang.String v;
boolean v;
org.slf4j.Logger v, v;
org.apache.hadoop.hive.conf.HiveConf v;
java.lang.Exception v;
org.apache.hive.service.server.HiveServer v;
org.apache.hadoop.hive.ql.exec.tez.TezSessionPoolManager v, v, v, v;
v := @this: org.apache.hive.service.server.HiveServer;
v := @parameter: org.apache.hadoop.hive.metastore.api.WMFullResourcePlan;
label:
v = <org.apache.hive.service.server.HiveServer2: org.slf4j.Logger LOG>;
if v == null goto label;
v = virtualinvoke v.<org.apache.hadoop.hive.metastore.api.WMFullResourcePlan: org.apache.hadoop.hive.metastore.api.WMResourcePlan getPlan()>();
if v != null goto label;
label:
v = "null";
goto label;
label:
v = virtualinvoke v.<org.apache.hadoop.hive.metastore.api.WMFullResourcePlan: org.apache.hadoop.hive.metastore.api.WMResourcePlan getPlan()>();
v = virtualinvoke v.<org.apache.hadoop.hive.metastore.api.WMResourcePlan: java.lang.String getName()>();
label:
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String,java.lang.Object)>("Initializing tez session pool manager. Active resource plan: {}", v);
v = staticinvoke <org.apache.hadoop.hive.ql.exec.tez.TezSessionPoolManager: org.apache.hadoop.hive.ql.exec.tez.TezSessionPoolManager getInstance()>();
v.<org.apache.hive.service.server.HiveServer2: org.apache.hadoop.hive.ql.exec.tez.TezSessionPoolManager tezSessionPoolManager> = v;
v = virtualinvoke v.<org.apache.hive.service.server.HiveServer2: org.apache.hadoop.hive.conf.HiveConf getHiveConf()>();
v = <org.apache.hadoop.hive.conf.HiveConf$ConfVars: org.apache.hadoop.hive.conf.HiveConf$ConfVars HIVE_SERVER2_TEZ_INITIALIZE_DEFAULT_SESSIONS>;
v = virtualinvoke v.<org.apache.hadoop.hive.conf.HiveConf: boolean getBoolVar(org.apache.hadoop.hive.conf.HiveConf$ConfVars)>(v);
if v == 0 goto label;
v = v.<org.apache.hive.service.server.HiveServer2: org.apache.hadoop.hive.ql.exec.tez.TezSessionPoolManager tezSessionPoolManager>;
virtualinvoke v.<org.apache.hadoop.hive.ql.exec.tez.TezSessionPoolManager: void setupPool(org.apache.hadoop.hive.conf.HiveConf)>(v);
goto label;
label:
v = v.<org.apache.hive.service.server.HiveServer2: org.apache.hadoop.hive.ql.exec.tez.TezSessionPoolManager tezSessionPoolManager>;
virtualinvoke v.<org.apache.hadoop.hive.ql.exec.tez.TezSessionPoolManager: void setupNonPool(org.apache.hadoop.hive.conf.HiveConf)>(v);
label:
v = v.<org.apache.hive.service.server.HiveServer2: org.apache.hadoop.hive.ql.exec.tez.TezSessionPoolManager tezSessionPoolManager>;
virtualinvoke v.<org.apache.hadoop.hive.ql.exec.tez.TezSessionPoolManager: void startPool(org.apache.hadoop.hive.conf.HiveConf,org.apache.hadoop.hive.metastore.api.WMFullResourcePlan)>(v, v);
v = <org.apache.hive.service.server.HiveServer2: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String)>("Tez session pool manager initialized.");
label:
goto label;
label:
v := @caughtexception;
v = new org.apache.hive.service.ServiceException;
specialinvoke v.<org.apache.hive.service.ServiceException: void <init>(java.lang.String,java.lang.Throwable)>("Unable to setup tez session pool", v);
throw v;
label:
return;
catch java.lang.Exception from label to label with label;
}
private void initAndStartWorkloadManager(org.apache.hadoop.hive.metastore.api.WMFullResourcePlan)
{
org.apache.hive.service.ServiceException v;
org.apache.hadoop.hive.metastore.api.WMFullResourcePlan v;
org.apache.hadoop.hive.metastore.api.WMResourcePlan v, v;
org.apache.hadoop.hive.conf.HiveConf$ConfVars v;
java.lang.String v, v, v, v;
boolean v;
org.slf4j.Logger v, v, v;
org.apache.hadoop.hive.conf.HiveConf v;
java.lang.Exception v;
org.apache.hadoop.hive.ql.exec.tez.WorkloadManager v, v;
org.apache.hive.service.server.HiveServer v;
v := @this: org.apache.hive.service.server.HiveServer;
v := @parameter: org.apache.hadoop.hive.metastore.api.WMFullResourcePlan;
v = v.<org.apache.hive.service.server.HiveServer2: java.lang.String wmQueue>;
v = staticinvoke <org.apache.commons.lang.StringUtils: boolean isEmpty(java.lang.CharSequence)>(v);
if v != 0 goto label;
v = <org.apache.hive.service.server.HiveServer2: org.slf4j.Logger LOG>;
if v == null goto label;
v = virtualinvoke v.<org.apache.hadoop.hive.metastore.api.WMFullResourcePlan: org.apache.hadoop.hive.metastore.api.WMResourcePlan getPlan()>();
if v != null goto label;
label:
v = "null";
goto label;
label:
v = virtualinvoke v.<org.apache.hadoop.hive.metastore.api.WMFullResourcePlan: org.apache.hadoop.hive.metastore.api.WMResourcePlan getPlan()>();
v = virtualinvoke v.<org.apache.hadoop.hive.metastore.api.WMResourcePlan: java.lang.String getName()>();
label:
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String,java.lang.Object)>("Initializing workload management. Active resource plan: {}", v);
label:
v = v.<org.apache.hive.service.server.HiveServer2: java.lang.String wmQueue>;
v = virtualinvoke v.<org.apache.hive.service.server.HiveServer2: org.apache.hadoop.hive.conf.HiveConf getHiveConf()>();
v = staticinvoke <org.apache.hadoop.hive.ql.exec.tez.WorkloadManager: org.apache.hadoop.hive.ql.exec.tez.WorkloadManager create(java.lang.String,org.apache.hadoop.hive.conf.HiveConf,org.apache.hadoop.hive.metastore.api.WMFullResourcePlan)>(v, v, v);
v.<org.apache.hive.service.server.HiveServer2: org.apache.hadoop.hive.ql.exec.tez.WorkloadManager wm> = v;
v = v.<org.apache.hive.service.server.HiveServer2: org.apache.hadoop.hive.ql.exec.tez.WorkloadManager wm>;
virtualinvoke v.<org.apache.hadoop.hive.ql.exec.tez.WorkloadManager: void start()>();
v = <org.apache.hive.service.server.HiveServer2: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String)>("Workload manager initialized.");
label:
goto label;
label:
v := @caughtexception;
v = new org.apache.hive.service.ServiceException;
specialinvoke v.<org.apache.hive.service.ServiceException: void <init>(java.lang.String,java.lang.Throwable)>("Unable to instantiate and start Workload Manager", v);
throw v;
label:
v = <org.apache.hive.service.server.HiveServer2: org.slf4j.Logger LOG>;
v = <org.apache.hadoop.hive.conf.HiveConf$ConfVars: org.apache.hadoop.hive.conf.HiveConf$ConfVars HIVE_SERVER2_TEZ_INTERACTIVE_QUEUE>;
v = v.<org.apache.hadoop.hive.conf.HiveConf$ConfVars: java.lang.String varname>;
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String,java.lang.Object)>("Workload management is not enabled as {} config is not set", v);
label:
return;
catch java.lang.Exception from label to label with label;
}
private void closeAndDisallowHiveSessions()
{
boolean v;
org.apache.hive.service.cli.HiveSQLException v;
org.apache.hive.service.cli.SessionHandle v;
org.apache.hive.service.cli.session.SessionManager v, v, v;
org.slf4j.Logger v, v, v;
java.util.Iterator v;
org.apache.hive.service.cli.CLIService v, v, v, v;
java.util.Collection v;
org.apache.hive.service.server.HiveServer v;
java.lang.Object v;
v := @this: org.apache.hive.service.server.HiveServer;
v = <org.apache.hive.service.server.HiveServer2: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String)>("Closing all open hive sessions.");
v = v.<org.apache.hive.service.server.HiveServer2: org.apache.hive.service.cli.CLIService cliService>;
if v != null goto label;
return;
label:
v = v.<org.apache.hive.service.server.HiveServer2: org.apache.hive.service.cli.CLIService cliService>;
v = virtualinvoke v.<org.apache.hive.service.cli.CLIService: org.apache.hive.service.cli.session.SessionManager getSessionManager()>();
virtualinvoke v.<org.apache.hive.service.cli.session.SessionManager: void allowSessions(boolean)>(0);
label:
v = v.<org.apache.hive.service.server.HiveServer2: org.apache.hive.service.cli.CLIService cliService>;
v = virtualinvoke v.<org.apache.hive.service.cli.CLIService: org.apache.hive.service.cli.session.SessionManager getSessionManager()>();
v = virtualinvoke v.<org.apache.hive.service.cli.session.SessionManager: java.util.Collection getSessions()>();
v = interfaceinvoke v.<java.util.Collection: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = v.<org.apache.hive.service.server.HiveServer2: org.apache.hive.service.cli.CLIService cliService>;
v = virtualinvoke v.<org.apache.hive.service.cli.CLIService: org.apache.hive.service.cli.session.SessionManager getSessionManager()>();
v = interfaceinvoke v.<org.apache.hive.service.cli.session.HiveSession: org.apache.hive.service.cli.SessionHandle getSessionHandle()>();
virtualinvoke v.<org.apache.hive.service.cli.session.SessionManager: void closeSession(org.apache.hive.service.cli.SessionHandle)>(v);
goto label;
label:
v = <org.apache.hive.service.server.HiveServer2: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String)>("Closed all open hive sessions");
label:
goto label;
label:
v := @caughtexception;
v = <org.apache.hive.service.server.HiveServer2: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void error(java.lang.String,java.lang.Throwable)>("Unable to close all open sessions.", v);
label:
return;
catch org.apache.hive.service.cli.HiveSQLException from label to label with label;
}
private void stopOrDisconnectTezSessions()
{
org.slf4j.Logger v, v, v, v, v;
java.lang.Exception v, v;
org.apache.hadoop.hive.ql.exec.tez.WorkloadManager v, v;
org.apache.hive.service.server.HiveServer v;
org.apache.hadoop.hive.ql.exec.tez.TezSessionPoolManager v, v;
v := @this: org.apache.hive.service.server.HiveServer;
v = <org.apache.hive.service.server.HiveServer2: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String)>("Stopping/Disconnecting tez sessions.");
v = v.<org.apache.hive.service.server.HiveServer2: org.apache.hadoop.hive.ql.exec.tez.TezSessionPoolManager tezSessionPoolManager>;
if v == null goto label;
label:
v = v.<org.apache.hive.service.server.HiveServer2: org.apache.hadoop.hive.ql.exec.tez.TezSessionPoolManager tezSessionPoolManager>;
virtualinvoke v.<org.apache.hadoop.hive.ql.exec.tez.TezSessionPoolManager: void stop()>();
v = <org.apache.hive.service.server.HiveServer2: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String)>("Stopped tez session pool manager.");
label:
goto label;
label:
v := @caughtexception;
v = <org.apache.hive.service.server.HiveServer2: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void error(java.lang.String,java.lang.Throwable)>("Error while stopping tez session pool manager.", v);
label:
v = v.<org.apache.hive.service.server.HiveServer2: org.apache.hadoop.hive.ql.exec.tez.WorkloadManager wm>;
if v == null goto label;
label:
v = v.<org.apache.hive.service.server.HiveServer2: org.apache.hadoop.hive.ql.exec.tez.WorkloadManager wm>;
virtualinvoke v.<org.apache.hadoop.hive.ql.exec.tez.WorkloadManager: void stop()>();
v = <org.apache.hive.service.server.HiveServer2: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String)>("Stopped workload manager.");
label:
goto label;
label:
v := @caughtexception;
v = <org.apache.hive.service.server.HiveServer2: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void error(java.lang.String,java.lang.Throwable)>("Error while stopping workload manager.", v);
label:
return;
catch java.lang.Exception from label to label with label;
catch java.lang.Exception from label to label with label;
}
public synchronized void decommission()
{
org.slf4j.Logger v, v, v;
java.lang.CharSequence v;
java.io.File v;
java.lang.Exception v;
org.apache.hadoop.hive.common.ZooKeeperHiveHelper v, v;
org.apache.hive.service.server.HiveServer v;
java.lang.String v, v;
boolean v, v;
v := @this: org.apache.hive.service.server.HiveServer;
v = <org.apache.hive.service.server.HiveServer2: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String)>("Decommissioning HiveServer2");
v = v.<org.apache.hive.service.server.HiveServer2: org.apache.hadoop.hive.common.ZooKeeperHiveHelper zooKeeperHelper>;
if v == null goto label;
v = virtualinvoke v.<org.apache.hive.service.server.HiveServer2: boolean isDeregisteredWithZooKeeper()>();
if v != 0 goto label;
label:
v = v.<org.apache.hive.service.server.HiveServer2: org.apache.hadoop.hive.common.ZooKeeperHiveHelper zooKeeperHelper>;
virtualinvoke v.<org.apache.hadoop.hive.common.ZooKeeperHiveHelper: void removeServerInstanceFromZooKeeper()>();
label:
goto label;
label:
v := @caughtexception;
v = <org.apache.hive.service.server.HiveServer2: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void error(java.lang.String,java.lang.Throwable)>("Error removing znode for this HiveServer instance from ZooKeeper.", v);
label:
v = staticinvoke <java.lang.System: java.lang.String getenv(java.lang.String)>("HIVESERVER2_PID_DIR");
v = staticinvoke <java.lang.System: java.lang.String getenv(java.lang.String)>("HIVE_CONF_DIR");
v = staticinvoke <org.apache.commons.lang.StringUtils: java.lang.CharSequence defaultIfEmpty(java.lang.CharSequence,java.lang.CharSequence)>(v, v);
v = staticinvoke <org.apache.commons.lang.StringUtils: boolean isNotEmpty(java.lang.CharSequence)>(v);
if v == 0 goto label;
v = new java.io.File;
specialinvoke v.<java.io.File: void <init>(java.lang.String,java.lang.String)>(v, "hiveserver.pid");
v = <org.apache.hive.service.server.HiveServer2: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String,java.lang.Object)>("Deleting the tmp HiveServer pid file: {}", v);
staticinvoke <org.apache.commons.io.FileUtils: boolean deleteQuietly(java.io.File)>(v);
label:
specialinvoke v.<org.apache.hive.service.CompositeService: void decommission()>();
return;
catch java.lang.Exception from label to label with label;
}
public synchronized void graceful_stop()
{
java.lang.Throwable v;
long v, v, v, v, v, v, v, v, v;
java.lang.Integer v;
byte v;
java.lang.Long v;
org.apache.hadoop.hive.conf.HiveConf$ConfVars v;
java.lang.Thread v;
int v;
boolean v;
org.apache.hive.service.cli.session.SessionManager v, v;
org.slf4j.Logger v, v;
org.apache.hive.service.cli.CLIService v, v;
java.util.Collection v, v;
org.apache.hadoop.hive.conf.HiveConf v;
java.util.concurrent.TimeUnit v;
java.lang.InterruptedException v;
org.apache.hive.service.server.HiveServer v;
v := @this: org.apache.hive.service.server.HiveServer;
label:
virtualinvoke v.<org.apache.hive.service.server.HiveServer2: void decommission()>();
v = virtualinvoke v.<org.apache.hive.service.server.HiveServer2: org.apache.hadoop.hive.conf.HiveConf getHiveConf()>();
v = <org.apache.hadoop.hive.conf.HiveConf$ConfVars: org.apache.hadoop.hive.conf.HiveConf$ConfVars HIVE_SERVER2_GRACEFUL_STOP_TIMEOUT>;
v = <java.util.concurrent.TimeUnit: java.util.concurrent.TimeUnit MILLISECONDS>;
v = staticinvoke <org.apache.hadoop.hive.conf.HiveConf: long getTimeVar(org.apache.hadoop.conf.Configuration,org.apache.hadoop.hive.conf.HiveConf$ConfVars,java.util.concurrent.TimeUnit)>(v, v, v);
v = v - 30000L;
v = v;
v = staticinvoke <java.lang.System: long currentTimeMillis()>();
label:
v = v cmp 0L;
if v <= 0 goto label;
v = virtualinvoke v.<org.apache.hive.service.server.HiveServer2: org.apache.hive.service.cli.CLIService getCliService()>();
v = virtualinvoke v.<org.apache.hive.service.cli.CLIService: org.apache.hive.service.cli.session.SessionManager getSessionManager()>();
v = virtualinvoke v.<org.apache.hive.service.cli.session.SessionManager: java.util.Collection getOperations()>();
v = interfaceinvoke v.<java.util.Collection: boolean isEmpty()>();
if v != 0 goto label;
v = staticinvoke <java.lang.Math: long min(long,long)>(100L, v);
staticinvoke <java.lang.Thread: void sleep(long)>(v);
v = v + v;
v = staticinvoke <java.lang.System: long currentTimeMillis()>();
v = v - v;
goto label;
label:
v := @caughtexception;
v = <org.apache.hive.service.server.HiveServer2: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void warn(java.lang.String)>("Interrupted while waiting for all live operations to be done");
v = staticinvoke <java.lang.Thread: java.lang.Thread currentThread()>();
virtualinvoke v.<java.lang.Thread: void interrupt()>();
label:
v = <org.apache.hive.service.server.HiveServer2: org.slf4j.Logger LOG>;
v = staticinvoke <java.lang.System: long currentTimeMillis()>();
v = v - v;
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(v);
v = virtualinvoke v.<org.apache.hive.service.server.HiveServer2: org.apache.hive.service.cli.CLIService getCliService()>();
v = virtualinvoke v.<org.apache.hive.service.cli.CLIService: org.apache.hive.service.cli.session.SessionManager getSessionManager()>();
v = virtualinvoke v.<org.apache.hive.service.cli.session.SessionManager: java.util.Collection getOperations()>();
v = interfaceinvoke v.<java.util.Collection: int size()>();
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String,java.lang.Object,java.lang.Object)>("Spent {}ms waiting for live operations to be done, current live operations: {}", v, v);
label:
virtualinvoke v.<org.apache.hive.service.server.HiveServer2: void stop()>();
goto label;
label:
v := @caughtexception;
virtualinvoke v.<org.apache.hive.service.server.HiveServer2: void stop()>();
throw v;
label:
return;
catch java.lang.InterruptedException from label to label with label;
catch java.lang.Throwable from label to label with label;
}
public synchronized void stop()
{
org.apache.hadoop.hive.common.metrics.common.Metrics v;
org.apache.hadoop.hive.common.ZooKeeperHiveHelper v, v;
org.apache.hive.http.HttpServer v, v;
java.util.concurrent.ExecutorService v;
boolean v, v, v;
org.slf4j.Logger v, v, v, v, v, v;
org.apache.hadoop.hive.ql.scheduled.ScheduledQueryExecutionService v, v;
org.apache.hadoop.hive.conf.HiveConf v;
java.lang.Exception v, v, v;
org.apache.curator.framework.CuratorFramework v, v;
org.apache.hadoop.hive.ql.parse.repl.metric.MetricSink v;
org.apache.hive.service.server.HS2ActivePassiveHARegistry v, v;
org.apache.hive.service.server.HiveServer v;
v := @this: org.apache.hive.service.server.HiveServer;
v = <org.apache.hive.service.server.HiveServer2: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String)>("Shutting down HiveServer2");
v = virtualinvoke v.<org.apache.hive.service.server.HiveServer2: org.apache.hadoop.hive.conf.HiveConf getHiveConf()>();
specialinvoke v.<org.apache.hive.service.CompositeService: void stop()>();
v = v.<org.apache.hive.service.server.HiveServer2: org.apache.hadoop.hive.ql.scheduled.ScheduledQueryExecutionService scheduledQueryService>;
if v == null goto label;
label:
v = v.<org.apache.hive.service.server.HiveServer2: org.apache.hadoop.hive.ql.scheduled.ScheduledQueryExecutionService scheduledQueryService>;
virtualinvoke v.<org.apache.hadoop.hive.ql.scheduled.ScheduledQueryExecutionService: void close()>();
label:
goto label;
label:
v := @caughtexception;
v = <org.apache.hive.service.server.HiveServer2: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void error(java.lang.String,java.lang.Throwable)>("Error stopping schq", v);
label:
v = staticinvoke <org.apache.hadoop.hive.ql.parse.repl.metric.MetricSink: org.apache.hadoop.hive.ql.parse.repl.metric.MetricSink getInstance()>();
virtualinvoke v.<org.apache.hadoop.hive.ql.parse.repl.metric.MetricSink: void tearDown()>();
v = v.<org.apache.hive.service.server.HiveServer2: org.apache.hive.service.server.HS2ActivePassiveHARegistry hs2HARegistry>;
if v == null goto label;
v = v.<org.apache.hive.service.server.HiveServer2: org.apache.hive.service.server.HS2ActivePassiveHARegistry hs2HARegistry>;
virtualinvoke v.<org.apache.hive.service.server.HS2ActivePassiveHARegistry: void stop()>();
v = v.<org.apache.hive.service.server.HiveServer2: java.util.concurrent.ExecutorService leaderActionsExecutorService>;
specialinvoke v.<org.apache.hive.service.server.HiveServer2: void shutdownExecutor(java.util.concurrent.ExecutorService)>(v);
v = <org.apache.hive.service.server.HiveServer2: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String)>("HS2 HA registry stopped");
v.<org.apache.hive.service.server.HiveServer2: org.apache.hive.service.server.HS2ActivePassiveHARegistry hs2HARegistry> = null;
label:
v = v.<org.apache.hive.service.server.HiveServer2: org.apache.hive.http.HttpServer webServer>;
if v == null goto label;
label:
v = v.<org.apache.hive.service.server.HiveServer2: org.apache.hive.http.HttpServer webServer>;
virtualinvoke v.<org.apache.hive.http.HttpServer: void stop()>();
v = <org.apache.hive.service.server.HiveServer2: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String)>("Web UI has stopped");
label:
goto label;
label:
v := @caughtexception;
v = <org.apache.hive.service.server.HiveServer2: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void error(java.lang.String,java.lang.Throwable)>("Error stopping Web UI: ", v);
label:
staticinvoke <org.apache.hadoop.hive.common.metrics.common.MetricsFactory: org.apache.hadoop.hive.common.metrics.common.Metrics getInstance()>();
v = v.<org.apache.hive.service.server.HiveServer2: boolean serviceDiscovery>;
if v == 0 goto label;
v = v.<org.apache.hive.service.server.HiveServer2: boolean activePassiveHA>;
if v != 0 goto label;
label:
v = v.<org.apache.hive.service.server.HiveServer2: org.apache.hadoop.hive.common.ZooKeeperHiveHelper zooKeeperHelper>;
if v == null goto label;
v = v.<org.apache.hive.service.server.HiveServer2: org.apache.hadoop.hive.common.ZooKeeperHiveHelper zooKeeperHelper>;
virtualinvoke v.<org.apache.hadoop.hive.common.ZooKeeperHiveHelper: void removeServerInstanceFromZooKeeper()>();
label:
goto label;
label:
v := @caughtexception;
v = <org.apache.hive.service.server.HiveServer2: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void error(java.lang.String,java.lang.Throwable)>("Error removing znode for this HiveServer instance from ZooKeeper.", v);
label:
specialinvoke v.<org.apache.hive.service.server.HiveServer2: void stopOrDisconnectTezSessions()>();
v = v.<org.apache.hive.service.server.HiveServer2: org.apache.curator.framework.CuratorFramework zKClientForPrivSync>;
if v == null goto label;
v = v.<org.apache.hive.service.server.HiveServer2: org.apache.curator.framework.CuratorFramework zKClientForPrivSync>;
interfaceinvoke v.<org.apache.curator.framework.CuratorFramework: void close()>();
label:
if v == null goto label;
v = staticinvoke <org.apache.hive.service.auth.AuthType: boolean isSamlAuthMode(org.apache.hadoop.conf.Configuration)>(v);
if v == 0 goto label;
staticinvoke <org.apache.hive.service.auth.saml.HiveSaml2Client: void shutdown()>();
label:
return;
catch java.lang.Exception from label to label with label;
catch java.lang.Exception from label to label with label;
catch java.lang.Exception from label to label with label;
}
private void shutdownExecutor(java.util.concurrent.ExecutorService)
{
java.lang.Integer v, v;
int v, v;
java.lang.String v, v, v;
java.util.concurrent.ExecutorService v;
boolean v;
org.slf4j.Logger v, v, v, v;
java.util.concurrent.TimeUnit v;
java.util.List v, v;
java.lang.InterruptedException v;
org.apache.hive.service.server.HiveServer v;
v := @this: org.apache.hive.service.server.HiveServer;
v := @parameter: java.util.concurrent.ExecutorService;
interfaceinvoke v.<java.util.concurrent.ExecutorService: void shutdown()>();
label:
v = <java.util.concurrent.TimeUnit: java.util.concurrent.TimeUnit SECONDS>;
v = interfaceinvoke v.<java.util.concurrent.ExecutorService: boolean awaitTermination(long,java.util.concurrent.TimeUnit)>(60L, v);
if v != 0 goto label;
v = <org.apache.hive.service.server.HiveServer2: org.slf4j.Logger LOG>;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(60);
interfaceinvoke v.<org.slf4j.Logger: void warn(java.lang.String,java.lang.Object)>("Executor service did not terminate in the specified time {} sec", v);
v = interfaceinvoke v.<java.util.concurrent.ExecutorService: java.util.List shutdownNow()>();
v = <org.apache.hive.service.server.HiveServer2: org.slf4j.Logger LOG>;
v = interfaceinvoke v.<java.util.List: int size()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (int)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("Executor service was abruptly shut down. \u tasks will not be executed.");
interfaceinvoke v.<org.slf4j.Logger: void warn(java.lang.String)>(v);
label:
goto label;
label:
v := @caughtexception;
v = <org.apache.hive.service.server.HiveServer2: org.slf4j.Logger LOG>;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(60);
v = virtualinvoke v.<java.lang.InterruptedException: java.lang.String getMessage()>();
interfaceinvoke v.<org.slf4j.Logger: void warn(java.lang.String,java.lang.Object,java.lang.Object)>("Executor service did not terminate in the specified time {} sec. Exception: {}", v, v);
v = interfaceinvoke v.<java.util.concurrent.ExecutorService: java.util.List shutdownNow()>();
v = <org.apache.hive.service.server.HiveServer2: org.slf4j.Logger LOG>;
v = interfaceinvoke v.<java.util.List: int size()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (int)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("Executor service was abruptly shut down. \u tasks will not be executed.");
interfaceinvoke v.<org.slf4j.Logger: void warn(java.lang.String)>(v);
label:
return;
catch java.lang.InterruptedException from label to label with label;
}
public static void scheduleClearDanglingScratchDir(org.apache.hadoop.hive.conf.HiveConf, int)
{
org.apache.commons.lang.concurrent.BasicThreadFactory$Builder v, v, v;
org.apache.hadoop.hive.ql.session.ClearDanglingScratchDir v;
long v;
org.apache.hadoop.hive.conf.HiveConf$ConfVars v, v, v;
int v;
java.util.concurrent.ScheduledExecutorService v;
java.lang.String v;
boolean v;
org.apache.hadoop.hive.conf.HiveConf v;
org.apache.commons.lang.concurrent.BasicThreadFactory v;
java.util.concurrent.TimeUnit v, v;
v := @parameter: org.apache.hadoop.hive.conf.HiveConf;
v := @parameter: int;
v = <org.apache.hadoop.hive.conf.HiveConf$ConfVars: org.apache.hadoop.hive.conf.HiveConf$ConfVars HIVE_SERVER2_CLEAR_DANGLING_SCRATCH_DIR>;
v = virtualinvoke v.<org.apache.hadoop.hive.conf.HiveConf: boolean getBoolVar(org.apache.hadoop.hive.conf.HiveConf$ConfVars)>(v);
if v == 0 goto label;
v = new org.apache.commons.lang.concurrent.BasicThreadFactory$Builder;
specialinvoke v.<org.apache.commons.lang.concurrent.BasicThreadFactory$Builder: void <init>()>();
v = virtualinvoke v.<org.apache.commons.lang.concurrent.BasicThreadFactory$Builder: org.apache.commons.lang.concurrent.BasicThreadFactory$Builder namingPattern(java.lang.String)>("cleardanglingscratchdir-%d");
v = virtualinvoke v.<org.apache.commons.lang.concurrent.BasicThreadFactory$Builder: org.apache.commons.lang.concurrent.BasicThreadFactory$Builder daemon(boolean)>(1);
v = virtualinvoke v.<org.apache.commons.lang.concurrent.BasicThreadFactory$Builder: org.apache.commons.lang.concurrent.BasicThreadFactory build()>();
v = staticinvoke <java.util.concurrent.Executors: java.util.concurrent.ScheduledExecutorService newSingleThreadScheduledExecutor(java.util.concurrent.ThreadFactory)>(v);
v = new org.apache.hadoop.hive.ql.session.ClearDanglingScratchDir;
v = <org.apache.hadoop.hive.conf.HiveConf$ConfVars: org.apache.hadoop.hive.conf.HiveConf$ConfVars SCRATCHDIR>;
v = staticinvoke <org.apache.hadoop.hive.conf.HiveConf: java.lang.String getVar(org.apache.hadoop.conf.Configuration,org.apache.hadoop.hive.conf.HiveConf$ConfVars)>(v, v);
specialinvoke v.<org.apache.hadoop.hive.ql.session.ClearDanglingScratchDir: void <init>(boolean,boolean,boolean,java.lang.String,org.apache.hadoop.hive.conf.HiveConf)>(0, 0, 0, v, v);
v = <org.apache.hadoop.hive.conf.HiveConf$ConfVars: org.apache.hadoop.hive.conf.HiveConf$ConfVars HIVE_SERVER2_CLEAR_DANGLING_SCRATCH_DIR_INTERVAL>;
v = <java.util.concurrent.TimeUnit: java.util.concurrent.TimeUnit SECONDS>;
v = staticinvoke <org.apache.hadoop.hive.conf.HiveConf: long getTimeVar(org.apache.hadoop.conf.Configuration,org.apache.hadoop.hive.conf.HiveConf$ConfVars,java.util.concurrent.TimeUnit)>(v, v, v);
v = <java.util.concurrent.TimeUnit: java.util.concurrent.TimeUnit SECONDS>;
interfaceinvoke v.<java.util.concurrent.ScheduledExecutorService: java.util.concurrent.ScheduledFuture scheduleAtFixedRate(java.lang.Runnable,long,long,java.util.concurrent.TimeUnit)>(v, v, v, v);
label:
return;
}
public void startPrivilegeSynchronizer(org.apache.hadoop.hive.conf.HiveConf) throws java.lang.Exception
{
org.apache.curator.framework.recipes.leader.LeaderLatch v;
org.apache.hadoop.hive.common.ZooKeeperHiveHelper v;
java.lang.Thread v;
org.apache.hadoop.hive.metastore.conf.MetastoreConf$ConfVars v, v, v;
org.apache.hadoop.hive.ql.security.authorization.plugin.HivePolicyProvider v, v;
boolean v, v, v;
org.apache.hadoop.hive.ql.session.SessionState v, v;
org.apache.hadoop.hive.ql.security.authorization.PrivilegeSynchronizer v;
java.util.List v;
org.apache.curator.framework.CuratorFramework v, v;
org.apache.curator.framework.api.ACLProvider v;
org.apache.hadoop.hive.ql.security.authorization.plugin.HiveAuthorizer v;
org.apache.hadoop.hive.ql.security.authorization.PolicyProviderContainer v;
org.apache.hadoop.hive.conf.HiveConf$ConfVars v, v, v;
int v, v;
java.lang.String v, v, v, v, v, v;
org.slf4j.Logger v, v;
java.util.Iterator v;
org.apache.hadoop.hive.conf.HiveConf v;
org.apache.hadoop.hive.ql.security.HiveAuthenticationProvider v;
org.apache.hive.service.server.HiveServer v;
java.lang.Object v;
v := @this: org.apache.hive.service.server.HiveServer;
v := @parameter: org.apache.hadoop.hive.conf.HiveConf;
v = <org.apache.hadoop.hive.conf.HiveConf$ConfVars: org.apache.hadoop.hive.conf.HiveConf$ConfVars HIVE_PRIVILEGE_SYNCHRONIZER>;
v = staticinvoke <org.apache.hadoop.hive.conf.HiveConf: boolean getBoolVar(org.apache.hadoop.conf.Configuration,org.apache.hadoop.hive.conf.HiveConf$ConfVars)>(v, v);
if v != 0 goto label;
return;
label:
v = new org.apache.hadoop.hive.ql.security.authorization.PolicyProviderContainer;
specialinvoke v.<org.apache.hadoop.hive.ql.security.authorization.PolicyProviderContainer: void <init>()>();
v = staticinvoke <org.apache.hadoop.hive.ql.session.SessionState: org.apache.hadoop.hive.ql.session.SessionState get()>();
v = virtualinvoke v.<org.apache.hadoop.hive.ql.session.SessionState: org.apache.hadoop.hive.ql.security.authorization.plugin.HiveAuthorizer getAuthorizerV2()>();
v = interfaceinvoke v.<org.apache.hadoop.hive.ql.security.authorization.plugin.HiveAuthorizer: org.apache.hadoop.hive.ql.security.authorization.plugin.HivePolicyProvider getHivePolicyProvider()>();
if v == null goto label;
virtualinvoke v.<org.apache.hadoop.hive.ql.security.authorization.PolicyProviderContainer: void addAuthorizer(org.apache.hadoop.hive.ql.security.authorization.plugin.HiveAuthorizer)>(v);
label:
v = <org.apache.hadoop.hive.metastore.conf.MetastoreConf$ConfVars: org.apache.hadoop.hive.metastore.conf.MetastoreConf$ConfVars PRE_EVENT_LISTENERS>;
v = staticinvoke <org.apache.hadoop.hive.metastore.conf.MetastoreConf: java.lang.String getVar(org.apache.hadoop.conf.Configuration,org.apache.hadoop.hive.metastore.conf.MetastoreConf$ConfVars)>(v, v);
if v == null goto label;
v = <org.apache.hadoop.hive.metastore.conf.MetastoreConf$ConfVars: org.apache.hadoop.hive.metastore.conf.MetastoreConf$ConfVars PRE_EVENT_LISTENERS>;
v = staticinvoke <org.apache.hadoop.hive.metastore.conf.MetastoreConf: java.lang.String getVar(org.apache.hadoop.conf.Configuration,org.apache.hadoop.hive.metastore.conf.MetastoreConf$ConfVars)>(v, v);
v = virtualinvoke v.<java.lang.String: boolean contains(java.lang.CharSequence)>("org.apache.hadoop.hive.ql.security.authorization.AuthorizationPreEventListener");
if v == 0 goto label;
v = <org.apache.hadoop.hive.metastore.conf.MetastoreConf$ConfVars: org.apache.hadoop.hive.metastore.conf.MetastoreConf$ConfVars HIVE_AUTHORIZATION_MANAGER>;
v = staticinvoke <org.apache.hadoop.hive.metastore.conf.MetastoreConf: java.lang.String getVar(org.apache.hadoop.conf.Configuration,org.apache.hadoop.hive.metastore.conf.MetastoreConf$ConfVars)>(v, v);
if v == null goto label;
v = <org.apache.hadoop.hive.conf.HiveConf$ConfVars: org.apache.hadoop.hive.conf.HiveConf$ConfVars HIVE_METASTORE_AUTHORIZATION_MANAGER>;
v = staticinvoke <org.apache.hadoop.hive.ql.session.SessionState: org.apache.hadoop.hive.ql.session.SessionState get()>();
v = virtualinvoke v.<org.apache.hadoop.hive.ql.session.SessionState: org.apache.hadoop.hive.ql.security.HiveAuthenticationProvider getAuthenticator()>();
v = staticinvoke <org.apache.hadoop.hive.ql.metadata.HiveUtils: java.util.List getMetaStoreAuthorizeProviderManagers(org.apache.hadoop.conf.Configuration,org.apache.hadoop.hive.conf.HiveConf$ConfVars,org.apache.hadoop.hive.ql.security.HiveAuthenticationProvider)>(v, v, v);
v = interfaceinvoke v.<java.util.List: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = interfaceinvoke v.<org.apache.hadoop.hive.ql.security.authorization.HiveMetastoreAuthorizationProvider: org.apache.hadoop.hive.ql.security.authorization.plugin.HivePolicyProvider getHivePolicyProvider()>();
if v == null goto label;
virtualinvoke v.<org.apache.hadoop.hive.ql.security.authorization.PolicyProviderContainer: void addAuthorizationProvider(org.apache.hadoop.hive.ql.security.authorization.HiveMetastoreAuthorizationProvider)>(v);
goto label;
label:
v = virtualinvoke v.<org.apache.hadoop.hive.ql.security.authorization.PolicyProviderContainer: int size()>();
if v <= 0 goto label;
staticinvoke <org.apache.hive.service.server.HiveServer2: void setUpZooKeeperAuth(org.apache.hadoop.hive.conf.HiveConf)>(v);
v = virtualinvoke v.<org.apache.hadoop.hive.conf.HiveConf: org.apache.hadoop.hive.common.ZooKeeperHiveHelper getZKConfig()>();
v = v.<org.apache.hive.service.server.HiveServer2: org.apache.curator.framework.api.ACLProvider zooKeeperAclProvider>;
v = virtualinvoke v.<org.apache.hadoop.hive.common.ZooKeeperHiveHelper: org.apache.curator.framework.CuratorFramework startZookeeperClient(org.apache.curator.framework.api.ACLProvider,boolean)>(v, 1);
v.<org.apache.hive.service.server.HiveServer2: org.apache.curator.framework.CuratorFramework zKClientForPrivSync> = v;
v = <org.apache.hadoop.hive.conf.HiveConf$ConfVars: org.apache.hadoop.hive.conf.HiveConf$ConfVars HIVE_SERVER2_ZOOKEEPER_NAMESPACE>;
v = virtualinvoke v.<org.apache.hadoop.hive.conf.HiveConf: java.lang.String getVar(org.apache.hadoop.hive.conf.HiveConf$ConfVars)>(v);
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("/\u0001/leader");
v = new org.apache.curator.framework.recipes.leader.LeaderLatch;
v = v.<org.apache.hive.service.server.HiveServer2: org.apache.curator.framework.CuratorFramework zKClientForPrivSync>;
specialinvoke v.<org.apache.curator.framework.recipes.leader.LeaderLatch: void <init>(org.apache.curator.framework.CuratorFramework,java.lang.String)>(v, v);
virtualinvoke v.<org.apache.curator.framework.recipes.leader.LeaderLatch: void start()>();
v = <org.apache.hive.service.server.HiveServer2: org.slf4j.Logger LOG>;
v = virtualinvoke v.<org.apache.hadoop.hive.ql.security.authorization.PolicyProviderContainer: int size()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (int)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("Find \u policy to synchronize, start PrivilegeSynchronizer");
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String)>(v);
v = new java.lang.Thread;
v = new org.apache.hadoop.hive.ql.security.authorization.PrivilegeSynchronizer;
specialinvoke v.<org.apache.hadoop.hive.ql.security.authorization.PrivilegeSynchronizer: void <init>(org.apache.curator.framework.recipes.leader.LeaderLatch,org.apache.hadoop.hive.ql.security.authorization.PolicyProviderContainer,org.apache.hadoop.hive.conf.HiveConf)>(v, v, v);
specialinvoke v.<java.lang.Thread: void <init>(java.lang.Runnable,java.lang.String)>(v, "PrivilegeSynchronizer");
virtualinvoke v.<java.lang.Thread: void setDaemon(boolean)>(1);
virtualinvoke v.<java.lang.Thread: void start()>();
goto label;
label:
v = <org.apache.hive.service.server.HiveServer2: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void warn(java.lang.String)>("No policy provider found, skip creating PrivilegeSynchronizer");
label:
return;
}
private static void startHiveServer2() throws java.lang.Throwable
{
java.lang.Throwable v, v, v, v;
java.lang.Error v;
java.util.Random v;
long v, v, v, v;
byte v;
org.apache.hadoop.hive.conf.HiveConf$ConfVars v, v;
java.lang.Thread v;
int v;
java.lang.String v, v;
org.apache.hadoop.hive.common.JvmPauseMonitor v;
org.slf4j.Logger v, v, v, v;
org.apache.hadoop.hive.conf.HiveConf v;
java.util.concurrent.TimeUnit v;
java.lang.InterruptedException v;
org.apache.hive.service.server.HiveServer v, v;
v = 0L;
label:
v = <org.apache.hive.service.server.HiveServer2: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String)>("Starting HiveServer2");
v = new org.apache.hadoop.hive.conf.HiveConf;
specialinvoke v.<org.apache.hadoop.hive.conf.HiveConf: void <init>()>();
v = <org.apache.hadoop.hive.conf.HiveConf$ConfVars: org.apache.hadoop.hive.conf.HiveConf$ConfVars HIVE_SERVER2_MAX_START_ATTEMPTS>;
v = virtualinvoke v.<org.apache.hadoop.hive.conf.HiveConf: long getLongVar(org.apache.hadoop.hive.conf.HiveConf$ConfVars)>(v);
v = <org.apache.hadoop.hive.conf.HiveConf$ConfVars: org.apache.hadoop.hive.conf.HiveConf$ConfVars HIVE_SERVER2_SLEEP_INTERVAL_BETWEEN_START_ATTEMPTS>;
v = <java.util.concurrent.TimeUnit: java.util.concurrent.TimeUnit MILLISECONDS>;
v = virtualinvoke v.<org.apache.hadoop.hive.conf.HiveConf: long getTimeVar(org.apache.hadoop.hive.conf.HiveConf$ConfVars,java.util.concurrent.TimeUnit)>(v, v);
v = null;
label:
staticinvoke <org.apache.hadoop.hive.common.ServerUtils: void cleanUpScratchDir(org.apache.hadoop.hive.conf.HiveConf)>(v);
v = new java.util.Random;
specialinvoke v.<java.util.Random: void <init>()>();
v = virtualinvoke v.<java.util.Random: int nextInt(int)>(600);
staticinvoke <org.apache.hive.service.server.HiveServer2: void scheduleClearDanglingScratchDir(org.apache.hadoop.hive.conf.HiveConf,int)>(v, v);
v = new org.apache.hive.service.server.HiveServer;
specialinvoke v.<org.apache.hive.service.server.HiveServer2: void <init>()>();
v = v;
virtualinvoke v.<org.apache.hive.service.server.HiveServer2: void init(org.apache.hadoop.hive.conf.HiveConf)>(v);
virtualinvoke v.<org.apache.hive.service.server.HiveServer2: void start()>();
label:
v = new org.apache.hadoop.hive.common.JvmPauseMonitor;
specialinvoke v.<org.apache.hadoop.hive.common.JvmPauseMonitor: void <init>(org.apache.hadoop.conf.Configuration)>(v);
virtualinvoke v.<org.apache.hadoop.hive.common.JvmPauseMonitor: void start()>();
label:
goto label;
label:
v := @caughtexception;
v = <org.apache.hive.service.server.HiveServer2: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void warn(java.lang.String,java.lang.Throwable)>("Could not initiate the JvmPauseMonitor thread. GCs and Pauses may not be warned upon.", v);
label:
goto label;
label:
v := @caughtexception;
if v == null goto label;
label:
virtualinvoke v.<org.apache.hive.service.server.HiveServer2: void stop()>();
label:
goto label;
label:
v := @caughtexception;
v = <org.apache.hive.service.server.HiveServer2: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String,java.lang.Throwable)>("Exception caught when calling stop of HiveServer before retrying start", v);
label:
goto label;
label:
v := @caughtexception;
throw v;
label:
v = v + 1L;
v = v;
v = v cmp v;
if v < 0 goto label;
v = new java.lang.Error;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (long)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("Max start attempts \u exhausted");
specialinvoke v.<java.lang.Error: void <init>(java.lang.String,java.lang.Throwable)>(v, v);
throw v;
label:
v = <org.apache.hive.service.server.HiveServer2: org.slf4j.Logger LOG>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (long,long)>(v, v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("Error starting HiveServer on attempt \u, will retry in \u0001ms");
interfaceinvoke v.<org.slf4j.Logger: void warn(java.lang.String,java.lang.Throwable)>(v, v);
label:
staticinvoke <java.lang.Thread: void sleep(long)>(v);
label:
goto label;
label:
v := @caughtexception;
v = staticinvoke <java.lang.Thread: java.lang.Thread currentThread()>();
virtualinvoke v.<java.lang.Thread: void interrupt()>();
goto label;
label:
return;
catch java.lang.Throwable from label to label with label;
catch java.lang.Throwable from label to label with label;
catch java.lang.Throwable from label to label with label;
catch java.lang.Throwable from label to label with label;
catch java.lang.InterruptedException from label to label with label;
}
private void maybeStartCompactorThreads(org.apache.hadoop.hive.conf.HiveConf) throws java.lang.Exception
{
java.lang.Integer v, v, v, v, v;
org.apache.hadoop.hive.metastore.conf.MetastoreConf$ConfVars v, v;
boolean v, v;
java.util.List v;
java.lang.StringBuilder v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
java.util.regex.Pattern v;
java.lang.Object[] v;
int v, v, v, v, v, v, v, v;
java.lang.String v, v, v, v;
org.slf4j.Logger v, v, v, v, v, v, v, v;
java.util.Iterator v;
org.apache.hadoop.hive.conf.HiveConf v;
org.apache.hadoop.hive.ql.txn.compactor.Worker v, v;
org.apache.hive.service.server.HiveServer v;
java.lang.Object v, v, v, v, v;
v := @this: org.apache.hive.service.server.HiveServer;
v := @parameter: org.apache.hadoop.hive.conf.HiveConf;
v = <org.apache.hadoop.hive.metastore.conf.MetastoreConf$ConfVars: org.apache.hadoop.hive.metastore.conf.MetastoreConf$ConfVars HIVE_METASTORE_RUNWORKER_IN>;
v = staticinvoke <org.apache.hadoop.hive.metastore.conf.MetastoreConf: java.lang.String getVar(org.apache.hadoop.conf.Configuration,org.apache.hadoop.hive.metastore.conf.MetastoreConf$ConfVars)>(v, v);
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>("hs2");
if v == 0 goto label;
v = <org.apache.hadoop.hive.metastore.conf.MetastoreConf$ConfVars: org.apache.hadoop.hive.metastore.conf.MetastoreConf$ConfVars COMPACTOR_WORKER_THREADS>;
v = staticinvoke <org.apache.hadoop.hive.metastore.conf.MetastoreConf: int getIntVar(org.apache.hadoop.conf.Configuration,org.apache.hadoop.hive.metastore.conf.MetastoreConf$ConfVars)>(v, v);
v = <org.apache.hadoop.hive.conf.Constants: java.util.regex.Pattern COMPACTION_POOLS_PATTERN>;
v = virtualinvoke v.<org.apache.hadoop.hive.conf.HiveConf: java.util.List getMatchingEntries(java.util.regex.Pattern)>(v);
v = new java.lang.StringBuilder;
specialinvoke v.<java.lang.StringBuilder: void <init>(int)>(2048);
virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>("This HS2 instance will act as Compactor with the following worker pool configuration:\n");
v = virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>("Global pool size: ");
v = virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(int)>(v);
virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>("\n");
v = <org.apache.hive.service.server.HiveServer2: org.slf4j.Logger LOG>;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String,java.lang.Object)>("Initializing the compaction pools with using the global worker limit: {} ", v);
label:
if v <= 0 goto label;
v = interfaceinvoke v.<java.util.List: int size()>();
if v <= 0 goto label;
v = interfaceinvoke v.<java.util.List: java.lang.Object remove(int)>(0);
v = interfaceinvoke v.<java.util.Map$Entry: java.lang.Object getValue()>();
v = interfaceinvoke v.<java.util.Map$Entry: java.lang.Object getKey()>();
v = virtualinvoke v.<org.apache.hadoop.hive.conf.HiveConf: int getInt(java.lang.String,int)>(v, 0);
if v != 0 goto label;
v = <org.apache.hive.service.server.HiveServer2: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void warn(java.lang.String,java.lang.Object)>("Compaction pool ({}) configured with zero workers. Skipping pool initialization", v);
v = virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>("Pool not initialized, 0 size: ");
v = virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>(v);
virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>("\n");
goto label;
label:
if v <= v goto label;
v = <org.apache.hive.service.server.HiveServer2: org.slf4j.Logger LOG>;
v = newarray (java.lang.Object)[3];
v[0] = v;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v[1] = v;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v[2] = v;
interfaceinvoke v.<org.slf4j.Logger: void warn(java.lang.String,java.lang.Object[])>("Global worker pool exhausted, compaction pool ({}) will be configured with less workers than the required number. ({} -> {})", v);
v = v;
label:
v = <org.apache.hive.service.server.HiveServer2: org.slf4j.Logger LOG>;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String,java.lang.Object,java.lang.Object)>("Initializing compaction pool ({}) with {} workers.", v, v);
v = 0;
label:
if v >= v goto label;
v = new org.apache.hadoop.hive.ql.txn.compactor.Worker;
specialinvoke v.<org.apache.hadoop.hive.ql.txn.compactor.Worker: void <init>()>();
virtualinvoke v.<org.apache.hadoop.hive.ql.txn.compactor.Worker: void setPoolName(java.lang.String)>(v);
staticinvoke <org.apache.hadoop.hive.ql.txn.compactor.CompactorThread: void initializeAndStartThread(org.apache.hadoop.hive.ql.txn.compactor.CompactorThread,org.apache.hadoop.conf.Configuration)>(v, v);
v = virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>("Worker - Name: ");
v = virtualinvoke v.<org.apache.hadoop.hive.ql.txn.compactor.Worker: java.lang.String getName()>();
v = virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>(v);
v = virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>(", Pool: ");
v = virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>(v);
v = virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>(", Priority: ");
v = virtualinvoke v.<org.apache.hadoop.hive.ql.txn.compactor.Worker: int getPriority()>();
v = virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(int)>(v);
virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>("\n");
v = v + 1;
goto label;
label:
v = v - v;
goto label;
label:
if v != 0 goto label;
v = <org.apache.hive.service.server.HiveServer2: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void warn(java.lang.String)>("No default compaction pool configured, all non-labeled compaction requests will remain unprocessed!");
v = interfaceinvoke v.<java.util.List: int size()>();
if v <= 0 goto label;
v = interfaceinvoke v.<java.util.List: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = interfaceinvoke v.<java.util.Map$Entry: java.lang.Object getValue()>();
v = <org.apache.hive.service.server.HiveServer2: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void warn(java.lang.String,java.lang.Object)>("There are no available workers for the following compaction pool: {} ", v);
v = virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>("Pool not initialized, no remaining free workers: ");
v = virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>(v);
virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>("\n");
goto label;
label:
virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>("Pool not initialized, no remaining free workers: default\n");
goto label;
label:
v = <org.apache.hive.service.server.HiveServer2: org.slf4j.Logger LOG>;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String,java.lang.Object)>("Initializing default compaction pool with {} workers.", v);
v = 0;
label:
if v >= v goto label;
v = new org.apache.hadoop.hive.ql.txn.compactor.Worker;
specialinvoke v.<org.apache.hadoop.hive.ql.txn.compactor.Worker: void <init>()>();
staticinvoke <org.apache.hadoop.hive.ql.txn.compactor.CompactorThread: void initializeAndStartThread(org.apache.hadoop.hive.ql.txn.compactor.CompactorThread,org.apache.hadoop.conf.Configuration)>(v, v);
v = virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>("Worker - Name: ");
v = virtualinvoke v.<org.apache.hadoop.hive.ql.txn.compactor.Worker: java.lang.String getName()>();
v = virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>(v);
v = virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>(", Pool: default, Priority: ");
v = virtualinvoke v.<org.apache.hadoop.hive.ql.txn.compactor.Worker: int getPriority()>();
v = virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(int)>(v);
virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>("\n");
v = v + 1;
goto label;
label:
v = <org.apache.hive.service.server.HiveServer2: org.slf4j.Logger LOG>;
v = virtualinvoke v.<java.lang.StringBuilder: java.lang.String toString()>();
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String)>(v);
label:
return;
}
static void deleteServerInstancesFromZooKeeper(java.lang.String) throws java.lang.Exception
{
org.apache.curator.framework.api.GetChildrenBuilder v, v;
org.apache.zookeeper.KeeperException$Code v, v;
org.apache.curator.framework.api.DeleteBuilder v;
org.apache.hadoop.hive.common.ZooKeeperHiveHelper v;
org.apache.hadoop.hive.conf.HiveConf$ConfVars v;
int v, v;
java.lang.String v, v, v, v, v, v, v, v;
boolean v;
java.io.PrintStream v;
org.slf4j.Logger v;
org.apache.zookeeper.KeeperException v;
org.apache.hadoop.hive.conf.HiveConf v;
java.util.concurrent.CountDownLatch v, v;
org.apache.curator.framework.CuratorFramework v;
org.apache.hive.service.server.HiveServer2$DeleteCallBack v;
java.lang.Object v, v, v, v, v;
v := @parameter: java.lang.String;
v = new org.apache.hadoop.hive.conf.HiveConf;
specialinvoke v.<org.apache.hadoop.hive.conf.HiveConf: void <init>()>();
staticinvoke <org.apache.hive.service.server.HiveServer2: void setUpZooKeeperAuth(org.apache.hadoop.hive.conf.HiveConf)>(v);
v = virtualinvoke v.<org.apache.hadoop.hive.conf.HiveConf: org.apache.hadoop.hive.common.ZooKeeperHiveHelper getZKConfig()>();
v = virtualinvoke v.<org.apache.hadoop.hive.common.ZooKeeperHiveHelper: org.apache.curator.framework.CuratorFramework getNewZookeeperClient()>();
interfaceinvoke v.<org.apache.curator.framework.CuratorFramework: void start()>();
v = <org.apache.hadoop.hive.conf.HiveConf$ConfVars: org.apache.hadoop.hive.conf.HiveConf$ConfVars HIVE_SERVER2_ZOOKEEPER_NAMESPACE>;
v = virtualinvoke v.<org.apache.hadoop.hive.conf.HiveConf: java.lang.String getVar(org.apache.hadoop.hive.conf.HiveConf$ConfVars)>(v);
v = interfaceinvoke v.<org.apache.curator.framework.CuratorFramework: org.apache.curator.framework.api.GetChildrenBuilder getChildren()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("/\u0001");
v = interfaceinvoke v.<org.apache.curator.framework.api.GetChildrenBuilder: java.lang.Object forPath(java.lang.String)>(v);
v = 0;
label:
v = interfaceinvoke v.<java.util.List: int size()>();
if v >= v goto label;
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(v);
v = new java.util.concurrent.CountDownLatch;
specialinvoke v.<java.util.concurrent.CountDownLatch: void <init>(int)>(1);
<org.apache.hive.service.server.HiveServer2: java.util.concurrent.CountDownLatch zkDeleteSignal> = v;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("version=\u;");
v = virtualinvoke v.<java.lang.String: boolean contains(java.lang.CharSequence)>(v);
if v == 0 goto label;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,java.lang.String)>(v, v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("/\u0001/\u0001");
v = <org.apache.hive.service.server.HiveServer2: org.slf4j.Logger LOG>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("Will attempt to remove the znode: \u from ZooKeeper");
interfaceinvoke v.<org.slf4j.Logger: void warn(java.lang.String)>(v);
v = <java.lang.System: java.io.PrintStream out>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("Will attempt to remove the znode: \u from ZooKeeper");
virtualinvoke v.<java.io.PrintStream: void println(java.lang.String)>(v);
v = interfaceinvoke v.<org.apache.curator.framework.CuratorFramework: org.apache.curator.framework.api.DeleteBuilder delete()>();
v = interfaceinvoke v.<org.apache.curator.framework.api.DeleteBuilder: java.lang.Object guaranteed()>();
v = new org.apache.hive.service.server.HiveServer2$DeleteCallBack;
specialinvoke v.<org.apache.hive.service.server.HiveServer2$DeleteCallBack: void <init>()>();
v = interfaceinvoke v.<org.apache.curator.framework.api.ChildrenDeletable: java.lang.Object inBackground(org.apache.curator.framework.api.BackgroundCallback)>(v);
interfaceinvoke v.<org.apache.curator.framework.api.ErrorListenerPathable: java.lang.Object forPath(java.lang.String)>(v);
v = <org.apache.hive.service.server.HiveServer2: java.util.concurrent.CountDownLatch zkDeleteSignal>;
virtualinvoke v.<java.util.concurrent.CountDownLatch: void await()>();
v = <org.apache.hive.service.server.HiveServer2: org.apache.zookeeper.KeeperException$Code zkDeleteResultCode>;
v = <org.apache.zookeeper.KeeperException$Code: org.apache.zookeeper.KeeperException$Code OK>;
if v == v goto label;
v = staticinvoke <org.apache.zookeeper.KeeperException: org.apache.zookeeper.KeeperException create(org.apache.zookeeper.KeeperException$Code)>(v);
throw v;
label:
v = interfaceinvoke v.<org.apache.curator.framework.CuratorFramework: org.apache.curator.framework.api.GetChildrenBuilder getChildren()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("/\u0001");
v = interfaceinvoke v.<org.apache.curator.framework.api.GetChildrenBuilder: java.lang.Object forPath(java.lang.String)>(v);
interfaceinvoke v.<java.util.List: boolean removeAll(java.util.Collection)>(v);
interfaceinvoke v.<java.util.List: boolean addAll(java.util.Collection)>(v);
label:
v = v + 1;
goto label;
label:
interfaceinvoke v.<org.apache.curator.framework.CuratorFramework: void close()>();
return;
}
public static void main(java.lang.String[])
{
java.lang.Throwable v;
org.apache.hive.service.server.HiveServer2$ServerOptionsProcessorResponse v;
org.slf4j.Logger v, v, v, v;
org.apache.hive.service.server.HiveServer2$ServerOptionsExecutor v;
java.lang.String[] v;
org.apache.hive.service.server.HiveServer2$ServerOptionsProcessor v;
int v;
java.lang.StringBuilder v;
java.lang.String v, v, v, v;
v := @parameter: java.lang.String[];
staticinvoke <org.apache.hadoop.hive.conf.HiveConf: void setLoadHiveServer2Config(boolean)>(1);
label:
v = new org.apache.hive.service.server.HiveServer2$ServerOptionsProcessor;
specialinvoke v.<org.apache.hive.service.server.HiveServer2$ServerOptionsProcessor: void <init>(java.lang.String)>("hiveserver2");
v = virtualinvoke v.<org.apache.hive.service.server.HiveServer2$ServerOptionsProcessor: org.apache.hive.service.server.HiveServer2$ServerOptionsProcessorResponse parse(java.lang.String[])>(v);
v = staticinvoke <org.apache.hadoop.hive.common.LogUtils: java.lang.String initHiveLog4j()>();
v = <org.apache.hive.service.server.HiveServer2: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String)>(v);
v = <org.apache.hive.service.server.HiveServer2: org.slf4j.Logger LOG>;
staticinvoke <org.apache.hive.common.util.HiveStringUtils: void startupShutdownMessage(java.lang.Class,java.lang.String[],org.slf4j.Logger)>(class "Lorg/apache/hive/service/server/HiveServer;", v, v);
v = <org.apache.hive.service.server.HiveServer2: org.slf4j.Logger LOG>;
v = virtualinvoke v.<org.apache.hive.service.server.HiveServer2$ServerOptionsProcessor: java.lang.StringBuilder getDebugMessage()>();
v = virtualinvoke v.<java.lang.StringBuilder: java.lang.String toString()>();
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String)>(v);
v = virtualinvoke v.<org.apache.hive.service.server.HiveServer2$ServerOptionsProcessorResponse: org.apache.hive.service.server.HiveServer2$ServerOptionsExecutor getServerOptionsExecutor()>();
interfaceinvoke v.<org.apache.hive.service.server.HiveServer2$ServerOptionsExecutor: void execute()>();
label:
goto label;
label:
v := @caughtexception;
v = <org.apache.hive.service.server.HiveServer2: org.slf4j.Logger LOG>;
v = virtualinvoke v.<org.apache.hadoop.hive.common.LogUtils$LogInitializationException: java.lang.String getMessage()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("Error initializing log: \u0001");
interfaceinvoke v.<org.slf4j.Logger: void error(java.lang.String,java.lang.Throwable)>(v, v);
v = (int) -1;
staticinvoke <java.lang.System: void exit(int)>(v);
label:
return;
catch org.apache.hadoop.hive.common.LogUtils$LogInitializationException from label to label with label;
}
static void <clinit>()
{
org.slf4j.Logger v;
v = staticinvoke <org.slf4j.LoggerFactory: org.slf4j.Logger getLogger(java.lang.Class)>(class "Lorg/apache/hive/service/server/HiveServer;");
<org.apache.hive.service.server.HiveServer2: org.slf4j.Logger LOG> = v;
return;
}
}