SAMZA-1048 : upgrade jetty dependency to Jetty 9 from Jetty 8

Jetty 8 is a very old jetty version and the current widely used version is Jetty 9. If a user is using standalone Samza in a Jetty container, and he/she is using Jetty 9, he/she may see some incompatibility issue and it makes a lot of sense for a user to upgrade the Jetty version on his/her side instead of downgrading the Jetty version.

Author: Fred Ji <[email protected]>

Reviewers: Yi Pan <[email protected]>

Closes apache#20 from fredji97/master

Author: Fred Ji

gradle/dependency-versions-scala-2.10.gradle

@@ -25,5 +25,5 @@ ext {
   // -language:reflectiveCalls: Allow the automatic use of reflection to access fields without warning or library import
   scalaOptions = "-feature -language:implicitConversions -language:reflectiveCalls"
   scalatraVersion = "2.2.1"
-  jettyVersion = "8.1.8.v20121106"
+  jettyVersion = "9.2.7.v20150116"
 }

samza-core/src/main/scala/org/apache/samza/coordinator/server/HttpServer.scala

@@ -21,7 +21,7 @@ package org.apache.samza.coordinator.server;
 
 import javax.servlet.Servlet
 import org.apache.samza.SamzaException
-import org.eclipse.jetty.server.Connector
+import org.eclipse.jetty.server.NetworkConnector
 import org.eclipse.jetty.server.Server
 import org.eclipse.jetty.servlet.DefaultServlet
 import org.eclipse.jetty.servlet.ServletContextHandler
@@ -129,7 +129,7 @@ class HttpServer(
    */
   def getUrl = {
     if (running) {
-      val runningPort = server.getConnectors()(0).asInstanceOf[Connector].getLocalPort()
+      val runningPort = server.getConnectors()(0).asInstanceOf[NetworkConnector].getLocalPort()
 
       new URL("http://" + Util.getLocalHost.getHostName + ":" + runningPort + rootPath)
     } else {

samza-rest/src/main/java/org/apache/samza/rest/SamzaRestService.java

@@ -30,6 +30,7 @@
 import org.apache.samza.util.CommandLine;
 import org.apache.samza.util.MetricsReporterLoader;
 import org.apache.samza.util.Util;
+import org.eclipse.jetty.server.NetworkConnector;
 import org.eclipse.jetty.server.Server;
 import org.eclipse.jetty.servlet.ServletContextHandler;
 import org.eclipse.jetty.servlet.ServletHolder;
@@ -165,7 +166,7 @@ public void start()
       log.info("Starting the metrics reporter : {}.", reporterName);
       metricsReporter.start();
     });
-    log.info("Starting server on port {}", server.getConnectors()[0].getPort());
+    log.info("Starting server on port {}", ((NetworkConnector) server.getConnectors()[0]).getPort());
     server.start();
     log.info("Server is running");
   }