You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@seatunnel.apache.org by wu...@apache.org on 2022/03/11 15:16:09 UTC
[incubator-seatunnel] branch dev updated: [Bug][Connector] Fix Flink ConsoleSink not printing results (#1417)
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 <zh...@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);
}