We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent dfae097 commit b2e4085Copy full SHA for b2e4085
console/console-sink/src/main/java/com/dtstack/flink/sql/sink/console/ConsoleOutputFormat.java
@@ -69,7 +69,11 @@ public void writeRecord(Tuple2 tuple2) throws IOException {
69
70
List<String[]> data = new ArrayList<>();
71
data.add(fieldNames);
72
- data.add(record.toString().split(","));
+ String[] recordStr = new String[record.getArity()];
73
+ for (int i=0; i < record.getArity(); i++) {
74
+ recordStr[i] = (String.valueOf(record.getField(i)));
75
+ }
76
+ data.add(recordStr);
77
TablePrintUtil.build(data).print();
78
79
outRecords.inc();
0 commit comments