Hi, this bug has been fixed in https://github.com/apache/incubator-seatunnel/pull/1417
在 2022年3月11日 09:21，wenjun<[email protected]> 写道： Hi, I also find this problem, I guess this might be caused by right now the `seatunnel-flink-jdbc` source will use the batch mode to execute the job. And I find in `org.apache.seatunnel.flink.sink.ConsoleSink.java` it will not print the DataSet in outputBatch method, this might be a BUG? ``` @Override public DataSink<Row> outputBatch(FlinkEnvironment env, DataSet<Row> rowDataSet) { return rowDataSet.output(this); } @Override public DataStreamSink<Row> outputStream(FlinkEnvironment env, DataStream<Row> dataStream) { return dataStream.print(); } ``` You can simply add print function in outputBatch, then you will see the result in console. ``` @Override public DataSink<Row> outputBatch(FlinkEnvironment env, DataSet<Row> rowDataSet) { try { rowDataSet.print(); } catch (Exception ex) { throw new RuntimeException("Print result into console error", ex); } return rowDataSet.output(this); } ``` Best, Wenjun On Fri, Mar 11, 2022 at 12:13 AM M Singh <[email protected]> wrote: > > Hi Folks: > I am trying to write a very simple seatunnel configuration which gets data from database (included below - it only has a jdbc source and console sink). However, the application terminates without any results. I am using Seatunnel 2.0.5-SNAPSHOT for my tests. > I have added the jdbc dependencies as required and have tried to add source_table_name in the console sink but still am not able to figure out what could be the reason that there are no console results. > If I use the fake source config example - it does work and shows output in the console. > Can you please let me know how to debug this and what could the issue ? > Thanks > > I am using configuration for Jdbc Source mentioned at https://seatunnel.apache.org/docs/flink/configuration/source-plugins/Jdbc > Here is the additional jdbc dependencies for the included config: > <dependency> <groupId>org.apache.flink</groupId> <artifactId>flink-connector-jdbc_${scala.binary.version}</artifactId> </dependency> <dependency> <groupId>mysql</groupId> <artifactId>mysql-connector-java</artifactId> <version>5.1.49</version> <scope>runtime</scope> </dependency> > > Here is the configuration seatunnel config (it's based on the fake example config https://seatunnel.apache.org/docs/flink/configuration/ConfigExamples/) > env { # You can set flink configuration here execution.parallelism = 1 #execution.checkpoint.interval = 10000 #execution.checkpoint.data-uri = "hdfs://localhost:9000/checkpoint"} > source { # This is a example source plugin **only for test and demonstrate the feature source plugin** JdbcSource { driver = "com.mysql.jdbc.Driver" url = "jdbc:mysql://localhost/mydatabase?useSSL=false" username = "root" password = "" query = "select * from people" result_table_name = "people" field_name = "name,age,phone" } # If you would like to get more information about how to configure seatunnel and see full list of source plugins, # please go to https://seatunnel.apache.org/docs/flink/configuration/source-plugins/Fake} > transform {## # If you would like to get more information about how to configure seatunnel and see full list of transform plugins,# # please go to https://seatunnel.apache.org/docs/flink/configuration/transform-plugins/Sql} > sink { ConsoleSink {# source_table_name = "people" } > # If you would like to get more information about how to configure seatunnel and see full list of sink plugins, # please go to https://seatunnel.apache.org/docs/flink/configuration/sink-plugins/Console} >
