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}
