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?
