Spark: Memory leak with embedded Jetty server

[xizhang]

I have a small REST web service written in Spark. It's dead simple: it reads a remote DB and return JSON data to client. I run it using the default embedded Jetty server on Google Compute Engine:

java -jar file_name.jar

It works fine except for a serious memory leak issue. :( But in JVM dump, I cannot find anything suspicious. At least not related to my code. Is the embedded Jetty server the problem? Is anything suggestions or actions I can take to track down the issue?

Thank you so much,

[wmacgyver]

one possible way to track this down is to deploy this as a war to a stand alone jetty? that would at least eliminate the embedded jetty as a source

[hexvalid]

Same issue. Every request increasing to memory usage

[tipsy]

? Is anything suggestions or actions I can take to track down the issue?

Strip away all non-offending code and post an example.

[xizhang]

Sure, thanks! here is an example of my code:

public class Main {

   public static void main(String[] args) {
      get("/ping", (request, response) -> {
         Sql2o sql2oForPing = new Sql2o(CONNECTION_URL, "user", "password");
         try(Connection conn = sql2oForPing.open()) {
           return conn.createQuery("select count(*) from messages").executeScalar(Integer.class) > 0 ?
               "has data" : "no data";
         } catch (RuntimeException ex) {
           return "DB error:" + ex;
         }
      });
   }
}

BTW I am trying war file + Tomcat too. I will update the thread with result.

[kendrickwilson]

Take a look at http://www.sql2o.org/docs/configuration/

I would try something like following.....

public class Main {
   public static void main(String[] args) {
     // setup once
      Sql2o sql2oForPing = new Sql2o(CONNECTION_URL, "user", "password");

      // reuse over and over
      get("/ping", (request, response) -> {
         try(Connection conn = sql2oForPing.open()) {
           return conn.createQuery("select count(*) from messages").executeScalar(Integer.class) > 0 ?
               "has data" : "no data";
         } catch (RuntimeException ex) {
           return "DB error:" + ex;
         }
      });
   }
}

[kllm]

+1