JDBC Table Sink doesn't seem to sink to database.

Posted by John Smith on
URL: http://deprecated-apache-flink-user-mailing-list-archive.369.s1.nabble.com/JDBC-Table-Sink-doesn-t-seem-to-sink-to-database-tp30525.html

Hi, using 1.8.0

I have the following job: https://pastebin.com/ibZUE8Qx

So the job does the following steps...
1- Consume from Kafka and return JsonObject
2- Map JsonObject to MyPojo
3- Convert The stream to a table
4- Insert the table to JDBC sink table
5- Print the table.

- The job seems to work with no errors and I can see the row print to the console and I see nothing in my database. 

- If I put invalid host for the database and restart the job, I get a connection SQLException error. So at least we know that works.
- If I make a typo on the INSERT INTO statement like INSERTS INTO non_existing_table, there are no exceptions thrown, the print happens, the stream continues to work.
- If I drop the table from the database, same thing, no exceptions thrown, the print happens, the stream continues to work.

So am I missing something?