diff --git a/build-common.xml b/build-common.xml
index 940f4e9..cb4d9b5 100644
--- a/build-common.xml
+++ b/build-common.xml
@@ -191,7 +191,9 @@
-
+
diff --git a/build.properties b/build.properties
index 008d1bb..4ae8e16 100644
--- a/build.properties
+++ b/build.properties
@@ -75,8 +75,8 @@ common.jar=${hadoop.root}/lib/commons-httpclient-3.0.1.jar
# module names needed for build process
# full profile
-iterate.hive.full.all=ant,shims,common,serde,metastore,ql,contrib,service,cli,jdbc,beeline,hwi,hbase-handler,testutils,hcatalog
-iterate.hive.full.modules=shims,common,serde,metastore,ql,contrib,service,cli,jdbc,beeline,hwi,hbase-handler,testutils,hcatalog
+iterate.hive.full.all=ant,shims,common,serde,metastore,ql,contrib,service,cli,jdbc,beeline,hwi
+iterate.hive.full.modules=shims,common,serde,metastore,ql,contrib,service,cli,jdbc,beeline,hwi
iterate.hive.full.tests=ql,contrib,hbase-handler,hwi,jdbc,beeline,metastore,odbc,serde,service,hcatalog
iterate.hive.full.thrift=ql,service,metastore,serde
iterate.hive.full.protobuf=ql
@@ -91,8 +91,8 @@ iterate.hive.nohcat.protobuf=ql
iterate.hive.nohcat.cpp=odbc
# core profile
-iterate.hive.core.all=ant,shims,common,serde,metastore,ql,cli
-iterate.hive.core.modules=shims,common,serde,metastore,ql,cli
+iterate.hive.core.all=ant,shims,common,serde,metastore,ql,service,cli
+iterate.hive.core.modules=shims,common,serde,metastore,ql,service,cli
iterate.hive.core.tests=ql
iterate.hive.core.thrift=ql
iterate.hive.core.protobuf=ql
diff --git a/hbase-handler/ivy.xml b/hbase-handler/ivy.xml
index 7be8649..57c0a60 100644
--- a/hbase-handler/ivy.xml
+++ b/hbase-handler/ivy.xml
@@ -36,7 +36,7 @@
-
+
diff --git a/hcatalog/pom.xml b/hcatalog/pom.xml
index 499e8c9..d8271ee 100644
--- a/hcatalog/pom.xml
+++ b/hcatalog/pom.xml
@@ -33,7 +33,7 @@
${project.version}
1.9.2
1.14
- 7.6.0.v20120127
+ 8.1.14.v20131031
1.1
0.10.1
1.6.1
@@ -109,13 +109,6 @@
org.apache.hadoop
- hadoop-hdfs
- ${hadoop23.version}
- tests
- compile
-
-
- org.apache.hadoop
hadoop-mapreduce-client-core
${hadoop23.version}
compile
@@ -129,26 +122,12 @@
org.apache.hadoop
- hadoop-yarn-server-tests
- ${hadoop23.version}
- tests
- compile
-
-
- org.apache.hadoop
hadoop-mapreduce-client-app
${hadoop23.version}
compile
org.apache.hadoop
- hadoop-common
- ${hadoop23.version}
- tests
- compile
-
-
- org.apache.hadoop
hadoop-mapreduce-client-hs
${hadoop23.version}
compile
@@ -163,7 +142,6 @@
org.apache.pig
pig
${pig.version}
- h2
compile
@@ -176,7 +154,6 @@
server-extensions
webhcat/java-client
webhcat/svr
- storage-handlers/hbase
diff --git a/hcatalog/server-extensions/pom.xml b/hcatalog/server-extensions/pom.xml
index f9ec4a5..6b76bfa 100644
--- a/hcatalog/server-extensions/pom.xml
+++ b/hcatalog/server-extensions/pom.xml
@@ -65,6 +65,12 @@
${hcatalog.version}
compile
+
+ org.apache.hadoop
+ hadoop-common
+ ${hadoop23.version}
+ compile
+
diff --git a/hcatalog/webhcat/java-client/pom.xml b/hcatalog/webhcat/java-client/pom.xml
index 97ec5f6..2b692e5 100644
--- a/hcatalog/webhcat/java-client/pom.xml
+++ b/hcatalog/webhcat/java-client/pom.xml
@@ -41,5 +41,17 @@
${hcatalog.version}
compile
+
+ org.apache.hadoop
+ hadoop-common
+ ${hadoop23.version}
+ compile
+
+
+ org.apache.hadoop
+ hadoop-mapreduce-client-core
+ ${hadoop23.version}
+ compile
+
diff --git a/hcatalog/webhcat/svr/pom.xml b/hcatalog/webhcat/svr/pom.xml
index da6038a..a560604 100644
--- a/hcatalog/webhcat/svr/pom.xml
+++ b/hcatalog/webhcat/svr/pom.xml
@@ -89,8 +89,20 @@
compile
- org.eclipse.jetty.aggregate
- jetty-all-server
+ org.eclipse.jetty
+ jetty-server
+ ${jetty.webhcat.version}
+ compile
+
+
+ org.eclipse.jetty
+ jetty-util
+ ${jetty.webhcat.version}
+ compile
+
+
+ org.eclipse.jetty
+ jetty-rewrite
${jetty.webhcat.version}
compile
@@ -106,5 +118,23 @@
${slf4j.version}
compile
+
+ org.apache.hadoop
+ hadoop-common
+ ${hadoop23.version}
+ compile
+
+
+ org.apache.hadoop
+ hadoop-mapreduce-client-core
+ ${hadoop23.version}
+ compile
+
+
+ org.apache.hadoop
+ hadoop-hdfs
+ ${hadoop23.version}
+ compile
+
diff --git a/hcatalog/webhcat/svr/src/main/java/org/apache/hive/hcatalog/templeton/Main.java b/hcatalog/webhcat/svr/src/main/java/org/apache/hive/hcatalog/templeton/Main.java
index 0f37278..fb3f825 100644
--- a/hcatalog/webhcat/svr/src/main/java/org/apache/hive/hcatalog/templeton/Main.java
+++ b/hcatalog/webhcat/svr/src/main/java/org/apache/hive/hcatalog/templeton/Main.java
@@ -25,6 +25,8 @@
import java.io.IOException;
import java.util.ArrayList;
import java.util.HashMap;
+import java.util.EnumSet;
+import javax.servlet.DispatcherType;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
@@ -169,21 +171,21 @@ public Server runServer(int port)
* callbacks. So jetty would fail the request as unauthorized.
*/
root.addFilter(fHolder, "/" + SERVLET_PATH + "/v1/ddl/*",
- FilterMapping.REQUEST);
+ EnumSet.of(DispatcherType.REQUEST));
root.addFilter(fHolder, "/" + SERVLET_PATH + "/v1/pig/*",
- FilterMapping.REQUEST);
+ EnumSet.of(DispatcherType.REQUEST));
root.addFilter(fHolder, "/" + SERVLET_PATH + "/v1/hive/*",
- FilterMapping.REQUEST);
+ EnumSet.of(DispatcherType.REQUEST));
root.addFilter(fHolder, "/" + SERVLET_PATH + "/v1/queue/*",
- FilterMapping.REQUEST);
+ EnumSet.of(DispatcherType.REQUEST));
root.addFilter(fHolder, "/" + SERVLET_PATH + "/v1/jobs/*",
- FilterMapping.REQUEST);
+ EnumSet.of(DispatcherType.REQUEST));
root.addFilter(fHolder, "/" + SERVLET_PATH + "/v1/mapreduce/*",
- FilterMapping.REQUEST);
+ EnumSet.of(DispatcherType.REQUEST));
root.addFilter(fHolder, "/" + SERVLET_PATH + "/v1/status/*",
- FilterMapping.REQUEST);
+ EnumSet.of(DispatcherType.REQUEST));
root.addFilter(fHolder, "/" + SERVLET_PATH + "/v1/version/*",
- FilterMapping.REQUEST);
+ EnumSet.of(DispatcherType.REQUEST));
// Connect Jersey
ServletHolder h = new ServletHolder(new ServletContainer(makeJerseyConfig()));
diff --git a/hwi/ivy.xml b/hwi/ivy.xml
index 81fa89b..aa5435d 100644
--- a/hwi/ivy.xml
+++ b/hwi/ivy.xml
@@ -28,7 +28,7 @@
-
+
-
-
-
-
-
-
-
+
-
-
-
+
+
-
-
-
+
+
+
+
+
+
+
+
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
+
+
+
-
diff --git a/ivy/libraries.properties b/ivy/libraries.properties
index 92ba790..8c9789b 100644
--- a/ivy/libraries.properties
+++ b/ivy/libraries.properties
@@ -50,7 +50,7 @@ javaewah.version=0.3.2
jdo-api.version=3.0.1
jdom.version=1.1
jetty.version=6.1.26
-jline.version=0.9.94
+jline.version=1.0
json.version=20090211
junit.version=4.10
libfb303.version=0.9.0
diff --git a/jdbc/src/java/org/apache/hive/jdbc/HiveConnection.java b/jdbc/src/java/org/apache/hive/jdbc/HiveConnection.java
index f155686..9a511bd 100644
--- a/jdbc/src/java/org/apache/hive/jdbc/HiveConnection.java
+++ b/jdbc/src/java/org/apache/hive/jdbc/HiveConnection.java
@@ -235,7 +235,6 @@ private void openSession() throws SQLException {
try {
TOpenSessionResp openResp = client.OpenSession(openReq);
-
// validate connection
Utils.verifySuccess(openResp.getStatus());
if (!supportedProtocols.contains(openResp.getServerProtocolVersion())) {
diff --git a/metastore/ivy.xml b/metastore/ivy.xml
index 4bbdfe6..1cd6399 100644
--- a/metastore/ivy.xml
+++ b/metastore/ivy.xml
@@ -31,9 +31,6 @@
-
-
-
diff --git a/odbc/Makefile b/odbc/Makefile
index 2c55903..db6ba21 100644
--- a/odbc/Makefile
+++ b/odbc/Makefile
@@ -46,7 +46,7 @@ ARXFLAGS = -x
CC = gcc
CFLAGS = -Wall -g -fPIC
CXX = g++
-CXXFLAGS = -Wall -g -fPIC
+CXXFLAGS = -Wall -g -fPIC -DHAVE_STDINT_H
LD = g++
INSTALL = /usr/bin/install -c
SHELL = /bin/sh
@@ -135,7 +135,7 @@ LIB_FB303_ADD = -L$(LIB_FB303_DIR) -lfb303
LIB_FB303_AR = $(LIB_FB303_DIR)/libfb303.a
-all:: $(AR_TARGET) $(SO_TARGET) $(HIVE_CLIENT_TEST)
+all:: $(SO_TARGET) $(HIVE_CLIENT_TEST)
$(AR_TARGET): $(METASTORE_OBJS) $(SERVICE_OBJS) $(QL_OBJS) $(ODBC_OBJS)
if test -z '$(THRIFT_HOME)'; then echo 'THRIFT_HOME directory?'; exit 1; else exit 0; fi
@@ -189,5 +189,5 @@ uninstall:
clean:
rm -rf $(ODBC_BUILD_DIR) $(OBJ_SERVICE_BUILD_DIR) $(OBJ_QL_BUILD_DIR) $(OBJ_METASTORE_BUILD_DIR)
-test: $(AR_TARGET) $(SO_TARGET) $(HIVE_CLIENT_TEST)
+test: $(SO_TARGET) $(HIVE_CLIENT_TEST)
LD_LIBRARY_PATH=$(LIB_ODBC_BUILD_DIR):$(LIB_THRIFT_DIR):$(LIB_FB303_DIR):$(LD_LIBRARY_PATH) $(HIVE_CLIENT_TEST)
diff --git a/odbc/src/cpp/hiveclient.cpp b/odbc/src/cpp/hiveclient.cpp
index 450eb0b..dc5aeab 100644
--- a/odbc/src/cpp/hiveclient.cpp
+++ b/odbc/src/cpp/hiveclient.cpp
@@ -18,6 +18,7 @@
#include
#include
+#include
#include
#include
diff --git a/ql/build.xml b/ql/build.xml
index 64e7b59..95344fd 100644
--- a/ql/build.xml
+++ b/ql/build.xml
@@ -197,7 +197,10 @@
deprecation="${javac.deprecation}"
includeantruntime="false">
-
+
+
+
+
@@ -208,108 +211,12 @@
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
diff --git a/ql/ivy.xml b/ql/ivy.xml
index 08a8d6f..3ff4f40 100644
--- a/ql/ivy.xml
+++ b/ql/ivy.xml
@@ -44,10 +44,10 @@
-
-
+
@@ -57,13 +57,6 @@
-
-
-
-
-
diff --git a/ql/src/java/org/apache/hadoop/hive/ql/exec/ExplainTask.java b/ql/src/java/org/apache/hadoop/hive/ql/exec/ExplainTask.java
index 7e1f6ef..e5178b6 100644
--- a/ql/src/java/org/apache/hadoop/hive/ql/exec/ExplainTask.java
+++ b/ql/src/java/org/apache/hadoop/hive/ql/exec/ExplainTask.java
@@ -48,9 +48,9 @@
import org.apache.hadoop.hive.ql.plan.api.StageType;
import org.apache.hadoop.io.IOUtils;
import org.apache.hadoop.util.StringUtils;
-import org.json.JSONArray;
-import org.json.JSONException;
-import org.json.JSONObject;
+import org.codehaus.jettison.json.JSONArray;
+import org.codehaus.jettison.json.JSONException;
+import org.codehaus.jettison.json.JSONObject;
/**
* ExplainTask implementation.
diff --git a/ql/src/java/org/apache/hadoop/hive/ql/io/orc/RecordReaderImpl.java b/ql/src/java/org/apache/hadoop/hive/ql/io/orc/RecordReaderImpl.java
index 5beb48e..db0b623 100644
--- a/ql/src/java/org/apache/hadoop/hive/ql/io/orc/RecordReaderImpl.java
+++ b/ql/src/java/org/apache/hadoop/hive/ql/io/orc/RecordReaderImpl.java
@@ -1129,9 +1129,7 @@ Object next(Object previous) throws IOException {
void seek(PositionProvider[] index) throws IOException {
super.seek(index);
for(TreeReader kid: fields) {
- if (kid != null) {
- kid.seek(index);
- }
+ kid.seek(index);
}
}
@@ -1177,9 +1175,7 @@ void startStripe(Map streams,
void skipRows(long items) throws IOException {
items = countNonNulls(items);
for(TreeReader field: fields) {
- if (field != null) {
- field.skipRows(items);
- }
+ field.skipRows(items);
}
}
}
diff --git a/ql/src/java/org/apache/hadoop/hive/ql/io/orc/SnappyCodec.java b/ql/src/java/org/apache/hadoop/hive/ql/io/orc/SnappyCodec.java
index e3131a3..c8324ad 100644
--- a/ql/src/java/org/apache/hadoop/hive/ql/io/orc/SnappyCodec.java
+++ b/ql/src/java/org/apache/hadoop/hive/ql/io/orc/SnappyCodec.java
@@ -18,7 +18,7 @@
package org.apache.hadoop.hive.ql.io.orc;
-import org.iq80.snappy.Snappy;
+import org.xerial.snappy.Snappy;
import java.io.IOException;
import java.nio.ByteBuffer;
diff --git a/ql/src/java/org/apache/hadoop/hive/ql/parse/EximUtil.java b/ql/src/java/org/apache/hadoop/hive/ql/parse/EximUtil.java
index 3031d1c..222f276 100644
--- a/ql/src/java/org/apache/hadoop/hive/ql/parse/EximUtil.java
+++ b/ql/src/java/org/apache/hadoop/hive/ql/parse/EximUtil.java
@@ -47,9 +47,9 @@
import org.apache.thrift.TException;
import org.apache.thrift.TSerializer;
import org.apache.thrift.protocol.TJSONProtocol;
-import org.json.JSONArray;
-import org.json.JSONException;
-import org.json.JSONObject;
+import org.codehaus.jettison.json.JSONArray;
+import org.codehaus.jettison.json.JSONException;
+import org.codehaus.jettison.json.JSONObject;
/**
*
diff --git a/ql/src/java/org/apache/hadoop/hive/ql/udf/generic/AbstractGenericUDFEWAHBitmapBop.java b/ql/src/java/org/apache/hadoop/hive/ql/udf/generic/AbstractGenericUDFEWAHBitmapBop.java
index 58ea3ba..198bab5 100644
--- a/ql/src/java/org/apache/hadoop/hive/ql/udf/generic/AbstractGenericUDFEWAHBitmapBop.java
+++ b/ql/src/java/org/apache/hadoop/hive/ql/udf/generic/AbstractGenericUDFEWAHBitmapBop.java
@@ -22,7 +22,7 @@
import java.util.ArrayList;
import java.util.List;
-import javaewah.EWAHCompressedBitmap;
+import com.googlecode.javaewah.EWAHCompressedBitmap;
import org.apache.hadoop.hive.ql.exec.UDFArgumentException;
import org.apache.hadoop.hive.ql.exec.UDFArgumentLengthException;
diff --git a/ql/src/java/org/apache/hadoop/hive/ql/udf/generic/GenericUDAFEWAHBitmap.java b/ql/src/java/org/apache/hadoop/hive/ql/udf/generic/GenericUDAFEWAHBitmap.java
index e4b412e..bb8afe7 100644
--- a/ql/src/java/org/apache/hadoop/hive/ql/udf/generic/GenericUDAFEWAHBitmap.java
+++ b/ql/src/java/org/apache/hadoop/hive/ql/udf/generic/GenericUDAFEWAHBitmap.java
@@ -20,7 +20,7 @@
import java.io.IOException;
import java.util.ArrayList;
-import javaewah.EWAHCompressedBitmap;
+import com.googlecode.javaewah.EWAHCompressedBitmap;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
diff --git a/ql/src/java/org/apache/hadoop/hive/ql/udf/generic/GenericUDFEWAHBitmapAnd.java b/ql/src/java/org/apache/hadoop/hive/ql/udf/generic/GenericUDFEWAHBitmapAnd.java
index 7838b54..b942988 100644
--- a/ql/src/java/org/apache/hadoop/hive/ql/udf/generic/GenericUDFEWAHBitmapAnd.java
+++ b/ql/src/java/org/apache/hadoop/hive/ql/udf/generic/GenericUDFEWAHBitmapAnd.java
@@ -18,7 +18,7 @@
package org.apache.hadoop.hive.ql.udf.generic;
-import javaewah.EWAHCompressedBitmap;
+import com.googlecode.javaewah.EWAHCompressedBitmap;
import org.apache.hadoop.hive.ql.exec.Description;
diff --git a/ql/src/java/org/apache/hadoop/hive/ql/udf/generic/GenericUDFEWAHBitmapEmpty.java b/ql/src/java/org/apache/hadoop/hive/ql/udf/generic/GenericUDFEWAHBitmapEmpty.java
index 4a14a65..f0617c1 100644
--- a/ql/src/java/org/apache/hadoop/hive/ql/udf/generic/GenericUDFEWAHBitmapEmpty.java
+++ b/ql/src/java/org/apache/hadoop/hive/ql/udf/generic/GenericUDFEWAHBitmapEmpty.java
@@ -21,7 +21,7 @@
import java.io.IOException;
import java.util.ArrayList;
-import javaewah.EWAHCompressedBitmap;
+import com.googlecode.javaewah.EWAHCompressedBitmap;
import org.apache.hadoop.hive.ql.exec.Description;
import org.apache.hadoop.hive.ql.exec.UDFArgumentException;
diff --git a/ql/src/java/org/apache/hadoop/hive/ql/udf/generic/GenericUDFEWAHBitmapOr.java b/ql/src/java/org/apache/hadoop/hive/ql/udf/generic/GenericUDFEWAHBitmapOr.java
index d438f82..47e9447 100644
--- a/ql/src/java/org/apache/hadoop/hive/ql/udf/generic/GenericUDFEWAHBitmapOr.java
+++ b/ql/src/java/org/apache/hadoop/hive/ql/udf/generic/GenericUDFEWAHBitmapOr.java
@@ -18,7 +18,7 @@
package org.apache.hadoop.hive.ql.udf.generic;
-import javaewah.EWAHCompressedBitmap;
+import com.googlecode.javaewah.EWAHCompressedBitmap;
import org.apache.hadoop.hive.ql.exec.Description;
diff --git a/service/src/java/org/apache/hive/service/cli/thrift/ThriftCLIService.java b/service/src/java/org/apache/hive/service/cli/thrift/ThriftCLIService.java
index 857e627..1098f08 100644
--- a/service/src/java/org/apache/hive/service/cli/thrift/ThriftCLIService.java
+++ b/service/src/java/org/apache/hive/service/cli/thrift/ThriftCLIService.java
@@ -59,7 +59,7 @@
protected int portNum;
protected InetSocketAddress serverAddress;
protected TServer server;
- protected org.mortbay.jetty.Server httpServer;
+ protected org.eclipse.jetty.server.Server httpServer;
private boolean isStarted = false;
protected boolean isEmbedded = false;
diff --git a/service/src/java/org/apache/hive/service/cli/thrift/ThriftHttpCLIService.java b/service/src/java/org/apache/hive/service/cli/thrift/ThriftHttpCLIService.java
index e487a7f..e6e139b 100644
--- a/service/src/java/org/apache/hive/service/cli/thrift/ThriftHttpCLIService.java
+++ b/service/src/java/org/apache/hive/service/cli/thrift/ThriftHttpCLIService.java
@@ -26,10 +26,11 @@
import org.apache.thrift.protocol.TBinaryProtocol;
import org.apache.thrift.protocol.TProtocolFactory;
import org.apache.thrift.server.TServlet;
-import org.mortbay.jetty.nio.SelectChannelConnector;
-import org.mortbay.jetty.servlet.Context;
-import org.mortbay.jetty.servlet.ServletHolder;
-import org.mortbay.thread.QueuedThreadPool;
+import org.eclipse.jetty.server.Connector;
+import org.eclipse.jetty.server.nio.SelectChannelConnector;
+import org.eclipse.jetty.servlet.ServletContextHandler;
+import org.eclipse.jetty.servlet.ServletHolder;
+import org.eclipse.jetty.util.thread.QueuedThreadPool;
public class ThriftHttpCLIService extends ThriftCLIService {
@@ -75,11 +76,10 @@ public void run() {
}
}
- httpServer = new org.mortbay.jetty.Server();
-
QueuedThreadPool threadPool = new QueuedThreadPool();
threadPool.setMinThreads(minWorkerThreads);
threadPool.setMaxThreads(maxWorkerThreads);
+ httpServer = new org.eclipse.jetty.server.Server();
httpServer.setThreadPool(threadPool);
SelectChannelConnector connector = new SelectChannelConnector();
connector.setPort(portNum);
@@ -93,7 +93,7 @@ public void run() {
TProtocolFactory protocolFactory = new TBinaryProtocol.Factory();
TServlet thriftHttpServlet = new ThriftHttpServlet(processor, protocolFactory);
- final Context context = new Context(httpServer, "/", Context.SESSIONS);
+ final ServletContextHandler context = new ServletContextHandler(httpServer, "/", ServletContextHandler.SESSIONS);
context.addServlet(new ServletHolder(thriftHttpServlet), httpPath);
// TODO: check defaults: maxTimeout, keepalive, maxBodySize, bodyRecieveDuration, etc.
@@ -144,4 +144,4 @@ private static void verifyHttpConfiguration(HiveConf hiveConf) {
}
}
-}
\ No newline at end of file
+}
diff --git a/shims/ivy.xml b/shims/ivy.xml
index c0312bc..842f336 100644
--- a/shims/ivy.xml
+++ b/shims/ivy.xml
@@ -39,7 +39,7 @@
-
+
@@ -48,9 +48,10 @@
rev="${hadoop-0.23.version}"
conf="hadoop0.23.shim->default">
-
+
+
+
+
-
+
+
+
+
@@ -97,13 +103,7 @@
-
-
-
-
-
+
+
+
diff --git a/shims/src/0.23/java/org/apache/hadoop/hive/shims/Jetty23Shims.java b/shims/src/0.23/java/org/apache/hadoop/hive/shims/Jetty23Shims.java
index 9328749..786a9d6 100644
--- a/shims/src/0.23/java/org/apache/hadoop/hive/shims/Jetty23Shims.java
+++ b/shims/src/0.23/java/org/apache/hadoop/hive/shims/Jetty23Shims.java
@@ -19,9 +19,11 @@
import java.io.IOException;
-import org.mortbay.jetty.bio.SocketConnector;
-import org.mortbay.jetty.handler.RequestLogHandler;
-import org.mortbay.jetty.webapp.WebAppContext;
+import org.eclipse.jetty.server.Connector;
+import org.eclipse.jetty.server.Server;
+import org.eclipse.jetty.server.nio.SelectChannelConnector;
+import org.eclipse.jetty.server.handler.RequestLogHandler;
+import org.eclipse.jetty.webapp.WebAppContext;
/**
* Jetty23Shims.
@@ -34,20 +36,20 @@ public Server startServer(String listen, int port) throws IOException {
return s;
}
- private static class Server extends org.mortbay.jetty.Server implements JettyShims.Server {
+ private static class Server extends org.eclipse.jetty.server.Server implements JettyShims.Server {
public void addWar(String war, String contextPath) {
WebAppContext wac = new WebAppContext();
wac.setContextPath(contextPath);
wac.setWar(war);
RequestLogHandler rlh = new RequestLogHandler();
rlh.setHandler(wac);
- this.addHandler(rlh);
+ this.setHandler(rlh);
}
public void setupListenerHostPort(String listen, int port)
throws IOException {
- SocketConnector connector = new SocketConnector();
+ Connector connector = new SelectChannelConnector();
connector.setPort(port);
connector.setHost(listen);
this.addConnector(connector);