Browse Source

[spark] Fix connecting to livy, starting a session

Erick Tryzelaar 11 years ago
parent
commit
34dbb3ed1d
2 changed files with 7 additions and 3 deletions
  1. 1 1
      apps/spark/src/spark/conf.py
  2. 6 2
      apps/spark/src/spark/job_server_api.py

+ 1 - 1
apps/spark/src/spark/conf.py

@@ -32,7 +32,7 @@ def coerce_json(j):
 JOB_SERVER_URL = Config(
   key="server_url",
   help=_t("URL of the Spark Job Server."),
-  default="http://localhost:8080/"
+  default="http://localhost:8998/"
 )
 
 LANGUAGES = Config(

+ 6 - 2
apps/spark/src/spark/job_server_api.py

@@ -81,11 +81,15 @@ class JobServerApi(object):
       self._thread_local.user = user
 
   def create_session(self, **kwargs):
-    return self._root.post('sessions', params=kwargs)
+    return self._root.post('sessions',
+        data=json.dumps(kwargs),
+        contenttype='application/json')
 
   def submit_statement(self, uuid, statement):
     data = {'statement': statement}
-    return self._root.post('sessions/%s' % uuid, data=json.dumps(data), contenttype=_JSON_CONTENT_TYPE)
+    return self._root.post('sessions/%s' % uuid,
+        data=json.dumps(data),
+        contenttype=_JSON_CONTENT_TYPE)
 
   def fetch_data(self, session, cell):
     return self._root.get('sessions/%s/cells/%s' % (session, cell))