Fix delimiter issue.

caxqueiroz · Mar 28, 2016 · 582da68 · 582da68
1 parent 467dbb6
commit 582da68
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/src/main/java/io/pivotal/spring/xd/jdbcgpfdist/gpfdist/GPFDistMessageHandler.java b/src/main/java/io/pivotal/spring/xd/jdbcgpfdist/gpfdist/GPFDistMessageHandler.java
@@ -90,7 +90,7 @@ protected void doWrite(Message<?> message) throws Exception {
             String data = (String)payload;
             log.info("data:"  + data);
             if (delimiter != null) {
-                processor.onNext(Buffer.wrap(data));
+                processor.onNext(Buffer.wrap(data+delimiter));
             } else {
                 processor.onNext(Buffer.wrap(data));
             }

diff --git a/src/main/java/io/pivotal/spring/xd/jdbcgpfdist/jdbc/CustomRowMapper.java b/src/main/java/io/pivotal/spring/xd/jdbcgpfdist/jdbc/CustomRowMapper.java
@@ -30,7 +30,7 @@ public String mapRow(ResultSet resultSet, int i) throws SQLException {
             sb.append(columnDelimiter);
         }
 
-        String row = sb.append(resultSet.getObject(columnsCount)).append("\t").toString();
+        String row = sb.append(resultSet.getObject(columnsCount)).toString();
         log.info(row);
         return row;
     }