Я столкнулся со странной проблемой при попытке подключиться к базе данных HBase 0.98.5-hadoop2 из EJB, развернутого на WildFly 8.1.0.Final.
Этот код отлично работает как отдельное приложение:
public static void main(String[] args) throws IOException {
Configuration config = getConfiguration();
HConnection connection = HConnectionManager.createConnection(config);
}
private static Configuration getConfiguration() {
Configuration config = HBaseConfiguration.create();
config.set("hbase.zookeeper.quorum", "hbase"); //
config.set("hbase.client.retries.number", "3"); //
config.set("hbase.cluster.distributed", "true");
return config;
}
но когда я включаю его в EJB и запускаю с сервера, у меня есть следующее исключение:
То же самое происходит на машинах Linux, за исключением того, что UnixLoginModule не может найти.
Фактическое исключение происходит в этой строке из org.apache.hadoop.hbase.security.User
Далее следует очень простой код EJB, иллюстрирующий тему. Он не работает независимо от того, существует сервер HBase или нет.
private SecureHadoopUser() throws IOException {
ugi = UserGroupInformation.getCurrentUser();
}
Я настроил клиент HBase как модуль, вот содержимое module.xml
package hbasetest;
import java.io.IOException;
import javax.ejb.Stateless;
import org.apache.hadoop.security.UserGroupInformation;
@Stateless
public class HbaseExecutorImpl implements HbaseExecutor {
public void test() {
try {
UserGroupInformation ugi = UserGroupInformation.getCurrentUser();
} catch (IOException ex) {
throw new RuntimeException(ex);
}
}
}
jboss-deployment-structure.xml выглядит так:
<?xml version="1.0" encoding="UTF-8"?>
<module xmlns="urn:jboss:module:1.3" name="com.something.hbaseclient">
<resources>
<resource-root path="activation-1.1.jar"/>
<resource-root path="aopalliance-1.0.jar"/>
<resource-root path="asm-3.1.jar"/>
<resource-root path="avro-1.7.7.jar"/>
<resource-root path="commons-beanutils-1.7.0.jar"/>
<resource-root path="commons-beanutils-core-1.8.0.jar"/>
<resource-root path="commons-cli-1.2.jar"/>
<resource-root path="commons-codec-1.7.jar"/>
<resource-root path="commons-collections-3.2.1.jar"/>
<resource-root path="commons-compress-1.4.1.jar"/>
<resource-root path="commons-configuration-1.6.jar"/>
<resource-root path="commons-digester-1.8.jar"/>
<resource-root path="commons-httpclient-3.1.jar"/>
<resource-root path="commons-io-2.4.jar"/>
<resource-root path="commons-lang-2.6.jar"/>
<resource-root path="commons-logging-1.1.1.jar"/>
<resource-root path="commons-math-2.1.jar"/>
<resource-root path="commons-net-3.1.jar"/>
<resource-root path="findbugs-annotations-1.3.9-1.jar"/>
<resource-root path="guava-12.0.1.jar"/>
<resource-root path="guice-3.0.jar"/>
<resource-root path="guice-servlet-3.0.jar"/>
<resource-root path="hadoop-auth-2.2.0.jar"/>
<resource-root path="hadoop-common-2.2.0.jar"/>
<resource-root path="hadoop-mapreduce-client-core-2.2.0.jar"/>
<resource-root path="hadoop-yarn-api-2.2.0.jar"/>
<resource-root path="hadoop-yarn-common-2.2.0.jar"/>
<resource-root path="hbase-client-0.98.5-hadoop2.jar"/>
<resource-root path="hbase-common-0.98.5-hadoop2.jar"/>
<resource-root path="hbase-protocol-0.98.5-hadoop2.jar"/>
<resource-root path="htrace-core-2.04.jar"/>
<resource-root path="jackson-core-asl-1.8.8.jar"/>
<resource-root path="jackson-jaxrs-1.8.8.jar"/>
<resource-root path="jackson-mapper-asl-1.8.8.jar"/>
<resource-root path="jackson-xc-1.8.8.jar"/>
<resource-root path="javax.inject-1.jar"/>
<resource-root path="jaxb-api-2.2.2.jar"/>
<resource-root path="jaxb-impl-2.2.3-1.jar"/>
<resource-root path="jboss-ejb-api_3.2_spec-1.0.0.Final.jar"/>
<resource-root path="jersey-core-1.8.jar"/>
<resource-root path="jersey-guice-1.9.jar"/>
<resource-root path="jersey-json-1.8.jar"/>
<resource-root path="jersey-server-1.8.jar"/>
<resource-root path="jets3t-0.6.1.jar"/>
<resource-root path="jettison-1.3.1.jar"/>
<resource-root path="jetty-6.1.26.jar"/>
<resource-root path="jetty-util-6.1.26.jar"/>
<resource-root path="jsch-0.1.42.jar"/>
<resource-root path="jsr305-1.3.9.jar"/>
<resource-root path="log4j-1.2.17.jar"/>
<resource-root path="netty-3.6.6.Final.jar"/>
<resource-root path="paranamer-2.3.jar"/>
<resource-root path="protobuf-java-2.5.0.jar"/>
<resource-root path="slf4j-api-1.6.4.jar"/>
<resource-root path="slf4j-log4j12-1.6.4.jar"/>
<resource-root path="snappy-java-1.0.4.1.jar"/>
<resource-root path="xmlenc-0.52.jar"/>
<resource-root path="xz-1.0.jar"/>
<resource-root path="zookeeper-3.4.6.jar"/>
</resources>
<dependencies>
<module name="javaee.api"/>
</dependencies>
</module>
Я хотел бы знать, что происходит. Кажется, что код, находящийся в WildFly, имеет неправильный контекст безопасности, и, следовательно, некоторые настройки WildFly должны быть полезны, но я действительно понятия не имею, что делать сейчас.
<jboss-deployment-structure>
<deployment>
<dependencies>
<module name="com.something.hbaseclient"/>
</dependencies>
</deployment>
</jboss-deployment-structure>
На всякий случай, если кому-то интересно, я исправил эту проблему, добавив это
