Why this INSERT does not insert row in table (jdbc connection works, I can create 'Customers' table from MySQL table)? tEnv.executeSql("CREATE TABLE Customers (" + " customer_number INT, " + " pid_no INT, " + " name STRING, " + " PRIMARY KEY (customer_number) NOT ENFORCED" + " ) WITH ( " + " 'connector' = 'jdbc', " + " 'url' = 'jdbc:mysql://localhost:3306/test', " + " 'username' = 'some_user', " + " 'table-name' = 'customers', " + " 'password' = ''" + ")");
//This insert does nothing (not even error) tEnv.executeSql("INSERT INTO Customers (customer_number, pid_no, name) VALUES (4000, 100, 'customer')"); According to documentation (https://nightlies.apache.org/flink/flink-docs-master/docs/connectors/table/jdbc/) it should work. Regards, Mike