????flink-jdbc-driver????mysql??????(flink1.10.0)

[????]

??????????jdbc????gateway????????mysql??????????????????jdbc-driver????mysql??????????????????????????????SQL-gateway??????????????????????????sqlclient??????????????????????????????????????????????????????????????????????????????????????tablesink??????????????????Caused
 by: org.apache.flink.table.api.TableException: RetractStreamTableSink and 
UpsertStreamTableSink is not supported in Batch environment.  at 
org.apache.flink.table.planner.plan.nodes.physical.batch.BatchExecSink.translateToPlanInternal(BatchExecSink.scala:85)
       at 
org.apache.flink.table.planner.plan.nodes.physical.batch.BatchExecSink.translateToPlanInternal(BatchExecSink.scala:48)
       at 
org.apache.flink.table.planner.plan.nodes.exec.ExecNode$class.translateToPlan(ExecNode.scala:58)
     at 
org.apache.flink.table.planner.plan.nodes.physical.batch.BatchExecSink.translateToPlan(BatchExecSink.scala:48)
       at 
org.apache.flink.table.planner.delegation.BatchPlanner$$anonfun$translateToPlan$1.apply(BatchPlanner.scala:69)
       at 
org.apache.flink.table.planner.delegation.BatchPlanner$$anonfun$translateToPlan$1.apply(BatchPlanner.scala:68)
????????????Connection connection = 
DriverManager.getConnection("jdbc:flink://dataflow1:8083?planner=blink");
Statement statement = connection.createStatement();
sql = "CREATE TABLE t_user_target (\n" +
        "  id BIGINT,\n" +
        "  username VARCHAR\n" +
        ") WITH (\n" +
        "  'connector.type' = 'jdbc',\n" +
        "  'connector.driver' = 'com.mysql.jdbc.Driver',\n" +
        "  'connector.url' = 'jdbc:mysql://172.18.100.85:3306/targetdb',\n" +
        "  'connector.table' = 't1target',\n" +
        "  'connector.username' = 'root',\n" +
        "  'connector.password' = 'root',\n" +
        "  'connector.write.flush.max-rows' = '5000'\n" +
        ");";
statement.executeUpdate(sql);
statement.execute("insert into t_user_target values(1,'fan'),(2,'ss')");