如果您只想将作业输出写入mysql，我建议您使用一种不同的输出格式，称为 DBOutputFormat 如下所述：
伴随类dboutputformat将允许您将结果写回数据库。设置作业时，调用conf.setoutputformat（dboutputformat.class）；然后像以前一样调用dbconfiguration.configuredb（）。
然后，dboutputformat.setoutput（）方法定义将结果写回数据库的方式。它的三个参数是作业的jobconf对象、定义要写入的表名称的字符串和定义要填充的表字段的字符串数组。e、 例如，dboutputformat.setoutput（job，“employees”，“employeer_id”，“name”）；。
您先前创建的同一个dbwritable实现足以将记录注入数据库。write（preparedstatement stmt）方法将在从reducer传递给outputcollector的dbwritable的每个示例上调用。在reduce结束时，这些preparedstatement对象将转换为insert语句，以针对sql数据库运行。
其中“如前所述”指本说明：

DBConfiguration.configureDB(conf, “com.mysql.jdbc.Driver”, “jdbc:mysql://localhost/mydatabase”);

从mysql中读取，这与 DBInputFormat .

sqoop设计用于在mysql/其他关系数据库和hadoop/hbase之间导出/导入数据。一个非常好的关于sqoop的教程可以在这里找到，它解释了它的各种功能。不确定这是不是你想做的。
如果您需要在mapreduce作业中从mysql读写数据， DBInputFormat/DBOutput hadoop类可以按照@charles的建议使用

谢谢查尔斯和维卡斯。这无疑使我走上了正确的道路。最后我用了https://github.com/cwensel/cascading.jdbc 它使用hadoop类 DBInputFormat/DBOutput 使设置读写db的级联作业变得容易。
为了编写，我刚刚将我的tap的输出流更改为：

String url = "jdbc:mysql://localhost:3306/mydb?user=myusername&password=mypassword";
String driver = "com.mysql.jdbc.Driver";
String tableName = "mytable";   
String[] columnNames = {'col1', 'col2', 'col3'}; //Columns I want to write to 
TableDesc tableDesc = new TableDesc( tableName );

JDBCScheme dbScheme = new JDBCScheme( columnNames );
Tap dbOutputTap = new JDBCTap( url, driver, tableDesc, dbScheme );

为了从数据库中读取数据，我做了一个如下的点击：

String url = "jdbc:mysql://localhost:3306/mydb?user=myusername&password=mypassword";
String driver = "com.mysql.jdbc.Driver";
String tableName = "mytable";      
String[] columnNames = {'col1', 'col2', 'col3'}; //Columns I want to read from 
TableDesc tableDesc = new TableDesc( tableName );

JDBCScheme dbScheme = new JDBCScheme( columnNames, "col1<40" );
Tap dbInputTap = new JDBCTap( url, driver, tableDesc, dbScheme );

我也遇到过级联dbmigrate，但似乎这只是用于从db读取数据，而不是向它们写入数据。