public class org.apache.hive.service.server.KillQueryZookeeperManager extends org.apache.hive.service.AbstractService
{
private static final org.slf4j.Logger LOG;
private static final java.lang.String SASL_LOGIN_CONTEXT_NAME;
public static final int MAX_WAIT_ON_CONFIRMATION_SECONDS;
public static final int MAX_WAIT_ON_KILL_SECONDS;
private org.apache.curator.framework.CuratorFramework zooKeeperClient;
private java.lang.String zkPrincipal;
private java.lang.String zkKeytab;
private java.lang.String zkNameSpace;
private final org.apache.hive.service.server.KillQueryImpl localKillQueryImpl;
private final org.apache.hive.service.server.HiveServer hiveServer;
private org.apache.hadoop.hive.conf.HiveConf conf;
private org.apache.curator.framework.recipes.cache.PathChildrenCache killQueryListener;
public void <init>(org.apache.hive.service.cli.operation.OperationManager, org.apache.hive.service.server.HiveServer)
{
org.apache.hive.service.cli.operation.OperationManager v;
org.apache.hive.service.server.KillQueryZookeeperManager v;
org.apache.hive.service.server.KillQueryImpl v;
org.apache.hive.service.server.HiveServer v;
java.lang.Class v;
java.lang.String v;
v := @this: org.apache.hive.service.server.KillQueryZookeeperManager;
v := @parameter: org.apache.hive.service.cli.operation.OperationManager;
v := @parameter: org.apache.hive.service.server.HiveServer;
v = class "Lorg/apache/hive/service/server/KillQueryZookeeperManager;";
v = virtualinvoke v.<java.lang.Class: java.lang.String getSimpleName()>();
specialinvoke v.<org.apache.hive.service.AbstractService: void <init>(java.lang.String)>(v);
v.<org.apache.hive.service.server.KillQueryZookeeperManager: org.apache.curator.framework.recipes.cache.PathChildrenCache killQueryListener> = null;
v.<org.apache.hive.service.server.KillQueryZookeeperManager: org.apache.hive.service.server.HiveServer hiveServer2> = v;
v = new org.apache.hive.service.server.KillQueryImpl;
specialinvoke v.<org.apache.hive.service.server.KillQueryImpl: void <init>(org.apache.hive.service.cli.operation.OperationManager,org.apache.hive.service.server.KillQueryZookeeperManager)>(v, v);
v.<org.apache.hive.service.server.KillQueryZookeeperManager: org.apache.hive.service.server.KillQueryImpl localKillQueryImpl> = v;
return;
}
public synchronized void init(org.apache.hadoop.hive.conf.HiveConf)
{
org.apache.curator.framework.api.ACLProvider v;
org.apache.hive.service.server.KillQueryZookeeperManager$ZkConnectionStateListener v;
org.apache.hive.service.server.KillQueryZookeeperManager v;
org.apache.hadoop.hive.common.ZooKeeperHiveHelper v;
org.apache.hadoop.hive.conf.HiveConf$ConfVars v, v, v, v;
org.apache.curator.framework.listen.Listenable v;
java.lang.String v, v, v, v, v, v, v, v;
boolean v, v;
org.apache.hadoop.hive.conf.HiveConf v;
org.apache.curator.framework.CuratorFramework v, v;
v := @this: org.apache.hive.service.server.KillQueryZookeeperManager;
v := @parameter: org.apache.hadoop.hive.conf.HiveConf;
v.<org.apache.hive.service.server.KillQueryZookeeperManager: org.apache.hadoop.hive.conf.HiveConf conf> = v;
v = <org.apache.hadoop.hive.conf.HiveConf$ConfVars: org.apache.hadoop.hive.conf.HiveConf$ConfVars HIVE_ZOOKEEPER_KILLQUERY_NAMESPACE>;
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);
v.<org.apache.hive.service.server.KillQueryZookeeperManager: java.lang.String zkNameSpace> = v;
v = v.<org.apache.hive.service.server.KillQueryZookeeperManager: java.lang.String zkNameSpace>;
v = staticinvoke <org.apache.commons.lang.StringUtils: boolean isBlank(java.lang.CharSequence)>(v);
if v != 0 goto label;
v = 1;
goto label;
label:
v = 0;
label:
v = <org.apache.hadoop.hive.conf.HiveConf$ConfVars: org.apache.hadoop.hive.conf.HiveConf$ConfVars HIVE_ZOOKEEPER_KILLQUERY_NAMESPACE>;
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 cannot be null or empty");
staticinvoke <com.google.common.base.Preconditions: void checkArgument(boolean,java.lang.Object)>(v, v);
v = <org.apache.hadoop.hive.conf.HiveConf$ConfVars: org.apache.hadoop.hive.conf.HiveConf$ConfVars HIVE_SERVER2_KERBEROS_PRINCIPAL>;
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);
v.<org.apache.hive.service.server.KillQueryZookeeperManager: java.lang.String zkPrincipal> = v;
v = <org.apache.hadoop.hive.conf.HiveConf$ConfVars: org.apache.hadoop.hive.conf.HiveConf$ConfVars HIVE_SERVER2_KERBEROS_KEYTAB>;
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);
v.<org.apache.hive.service.server.KillQueryZookeeperManager: java.lang.String zkKeytab> = v;
v = virtualinvoke v.<org.apache.hadoop.hive.conf.HiveConf: org.apache.hadoop.hive.common.ZooKeeperHiveHelper getZKConfig()>();
v = v.<org.apache.hive.service.server.KillQueryZookeeperManager: java.lang.String zkNameSpace>;
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 = specialinvoke v.<org.apache.hive.service.server.KillQueryZookeeperManager: org.apache.curator.framework.api.ACLProvider getACLProviderForZKPath(java.lang.String)>(v);
v = virtualinvoke v.<org.apache.hadoop.hive.common.ZooKeeperHiveHelper: org.apache.curator.framework.CuratorFramework getNewZookeeperClient(org.apache.curator.framework.api.ACLProvider)>(v);
v.<org.apache.hive.service.server.KillQueryZookeeperManager: org.apache.curator.framework.CuratorFramework zooKeeperClient> = v;
v = v.<org.apache.hive.service.server.KillQueryZookeeperManager: org.apache.curator.framework.CuratorFramework zooKeeperClient>;
v = interfaceinvoke v.<org.apache.curator.framework.CuratorFramework: org.apache.curator.framework.listen.Listenable getConnectionStateListenable()>();
v = new org.apache.hive.service.server.KillQueryZookeeperManager$ZkConnectionStateListener;
specialinvoke v.<org.apache.hive.service.server.KillQueryZookeeperManager$ZkConnectionStateListener: void <init>()>();
interfaceinvoke v.<org.apache.curator.framework.listen.Listenable: void addListener(java.lang.Object)>(v);
specialinvoke v.<org.apache.hive.service.AbstractService: void init(org.apache.hadoop.hive.conf.HiveConf)>(v);
return;
}
public synchronized void start()
{
org.apache.zookeeper.CreateMode v;
org.apache.hive.service.ServiceException v;
boolean v;
java.lang.Exception v;
java.util.List v;
org.apache.curator.framework.CuratorFramework v, v, v, v, v;
java.lang.Throwable v;
org.apache.curator.framework.recipes.cache.PathChildrenCache$StartMode v;
org.apache.curator.framework.api.CreateBuilder v;
org.apache.zookeeper.KeeperException$Code v, v;
org.apache.hive.service.server.KillQueryZookeeperManager v;
org.apache.curator.framework.api.SetACLBuilder v;
java.lang.String v, v, v, v, v, v, v, v, v, v, v, v;
org.slf4j.Logger v, v, v;
org.apache.hadoop.hive.conf.HiveConf v, v;
java.lang.RuntimeException v;
org.apache.curator.framework.recipes.cache.PathChildrenCache v, v;
java.lang.Class v;
java.lang.Object v, v;
org.apache.curator.framework.api.ProtectACLCreateModeStatPathAndBytesable v;
v := @this: org.apache.hive.service.server.KillQueryZookeeperManager;
specialinvoke v.<org.apache.hive.service.AbstractService: void start()>();
v = v.<org.apache.hive.service.server.KillQueryZookeeperManager: org.apache.curator.framework.CuratorFramework zooKeeperClient>;
if v != null goto label;
v = new org.apache.hive.service.ServiceException;
specialinvoke v.<org.apache.hive.service.ServiceException: void <init>(java.lang.String)>("Failed start zookeeperClient in KillQueryZookeeperManager");
throw v;
label:
v = virtualinvoke v.<org.apache.hive.service.server.KillQueryZookeeperManager: org.apache.hadoop.hive.conf.HiveConf getHiveConf()>();
v = v.<org.apache.hive.service.server.KillQueryZookeeperManager: java.lang.String zkPrincipal>;
v = v.<org.apache.hive.service.server.KillQueryZookeeperManager: java.lang.String zkKeytab>;
staticinvoke <org.apache.hadoop.hive.registry.impl.ZookeeperUtils: java.lang.String setupZookeeperAuth(org.apache.hadoop.conf.Configuration,java.lang.String,java.lang.String,java.lang.String)>(v, "KillQueryZooKeeperClient", v, v);
v = v.<org.apache.hive.service.server.KillQueryZookeeperManager: org.apache.curator.framework.CuratorFramework zooKeeperClient>;
interfaceinvoke v.<org.apache.curator.framework.CuratorFramework: void start()>();
label:
v = v.<org.apache.hive.service.server.KillQueryZookeeperManager: org.apache.curator.framework.CuratorFramework zooKeeperClient>;
v = interfaceinvoke v.<org.apache.curator.framework.CuratorFramework: org.apache.curator.framework.api.CreateBuilder create()>();
v = interfaceinvoke v.<org.apache.curator.framework.api.CreateBuilder: org.apache.curator.framework.api.ProtectACLCreateModeStatPathAndBytesable creatingParentsIfNeeded()>();
v = <org.apache.zookeeper.CreateMode: org.apache.zookeeper.CreateMode PERSISTENT>;
v = interfaceinvoke v.<org.apache.curator.framework.api.ProtectACLCreateModeStatPathAndBytesable: java.lang.Object withMode(org.apache.zookeeper.CreateMode)>(v);
v = v.<org.apache.hive.service.server.KillQueryZookeeperManager: java.lang.String zkNameSpace>;
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");
interfaceinvoke v.<org.apache.curator.framework.api.ACLBackgroundPathAndBytesable: java.lang.Object forPath(java.lang.String)>(v);
v = v.<org.apache.hive.service.server.KillQueryZookeeperManager: org.apache.hadoop.hive.conf.HiveConf conf>;
v = staticinvoke <org.apache.hadoop.hive.registry.impl.ZookeeperUtils: boolean isKerberosEnabled(org.apache.hadoop.conf.Configuration)>(v);
if v == 0 goto label;
v = v.<org.apache.hive.service.server.KillQueryZookeeperManager: org.apache.curator.framework.CuratorFramework zooKeeperClient>;
v = interfaceinvoke v.<org.apache.curator.framework.CuratorFramework: org.apache.curator.framework.api.SetACLBuilder setACL()>();
v = staticinvoke <org.apache.hive.service.server.KillQueryZookeeperManager: java.util.List createSecureAcls()>();
v = interfaceinvoke v.<org.apache.curator.framework.api.SetACLBuilder: java.lang.Object withACL(java.util.List)>(v);
v = v.<org.apache.hive.service.server.KillQueryZookeeperManager: java.lang.String zkNameSpace>;
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");
interfaceinvoke v.<org.apache.curator.framework.api.BackgroundPathable: java.lang.Object forPath(java.lang.String)>(v);
label:
v = <org.apache.hive.service.server.KillQueryZookeeperManager: org.slf4j.Logger LOG>;
v = v.<org.apache.hive.service.server.KillQueryZookeeperManager: java.lang.String zkNameSpace>;
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[])>("Created the root namespace: \u on ZooKeeper");
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String)>(v);
label:
goto label;
label:
v := @caughtexception;
v = virtualinvoke v.<org.apache.zookeeper.KeeperException: org.apache.zookeeper.KeeperException$Code code()>();
v = <org.apache.zookeeper.KeeperException$Code: org.apache.zookeeper.KeeperException$Code NODEEXISTS>;
if v == v goto label;
v = <org.apache.hive.service.server.KillQueryZookeeperManager: org.slf4j.Logger LOG>;
v = v.<org.apache.hive.service.server.KillQueryZookeeperManager: java.lang.String zkNameSpace>;
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[])>("Unable to create namespace: \u on ZooKeeper");
interfaceinvoke v.<org.slf4j.Logger: void error(java.lang.String,java.lang.Throwable)>(v, v);
throw v;
label:
v = new org.apache.curator.framework.recipes.cache.PathChildrenCache;
v = v.<org.apache.hive.service.server.KillQueryZookeeperManager: org.apache.curator.framework.CuratorFramework zooKeeperClient>;
v = v.<org.apache.hive.service.server.KillQueryZookeeperManager: java.lang.String zkNameSpace>;
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");
specialinvoke v.<org.apache.curator.framework.recipes.cache.PathChildrenCache: void <init>(org.apache.curator.framework.CuratorFramework,java.lang.String,boolean)>(v, v, 0);
v.<org.apache.hive.service.server.KillQueryZookeeperManager: org.apache.curator.framework.recipes.cache.PathChildrenCache killQueryListener> = v;
v = v.<org.apache.hive.service.server.KillQueryZookeeperManager: org.apache.curator.framework.recipes.cache.PathChildrenCache killQueryListener>;
v = <org.apache.curator.framework.recipes.cache.PathChildrenCache$StartMode: org.apache.curator.framework.recipes.cache.PathChildrenCache$StartMode NORMAL>;
virtualinvoke v.<org.apache.curator.framework.recipes.cache.PathChildrenCache: void start(org.apache.curator.framework.recipes.cache.PathChildrenCache$StartMode)>(v);
specialinvoke v.<org.apache.hive.service.server.KillQueryZookeeperManager: void startListeningForQueries()>();
v = class "Lorg/apache/curator/utils/CloseableUtils;";
virtualinvoke v.<java.lang.Class: java.lang.String getName()>();
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 start zookeeperClient in KillQueryZookeeperManager", v);
throw v;
label:
v = <org.apache.hive.service.server.KillQueryZookeeperManager: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String)>("KillQueryZookeeperManager service started.");
return;
catch org.apache.zookeeper.KeeperException from label to label with label;
catch java.lang.Exception from label to label with label;
}
private org.apache.curator.framework.api.ACLProvider getACLProviderForZKPath(java.lang.String)
{
org.apache.hive.service.server.KillQueryZookeeperManager v;
org.apache.hadoop.hive.conf.HiveConf v;
org.apache.hive.service.server.KillQueryZookeeperManager$1 v;
java.lang.String v;
boolean v;
v := @this: org.apache.hive.service.server.KillQueryZookeeperManager;
v := @parameter: java.lang.String;
v = v.<org.apache.hive.service.server.KillQueryZookeeperManager: org.apache.hadoop.hive.conf.HiveConf conf>;
v = staticinvoke <org.apache.hadoop.hive.registry.impl.ZookeeperUtils: boolean isKerberosEnabled(org.apache.hadoop.conf.Configuration)>(v);
v = new org.apache.hive.service.server.KillQueryZookeeperManager$1;
specialinvoke v.<org.apache.hive.service.server.KillQueryZookeeperManager$1: void <init>(org.apache.hive.service.server.KillQueryZookeeperManager,boolean,java.lang.String)>(v, v, v);
return v;
}
private static java.util.List createSecureAcls()
{
java.util.ArrayList v, v, v;
v = new java.util.ArrayList;
v = <org.apache.zookeeper.ZooDefs$Ids: java.util.ArrayList READ_ACL_UNSAFE>;
specialinvoke v.<java.util.ArrayList: void <init>(java.util.Collection)>(v);
v = <org.apache.zookeeper.ZooDefs$Ids: java.util.ArrayList CREATOR_ALL_ACL>;
interfaceinvoke v.<java.util.List: boolean addAll(java.util.Collection)>(v);
return v;
}
private void startListeningForQueries()
{
org.apache.hive.service.server.KillQueryZookeeperManager v;
org.slf4j.Logger v;
org.apache.curator.framework.listen.Listenable v;
org.apache.curator.framework.recipes.cache.PathChildrenCache v;
org.apache.curator.framework.recipes.cache.PathChildrenCacheListener v;
v := @this: org.apache.hive.service.server.KillQueryZookeeperManager;
v = staticinvoke <org.apache.hive.service.server.KillQueryZookeeperManager$lambda_startListeningForQueries_0__31: org.apache.curator.framework.recipes.cache.PathChildrenCacheListener bootstrap$(org.apache.hive.service.server.KillQueryZookeeperManager)>(v);
v = <org.apache.hive.service.server.KillQueryZookeeperManager: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String)>("Start to listen for kill query requests.");
v = v.<org.apache.hive.service.server.KillQueryZookeeperManager: org.apache.curator.framework.recipes.cache.PathChildrenCache killQueryListener>;
v = virtualinvoke v.<org.apache.curator.framework.recipes.cache.PathChildrenCache: org.apache.curator.framework.listen.Listenable getListenable()>();
interfaceinvoke v.<org.apache.curator.framework.listen.Listenable: void addListener(java.lang.Object)>(v);
return;
}
public synchronized void stop()
{
org.apache.hive.service.server.KillQueryZookeeperManager v;
org.apache.curator.framework.CuratorFramework v;
org.slf4j.Logger v;
org.apache.curator.framework.recipes.cache.PathChildrenCache v;
v := @this: org.apache.hive.service.server.KillQueryZookeeperManager;
specialinvoke v.<org.apache.hive.service.AbstractService: void stop()>();
v = <org.apache.hive.service.server.KillQueryZookeeperManager: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String)>("Stopping KillQueryZookeeperManager service.");
v = v.<org.apache.hive.service.server.KillQueryZookeeperManager: org.apache.curator.framework.recipes.cache.PathChildrenCache killQueryListener>;
staticinvoke <org.apache.curator.utils.CloseableUtils: void closeQuietly(java.io.Closeable)>(v);
v = v.<org.apache.hive.service.server.KillQueryZookeeperManager: org.apache.curator.framework.CuratorFramework zooKeeperClient>;
staticinvoke <org.apache.curator.utils.CloseableUtils: void closeQuietly(java.io.Closeable)>(v);
return;
}
private java.util.List getAllServerUrls()
{
org.apache.curator.framework.api.GetChildrenBuilder v;
java.util.ArrayList v;
org.apache.hive.service.server.KillQueryZookeeperManager v;
org.apache.hadoop.hive.conf.HiveConf$ConfVars v, v, v;
java.lang.String v, v;
boolean v, v;
org.slf4j.Logger v;
org.apache.hadoop.hive.conf.HiveConf v, v, v;
java.lang.Exception v;
org.apache.curator.framework.CuratorFramework v;
java.lang.Object v;
v := @this: org.apache.hive.service.server.KillQueryZookeeperManager;
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>()>();
v = v.<org.apache.hive.service.server.KillQueryZookeeperManager: org.apache.hadoop.hive.conf.HiveConf conf>;
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);
if v == 0 goto label;
v = v.<org.apache.hive.service.server.KillQueryZookeeperManager: org.apache.hadoop.hive.conf.HiveConf conf>;
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);
if v != 0 goto label;
v = v.<org.apache.hive.service.server.KillQueryZookeeperManager: org.apache.hadoop.hive.conf.HiveConf conf>;
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);
label:
v = v.<org.apache.hive.service.server.KillQueryZookeeperManager: org.apache.curator.framework.CuratorFramework zooKeeperClient>;
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 addAll(java.util.Collection)>(v);
label:
goto label;
label:
v := @caughtexception;
v = <org.apache.hive.service.server.KillQueryZookeeperManager: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void error(java.lang.String,java.lang.Throwable)>("Unable the get available server hosts", v);
label:
return v;
catch java.lang.Exception from label to label with label;
}
private java.lang.String getServerHost()
{
org.apache.hive.service.server.KillQueryZookeeperManager v;
org.slf4j.Logger v;
org.apache.hive.service.server.HiveServer v, v;
java.lang.String v, v;
java.lang.Exception v;
v := @this: org.apache.hive.service.server.KillQueryZookeeperManager;
v = v.<org.apache.hive.service.server.KillQueryZookeeperManager: org.apache.hive.service.server.HiveServer hiveServer2>;
if v != null goto label;
return "";
label:
v = v.<org.apache.hive.service.server.KillQueryZookeeperManager: org.apache.hive.service.server.HiveServer hiveServer2>;
v = virtualinvoke v.<org.apache.hive.service.server.HiveServer2: java.lang.String getServerInstanceURI()>();
v = staticinvoke <org.apache.hive.service.server.KillQueryZookeeperManager: java.lang.String removeDelimiter(java.lang.String)>(v);
label:
return v;
label:
v := @caughtexception;
v = <org.apache.hive.service.server.KillQueryZookeeperManager: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void error(java.lang.String,java.lang.Throwable)>("Unable to determine the server host", v);
return "";
catch java.lang.Exception from label to label with label;
}
public void killQuery(java.lang.String, java.lang.String, boolean) throws java.io.IOException
{
org.apache.hive.service.server.KillQueryZookeeperManager v;
org.apache.hive.service.server.KillQueryZookeeperManager$KillQueryZookeeperBarrier v;
int v, v, v;
java.lang.String v, v, v, v, v, v;
boolean v, v;
org.slf4j.Logger v, v;
java.io.IOException v, v;
java.lang.Exception v;
java.util.concurrent.TimeUnit v;
java.util.List v;
org.apache.curator.framework.CuratorFramework v;
org.apache.hive.service.server.HiveServer v;
v := @this: org.apache.hive.service.server.KillQueryZookeeperManager;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v := @parameter: boolean;
v = specialinvoke v.<org.apache.hive.service.server.KillQueryZookeeperManager: java.util.List getAllServerUrls()>();
v = interfaceinvoke v.<java.util.List: int size()>();
if v >= 2 goto label;
return;
label:
v = new org.apache.hive.service.server.KillQueryZookeeperManager$KillQueryZookeeperBarrier;
v = v.<org.apache.hive.service.server.KillQueryZookeeperManager: org.apache.curator.framework.CuratorFramework zooKeeperClient>;
v = v.<org.apache.hive.service.server.KillQueryZookeeperManager: java.lang.String zkNameSpace>;
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");
specialinvoke v.<org.apache.hive.service.server.KillQueryZookeeperManager$KillQueryZookeeperBarrier: void <init>(org.apache.curator.framework.CuratorFramework,java.lang.String)>(v, v);
label:
v = v.<org.apache.hive.service.server.KillQueryZookeeperManager: org.apache.hive.service.server.HiveServer hiveServer2>;
v = virtualinvoke v.<org.apache.hive.service.server.HiveServer2: java.lang.String getServerInstanceURI()>();
virtualinvoke v.<org.apache.hive.service.server.KillQueryZookeeperManager$KillQueryZookeeperBarrier: void setBarrier(java.lang.String,java.lang.String,java.lang.String,boolean)>(v, v, v, v);
v = <org.apache.hive.service.server.KillQueryZookeeperManager: org.slf4j.Logger LOG>;
v = virtualinvoke v.<org.apache.hive.service.server.KillQueryZookeeperManager$KillQueryZookeeperBarrier: java.lang.String getBarrierPath()>();
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String,java.lang.Object,java.lang.Object)>("Created kill query barrier in path: {} for queryId: {}", v, v);
v = interfaceinvoke v.<java.util.List: int size()>();
v = v - 1;
v = <java.util.concurrent.TimeUnit: java.util.concurrent.TimeUnit SECONDS>;
v = virtualinvoke v.<org.apache.hive.service.server.KillQueryZookeeperManager$KillQueryZookeeperBarrier: boolean waitOnBarrier(int,long,long,java.util.concurrent.TimeUnit)>(v, 30L, 180L, v);
label:
goto label;
label:
v := @caughtexception;
v = <org.apache.hive.service.server.KillQueryZookeeperManager: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void error(java.lang.String,java.lang.Throwable)>("Unable to create Barrier on Zookeeper for KillQuery", v);
v = new java.io.IOException;
specialinvoke v.<java.io.IOException: void <init>(java.lang.Throwable)>(v);
throw v;
label:
if v != 0 goto label;
v = new java.io.IOException;
specialinvoke v.<java.io.IOException: void <init>(java.lang.String)>("Unable to kill query on remote servers");
throw v;
label:
return;
catch java.lang.Exception from label to label with label;
}
private static java.lang.String removeDelimiter(java.lang.String)
{
java.lang.String v, v;
v := @parameter: java.lang.String;
if v != null goto label;
return null;
label:
v = virtualinvoke v.<java.lang.String: java.lang.String replaceAll(java.lang.String,java.lang.String)>(":", "");
return v;
}
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/KillQueryZookeeperManager;");
<org.apache.hive.service.server.KillQueryZookeeperManager: org.slf4j.Logger LOG> = v;
return;
}
}