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

Reply via email to