我写了一个 MapReduce 程序来将数据导出到 MySQL。我使用 DBOutputFormat 类和 jdbc 用于 MySQL。当数据很小(例如 2M)时,一切正常。但是当我的数据较大(例如5Mbytes)时,它报错了异常“Connection.close() 已被调用。此状态下的操作无效。”
my.cnf 中的“wait_timeout”值是28800,已经足够了。但是我在 Google 中搜索的相同问题都是关于 my.cnf 中的“wait_timeout”。我对 jdbc 比较新鲜。我不知道 jdbc或者hadoop应该配置以及如何配置。或者如果关闭了mysql连接,我可以重新连接吗?如何。请给我一些代码。
任何帮助将不胜感激。
问问题
520 次