处理canal client代码

liukelin · Aug 29, 2016 · d960f62 · d960f62
1 parent 3a3b9ad
commit d960f62
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/canal-client/bin/canal/client/CanalClientTest.class b/canal-client/bin/canal/client/CanalClientTest.class
diff --git a/canal-client/src/canal/client/CanalClientTest.java b/canal-client/src/canal/client/CanalClientTest.java
@@ -300,7 +300,7 @@ private static void printEntry(List<Entry> entrys) {
                     after = printColumn(rowData.getAfterColumnsList());  
                 }
 
-                String row_data = header_str + row_str + "\"before\":" +before + ",\"after\":" + after + ",\"time\":\"" + timeStr +"\"}\r\n";
+                String row_data = header_str + row_str + "\"before\":" +before + ",\"after\":" + after + ",\"time\":\"" + timeStr +"\"}";
                 dataArray.add(row_data);   
                 save_data_logs(row_data);
                 //System.out.println(row_data);
@@ -389,7 +389,7 @@ private static void save_data_logs(String row_data){
     	FileWriter writer;
         try {
             writer = new FileWriter(filename, true);
-            writer.write(row_data);
+            writer.write(row_data + "\r\n");
             writer.flush();
             writer.close();
         } catch (IOException e) {