Update javaspark so it works.

GoogleCloudPlatform · Jan 13, 2017 · 36518b6 · 36518b6
1 parent a166020
commit 36518b6
Show file tree

Hide file tree

Showing 4 changed files with 8 additions and 7 deletions.
diff --git a/flexible/sparkjava/pom.xml b/flexible/sparkjava/pom.xml
@@ -19,6 +19,7 @@
     <maven.compiler.source>1.8</maven.compiler.source>
 
     <appengine.maven.plugin>1.0.0</appengine.maven.plugin>
+    <app.stage.artifact>${project.build.directory}/spark-1.0-jar-with-dependencies.jar</app.stage.artifact>
   </properties>
 
   <dependencies>
@@ -44,8 +45,8 @@
     </dependency>
     <dependency>
       <groupId>com.google.cloud</groupId>
-      <artifactId>google-cloud</artifactId>
-      <version>0.4.0</version>
+      <artifactId>google-cloud-datastore</artifactId>
+      <version>0.8.1-beta</version>
     </dependency>
   </dependencies>
   <build>
@@ -83,7 +84,7 @@
           <mainClass>com.google.appengine.sparkdemo.Main</mainClass>
           <arguments>
             <argument>-jar</argument>
-            <argument>target/spark-1.0-jar-with-dependencies.jar</argument>
+            <argument>${app.stage.stagingDirectory}/spark-1.0-jar-with-dependencies.jar</argument>
           </arguments>
         </configuration>
       </plugin>

diff --git a/...e/sparkjava/src/main/appengine/Dockerfile → ...ible/sparkjava/src/main/docker/Dockerfile b/...e/sparkjava/src/main/appengine/Dockerfile → ...ible/sparkjava/src/main/docker/Dockerfile
diff --git a/flexible/sparkjava/src/test/java/com/google/appengine/sparkdemo/UserServiceTest.java b/flexible/sparkjava/src/test/java/com/google/appengine/sparkdemo/UserServiceTest.java
@@ -31,13 +31,15 @@
 import com.google.cloud.datastore.testing.LocalDatastoreHelper;
 import com.google.common.collect.Iterators;
 
+import org.joda.time.Duration;
 import org.junit.AfterClass;
 import org.junit.Before;
 import org.junit.BeforeClass;
 import org.junit.Test;
 
 import java.io.IOException;
 import java.util.List;
+import java.util.concurrent.TimeoutException;
 
 public class UserServiceTest {
 
@@ -72,8 +74,8 @@ public void setUp() {
   }
 
   @AfterClass
-  public static void afterClass() throws IOException, InterruptedException {
-    HELPER.stop();
+  public static void afterClass() throws IOException, InterruptedException, TimeoutException {
+    HELPER.stop(Duration.standardMinutes(1));
   }
 
   @Test

diff --git a/pom.xml b/pom.xml
@@ -98,9 +98,7 @@
         <module>flexible/mailjet</module>
         <module>flexible/memcache</module>
         <module>flexible/sendgrid</module>
-<!--
         <module>flexible/sparkjava</module>
- -->
         <module>flexible/static-files</module>
         <module>flexible/twilio</module>
         <module>language/analysis</module>