azkaban-developers

diff --git a/azkaban-execserver/src/main/java/azkaban/execapp/AzkabanExecutorServer.java b/azkaban-execserver/src/main/java/azkaban/execapp/AzkabanExecutorServer.java
index d9a4bc0..5c9ea10 100644
--- a/azkaban-execserver/src/main/java/azkaban/execapp/AzkabanExecutorServer.java
+++ b/azkaban-execserver/src/main/java/azkaban/execapp/AzkabanExecutorServer.java
@@ -36,6 +36,7 @@ import org.mortbay.jetty.Connector;
 import org.mortbay.jetty.Server;
 import org.mortbay.jetty.servlet.Context;
 import org.mortbay.jetty.servlet.ServletHolder;
+import org.mortbay.log.Log;
 import org.mortbay.thread.QueuedThreadPool;
 
 import azkaban.executor.ExecutorLoader;
@@ -71,6 +72,7 @@ public class AzkabanExecutorServer {
   public static final String JOBTYPE_PLUGIN_DIR = "azkaban.jobtype.plugin.dir";
   public static final String METRIC_INTERVAL = "executor.metric.milisecinterval.";
   public static final int DEFAULT_PORT_NUMBER = 12321;
+  public static final int DEFAULT_HEADER_BUFFER_SIZE = 4096;  
 
   private static final String DEFAULT_TIMEZONE_ID = "default.timezone.id";
   private static final int DEFAULT_THREAD_NUMBER = 50;
@@ -104,9 +106,14 @@ public class AzkabanExecutorServer {
 
     boolean isStatsOn = props.getBoolean("executor.connector.stats", true);
     logger.info("Setting up connector with stats on: " + isStatsOn);
-
-    for (Connector connector : server.getConnectors()) {
+    
+    for (Connector connector : server.getConnectors()) {      
       connector.setStatsOn(isStatsOn);
+      logger.info(String.format("Jetty connector name: %s, default header buffer size: %d",
+              connector.getName(), connector.getHeaderBufferSize()));     
+      connector.setHeaderBufferSize(props.getInt("jetty.headerBufferSize", DEFAULT_HEADER_BUFFER_SIZE));
+      logger.info(String.format("Jetty connector name: %s, (if) new header buffer size: %d",
+              connector.getName(), connector.getHeaderBufferSize()));
     }
 
     Context root = new Context(server, "/", Context.SESSIONS);