fix test & config file.

zzt93 · Sep 11, 2018 · 782bd6d · 782bd6d
1 parent fdd7abf
commit 782bd6d
Show file tree

Hide file tree

Showing 3 changed files with 6 additions and 9 deletions.
diff --git a/src/main/resources/config.yml b/src/main/resources/config.yml
@@ -4,7 +4,7 @@ syncer:
   input:
     max-retry: 5
     input-meta:
-      last-run-metadata-dir: //Users/xiong/data/syncer/input/last_position/
+      last-run-metadata-dir: /data/syncer/input/last_position/
 
   filter:
     worker: 12
@@ -14,4 +14,4 @@ syncer:
     batch:
       worker: 2
     output-meta:
-      failure-log-dir: //Users/xiong/data/syncer/output/failure/
+      failure-log-dir: /data/syncer/output/failure/
diff --git a/src/test/java/com/github/zzt93/syncer/common/thread/WaitingAckHookTest.java b/src/test/java/com/github/zzt93/syncer/common/thread/WaitingAckHookTest.java
@@ -9,19 +9,17 @@ public class WaitingAckHookTest {
   public void setUp() throws Exception {
   }
 
-  @Test
   public void exit() {
     Runtime.getRuntime().addShutdownHook(new Thread(()-> System.out.println("exit")));
     System.exit(0);
   }
 
-  @Test
   public void exitMulti() {
-    // deadlock
     Runtime.getRuntime().addShutdownHook(new Thread(()-> {
       System.out.println("exit");
-      System.exit(0);
-      System.out.println("exit2");
+      // deadlock
+//      System.exit(0);
+//      System.out.println("exit2");
     }));
     System.exit(0);
   }

diff --git a/...test/java/com/github/zzt93/syncer/config/pipeline/common/ElasticsearchConnectionTest.java b/...test/java/com/github/zzt93/syncer/config/pipeline/common/ElasticsearchConnectionTest.java
@@ -20,7 +20,6 @@ public class ElasticsearchConnectionTest {
   /**
    * https://discuss.elastic.co/t/java-api-plainless-script-indexof-give-wrong-answer/139016/7
    */
-  @Test
   public void scriptIndexOf() throws Exception {
     ElasticsearchConnection elasticsearchConnection = new ElasticsearchConnection();
     elasticsearchConnection.setClusterName("searcher-integration");
@@ -67,7 +66,7 @@ private UpdateRequestBuilder updateRequest(AbstractClient client, Script meta) {
   }
 
   @Test
-  public void name() throws Exception {
+  public void name() {
     ArrayList<Long> l = Lists.newArrayList(1L, 2L);
     System.out.println(l.indexOf(1));
     System.out.println(l.indexOf(1L));