[incubator-seatunnel] branch dev updated: [Bug][Connector] Fix Flink ConsoleSink not printing results (#1417)

[wuchunfu]

This is an automated email from the ASF dual-hosted git repository.

wuchunfu pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/incubator-seatunnel.git


The following commit(s) were added to refs/heads/dev by this push:
     new 9374972  [Bug][Connector] Fix Flink ConsoleSink not printing results 
(#1417)
9374972 is described below

commit 93749721768ccbf6d686f2e29af06c150b6b4ad5
Author: Simon <zhangshim...@cvte.com>
AuthorDate: Fri Mar 11 23:16:05 2022 +0800

    [Bug][Connector] Fix Flink ConsoleSink not printing results (#1417)
    
    * consolesink
    
    * trigger rebuild
---
 .../main/java/org/apache/seatunnel/flink/sink/ConsoleSink.java   | 9 +++++++++
 1 file changed, 9 insertions(+)

diff --git 
a/seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-console/src/main/java/org/apache/seatunnel/flink/sink/ConsoleSink.java
 
b/seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-console/src/main/java/org/apache/seatunnel/flink/sink/ConsoleSink.java
index 46c7212..422ea43 100644
--- 
a/seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-console/src/main/java/org/apache/seatunnel/flink/sink/ConsoleSink.java
+++ 
b/seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-console/src/main/java/org/apache/seatunnel/flink/sink/ConsoleSink.java
@@ -31,14 +31,23 @@ import org.apache.flink.configuration.Configuration;
 import org.apache.flink.streaming.api.datastream.DataStream;
 import org.apache.flink.streaming.api.datastream.DataStreamSink;
 import org.apache.flink.types.Row;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
 
 public class ConsoleSink extends RichOutputFormat<Row> implements 
FlinkBatchSink<Row, Row>, FlinkStreamSink<Row, Row> {
 
+    private static final Logger LOGGER = 
LoggerFactory.getLogger(ConsoleSink.class);
+
     private static final long serialVersionUID = 3482649370594181723L;
     private Config config;
 
     @Override
     public DataSink<Row> outputBatch(FlinkEnvironment env, DataSet<Row> 
rowDataSet) {
+        try {
+            rowDataSet.print();
+        } catch (Exception e) {
+            LOGGER.error("Failed to print result! ", e);
+        }
         return rowDataSet.output(this);
     }